datasynchronization

Documentation

Index

• Constants
• Variables
• type BackoffAndJitterStrategy
  • func NewWithFirstRetryDelay(firstRetryDelay time.Duration) *BackoffAndJitterStrategy
  • func (b *BackoffAndJitterStrategy) NextDelay() time.Duration
  • func (s *BackoffAndJitterStrategy) SetGoodRunAtNow()
• type MockStreaming
  • func (m *MockStreaming) Close() error
  • func (m *MockStreaming) IsInitialized() bool
  • func (m *MockStreaming) Start() <-chan struct{}
• type MockStreamingBuilder
  • func NewMockStreamingBuilder(success bool, loadDate bool, waitTime time.Duration) *MockStreamingBuilder
  • func (m *MockStreamingBuilder) CreateDataSynchronizer(_ Context, dataUpdater DataUpdater) (DataSynchronizer, error)
• type NullDataSynchronizer
  • func NewNullDataSynchronizer(dataUpdater DataUpdater) *NullDataSynchronizer
  • func (n *NullDataSynchronizer) Close() error
  • func (n *NullDataSynchronizer) IsInitialized() bool
  • func (n *NullDataSynchronizer) Start() <-chan struct{}
• type Streaming
  • func NewStreaming(context Context, dataUpdater DataUpdater, firstRetryDelay time.Duration, ...) *Streaming
  • func (s *Streaming) Close() error
  • func (s *Streaming) IsInitialized() bool
  • func (s *Streaming) Start() <-chan struct{}

Constants

const (
	CloseAndThenReconnByDatasyncError = "data sync error"
)

Variables

var (
	// JsonParsingError internal error, normally internal test use
	JsonParsingError = fmt.Errorf(jsonParsingErrorMsg)
	R2PChCap         = 100
)

Types

type BackoffAndJitterStrategy

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

func NewWithFirstRetryDelay

func NewWithFirstRetryDelay(firstRetryDelay time.Duration) *BackoffAndJitterStrategy

func (*BackoffAndJitterStrategy) NextDelay

func (b *BackoffAndJitterStrategy) NextDelay() time.Duration

func (*BackoffAndJitterStrategy) SetGoodRunAtNow

func (s *BackoffAndJitterStrategy) SetGoodRunAtNow()

type MockStreaming

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

func (*MockStreaming) Close

func (m *MockStreaming) Close() error

func (*MockStreaming) IsInitialized

func (m *MockStreaming) IsInitialized() bool

func (*MockStreaming) Start

func (m *MockStreaming) Start() <-chan struct{}

type MockStreamingBuilder

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

func NewMockStreamingBuilder

func NewMockStreamingBuilder(success bool, loadDate bool, waitTime time.Duration) *MockStreamingBuilder

func (*MockStreamingBuilder) CreateDataSynchronizer

func (m *MockStreamingBuilder) CreateDataSynchronizer(_ Context, dataUpdater DataUpdater) (DataSynchronizer, error)

type NullDataSynchronizer

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

func NewNullDataSynchronizer

func NewNullDataSynchronizer(dataUpdater DataUpdater) *NullDataSynchronizer

func (*NullDataSynchronizer) Close

func (n *NullDataSynchronizer) Close() error

func (*NullDataSynchronizer) IsInitialized

func (n *NullDataSynchronizer) IsInitialized() bool

func (*NullDataSynchronizer) Start

func (n *NullDataSynchronizer) Start() <-chan struct{}

type Streaming

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

func NewStreaming

func NewStreaming(context Context, dataUpdater DataUpdater, firstRetryDelay time.Duration, maxRetryTimes int) *Streaming

func (*Streaming) Close

func (s *Streaming) Close() error

func (*Streaming) IsInitialized

func (s *Streaming) IsInitialized() bool

func (*Streaming) Start

func (s *Streaming) Start() <-chan struct{}