internal

Documentation

Overview

Package internal contains SDK implementation details that are shared between packages, but are not exposed to application code. The datasource and datastore subpackages contain implementation components specific to their areas of functionality.

Index

• Constants
• func LogErrorNilPointerMethod(typeName string)
• func NewFlagTrackerImpl(broadcaster *FlagChangeEventBroadcaster, ...) interfaces.FlagTracker
• type BigSegmentStoreStatusBroadcaster
  • func NewBigSegmentStoreStatusBroadcaster() *BigSegmentStoreStatusBroadcaster
  • func (b *BigSegmentStoreStatusBroadcaster) AddListener() <-chan interfaces.BigSegmentStoreStatus
  • func (b *BigSegmentStoreStatusBroadcaster) Broadcast(value interfaces.BigSegmentStoreStatus)
  • func (b *BigSegmentStoreStatusBroadcaster) Close()
  • func (b *BigSegmentStoreStatusBroadcaster) RemoveListener(ch <-chan interfaces.BigSegmentStoreStatus)
• type ClientContextImpl
• type DataSourceStatusBroadcaster
  • func NewDataSourceStatusBroadcaster() *DataSourceStatusBroadcaster
  • func (b *DataSourceStatusBroadcaster) AddListener() <-chan interfaces.DataSourceStatus
  • func (b *DataSourceStatusBroadcaster) Broadcast(value interfaces.DataSourceStatus)
  • func (b *DataSourceStatusBroadcaster) Close()
  • func (b *DataSourceStatusBroadcaster) RemoveListener(ch <-chan interfaces.DataSourceStatus)
• type DataStoreStatusBroadcaster
  • func NewDataStoreStatusBroadcaster() *DataStoreStatusBroadcaster
  • func (b *DataStoreStatusBroadcaster) AddListener() <-chan interfaces.DataStoreStatus
  • func (b *DataStoreStatusBroadcaster) Broadcast(value interfaces.DataStoreStatus)
  • func (b *DataStoreStatusBroadcaster) Close()
  • func (b *DataStoreStatusBroadcaster) RemoveListener(ch <-chan interfaces.DataStoreStatus)
• type FlagChangeEventBroadcaster
  • func NewFlagChangeEventBroadcaster() *FlagChangeEventBroadcaster
  • func (b *FlagChangeEventBroadcaster) AddListener() <-chan interfaces.FlagChangeEvent
  • func (b *FlagChangeEventBroadcaster) Broadcast(value interfaces.FlagChangeEvent)
  • func (b *FlagChangeEventBroadcaster) Close()
  • func (b *FlagChangeEventBroadcaster) HasListeners() bool
  • func (b *FlagChangeEventBroadcaster) RemoveListener(ch <-chan interfaces.FlagChangeEvent)

Constants

const SDKVersion = "5.9.0"

SDKVersion is the current version string of the SDK. This is updated by our release scripts.

Functions

func LogErrorNilPointerMethod

func LogErrorNilPointerMethod(typeName string)

LogErrorNilPointerMethod prints a message to os.Stderr to indicate that the application tried to call a method on a nil pointer receiver.

func NewFlagTrackerImpl

func NewFlagTrackerImpl(
	broadcaster *FlagChangeEventBroadcaster,
	evaluateFn func(flagKey string, context ldcontext.Context, defaultValue ldvalue.Value) ldvalue.Value,
) interfaces.FlagTracker

NewFlagTrackerImpl creates the internal implementation of FlagTracker.

Types

type BigSegmentStoreStatusBroadcaster

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

BigSegmentStoreStatusBroadcaster is the internal implementation of publish-subscribe for BigSegmentStoreStatus values.

func NewBigSegmentStoreStatusBroadcaster

func NewBigSegmentStoreStatusBroadcaster() *BigSegmentStoreStatusBroadcaster

NewBigSegmentStoreStatusBroadcaster creates an instance of BigSegmentStoreStatusBroadcaster.

func (*BigSegmentStoreStatusBroadcaster) AddListener

func (b *BigSegmentStoreStatusBroadcaster) AddListener() <-chan interfaces.BigSegmentStoreStatus

AddListener creates a new channel for listening to broadcast values. This is created with a small channel buffer, but it is the consumer's responsibility to consume the channel to avoid blocking an SDK goroutine.

func (*BigSegmentStoreStatusBroadcaster) Broadcast

func (b *BigSegmentStoreStatusBroadcaster) Broadcast(value interfaces.BigSegmentStoreStatus)

Broadcast broadcasts a new value to the registered listeners, if any.

func (*BigSegmentStoreStatusBroadcaster) Close

func (b *BigSegmentStoreStatusBroadcaster) Close()

Close closes all currently registered listener channels.

