source

package

Go to main page

Versions in this module

v0

v0.16.1

Oct 4, 2025

v0.16.0

Sep 30, 2025

Changes in this version

type CandleStore

+ func (s *CandleStore) Lock()

+ func (s *CandleStore) TryLock() bool

+ func (s *CandleStore) Unlock()

+ type OrderBook struct

+ Ask kit.LeakyHeap[Ask]

+ Bid kit.LeakyHeap[Bid]

+ func (s *OrderBook) Lock()

+ func (s *OrderBook) TryLock() bool

+ func (s *OrderBook) Unlock()

+ type WorkingState interface

v0.15.1

Sep 28, 2025

Changes in this version

+ type Ask uint64

+ func (this Ask) After(that Ask) bool

+ func (this Ask) Before(that Ask) bool

+ func (this Ask) Compare(that Ask) int

+ func (this Ask) Equal(that Ask) bool

+ type Bid uint64

+ func (this Bid) After(that Bid) bool

+ func (this Bid) Before(that Bid) bool

+ func (this Bid) Compare(that Bid) int

+ func (this Bid) Equal(that Bid) bool

+ type BookBase struct

+ Ask kit.LeakyHeap[Ask]

+ Bid kit.LeakyHeap[Bid]

+ func (this BookBase) Endpoint() string

+ type CandleBase struct

+ Symbol [1024]CandleStore

+ func (this CandleBase) Endpoint() string

+ type CandleStore struct

+ Candle [10]core.CandleEvent

+ Interval [10]int64

+ New [10]bool

v0.15.0

Sep 26, 2025

Changes in this version

+ type BatchDecodeFunc func(frame []byte, destination []T) (int, bool, error)

+ type BatchDecoder interface

+ Decode func(frame []byte, destination []T) (int, bool, error)

+ type BookCodec interface

+ func NewBookCodec(endpoint endpoint, sub, unsub ProtoMsgFunc, ...) BookCodec

+ func NewCoinbaseBookCodec() BookCodec

+ func NewKrakenBookCodec() BookCodec

+ type CandleCodec interface

+ func NewCandleCodec(endpoint endpoint, sub, unsub ProtoMsgFunc, ...) CandleCodec

+ func NewCoinbaseCandleCodec() CandleCodec

+ func NewKrakenCandleCodec() CandleCodec

+ type LossyDecodeFunc func(base *B, frame []byte) (T, bool, error)

+ type ProtoMsgFunc func(key core.Key) []byte

type SinkDecoder

+ Try func(key core.Key) (T, bool, error)

+ type SinkFunc func(base *B, key core.Key, frame []byte) (T, bool, error)

+ type SinkTryFunc func(base *B, key core.Key) (T, bool, error)

+ type SymbolCodec interface

+ func NewCoinbaseSymbolCodec() SymbolCodec

+ func NewKrakenSymbolCodec() SymbolCodec

+ func NewSymbolCodec(endpoint endpoint, sub, unsub ProtoMsgFunc, ...) SymbolCodec

+ type TradeCodec interface

+ func NewCoinbaseTradeCodec() TradeCodec

+ func NewKrakenTradeCodec() TradeCodec

+ func NewTradeCodec(endpoint endpoint, sub, unsub ProtoMsgFunc, ...) TradeCodec

+ type UnitDecoder interface

+ Decode func(frame []byte) (T, bool, error)

v0.14.2

Sep 26, 2025

v0.14.1

Sep 24, 2025

Changes in this version

+ type BookProto interface

+ type CandleProto interface

+ type MultiDecoder interface

+ Decode func(frame []byte, destination []T) (int, bool, error)

+ type SingleDecoder interface

+ Decode func(frame []byte) (T, bool, error)

+ type SinkDecoder interface

+ Rebuild func(key core.Key) (T, bool, error)

+ Sink func(key core.Key, frame []byte) (T, bool, error)

+ type SymbolProto interface

+ type TradeProto interface

v0.14.0

Sep 24, 2025

Changes in this version

+ var ErrBadRead = errors.New("matt::chasm::source: bad read")

+ var ErrBadUpgrade = errors.New("matt::chasm::source: bad upgrade")

+ type DecodeKeyFunc func(raw []byte) []core.Key

+ type EventDecoder interface

+ Feed func(key core.Key, frame []byte) (T, bool, error)

+ type KeyGetter interface

+ All func() []core.Key

+ Offline func() []core.Key

+ Online func() []core.Key

+ func NewKeyGetter(online, offline, all DecodeKeyFunc, req http.Request) KeyGetter

+ type Proto interface

+ Endpoint func() string

+ Subscribe func(key core.Key) []byte

+ Unsubscribe func(key core.Key) []byte

+ type Reader interface

+ Close func() error

+ Next func() error

+ Open func() error

+ Read func() (T, bool)

+ type Source interface

+ Book func(key core.Key) Reader[core.BookEvent]

+ Candle func(key core.Key) Reader[core.CandleEvent]

+ Get func() KeyGetter

+ Symbol func(key core.Key) Reader[core.SymbolEvent]

+ Trade func(key core.Key) Reader[core.TradeEvent]

+ func NewSource(origin string, symbol Proto[core.SymbolEvent], book Proto[core.BookEvent], ...) Source

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL