workers

Documentation

Index

• type SnapshotReader
• type SnapshotWriter

Types

type SnapshotReader

type SnapshotReader interface {
	Init() (SnapshotReader, error)
	Close() error
	Exchanges() []string
	Pairs(exchangeName string) []common.Pair
	TimeRange(exchangeName string, pair common.Pair) *utils.TimeRange
	Read(exchangeName string, pair common.Pair, timeRange utils.TimeRange, interval int64, mode common.SnapshotMode, size int, ctx context.Context) (chan common.Snapshot, error)
}

type SnapshotWriter

type SnapshotWriter interface {
	Init(ch chan common.Snapshot) SnapshotWriter
	Run(ctx context.Context) error
	Close() error
}