sink

package
v0.14.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 24, 2025 License: Unlicense Imports: 4 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Symbol       byte = 's'
	Book         byte = 'b'
	Candle       byte = 'c'
	Trade        byte = 't'
	Online       byte = 'o'
	MinOrder     byte = 'm'
	MinIncrement byte = 'i'
	Bid          byte = 'b'
	Ask          byte = 'a'
	Open         byte = 'o'
	High         byte = 'h'
	Low          byte = 'l'
	Close        byte = 'c'
	Buy          byte = 'b'
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Sink 

type Sink interface {
	Symbol(key core.Key) Writer[core.SymbolEvent]
	Book(key core.Key) Writer[core.BookEvent]
	Candle(key core.Key) Writer[core.CandleEvent]
	Trade(key core.Key) Writer[core.TradeEvent]
}

func NewSink 

func NewSink(location string) (Sink, error)

type Writer 

type Writer[T core.Event] interface {
	Write(event T) error
	Flush() error
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.