Package io.harness.cf.client.connector

Class LocalConnector

java.lang.Object

io.harness.cf.client.connector.LocalConnector

All Implemented Interfaces:

Connector, java.lang.AutoCloseable

public class LocalConnector
extends java.lang.Object
implements Connector, java.lang.AutoCloseable

Constructor Summary

Constructors

Constructor	Description
LocalConnector(@NonNull java.lang.String source)

Method Summary

Modifier and Type	Method	Description
java.lang.String	authenticate()
void	close()
FeatureConfig	getFlag(@NonNull java.lang.String identifier)
java.util.List<FeatureConfig>	getFlags()
Segment	getSegment(@NonNull java.lang.String identifier)
java.util.List<Segment>	getSegments()
protected java.util.stream.Stream<java.io.File>	listFiles(@NonNull java.lang.String source, @NonNull java.lang.String domain)
protected <T> T	load(@NonNull java.io.File file, @NonNull java.lang.Class<T> classOfT)
void	postMetrics(@NonNull Metrics metrics)
void	setOnUnauthorized(java.lang.Runnable runnable)	If the http interceptor detects unauthorised during an API call then this callback is used to retry auth
Service	stream(@NonNull Updater updater)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LocalConnector

public LocalConnector(@NonNull
                      @NonNull java.lang.String source)

Method Detail

authenticate

public java.lang.String authenticate()

Specified by:

authenticate in interface Connector

setOnUnauthorized

public void setOnUnauthorized(java.lang.Runnable runnable)

Description copied from interface: Connector

If the http interceptor detects unauthorised during an API call then this callback is used to retry auth

Specified by:

setOnUnauthorized in interface Connector

listFiles

protected java.util.stream.Stream<java.io.File> listFiles(@NonNull
                                                          @NonNull java.lang.String source,
                                                          @NonNull
                                                          @NonNull java.lang.String domain)
                                                   throws ConnectorException

Throws:

ConnectorException

load

protected <T> T load(@NonNull
                     @NonNull java.io.File file,
                     @NonNull
                     @NonNull java.lang.Class<T> classOfT)

getFlags

public java.util.List<FeatureConfig> getFlags()
                                       throws ConnectorException

Specified by:

getFlags in interface Connector

Throws:

ConnectorException

getFlag

public FeatureConfig getFlag(@NonNull
                             @NonNull java.lang.String identifier)
                      throws ConnectorException

Specified by:

getFlag in interface Connector

Throws:

ConnectorException

getSegments

public java.util.List<Segment> getSegments()
                                    throws ConnectorException

Specified by:

getSegments in interface Connector

Throws:

ConnectorException

getSegment

public Segment getSegment(@NonNull
                          @NonNull java.lang.String identifier)
                   throws ConnectorException

Specified by:

getSegment in interface Connector

Throws:

ConnectorException

postMetrics

public void postMetrics(@NonNull
                        @NonNull Metrics metrics)
                 throws ConnectorException

Specified by:

postMetrics in interface Connector

Throws:

ConnectorException

stream

public Service stream(@NonNull
                      @NonNull Updater updater)
               throws ConnectorException

Specified by:

stream in interface Connector

Throws:

ConnectorException

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface Connector