orikik/frostfs-sdk-java-example
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

[#3] update examples for v0.7.0

Browse source
This commit is contained in:
Ori Bruk 2025-02-20 19:34:59 +03:00
parent 0170ab226f
commit a7834fb6f1
6 changed files with 26 additions and 21 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
pom.xml
View file

@ -24,7 +24,7 @@
<dependency>
<groupId>info.frostfs.sdk</groupId>
<artifactId>client</artifactId>
<version>0.6.0</version>
<version>0.7.0</version>
</dependency>
</dependencies>
</project>

2
src/main/java/info/frostfs/sdk/Main.java
View file

@ -11,7 +11,7 @@ import java.util.concurrent.TimeUnit;
public class Main {
public static void main(String[] args) {
CallContext callContext = new CallContext(1, TimeUnit.SECONDS);
CallContext callContext = new CallContext(1, TimeUnit.MINUTES);
//INIT
ClientSettings clientSettings = new ClientSettings(

9
src/main/java/info/frostfs/sdk/examples/ContainerExample.java
View file

@ -5,7 +5,6 @@ import info.frostfs.sdk.dto.container.Container;
import info.frostfs.sdk.dto.container.ContainerId;
import info.frostfs.sdk.dto.netmap.PlacementPolicy;
import info.frostfs.sdk.dto.netmap.Replica;
import info.frostfs.sdk.enums.BasicAcl;
import info.frostfs.sdk.jdo.parameters.CallContext;
import info.frostfs.sdk.jdo.parameters.container.PrmContainerCreate;
import info.frostfs.sdk.jdo.parameters.container.PrmContainerDelete;
@ -13,6 +12,7 @@ import info.frostfs.sdk.jdo.parameters.container.PrmContainerGet;
import info.frostfs.sdk.jdo.parameters.container.PrmContainerGetAll;
import java.util.List;
import java.util.UUID;
public class ContainerExample {
@ -21,8 +21,11 @@ public class ContainerExample {
List<ContainerId> containerIds = frostFSClient.listContainers(new PrmContainerGetAll(), callContext);
//CREATE
var placementPolicy = new PlacementPolicy(new Replica[]{new Replica(1)}, true);
var prmContainerCreate = new PrmContainerCreate(new Container(BasicAcl.PUBLIC_RW, placementPolicy));
var placementPolicy = new PlacementPolicy(new Replica[]{new Replica(3)}, true, 1);
var prmContainerCreate = new PrmContainerCreate(new Container(placementPolicy));
prmContainerCreate.getContainer().getAttributes().put("с", UUID.randomUUID().toString());
var containerId = frostFSClient.createContainer(prmContainerCreate, callContext);
//GET

15
src/main/java/info/frostfs/sdk/examples/ObjectExample.java
View file

@ -12,7 +12,10 @@ import info.frostfs.sdk.dto.object.ObjectAttribute;
import info.frostfs.sdk.dto.object.ObjectFrostFS;
import info.frostfs.sdk.dto.object.ObjectHeader;
import info.frostfs.sdk.dto.object.ObjectId;
import info.frostfs.sdk.enums.*;
import info.frostfs.sdk.enums.ObjectType;
import info.frostfs.sdk.enums.RuleMatchType;
import info.frostfs.sdk.enums.RuleStatus;
import info.frostfs.sdk.enums.TargetType;
import info.frostfs.sdk.jdo.parameters.CallContext;
import info.frostfs.sdk.jdo.parameters.ape.PrmApeChainAdd;
import info.frostfs.sdk.jdo.parameters.container.PrmContainerCreate;
@ -28,6 +31,7 @@ import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.nio.charset.StandardCharsets;
import java.util.UUID;
import java.util.concurrent.TimeUnit;
import static java.util.Objects.isNull;
@ -35,15 +39,16 @@ import static java.util.Objects.isNull;
public class ObjectExample {
public static void testObject(FrostFSClient frostFSClient, CallContext callContext) {
var placementPolicy = new PlacementPolicy(new Replica[]{new Replica(1)}, true);
var prmContainerCreate = new PrmContainerCreate(new Container(BasicAcl.PUBLIC_RW, placementPolicy));
prmContainerCreate.getContainer().getAttributes().put("__SYSTEM__DISABLE_HOMOMORPHIC_HASHING", "false");
var placementPolicy = new PlacementPolicy(new Replica[]{new Replica(3)}, true, 1);
var prmContainerCreate = new PrmContainerCreate(new Container(placementPolicy));
prmContainerCreate.getContainer().getAttributes().put("с", UUID.randomUUID().toString());
var containerId = frostFSClient.createContainer(prmContainerCreate, callContext);
frostFSClient.addChain(generatePrmApeChainAdd(containerId), callContext);
//Some wait
WaitUtil.sleep(10000);
WaitUtil.sleep(8000);
//CREATE
ObjectId oid;

14
src/main/java/info/frostfs/sdk/examples/PoolExample.java
View file

@ -3,7 +3,6 @@ package info.frostfs.sdk.examples;
import info.frostfs.sdk.dto.container.Container;
import info.frostfs.sdk.dto.netmap.PlacementPolicy;
import info.frostfs.sdk.dto.netmap.Replica;
import info.frostfs.sdk.enums.BasicAcl;
import info.frostfs.sdk.jdo.ECDsa;
import info.frostfs.sdk.jdo.parameters.CallContext;
import info.frostfs.sdk.jdo.parameters.container.PrmContainerCreate;
@ -15,16 +14,15 @@ public class PoolExample {
public static void initPool(CallContext callContext) {
//Init
NodeParameters nodeParam1 = new NodeParameters(1, "http://10.78.130.160:8080", 1);
NodeParameters nodeParam2 = new NodeParameters(1, "http://10.78.130.161:8080", 1);
NodeParameters nodeParam3 = new NodeParameters(1, "http://10.78.130.167:8080", 1);
NodeParameters nodeParam4 = new NodeParameters(2, "http://10.78.130.169:8080", 1);
NodeParameters nodeParam1 = new NodeParameters(1, "http://ip1:8080", 1);
NodeParameters nodeParam2 = new NodeParameters(1, "http://ip2:8080", 1);
NodeParameters nodeParam3 = new NodeParameters(1, "http://ip3:8080", 1);
NodeParameters nodeParam4 = new NodeParameters(2, "http://ip4:8080", 1);
PoolInitParameters initParameters = new PoolInitParameters();
initParameters.setKey(new ECDsa("L4NzJXAFDXxhBPY6CupwAATpCyhMSoQXyQesyLcJ79eQHnmVmuMh"));
initParameters.setNodeParams(new NodeParameters[]{nodeParam1, nodeParam2, nodeParam3, nodeParam4});
Pool pool = new Pool(initParameters);
//Dial (Required!)
@ -33,8 +31,8 @@ public class PoolExample {
//Operations
var netmap = pool.getNetmapSnapshot(callContext);
var placementPolicy = new PlacementPolicy(new Replica[]{new Replica(4)}, true);
var prmContainerCreate = new PrmContainerCreate(new Container(BasicAcl.PUBLIC_RW, placementPolicy));
var placementPolicy = new PlacementPolicy(new Replica[]{new Replica(3)}, true, 1);
var prmContainerCreate = new PrmContainerCreate(new Container(placementPolicy));
var containerId = pool.createContainer(prmContainerCreate, callContext);
//ETC

5
src/main/java/info/frostfs/sdk/examples/container/ContainerCreate.java
View file

@ -4,15 +4,14 @@ import info.frostfs.sdk.FrostFSClient;
import info.frostfs.sdk.dto.container.Container;
import info.frostfs.sdk.dto.netmap.PlacementPolicy;
import info.frostfs.sdk.dto.netmap.Replica;
import info.frostfs.sdk.enums.BasicAcl;
import info.frostfs.sdk.jdo.parameters.CallContext;
import info.frostfs.sdk.jdo.parameters.container.PrmContainerCreate;
public class ContainerCreate {
public static void example(FrostFSClient frostFSClient, CallContext callContext) {
var placementPolicy = new PlacementPolicy(new Replica[]{new Replica(1)}, true);
var prmContainerCreate = new PrmContainerCreate(new Container(BasicAcl.PUBLIC_RW, placementPolicy));
var placementPolicy = new PlacementPolicy(new Replica[]{new Replica(1)}, true, 0);
var prmContainerCreate = new PrmContainerCreate(new Container(placementPolicy));
var containerId = frostFSClient.createContainer(prmContainerCreate, callContext);
}
}