datasource

type DataSourceUpdateSinkImpl ¶

type DataSourceUpdateSinkImpl struct {
	// contains filtered or unexported fields
}

DataSourceUpdateSinkImpl is the internal implementation of DataSourceUpdateSink. It is exported because the actual implementation type, rather than the interface, is required as a dependency of other SDK components.

func NewDataSourceUpdateSinkImpl(
	store subsystems.DataStore,
	dataStoreStatusProvider intf.DataStoreStatusProvider,
	dataSourceStatusBroadcaster *internal.Broadcaster[intf.DataSourceStatus],
	flagChangeEventBroadcaster *internal.Broadcaster[intf.FlagChangeEvent],
	logDataSourceOutageAsErrorAfter time.Duration,
	loggers ldlog.Loggers,
) *DataSourceUpdateSinkImpl

func (d *DataSourceUpdateSinkImpl) GetDataStoreStatusProvider() intf.DataStoreStatusProvider

func (d *DataSourceUpdateSinkImpl) GetLastStatus() intf.DataSourceStatus

func (d *DataSourceUpdateSinkImpl) Init(allData []st.Collection) bool

func (d *DataSourceUpdateSinkImpl) UpdateStatus(
	newState intf.DataSourceState,
	newError intf.DataSourceErrorInfo,
)

func (d *DataSourceUpdateSinkImpl) Upsert(
	kind st.DataKind,
	key string,
	item st.ItemDescriptor,
) bool

type PollingConfig ¶

type PollingConfig struct {
	BaseURI      string
	PollInterval time.Duration
	FilterKey    string
}

PollingConfig describes the configuration for a polling data source. It is exported so that it can be used in the PollingDataSourceBuilder.

type PollingProcessor ¶

type PollingProcessor struct {
	// contains filtered or unexported fields
}

PollingProcessor is the internal implementation of the polling data source.

This type is exported from internal so that the PollingDataSourceBuilder tests can verify its configuration. All other code outside of this package should interact with it only via the DataSource interface.

func NewPollingProcessor(
	context subsystems.ClientContext,
	dataSourceUpdates subsystems.DataSourceUpdateSink,
	cfg PollingConfig,
) *PollingProcessor

func (pp *PollingProcessor) Close() error

func (pp *PollingProcessor) GetBaseURI() string

func (pp *PollingProcessor) GetFilterKey() string

func (pp *PollingProcessor) GetPollInterval() time.Duration

func (pp *PollingProcessor) IsInitialized() bool

func (pp *PollingProcessor) Start(closeWhenReady chan<- struct{})

type Requester ¶

type Requester interface {
	Request() (data []ldstoretypes.Collection, cached bool, err error)
	BaseURI() string
	FilterKey() string
}

Requester allows PollingProcessor to delegate fetching data to another component. This is useful for testing the PollingProcessor without needing to set up a test HTTP server.

type StreamConfig ¶

type StreamConfig struct {
	URI                   string
	FilterKey             string
	InitialReconnectDelay time.Duration
}

StreamConfig describes the configuration for a streaming data source. It is exported so that it can be used in the StreamingDataSourceBuilder.

type StreamProcessor ¶

type StreamProcessor struct {
	// contains filtered or unexported fields
}

StreamProcessor is the internal implementation of the streaming data source.

This type is exported from internal so that the StreamingDataSourceBuilder tests can verify its configuration. All other code outside of this package should interact with it only via the DataSource interface.

func NewStreamProcessor(
	context subsystems.ClientContext,
	dataSourceUpdates subsystems.DataSourceUpdateSink,
	cfg StreamConfig,
) *StreamProcessor

func (sp *StreamProcessor) Close() error

func (sp *StreamProcessor) GetBaseURI() string

func (sp *StreamProcessor) GetFilterKey() string

func (sp *StreamProcessor) GetInitialReconnectDelay() time.Duration

func (sp *StreamProcessor) IsInitialized() bool

func (sp *StreamProcessor) Start(closeWhenReady chan<- struct{})