factories

Feb 20, 2023

Changes in this version

+ const DefaultCapacity

+ const DefaultFlushInterval

+ const DefaultRetryDelay

+ const DefaultRetryTimes

+ func ExternalDataSynchronization() DataSynchronizerFactory

+ func ExternalEventTrack() InsightProcessorFactory

+ type InMemoryStorageBuilder struct

+ func NewInMemoryStorageBuilder() InMemoryStorageBuilder

+ func (i InMemoryStorageBuilder) CreateDataStorage(Context) (DataStorage, error)

+ type InsightProcessorBuilder struct

+ func NewInsightProcessorBuilder() *InsightProcessorBuilder

+ func (i *InsightProcessorBuilder) Capacity(capacity int) *InsightProcessorBuilder

+ func (i *InsightProcessorBuilder) CreateInsightEventSender(context Context) (Sender, error)

+ func (i *InsightProcessorBuilder) CreateInsightProcessor(context Context) (InsightProcessor, error)

+ func (i *InsightProcessorBuilder) FlushInterval(flushInterval time.Duration) *InsightProcessorBuilder

+ func (i *InsightProcessorBuilder) MaxRetryTimes(maxRetryTimes int) *InsightProcessorBuilder

+ func (i *InsightProcessorBuilder) RetryInterval(retryInterval time.Duration) *InsightProcessorBuilder

+ type NetworkBuilder struct

+ func NewNetworkBuilder() *NetworkBuilder

+ func (n *NetworkBuilder) CaCert(caRoot string) *NetworkBuilder

+ func (n *NetworkBuilder) CertFile(certFilePath string) *NetworkBuilder

+ func (n *NetworkBuilder) ConnectTime(connectTimeout time.Duration) *NetworkBuilder

+ func (n *NetworkBuilder) CreateNetwork(config BasicConfig) (Network, error)

+ func (n *NetworkBuilder) KeyFile(keyFilePath string) *NetworkBuilder

+ func (n *NetworkBuilder) ProxyURL(proxy string) *NetworkBuilder

+ func (n *NetworkBuilder) ReadTime(readTimeout time.Duration) *NetworkBuilder

+ type StreamingBuilder struct

+ func NewStreamingBuilder() *StreamingBuilder

+ func (s *StreamingBuilder) CreateDataSynchronizer(context Context, dataUpdater DataUpdater) (DataSynchronizer, error)

+ func (s *StreamingBuilder) FirstRetryDelay(firstRetryDelay time.Duration) *StreamingBuilder

+ func (s *StreamingBuilder) MaxRetryTimes(maxRetryTimes int) *StreamingBuilder