writers

Documentation

Index

• func UniqueName(prefix string, pair common.Pair, exchange string) string
• type CacheWriter
  • func NewCacheWriterWriter(logger zerolog.Logger, exchange string, pair common.Pair) *CacheWriter
  • func (e *CacheWriter) Close() error
  • func (e *CacheWriter) GetSnapshots() []common.Snapshot
  • func (e *CacheWriter) IndexName() string
  • func (e *CacheWriter) Init(ch chan common.Snapshot) workers.SnapshotWriter
  • func (e *CacheWriter) Run(ctx context.Context) error
  • func (e *CacheWriter) SubscribeUpdates(chanId string, chanSize int) chan *common.Snapshot
  • func (e *CacheWriter) UnsubscribeUpdates(chanId string)
• type ElasticSearchWriter
  • func NewElasticSearchWriter(logger zerolog.Logger, exchange string, pair common.Pair, ...) *ElasticSearchWriter
  • func (e *ElasticSearchWriter) Close() error
  • func (e *ElasticSearchWriter) IndexName() string
  • func (e *ElasticSearchWriter) Init(ch chan common.Snapshot) workers.SnapshotWriter
  • func (e *ElasticSearchWriter) Run(ctx context.Context) error
• type ElasticSearchWriterConfig
  • func NewElasticSearchWriterConfig(indexPrefix string, esChanBufferSize int, esBulkSize int) ElasticSearchWriterConfig

Functions

func UniqueName

func UniqueName(prefix string, pair common.Pair, exchange string) string

Types

type CacheWriter

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

func NewCacheWriterWriter

func NewCacheWriterWriter(logger zerolog.Logger, exchange string, pair common.Pair) *CacheWriter

func (*CacheWriter) Close

func (e *CacheWriter) Close() error

func (*CacheWriter) GetSnapshots

func (e *CacheWriter) GetSnapshots() []common.Snapshot

func (*CacheWriter) IndexName

func (e *CacheWriter) IndexName() string

func (*CacheWriter) Init

func (e *CacheWriter) Init(ch chan common.Snapshot) workers.SnapshotWriter

func (*CacheWriter) Run

func (e *CacheWriter) Run(ctx context.Context) error

func (*CacheWriter) SubscribeUpdates

func (e *CacheWriter) SubscribeUpdates(chanId string, chanSize int) chan *common.Snapshot

func (*CacheWriter) UnsubscribeUpdates

func (e *CacheWriter) UnsubscribeUpdates(chanId string)

type ElasticSearchWriter

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

func NewElasticSearchWriter

func NewElasticSearchWriter(logger zerolog.Logger, exchange string, pair common.Pair, conf ElasticSearchWriterConfig, serverUrls ...string) *ElasticSearchWriter

func (*ElasticSearchWriter) Close

func (e *ElasticSearchWriter) Close() error

func (*ElasticSearchWriter) IndexName

func (e *ElasticSearchWriter) IndexName() string

func (*ElasticSearchWriter) Init

func (e *ElasticSearchWriter) Init(ch chan common.Snapshot) workers.SnapshotWriter

func (*ElasticSearchWriter) Run

func (e *ElasticSearchWriter) Run(ctx context.Context) error

type ElasticSearchWriterConfig

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

func NewElasticSearchWriterConfig

func NewElasticSearchWriterConfig(indexPrefix string, esChanBufferSize int, esBulkSize int) ElasticSearchWriterConfig