func (*BigSegmentStoreStatusBroadcaster) RemoveListener

func (b *BigSegmentStoreStatusBroadcaster) RemoveListener(ch <-chan interfaces.BigSegmentStoreStatus)

RemoveListener stops broadcasting to a channel that was created with AddListener.

type ClientContextImpl

type ClientContextImpl struct {
	subsystems.BasicClientContext
	// Used internally to share a diagnosticsManager instance between components.
	DiagnosticsManager *ldevents.DiagnosticsManager
}

ClientContextImpl is the SDK's standard implementation of interfaces.ClientContext.

type DataSourceStatusBroadcaster

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

DataSourceStatusBroadcaster is the internal implementation of publish-subscribe for DataSourceStatus values.

func NewDataSourceStatusBroadcaster

func NewDataSourceStatusBroadcaster() *DataSourceStatusBroadcaster

NewDataSourceStatusBroadcaster creates an instance of DataSourceStatusBroadcaster.

func (*DataSourceStatusBroadcaster) AddListener

func (b *DataSourceStatusBroadcaster) AddListener() <-chan interfaces.DataSourceStatus

AddListener creates a new channel for listening to broadcast values. This is created with a small channel buffer, but it is the consumer's responsibility to consume the channel to avoid blocking an SDK goroutine.

func (*DataSourceStatusBroadcaster) Broadcast

func (b *DataSourceStatusBroadcaster) Broadcast(value interfaces.DataSourceStatus)

Broadcast broadcasts a new value to the registered listeners, if any.

func (*DataSourceStatusBroadcaster) Close

func (b *DataSourceStatusBroadcaster) Close()

Close closes all currently registered listener channels.

func (*DataSourceStatusBroadcaster) RemoveListener

func (b *DataSourceStatusBroadcaster) RemoveListener(ch <-chan interfaces.DataSourceStatus)

RemoveListener stops broadcasting to a channel that was created with AddListener.

type DataStoreStatusBroadcaster

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

DataStoreStatusBroadcaster is the internal implementation of publish-subscribe for DataStoreStatus values.

func NewDataStoreStatusBroadcaster

func NewDataStoreStatusBroadcaster() *DataStoreStatusBroadcaster

NewDataStoreStatusBroadcaster creates an instance of DataStoreStatusBroadcaster.

func (*DataStoreStatusBroadcaster) AddListener

func (b *DataStoreStatusBroadcaster) AddListener() <-chan interfaces.DataStoreStatus

AddListener creates a new channel for listening to broadcast values. This is created with a small channel buffer, but it is the consumer's responsibility to consume the channel to avoid blocking an SDK goroutine.

func (*DataStoreStatusBroadcaster) Broadcast

func (b *DataStoreStatusBroadcaster) Broadcast(value interfaces.DataStoreStatus)

Broadcast broadcasts a new value to the registered listeners, if any.

func (*DataStoreStatusBroadcaster) Close

func (b *DataStoreStatusBroadcaster) Close()

Close closes all currently registered listener channels.

func (*DataStoreStatusBroadcaster) RemoveListener

func (b *DataStoreStatusBroadcaster) RemoveListener(ch <-chan interfaces.DataStoreStatus)

RemoveListener stops broadcasting to a channel that was created with AddListener.

type FlagChangeEventBroadcaster

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

FlagChangeEventBroadcaster is the internal implementation of publish-subscribe for FlagChangeEvent values.

func NewFlagChangeEventBroadcaster

func NewFlagChangeEventBroadcaster() *FlagChangeEventBroadcaster

NewFlagChangeEventBroadcaster creates an instance of FlagChangeEventBroadcaster.

func (*FlagChangeEventBroadcaster) AddListener

func (b *FlagChangeEventBroadcaster) AddListener() <-chan interfaces.FlagChangeEvent

AddListener creates a new channel for listening to broadcast values. This is created with a small channel buffer, but it is the consumer's responsibility to consume the channel to avoid blocking an SDK goroutine.

func (*FlagChangeEventBroadcaster) Broadcast

func (b *FlagChangeEventBroadcaster) Broadcast(value interfaces.FlagChangeEvent)

Broadcast broadcasts a new value to the registered listeners, if any.

func (*FlagChangeEventBroadcaster) Close

func (b *FlagChangeEventBroadcaster) Close()

Close closes all currently registered listener channels.

func (*FlagChangeEventBroadcaster) HasListeners

func (b *FlagChangeEventBroadcaster) HasListeners() bool

HasListeners returns true if any listeners are registered.

func (*FlagChangeEventBroadcaster) RemoveListener

func (b *FlagChangeEventBroadcaster) RemoveListener(ch <-chan interfaces.FlagChangeEvent)

RemoveListener stops broadcasting to a channel that was created with AddListener.