liran2000 / java-sdk Goto Github PK

public void example(){

    // flags defined in memory
    Map<String, Flag<?>> myFlags = new HashMap<>();
    myFlags.put("v2_enabled", Flag.builder()
        .variant("on", true)
        .variant("off", false)
        .defaultVariant("on")
        .build());

    // configure a provider
    OpenFeatureAPI api = OpenFeatureAPI.getInstance();
    api.setProviderAndWait(new InMemoryProvider(myFlags));

    // create a client
    Client client = api.getClient();

    // get a bool flag value
    boolean flagValue = client.getBooleanValue("v2_enabled", false);
}

    OpenFeatureAPI api = OpenFeatureAPI.getInstance();
    api.setProviderAndWait(new MyProvider());

    OpenFeatureAPI.getInstance().setProvider(new MyProvider());

// set a value to the global context
OpenFeatureAPI api = OpenFeatureAPI.getInstance();
Map<String, Value> apiAttrs = new HashMap<>();
apiAttrs.put("region", new Value(System.getEnv("us-east-1")));
EvaluationContext apiCtx = new ImmutableContext(apiAttrs);
api.setEvaluationContext(apiCtx);

// set a value to the client context
Map<String, Value> clientAttrs = new HashMap<>();
clientAttrs.put("region", new Value(System.getEnv("us-east-1")));
EvaluationContext clientCtx = new ImmutableContext(clientAttrs);
Client client = api.getInstance().getClient();
client.setEvaluationContext(clientCtx);

// set a value to the invocation context
Map<String, Value> requestAttrs = new HashMap<>();
requestAttrs.put("email", new Value(session.getAttribute("email")));
requestAttrs.put("product", new Value("productId"));
String targetingKey = session.getId();
EvaluationContext reqCtx = new ImmutableContext(targetingKey, requestAttrs);

boolean flagValue = client.getBooleanValue("some-flag", false, reqCtx);

  // add a hook globally, to run on all evaluations
  OpenFeatureAPI api = OpenFeatureAPI.getInstance();
  api.addHooks(new ExampleHook());
  
  // add a hook on this client, to run on all evaluations made by this client
  Client client = api.getClient();        
  client.addHooks(new ExampleHook());
  
  // add a hook for this evaluation only
  Boolean retval = client.getBooleanValue(flagKey, false, null,
          FlagEvaluationOptions.builder().hook(new ExampleHook()).build());

FeatureProvider scopedProvider = new MyProvider();

// registering the default provider
OpenFeatureAPI.getInstance().setProvider(LocalProvider());
// registering a named provider
OpenFeatureAPI.getInstance().setProvider("clientForCache", new CachedProvider());

// a client backed by default provider
Client clientDefault = OpenFeatureAPI.getInstance().getClient();
// a client backed by CachedProvider
Client clientNamed = OpenFeatureAPI.getInstance().getClient("clientForCache");

// add an event handler to a client
Client client = OpenFeatureAPI.getInstance().getClient();
client.onProviderConfigurationChanged((EventDetails eventDetails) -> {
    // do something when the provider's flag settings change
});

// add an event handler to the global API
OpenFeatureAPI.getInstance().onProviderStale((EventDetails eventDetails) -> {
    // do something when the provider's cache goes stale
});

// shut down all providers
OpenFeatureAPI.getInstance().shutdown();

public class MyProvider implements FeatureProvider {
    @Override
    public Metadata getMetadata() {
        return () -> "My Provider";
    }

    @Override
    public ProviderState getState() {
        // optionally indicate your provider's state (assumed to be READY if not implemented)
    }

    @Override
    public void initialize(EvaluationContext evaluationContext) throws Exception {
        // start up your provider
    }

    @Override
    public void shutdown() {
        // shut down your provider
    }

    @Override
    public ProviderEvaluation<Boolean> getBooleanEvaluation(String key, Boolean defaultValue, EvaluationContext ctx) {
        // resolve a boolean flag value
    }

    @Override
    public ProviderEvaluation<String> getStringEvaluation(String key, String defaultValue, EvaluationContext ctx) {
        // resolve a string flag value
    }

    @Override
    public ProviderEvaluation<Integer> getIntegerEvaluation(String key, Integer defaultValue, EvaluationContext ctx) {
        // resolve an int flag value
    }

    @Override
    public ProviderEvaluation<Double> getDoubleEvaluation(String key, Double defaultValue, EvaluationContext ctx) {
        // resolve a double flag value
    }

    @Override
    public ProviderEvaluation<Value> getObjectEvaluation(String key, Value defaultValue, EvaluationContext ctx) {
        // resolve an object flag value
    }
}

class MyEventProvider extends EventProvider {
    @Override
    public Metadata getMetadata() {
        return () -> "My Event Provider";
    }

    @Override
    public ProviderState getState() {
        // indicate your provider's state (required for EventProviders)
    }

    @Override
    public void initialize(EvaluationContext evaluationContext) throws Exception {
        // emit events when flags are changed in a hypothetical REST API
        this.restApiClient.onFlagsChanged(() -> {
            ProviderEventDetails details = ProviderEventDetails.builder().message("flags changed in API!").build();
            this.emitProviderConfigurationChanged(details);
        });
    }

    @Override
    public void shutdown() {
        // shut down your provider
    }

    // remaining provider methods...
}

class MyHook implements Hook {

    @Override
    public Optional before(HookContext ctx, Map hints) {
        // code that runs before the flag evaluation
    }

    @Override
    public void after(HookContext ctx, FlagEvaluationDetails details, Map hints) {
        // code that runs after the flag evaluation succeeds
    }

    @Override
    public void error(HookContext ctx, Exception error, Map hints) {
        // code that runs when there's an error during a flag evaluation
    }

    @Override
    public void finallyAfter(HookContext ctx, Map hints) {
        // code that runs regardless of success or error
    }
};