storage

Documentation

Index

• Constants
• func NewStorage(outDir, fileName string) (*storage, error)
• type Execution
• type MergeWriter
  • func NewMergeWriter() *MergeWriter
  • func (w *MergeWriter) Start(ctx context.Context, ch chan *Execution, outputFilePath string) error
• type Storage

Constants

const (
	TIME_LAYOUT = "2006-01-02T15:04:05.999999999"
)

Functions

func NewStorage

func NewStorage(outDir, fileName string) (*storage, error)

Types

type Execution

type Execution struct {
	ID       int
	Side     string
	Price    float64
	Size     float64
	ExecDate time.Time
}

type MergeWriter

type MergeWriter struct{}

func NewMergeWriter

func NewMergeWriter() *MergeWriter

func (*MergeWriter) Start

func (w *MergeWriter) Start(ctx context.Context, ch chan *Execution, outputFilePath string) error

type Storage

type Storage interface {
	Standby(ctx context.Context)
	Append(executions []*Execution) error
	GetOldestExecution() *Execution
	Reverse() error
}