data_provider

Documentation

Index

• type DataProvider
• type Factory
  • func NewDataProviderFactory(logger zerolog.Logger, streamApi state_stream.API, streamConfig backend.Config) *Factory
  • func (f *Factory) NewDataProvider(ch chan<- interface{}, topic string) DataProvider
• type MockBlockProvider
  • func NewMockBlockProvider(ch chan<- interface{}, topic string, logger zerolog.Logger, ...) *MockBlockProvider
  • func (p *MockBlockProvider) Close()
  • func (p *MockBlockProvider) ID() uuid.UUID
  • func (p *MockBlockProvider) Run(ctx context.Context)
  • func (p *MockBlockProvider) Topic() string

Types

type DataProvider

type DataProvider interface {
	Run(ctx context.Context)
	ID() uuid.UUID
	Topic() string
	Close()
}

type Factory

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

func NewDataProviderFactory

func NewDataProviderFactory(logger zerolog.Logger, streamApi state_stream.API, streamConfig backend.Config) *Factory

func (*Factory) NewDataProvider

func (f *Factory) NewDataProvider(ch chan<- interface{}, topic string) DataProvider

type MockBlockProvider

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

func NewMockBlockProvider

func NewMockBlockProvider(
	ch chan<- interface{},
	topic string,
	logger zerolog.Logger,
	streamApi state_stream.API,
) *MockBlockProvider

func (*MockBlockProvider) Close

func (p *MockBlockProvider) Close()

func (*MockBlockProvider) ID

func (p *MockBlockProvider) ID() uuid.UUID

func (*MockBlockProvider) Run

func (p *MockBlockProvider) Run(ctx context.Context)

func (*MockBlockProvider) Topic

func (p *MockBlockProvider) Topic() string