Documentation
¶
Overview ¶
Package datasourcev2 is an internal package containing implementation types for the SDK's data source implementations (streaming, polling, etc.) and related functionality. These types are not visible from outside of the SDK.
WARNING: This particular implementation supports the upcoming flag delivery v2 format which is not publicly available.
This does not include the file data source, which is in the ldfiledata package.
Index ¶
- type PollingProcessor
- func (pp *PollingProcessor) Close() error
- func (pp *PollingProcessor) Fetch(ds subsystems.DataSelector, ctx context.Context) (*subsystems.Basis, error)
- func (pp *PollingProcessor) GetBaseURI() string
- func (pp *PollingProcessor) GetFilterKey() string
- func (pp *PollingProcessor) GetPollInterval() time.Duration
- func (pp *PollingProcessor) Name() string
- func (pp *PollingProcessor) Sync(ds subsystems.DataSelector) <-chan subsystems.DataSynchronizerResult
- type PollingRequester
- type StreamProcessor
- func (sp *StreamProcessor) Close() error
- func (sp *StreamProcessor) Fetch(ds subsystems.DataSelector, _ context.Context) (*subsystems.Basis, error)
- func (sp *StreamProcessor) GetBaseURI() string
- func (sp *StreamProcessor) GetFilterKey() string
- func (sp *StreamProcessor) GetInitialReconnectDelay() time.Duration
- func (sp *StreamProcessor) Name() string
- func (sp *StreamProcessor) Sync(ds subsystems.DataSelector) <-chan subsystems.DataSynchronizerResult
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
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 NewFDv1PollingProcessor ¶ added in v7.10.2
func NewFDv1PollingProcessor( context subsystems.ClientContext, cfg datasource.PollingConfig, ) *PollingProcessor
NewFDv1PollingProcessor creates the internal implementation of the polling data source.
func NewPollingProcessor ¶
func NewPollingProcessor( context subsystems.ClientContext, cfg datasource.PollingConfig, ) *PollingProcessor
NewPollingProcessor creates the internal implementation of the polling data source.
func (*PollingProcessor) Close ¶
func (pp *PollingProcessor) Close() error
func (*PollingProcessor) Fetch ¶ added in v7.8.0
func (pp *PollingProcessor) Fetch(ds subsystems.DataSelector, ctx context.Context) (*subsystems.Basis, error)
func (*PollingProcessor) GetBaseURI ¶
func (pp *PollingProcessor) GetBaseURI() string
GetBaseURI returns the configured polling base URI, for testing.
func (*PollingProcessor) GetFilterKey ¶
func (pp *PollingProcessor) GetFilterKey() string
GetFilterKey returns the configured filter key, for testing.
func (*PollingProcessor) GetPollInterval ¶
func (pp *PollingProcessor) GetPollInterval() time.Duration
GetPollInterval returns the configured polling interval, for testing.
func (*PollingProcessor) Name ¶ added in v7.8.0
func (pp *PollingProcessor) Name() string
func (*PollingProcessor) Sync ¶ added in v7.8.0
func (pp *PollingProcessor) Sync(ds subsystems.DataSelector) <-chan subsystems.DataSynchronizerResult
type PollingRequester ¶
type PollingRequester interface {
Request(context.Context, subsystems.Selector) (*subsystems.ChangeSet, http.Header, error)
BaseURI() string
FilterKey() string
}
PollingRequester 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 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 ¶
func NewStreamProcessor( context subsystems.ClientContext, cfg datasource.StreamConfig, ) *StreamProcessor
NewStreamProcessor creates the internal implementation of the streaming data source.
func (*StreamProcessor) Close ¶
func (sp *StreamProcessor) Close() error
func (*StreamProcessor) Fetch ¶ added in v7.8.0
func (sp *StreamProcessor) Fetch(ds subsystems.DataSelector, _ context.Context) (*subsystems.Basis, error)
func (*StreamProcessor) GetBaseURI ¶
func (sp *StreamProcessor) GetBaseURI() string
GetBaseURI returns the configured streaming base URI, for testing.
func (*StreamProcessor) GetFilterKey ¶
func (sp *StreamProcessor) GetFilterKey() string
GetFilterKey returns the configured key, for testing.
func (*StreamProcessor) GetInitialReconnectDelay ¶
func (sp *StreamProcessor) GetInitialReconnectDelay() time.Duration
GetInitialReconnectDelay returns the configured reconnect delay, for testing.
func (*StreamProcessor) Name ¶ added in v7.8.0
func (sp *StreamProcessor) Name() string
func (*StreamProcessor) Sync ¶ added in v7.8.0
func (sp *StreamProcessor) Sync(ds subsystems.DataSelector) <-chan subsystems.DataSynchronizerResult
Source Files