core

package
v0.16.1 Latest Latest
Warning

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

 Go to latest Published: Oct 4, 2025 License: Unlicense Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DomainMask = domainMask
	SymIntBit  = symIntBit
	IntMask    = intMask
)

Variables

View Source 
var (
	ErrInvalid = errors.New("matt::chasm::core: invalid")
	ErrLocked  = errors.New("matt::chasm::core: locked")
	ErrNoOp    = errors.New("matt::chasm::core: no-op")
)

Functions

func DecodeInterval 

func DecodeInterval(key Key) time.Duration

Decode a Key's interval.

func DecodeSymbol 

func DecodeSymbol(key Key) string

Decode a Key's symbol.

func InitManager10 

func InitManager10(manager *Manager10, cfg Config)

func InitManager11 

func InitManager11(manager *Manager11, cfg Config)

func InitManager12 

func InitManager12(manager *Manager12, cfg Config)

func InitManager13 

func InitManager13(manager *Manager13, cfg Config)

func InitManager14 

func InitManager14(manager *Manager14, cfg Config)

func InitManager15 

func InitManager15(manager *Manager15, cfg Config)

func InitManager16 

func InitManager16(manager *Manager16, cfg Config)

func InitManager17 

func InitManager17(manager *Manager17, cfg Config)

func InitManager18 

func InitManager18(manager *Manager18, cfg Config)

func InitManager19 

func InitManager19(manager *Manager19, cfg Config)

func InitManager20 

func InitManager20(manager *Manager20, cfg Config)

func InitManager21 

func InitManager21(manager *Manager21, cfg Config)

func InitManager22 

func InitManager22(manager *Manager22, cfg Config)

func InitManager23 

func InitManager23(manager *Manager23, cfg Config)

func InitManager24 

func InitManager24(manager *Manager24, cfg Config)

func InitManager25 

func InitManager25(manager *Manager25, cfg Config)

func InitManager26 

func InitManager26(manager *Manager26, cfg Config)

func InitManager27 

func InitManager27(manager *Manager27, cfg Config)

func InitManager28 

func InitManager28(manager *Manager28, cfg Config)

func InitManager29 

func InitManager29(manager *Manager29, cfg Config)

func InitManager30 

func InitManager30(manager *Manager30, cfg Config)

func InitManager31 

func InitManager31(manager *Manager31, cfg Config)

func InitManager32 

func InitManager32(manager *Manager32, cfg Config)

func InitManager33 

func InitManager33(manager *Manager33, cfg Config)

func InitManager34 

func InitManager34(manager *Manager34, cfg Config)

func InitManager7 

func InitManager7(manager *Manager7, cfg Config)

func InitManager8 

func InitManager8(manager *Manager8, cfg Config)

func InitManager9 

func InitManager9(manager *Manager9, cfg Config)

func OkInterval 

func OkInterval(minute int64) bool

OkInterval validates that a duration given in minutes is acceptable for use in a Key. The minute count must be greater than zero and less than 2048.

Types

type BookDaemon 

type BookDaemon = Producer[EventLog[BookEvent]]

type BookEvent 

type BookEvent struct {
	Bid, Ask      uint64
	EventUnixTime int64
}

func (BookEvent) UnixNano 

func (this BookEvent) UnixNano() int64

type BookFactory 

type BookFactory = Factory[BookDaemon]

type BookLogRegistry 

type BookLogRegistry = Registry[EventLog[BookEvent]]

type BrokerageData 

type BrokerageData interface {
	Before(endUnixTime int64) BrokerageDataReader
	At(floorUnixTime int64) BrokerageDataReader
	After(startUnixTime int64) BrokerageDataReader
	UnixTimestamped
}

type BrokerageDataLogRegistry 

type BrokerageDataLogRegistry interface {
	Symbol() SymbolLogRegistry
	Book() BookLogRegistry
	Candle() CandleLogRegistry
	Trade() TradeLogRegistry
	Schedule() ScheduleLogRegistry
}

type BrokerageDataProvider 

type BrokerageDataProvider = Provider[BrokerageData]

type BrokerageDataReader 

type BrokerageDataReader interface {
	Symbol(key Key) (Cursor[SymbolEvent], error)
	Book(key Key) (Cursor[BookEvent], error)
	Candle(key Key) (Cursor[CandleEvent], error)
	Trade(key Key) (Cursor[TradeEvent], error)
	Schedule(key Key) (Cursor[ScheduleEvent], error)
}

type CandleDaemon 

type CandleDaemon = Producer[EventLog[CandleEvent]]

type CandleEvent 

type CandleEvent struct {
	Open, High, Low, Close uint64
	EventUnixTime          int64
}

func (CandleEvent) UnixNano 

func (this CandleEvent) UnixNano() int64

type CandleFactory 

type CandleFactory = Factory[CandleDaemon]

type CandleLogRegistry 

type CandleLogRegistry = Registry[EventLog[CandleEvent]]

type Config 

type Config struct {
	// Lineage tracks factories seen and entries are not deleted.
	// This is an initial bucket hint only; maps grow as needed, never shrink.
	// Per entry ≈ 32 B.
	Lineage int

	// Factories are kept around forever so daemons can be revived.
	// Fields are initial bucket hints only; maps grow as needed, never shrink.
	// Per entry ≈ 32 B.
	Factory FactoryConfig

	// Fields are initial bucket hints only; registries grow as needed, never shrink.
	// Per entry ≈ 24 B.
	Registry RegistryConfig

	// Must not be nil.
	OnAdd  func(DaemonInfo)
	OnKill func(DaemonInfo)
}

type Configurable 

type Configurable = common.Configurable[[]byte]

type Consumer 

type Consumer[T UnixTimestamped] interface {
	Daemon
	Initialize(provider Provider[T]) error
}

type Control 

type Control[T any] interface {
	Producer[T]
	WithLinker(linker Linker) Control[T]
}

type Cursor 

type Cursor[T UnixTimestamped] = common.Cursor[T]

type Daemon 

type Daemon interface {
	Configurable
	Run() error
	Shutdown() error
	Pause() error
	Resume() error
	Restart() error
	DaemonInfo
}

type DaemonInfo 

type DaemonInfo interface {
	Tag() string
	Config() []byte
	Status() (int, int64)
	Report() []byte
	FactoryInfo
}

type DataDaemon 

type DataDaemon = Consumer[BrokerageData]

type DataFactory 

type DataFactory = Factory[DataDaemon]

type Domain 

type Domain uint8
const (
	Symbol Domain = iota
	Book
	Candle
	Trade
	Schedule
	Data
)

func DecodeDomain 

func DecodeDomain(key Key) Domain

Decode a Key's domain. Keys without a domain set will report as Symbol.

type Event 

type Event interface {
	SymbolEvent | BookEvent | CandleEvent | TradeEvent
	UnixTimestamped
}

type EventLog 

type EventLog[T UnixTimestamped] = common.Log[T]

type Factory 

type Factory[T Daemon] interface {
	New() T
	FactoryInfo
}

type FactoryConfig 

type FactoryConfig struct {
	Symbol   int
	Book     int
	Candle   int
	Trade    int
	Schedule int
	Data     int
}

type FactoryInfo 

type FactoryInfo interface {
	Identifiable
}

type Identifiable 

type Identifiable = common.Identifiable[uuid.UUID]

type Key 

type Key = uint64

Key encodes an optional domain, symbol and optional interval.

func NewCandleKey 

func NewCandleKey(key Key, minute int64) Key

NewCandleKey should only be used with Keys created by NewKey. The minute count must be greater than zero and less than 2048. Domain is set to Candle.

func NewDomainKey 

func NewDomainKey(domain Domain, key Key) Key

NewDomainKey should only be used with Keys created by NewKey.

func NewKey 

func NewKey(symbol string) Key

The symbol must consist only of [ A-Z . - ] and be at most 10 characters long. Domain defaults to Symbol.

type Lineage 

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

func (Lineage) Alive 

func (this Lineage) Alive() bool

func (Lineage) HideContainer 

func (this Lineage) HideContainer(hidden bool)

type Linker 

type Linker interface {
	Liveness
	AddSymbol(SymbolFactory) error
	AddBook(BookFactory) error
	AddCandle(CandleFactory) error
	AddTrade(TradeFactory) error
	AddSchedule(ScheduleFactory) error
	AddData(DataFactory) error
	ResumeID(id uuid.UUID) error
	PauseID(id uuid.UUID) error
	Kill(id uuid.UUID) error
}

type Liveness 

type Liveness interface {
	Alive() int64
}

type Manager 

type Manager interface {
	Linker
	Revive(id uuid.UUID) error
	Get(id uuid.UUID) (Daemon, error)
	DaemonInfo(hidden bool, selector Selector) []DaemonInfo
	Pause(hidden bool, selector Selector) error
	Resume(hidden bool, selector Selector) error
	Restart(hidden bool, selector Selector) error
	SetConfig(hidden bool, selector Selector, config []byte) error
	Hide(selector Selector) error
	Show(selector Selector) error
	Shutdown() error
}

func NewManager10 

func NewManager10(cfg Config) Manager

func NewManager11 

func NewManager11(cfg Config) Manager

func NewManager12 

func NewManager12(cfg Config) Manager

func NewManager13 

func NewManager13(cfg Config) Manager

func NewManager14 

func NewManager14(cfg Config) Manager

func NewManager15 

func NewManager15(cfg Config) Manager

func NewManager16 

func NewManager16(cfg Config) Manager

func NewManager17 

func NewManager17(cfg Config) Manager

func NewManager18 

func NewManager18(cfg Config) Manager

func NewManager19 

func NewManager19(cfg Config) Manager

func NewManager20 

func NewManager20(cfg Config) Manager

func NewManager21 

func NewManager21(cfg Config) Manager

func NewManager22 

func NewManager22(cfg Config) Manager

func NewManager23 

func NewManager23(cfg Config) Manager

func NewManager24 

func NewManager24(cfg Config) Manager

func NewManager25 

func NewManager25(cfg Config) Manager

func NewManager26 

func NewManager26(cfg Config) Manager

func NewManager27 

func NewManager27(cfg Config) Manager

func NewManager28 

func NewManager28(cfg Config) Manager

func NewManager29 

func NewManager29(cfg Config) Manager

func NewManager30 

func NewManager30(cfg Config) Manager

func NewManager31 

func NewManager31(cfg Config) Manager

func NewManager32 

func NewManager32(cfg Config) Manager

func NewManager33 

func NewManager33(cfg Config) Manager

func NewManager34 

func NewManager34(cfg Config) Manager

func NewManager7 

func NewManager7(cfg Config) Manager

func NewManager8 

func NewManager8(cfg Config) Manager

func NewManager9 

func NewManager9(cfg Config) Manager

type Manager10 

type Manager10 struct {
	Lineage kit.CoarseMap[uuid.UUID, Lineage]
	// contains filtered or unexported fields
}

func (*Manager10) AddBook 

func (this *Manager10) AddBook(factory BookFactory) error

func (*Manager10) AddCandle 

func (this *Manager10) AddCandle(factory CandleFactory) error

func (*Manager10) AddData 

func (this *Manager10) AddData(factory DataFactory) error

func (*Manager10) AddSchedule 

func (this *Manager10) AddSchedule(factory ScheduleFactory) error

func (*Manager10) AddSymbol 

func (this *Manager10) AddSymbol(factory SymbolFactory) error

func (*Manager10) AddTrade 

func (this *Manager10) AddTrade(factory TradeFactory) error

func (*Manager10) Alive 

func (this *Manager10) Alive() int64

func (*Manager10) DaemonInfo 

func (this *Manager10) DaemonInfo(hidden bool, selector Selector) []DaemonInfo

func (*Manager10) Get 

func (this *Manager10) Get(id uuid.UUID) (Daemon, error)

func (*Manager10) Hide 

func (this *Manager10) Hide(selector Selector) error

func (*Manager10) Kill 

func (this *Manager10) Kill(id uuid.UUID) error

func (*Manager10) Pause 

func (this *Manager10) Pause(hidden bool, selector Selector) (err error)

func (*Manager10) PauseID 

func (this *Manager10) PauseID(id uuid.UUID) error

func (*Manager10) Restart 

func (this *Manager10) Restart(hidden bool, selector Selector) (err error)

func (*Manager10) Resume 

func (this *Manager10) Resume(hidden bool, selector Selector) (err error)

func (*Manager10) ResumeID 

func (this *Manager10) ResumeID(id uuid.UUID) error

func (*Manager10) Revive 

func (this *Manager10) Revive(id uuid.UUID) error

func (*Manager10) SetConfig 

func (this *Manager10) SetConfig(hidden bool, selector Selector, config []byte) error

func (*Manager10) Show 

func (this *Manager10) Show(selector Selector) error

func (*Manager10) Shutdown 

func (this *Manager10) Shutdown() (err error)

type Manager11 

type Manager11 struct {
	Lineage kit.CoarseMap[uuid.UUID, Lineage]
	// contains filtered or unexported fields
}

func (*Manager11) AddBook 

func (this *Manager11) AddBook(factory BookFactory) error

func (*Manager11) AddCandle 

func (this *Manager11) AddCandle(factory CandleFactory) error

func (*Manager11) AddData 

func (this *Manager11) AddData(factory DataFactory) error

func (*Manager11) AddSchedule 

func (this *Manager11) AddSchedule(factory ScheduleFactory) error

func (*Manager11) AddSymbol 

func (this *Manager11) AddSymbol(factory SymbolFactory) error

func (*Manager11) AddTrade 

func (this *Manager11) AddTrade(factory TradeFactory) error

func (*Manager11) Alive 

func (this *Manager11) Alive() int64

func (*Manager11) DaemonInfo 

func (this *Manager11) DaemonInfo(hidden bool, selector Selector) []DaemonInfo

func (*Manager11) Get 

func (this *Manager11) Get(id uuid.UUID) (Daemon, error)

func (*Manager11) Hide 

func (this *Manager11) Hide(selector Selector) error

func (*Manager11) Kill 

func (this *Manager11) Kill(id uuid.UUID) error

func (*Manager11) Pause 

func (this *Manager11) Pause(hidden bool, selector Selector) (err error)

func (*Manager11) PauseID 

func (this *Manager11) PauseID(id uuid.UUID) error

func (*Manager11) Restart 

func (this *Manager11) Restart(hidden bool, selector Selector) (err error)

func (*Manager11) Resume 

func (this *Manager11) Resume(hidden bool, selector Selector) (err error)

func (*Manager11) ResumeID 

func (this *Manager11) ResumeID(id uuid.UUID) error

func (*Manager11) Revive 

func (this *Manager11) Revive(id uuid.UUID) error

func (*Manager11) SetConfig 

func (this *Manager11) SetConfig(hidden bool, selector Selector, config []byte) error

func (*Manager11) Show 

func (this *Manager11) Show(selector Selector) error

func (*Manager11) Shutdown 

func (this *Manager11) Shutdown() (err error)

type Manager12 

type Manager12 struct {
	Lineage kit.CoarseMap[uuid.UUID, Lineage]
	// contains filtered or unexported fields
}

func (*Manager12) AddBook 

func (this *Manager12) AddBook(factory BookFactory) error

func (*Manager12) AddCandle 

func (this *Manager12) AddCandle(factory CandleFactory) error

func (*Manager12) AddData 

func (this *Manager12) AddData(factory DataFactory) error

func (*Manager12) AddSchedule 

func (this *Manager12) AddSchedule(factory ScheduleFactory) error

func (*Manager12) AddSymbol 

func (this *Manager12) AddSymbol(factory SymbolFactory) error

func (*Manager12) AddTrade 

func (this *Manager12) AddTrade(factory TradeFactory) error

func (*Manager12) Alive 

func (this *Manager12) Alive() int64

func (*Manager12) DaemonInfo 

func (this *Manager12) DaemonInfo(hidden bool, selector Selector) []DaemonInfo

func (*Manager12) Get 

func (this *Manager12) Get(id uuid.UUID) (Daemon, error)

func (*Manager12) Hide 

func (this *Manager12) Hide(selector Selector) error

func (*Manager12) Kill 

func (this *Manager12) Kill(id uuid.UUID) error

func (*Manager12) Pause 

func (this *Manager12) Pause(hidden bool, selector Selector) (err error)

func (*Manager12) PauseID 

func (this *Manager12) PauseID(id uuid.UUID) error

func (*Manager12) Restart 

func (this *Manager12) Restart(hidden bool, selector Selector) (err error)

func (*Manager12) Resume 

func (this *Manager12) Resume(hidden bool, selector Selector) (err error)

func (*Manager12) ResumeID 

func (this *Manager12) ResumeID(id uuid.UUID) error

func (*Manager12) Revive 

func (this *Manager12) Revive(id uuid.UUID) error

func (*Manager12) SetConfig 

func (this *Manager12) SetConfig(hidden bool, selector Selector, config []byte) error

func (*Manager12) Show 

func (this *Manager12) Show(selector Selector) error

func (*Manager12) Shutdown 

func (this *Manager12) Shutdown() (err error)

type Manager13 

type Manager13 struct {
	Lineage kit.CoarseMap[uuid.UUID, Lineage]
	// contains filtered or unexported fields
}

func (*Manager13) AddBook 

func (this *Manager13) AddBook(factory BookFactory) error

func (*Manager13) AddCandle 

func (this *Manager13) AddCandle(factory CandleFactory) error

func (*Manager13) AddData 

func (this *Manager13) AddData(factory DataFactory) error

func (*Manager13) AddSchedule 

func (this *Manager13) AddSchedule(factory ScheduleFactory) error

func (*Manager13) AddSymbol 

func (this *Manager13) AddSymbol(factory SymbolFactory) error

func (*Manager13) AddTrade 

func (this *Manager13) AddTrade(factory TradeFactory) error

func (*Manager13) Alive 

func (this *Manager13) Alive() int64

func (*Manager13) DaemonInfo 

func (this *Manager13) DaemonInfo(hidden bool, selector Selector) []DaemonInfo

func (*Manager13) Get 

func (this *Manager13) Get(id uuid.UUID) (Daemon, error)

func (*Manager13) Hide 

func (this *Manager13) Hide(selector Selector) error

func (*Manager13) Kill 

func (this *Manager13) Kill(id uuid.UUID) error

func (*Manager13) Pause 

func (this *Manager13) Pause(hidden bool, selector Selector) (err error)

func (*Manager13) PauseID 

func (this *Manager13) PauseID(id uuid.UUID) error

func (*Manager13) Restart 

func (this *Manager13) Restart(hidden bool, selector Selector) (err error)

func (*Manager13) Resume 

func (this *Manager13) Resume(hidden bool, selector Selector) (err error)

func (*Manager13) ResumeID 

func (this *Manager13) ResumeID(id uuid.UUID) error

func (*Manager13) Revive 

func (this *Manager13) Revive(id uuid.UUID) error

func (*Manager13) SetConfig 

func (this *Manager13) SetConfig(hidden bool, selector Selector, config []byte) error

func (*Manager13) Show 

func (this *Manager13) Show(selector Selector) error

func (*Manager13) Shutdown 

func (this *Manager13) Shutdown() (err error)

type Manager14 

type Manager14 struct {
	Lineage kit.CoarseMap[uuid.UUID, Lineage]
	// contains filtered or unexported fields
}

func (*Manager14) AddBook 

func (this *Manager14) AddBook(factory BookFactory) error

func (*Manager14) AddCandle 

func (this *Manager14) AddCandle(factory CandleFactory) error

func (*Manager14) AddData 

func (this *Manager14) AddData(factory DataFactory) error

func (*Manager14) AddSchedule 

func (this *Manager14) AddSchedule(factory ScheduleFactory) error

func (*Manager14) AddSymbol 

func (this *Manager14) AddSymbol(factory SymbolFactory) error

func (*Manager14) AddTrade 

func (this *Manager14) AddTrade(factory TradeFactory) error

func (*Manager14) Alive 

func (this *Manager14) Alive() int64

func (*Manager14) DaemonInfo 

func (this *Manager14) DaemonInfo(hidden bool, selector Selector) []DaemonInfo

func (*Manager14) Get 

func (this *Manager14) Get(id uuid.UUID) (Daemon, error)

func (*Manager14) Hide 

func (this *Manager14) Hide(selector Selector) error

func (*Manager14) Kill 

func (this *Manager14) Kill(id uuid.UUID) error

func (*Manager14) Pause 

func (this *Manager14) Pause(hidden bool, selector Selector) (err error)

func (*Manager14) PauseID 

func (this *Manager14) PauseID(id uuid.UUID) error

func (*Manager14) Restart 

func (this *Manager14) Restart(hidden bool, selector Selector) (err error)

func (*Manager14) Resume 

func (this *Manager14) Resume(hidden bool, selector Selector) (err error)

func (*Manager14) ResumeID 

func (this *Manager14) ResumeID(id uuid.UUID) error

func (*Manager14) Revive 

func (this *Manager14) Revive(id uuid.UUID) error

func (*Manager14) SetConfig 

func (this *Manager14) SetConfig(hidden bool, selector Selector, config []byte) error

func (*Manager14) Show 

func (this *Manager14) Show(selector Selector) error

func (*Manager14) Shutdown 

func (this *Manager14) Shutdown() (err error)

type Manager15 

type Manager15 struct {
	Lineage kit.CoarseMap[uuid.UUID, Lineage]
	// contains filtered or unexported fields
}

func (*Manager15) AddBook 

func (this *Manager15) AddBook(factory BookFactory) error

func (*Manager15) AddCandle 

func (this *Manager15) AddCandle(factory CandleFactory) error

func (*Manager15) AddData 

func (this *Manager15) AddData(factory DataFactory) error

func (*Manager15) AddSchedule 

func (this *Manager15) AddSchedule(factory ScheduleFactory) error

func (*Manager15) AddSymbol 

func (this *Manager15) AddSymbol(factory SymbolFactory) error

func (*Manager15) AddTrade 

func (this *Manager15) AddTrade(factory TradeFactory) error

func (*Manager15) Alive 

func (this *Manager15) Alive() int64

func (*Manager15) DaemonInfo 

func (this *Manager15) DaemonInfo(hidden bool, selector Selector) []DaemonInfo

func (*Manager15) Get 

func (this *Manager15) Get(id uuid.UUID) (Daemon, error)

func (*Manager15) Hide 

func (this *Manager15) Hide(selector Selector) error

func (*Manager15) Kill 

func (this *Manager15) Kill(id uuid.UUID) error

func (*Manager15) Pause 

func (this *Manager15) Pause(hidden bool, selector Selector) (err error)

func (*Manager15) PauseID 

func (this *Manager15) PauseID(id uuid.UUID) error

func (*Manager15) Restart 

func (this *Manager15) Restart(hidden bool, selector Selector) (err error)

func (*Manager15) Resume 

func (this *Manager15) Resume(hidden bool, selector Selector) (err error)

func (*Manager15) ResumeID 

func (this *Manager15) ResumeID(id uuid.UUID) error

func (*Manager15) Revive 

func (this *Manager15) Revive(id uuid.UUID) error

func (*Manager15) SetConfig 

func (this *Manager15) SetConfig(hidden bool, selector Selector, config []byte) error

func (*Manager15) Show 

func (this *Manager15) Show(selector Selector) error

func (*Manager15) Shutdown 

func (this *Manager15) Shutdown() (err error)

type Manager16 

type Manager16 struct {
	Lineage kit.CoarseMap[uuid.UUID, Lineage]
	// contains filtered or unexported fields
}

func (*Manager16) AddBook 

func (this *Manager16) AddBook(factory BookFactory) error

func (*Manager16) AddCandle 

func (this *Manager16) AddCandle(factory CandleFactory) error

func (*Manager16) AddData 

func (this *Manager16) AddData(factory DataFactory) error

func (*Manager16) AddSchedule 

func (this *Manager16) AddSchedule(factory ScheduleFactory) error

func (*Manager16) AddSymbol 

func (this *Manager16) AddSymbol(factory SymbolFactory) error

func (*Manager16) AddTrade 

func (this *Manager16) AddTrade(factory TradeFactory) error

func (*Manager16) Alive 

func (this *Manager16) Alive() int64

func (*Manager16) DaemonInfo 

func (this *Manager16) DaemonInfo(hidden bool, selector Selector) []DaemonInfo

func (*Manager16) Get 

func (this *Manager16) Get(id uuid.UUID) (Daemon, error)

func (*Manager16) Hide 

func (this *Manager16) Hide(selector Selector) error

func (*Manager16) Kill 

func (this *Manager16) Kill(id uuid.UUID) error

func (*Manager16) Pause 

func (this *Manager16) Pause(hidden bool, selector Selector) (err error)

func (*Manager16) PauseID 

func (this *Manager16) PauseID(id uuid.UUID) error

func (*Manager16) Restart 

func (this *Manager16) Restart(hidden bool, selector Selector) (err error)

func (*Manager16) Resume 

func (this *Manager16) Resume(hidden bool, selector Selector) (err error)

func (*Manager16) ResumeID 

func (this *Manager16) ResumeID(id uuid.UUID) error

func (*Manager16) Revive 

func (this *Manager16) Revive(id uuid.UUID) error

func (*Manager16) SetConfig 

func (this *Manager16) SetConfig(hidden bool, selector Selector, config []byte) error

func (*Manager16) Show 

func (this *Manager16) Show(selector Selector) error

func (*Manager16) Shutdown 

func (this *Manager16) Shutdown() (err error)

type Manager17 

type Manager17 struct {
	Lineage kit.CoarseMap[uuid.UUID, Lineage]
	// contains filtered or unexported fields
}

func (*Manager17) AddBook 

func (this *Manager17) AddBook(factory BookFactory) error

func (*Manager17) AddCandle 

func (this *Manager17) AddCandle(factory CandleFactory) error

func (*Manager17) AddData 

func (this *Manager17) AddData(factory DataFactory) error

func (*Manager17) AddSchedule 

func (this *Manager17) AddSchedule(factory ScheduleFactory) error

func (*Manager17) AddSymbol 

func (this *Manager17) AddSymbol(factory SymbolFactory) error

func (*Manager17) AddTrade 

func (this *Manager17) AddTrade(factory TradeFactory) error

func (*Manager17) Alive 

func (this *Manager17) Alive() int64

func (*Manager17) DaemonInfo 

func (this *Manager17) DaemonInfo(hidden bool, selector Selector) []DaemonInfo

func (*Manager17) Get 

func (this *Manager17) Get(id uuid.UUID) (Daemon, error)

func (*Manager17) Hide 

func (this *Manager17) Hide(selector Selector) error

func (*Manager17) Kill 

func (this *Manager17) Kill(id uuid.UUID) error

func (*Manager17) Pause 

func (this *Manager17) Pause(hidden bool, selector Selector) (err error)

func (*Manager17) PauseID 

func (this *Manager17) PauseID(id uuid.UUID) error

func (*Manager17) Restart 

func (this *Manager17) Restart(hidden bool, selector Selector) (err error)

func (*Manager17) Resume 

func (this *Manager17) Resume(hidden bool, selector Selector) (err error)

func (*Manager17) ResumeID 

func (this *Manager17) ResumeID(id uuid.UUID) error

func (*Manager17) Revive 

func (this *Manager17) Revive(id uuid.UUID) error

func (*Manager17) SetConfig 

func (this *Manager17) SetConfig(hidden bool, selector Selector, config []byte) error

func (*Manager17) Show 

func (this *Manager17) Show(selector Selector) error

func (*Manager17) Shutdown 

func (this *Manager17) Shutdown() (err error)

type Manager18 

type Manager18 struct {
	Lineage kit.CoarseMap[uuid.UUID, Lineage]
	// contains filtered or unexported fields
}

func (*Manager18) AddBook 

func (this *Manager18) AddBook(factory BookFactory) error

func (*Manager18) AddCandle 

func (this *Manager18) AddCandle(factory CandleFactory) error

func (*Manager18) AddData 

func (this *Manager18) AddData(factory DataFactory) error

func (*Manager18) AddSchedule 

func (this *Manager18) AddSchedule(factory ScheduleFactory) error

func (*Manager18) AddSymbol 

func (this *Manager18) AddSymbol(factory SymbolFactory) error

func (*Manager18) AddTrade 

func (this *Manager18) AddTrade(factory TradeFactory) error

func (*Manager18) Alive 

func (this *Manager18) Alive() int64

func (*Manager18) DaemonInfo 

func (this *Manager18) DaemonInfo(hidden bool, selector Selector) []DaemonInfo

func (*Manager18) Get 

func (this *Manager18) Get(id uuid.UUID) (Daemon, error)

func (*Manager18) Hide 

func (this *Manager18) Hide(selector Selector) error

func (*Manager18) Kill 

func (this *Manager18) Kill(id uuid.UUID) error

func (*Manager18) Pause 

func (this *Manager18) Pause(hidden bool, selector Selector) (err error)

func (*Manager18) PauseID 

func (this *Manager18) PauseID(id uuid.UUID) error

func (*Manager18) Restart 

func (this *Manager18) Restart(hidden bool, selector Selector) (err error)

func (*Manager18) Resume 

func (this *Manager18) Resume(hidden bool, selector Selector) (err error)

func (*Manager18) ResumeID 

func (this *Manager18) ResumeID(id uuid.UUID) error

func (*Manager18) Revive 

func (this *Manager18) Revive(id uuid.UUID) error

func (*Manager18) SetConfig 

func (this *Manager18) SetConfig(hidden bool, selector Selector, config []byte) error

func (*Manager18) Show 

func (this *Manager18) Show(selector Selector) error

func (*Manager18) Shutdown 

func (this *Manager18) Shutdown() (err error)

type Manager19 

type Manager19 struct {
	Lineage kit.CoarseMap[uuid.UUID, Lineage]
	// contains filtered or unexported fields
}

func (*Manager19) AddBook 

func (this *Manager19) AddBook(factory BookFactory) error

func (*Manager19) AddCandle 

func (this *Manager19) AddCandle(factory CandleFactory) error

func (*Manager19) AddData 

func (this *Manager19) AddData(factory DataFactory) error

func (*Manager19) AddSchedule 

func (this *Manager19) AddSchedule(factory ScheduleFactory) error

func (*Manager19) AddSymbol 

func (this *Manager19) AddSymbol(factory SymbolFactory) error

func (*Manager19) AddTrade 

func (this *Manager19) AddTrade(factory TradeFactory) error

func (*Manager19) Alive 

func (this *Manager19) Alive() int64

func (*Manager19) DaemonInfo 

func (this *Manager19) DaemonInfo(hidden bool, selector Selector) []DaemonInfo

func (*Manager19) Get 

func (this *Manager19) Get(id uuid.UUID) (Daemon, error)

func (*Manager19) Hide 

func (this *Manager19) Hide(selector Selector) error

func (*Manager19) Kill 

func (this *Manager19) Kill(id uuid.UUID) error

func (*Manager19) Pause 

func (this *Manager19) Pause(hidden bool, selector Selector) (err error)

func (*Manager19) PauseID 

func (this *Manager19) PauseID(id uuid.UUID) error

func (*Manager19) Restart 

func (this *Manager19) Restart(hidden bool, selector Selector) (err error)

func (*Manager19) Resume 

func (this *Manager19) Resume(hidden bool, selector Selector) (err error)

func (*Manager19) ResumeID 

func (this *Manager19) ResumeID(id uuid.UUID) error

func (*Manager19) Revive 

func (this *Manager19) Revive(id uuid.UUID) error

func (*Manager19) SetConfig 

func (this *Manager19) SetConfig(hidden bool, selector Selector, config []byte) error

func (*Manager19) Show 

func (this *Manager19) Show(selector Selector) error

func (*Manager19) Shutdown 

func (this *Manager19) Shutdown() (err error)

type Manager20 

type Manager20 struct {
	Lineage kit.CoarseMap[uuid.UUID, Lineage]
	// contains filtered or unexported fields
}

func (*Manager20) AddBook 

func (this *Manager20) AddBook(factory BookFactory) error

func (*Manager20) AddCandle 

func (this *Manager20) AddCandle(factory CandleFactory) error

func (*Manager20) AddData 

func (this *Manager20) AddData(factory DataFactory) error

func (*Manager20) AddSchedule 

func (this *Manager20) AddSchedule(factory ScheduleFactory) error

func (*Manager20) AddSymbol 

func (this *Manager20) AddSymbol(factory SymbolFactory) error

func (*Manager20) AddTrade 

func (this *Manager20) AddTrade(factory TradeFactory) error

func (*Manager20) Alive 

func (this *Manager20) Alive() int64

func (*Manager20) DaemonInfo 

func (this *Manager20) DaemonInfo(hidden bool, selector Selector) []DaemonInfo

func (*Manager20) Get 

func (this *Manager20) Get(id uuid.UUID) (Daemon, error)

func (*Manager20) Hide 

func (this *Manager20) Hide(selector Selector) error

func (*Manager20) Kill 

func (this *Manager20) Kill(id uuid.UUID) error

func (*Manager20) Pause 

func (this *Manager20) Pause(hidden bool, selector Selector) (err error)

func (*Manager20) PauseID 

func (this *Manager20) PauseID(id uuid.UUID) error

func (*Manager20) Restart 

func (this *Manager20) Restart(hidden bool, selector Selector) (err error)

func (*Manager20) Resume 

func (this *Manager20) Resume(hidden bool, selector Selector) (err error)

func (*Manager20) ResumeID 

func (this *Manager20) ResumeID(id uuid.UUID) error

func (*Manager20) Revive 

func (this *Manager20) Revive(id uuid.UUID) error

func (*Manager20) SetConfig 

func (this *Manager20) SetConfig(hidden bool, selector Selector, config []byte) error

func (*Manager20) Show 

func (this *Manager20) Show(selector Selector) error

func (*Manager20) Shutdown 

func (this *Manager20) Shutdown() (err error)

type Manager21 

type Manager21 struct {
	Lineage kit.CoarseMap[uuid.UUID, Lineage]
	// contains filtered or unexported fields
}

func (*Manager21) AddBook 

func (this *Manager21) AddBook(factory BookFactory) error

func (*Manager21) AddCandle 

func (this *Manager21) AddCandle(factory CandleFactory) error

func (*Manager21) AddData 

func (this *Manager21) AddData(factory DataFactory) error

func (*Manager21) AddSchedule 

func (this *Manager21) AddSchedule(factory ScheduleFactory) error

func (*Manager21) AddSymbol 

func (this *Manager21) AddSymbol(factory SymbolFactory) error

func (*Manager21) AddTrade 

func (this *Manager21) AddTrade(factory TradeFactory) error

func (*Manager21) Alive 

func (this *Manager21) Alive() int64

func (*Manager21) DaemonInfo 

func (this *Manager21) DaemonInfo(hidden bool, selector Selector) []DaemonInfo

func (*Manager21) Get 

func (this *Manager21) Get(id uuid.UUID) (Daemon, error)

func (*Manager21) Hide 

func (this *Manager21) Hide(selector Selector) error

func (*Manager21) Kill 

func (this *Manager21) Kill(id uuid.UUID) error

func (*Manager21) Pause 

func (this *Manager21) Pause(hidden bool, selector Selector) (err error)

func (*Manager21) PauseID 

func (this *Manager21) PauseID(id uuid.UUID) error

func (*Manager21) Restart 

func (this *Manager21) Restart(hidden bool, selector Selector) (err error)

func (*Manager21) Resume 

func (this *Manager21) Resume(hidden bool, selector Selector) (err error)

func (*Manager21) ResumeID 

func (this *Manager21) ResumeID(id uuid.UUID) error

func (*Manager21) Revive 

func (this *Manager21) Revive(id uuid.UUID) error

func (*Manager21) SetConfig 

func (this *Manager21) SetConfig(hidden bool, selector Selector, config []byte) error

func (*Manager21) Show 

func (this *Manager21) Show(selector Selector) error

func (*Manager21) Shutdown 

func (this *Manager21) Shutdown() (err error)

type Manager22 

type Manager22 struct {
	Lineage kit.CoarseMap[uuid.UUID, Lineage]
	// contains filtered or unexported fields
}

func (*Manager22) AddBook 

func (this *Manager22) AddBook(factory BookFactory) error

func (*Manager22) AddCandle 

func (this *Manager22) AddCandle(factory CandleFactory) error

func (*Manager22) AddData 

func (this *Manager22) AddData(factory DataFactory) error

func (*Manager22) AddSchedule 

func (this *Manager22) AddSchedule(factory ScheduleFactory) error

func (*Manager22) AddSymbol 

func (this *Manager22) AddSymbol(factory SymbolFactory) error

func (*Manager22) AddTrade 

func (this *Manager22) AddTrade(factory TradeFactory) error

func (*Manager22) Alive 

func (this *Manager22) Alive() int64

func (*Manager22) DaemonInfo 

func (this *Manager22) DaemonInfo(hidden bool, selector Selector) []DaemonInfo

func (*Manager22) Get 

func (this *Manager22) Get(id uuid.UUID) (Daemon, error)

func (*Manager22) Hide 

func (this *Manager22) Hide(selector Selector) error

func (*Manager22) Kill 

func (this *Manager22) Kill(id uuid.UUID) error

func (*Manager22) Pause 

func (this *Manager22) Pause(hidden bool, selector Selector) (err error)

func (*Manager22) PauseID 

func (this *Manager22) PauseID(id uuid.UUID) error

func (*Manager22) Restart 

func (this *Manager22) Restart(hidden bool, selector Selector) (err error)

func (*Manager22) Resume 

func (this *Manager22) Resume(hidden bool, selector Selector) (err error)

func (*Manager22) ResumeID 

func (this *Manager22) ResumeID(id uuid.UUID) error

func (*Manager22) Revive 

func (this *Manager22) Revive(id uuid.UUID) error

func (*Manager22) SetConfig 

func (this *Manager22) SetConfig(hidden bool, selector Selector, config []byte) error

func (*Manager22) Show 

func (this *Manager22) Show(selector Selector) error

func (*Manager22) Shutdown 

func (this *Manager22) Shutdown() (err error)

type Manager23 

type Manager23 struct {
	Lineage kit.CoarseMap[uuid.UUID, Lineage]
	// contains filtered or unexported fields
}

func (*Manager23) AddBook 

func (this *Manager23) AddBook(factory BookFactory) error

func (*Manager23) AddCandle 

func (this *Manager23) AddCandle(factory CandleFactory) error

func (*Manager23) AddData 

func (this *Manager23) AddData(factory DataFactory) error

func (*Manager23) AddSchedule 

func (this *Manager23) AddSchedule(factory ScheduleFactory) error

func (*Manager23) AddSymbol 

func (this *Manager23) AddSymbol(factory SymbolFactory) error

func (*Manager23) AddTrade 

func (this *Manager23) AddTrade(factory TradeFactory) error

func (*Manager23) Alive 

func (this *Manager23) Alive() int64

func (*Manager23) DaemonInfo 

func (this *Manager23) DaemonInfo(hidden bool, selector Selector) []DaemonInfo

func (*Manager23) Get 

func (this *Manager23) Get(id uuid.UUID) (Daemon, error)

func (*Manager23) Hide 

func (this *Manager23) Hide(selector Selector) error

func (*Manager23) Kill 

func (this *Manager23) Kill(id uuid.UUID) error

func (*Manager23) Pause 

func (this *Manager23) Pause(hidden bool, selector Selector) (err error)

func (*Manager23) PauseID 

func (this *Manager23) PauseID(id uuid.UUID) error

func (*Manager23) Restart 

func (this *Manager23) Restart(hidden bool, selector Selector) (err error)

func (*Manager23) Resume 

func (this *Manager23) Resume(hidden bool, selector Selector) (err error)

func (*Manager23) ResumeID 

func (this *Manager23) ResumeID(id uuid.UUID) error

func (*Manager23) Revive 

func (this *Manager23) Revive(id uuid.UUID) error

func (*Manager23) SetConfig 

func (this *Manager23) SetConfig(hidden bool, selector Selector, config []byte) error

func (*Manager23) Show 

func (this *Manager23) Show(selector Selector) error

func (*Manager23) Shutdown 

func (this *Manager23) Shutdown() (err error)

type Manager24 

type Manager24 struct {
	Lineage kit.CoarseMap[uuid.UUID, Lineage]
	// contains filtered or unexported fields
}

func (*Manager24) AddBook 

func (this *Manager24) AddBook(factory BookFactory) error

func (*Manager24) AddCandle 

func (this *Manager24) AddCandle(factory CandleFactory) error

func (*Manager24) AddData 

func (this *Manager24) AddData(factory DataFactory) error

func (*Manager24) AddSchedule 

func (this *Manager24) AddSchedule(factory ScheduleFactory) error

func (*Manager24) AddSymbol 

func (this *Manager24) AddSymbol(factory SymbolFactory) error

func (*Manager24) AddTrade 

func (this *Manager24) AddTrade(factory TradeFactory) error

func (*Manager24) Alive 

func (this *Manager24) Alive() int64

func (*Manager24) DaemonInfo 

func (this *Manager24) DaemonInfo(hidden bool, selector Selector) []DaemonInfo

func (*Manager24) Get 

func (this *Manager24) Get(id uuid.UUID) (Daemon, error)

func (*Manager24) Hide 

func (this *Manager24) Hide(selector Selector) error

func (*Manager24) Kill 

func (this *Manager24) Kill(id uuid.UUID) error

func (*Manager24) Pause 

func (this *Manager24) Pause(hidden bool, selector Selector) (err error)

func (*Manager24) PauseID 

func (this *Manager24) PauseID(id uuid.UUID) error

func (*Manager24) Restart 

func (this *Manager24) Restart(hidden bool, selector Selector) (err error)

func (*Manager24) Resume 

func (this *Manager24) Resume(hidden bool, selector Selector) (err error)

func (*Manager24) ResumeID 

func (this *Manager24) ResumeID(id uuid.UUID) error

func (*Manager24) Revive 

func (this *Manager24) Revive(id uuid.UUID) error

func (*Manager24) SetConfig 

func (this *Manager24) SetConfig(hidden bool, selector Selector, config []byte) error

func (*Manager24) Show 

func (this *Manager24) Show(selector Selector) error

func (*Manager24) Shutdown 

func (this *Manager24) Shutdown() (err error)

type Manager25 

type Manager25 struct {
	Lineage kit.CoarseMap[uuid.UUID, Lineage]
	// contains filtered or unexported fields
}

func (*Manager25) AddBook 

func (this *Manager25) AddBook(factory BookFactory) error

func (*Manager25) AddCandle 

func (this *Manager25) AddCandle(factory CandleFactory) error

func (*Manager25) AddData 

func (this *Manager25) AddData(factory DataFactory) error

func (*Manager25) AddSchedule 

func (this *Manager25) AddSchedule(factory ScheduleFactory) error

func (*Manager25) AddSymbol 

func (this *Manager25) AddSymbol(factory SymbolFactory) error

func (*Manager25) AddTrade 

func (this *Manager25) AddTrade(factory TradeFactory) error

func (*Manager25) Alive 

func (this *Manager25) Alive() int64

func (*Manager25) DaemonInfo 

func (this *Manager25) DaemonInfo(hidden bool, selector Selector) []DaemonInfo

func (*Manager25) Get 

func (this *Manager25) Get(id uuid.UUID) (Daemon, error)

func (*Manager25) Hide 

func (this *Manager25) Hide(selector Selector) error

func (*Manager25) Kill 

func (this *Manager25) Kill(id uuid.UUID) error

func (*Manager25) Pause 

func (this *Manager25) Pause(hidden bool, selector Selector) (err error)

func (*Manager25) PauseID 

func (this *Manager25) PauseID(id uuid.UUID) error

func (*Manager25) Restart 

func (this *Manager25) Restart(hidden bool, selector Selector) (err error)

func (*Manager25) Resume 

func (this *Manager25) Resume(hidden bool, selector Selector) (err error)

func (*Manager25) ResumeID 

func (this *Manager25) ResumeID(id uuid.UUID) error

func (*Manager25) Revive 

func (this *Manager25) Revive(id uuid.UUID) error

func (*Manager25) SetConfig 

func (this *Manager25) SetConfig(hidden bool, selector Selector, config []byte) error

func (*Manager25) Show 

func (this *Manager25) Show(selector Selector) error

func (*Manager25) Shutdown 

func (this *Manager25) Shutdown() (err error)

type Manager26 

type Manager26 struct {
	Lineage kit.CoarseMap[uuid.UUID, Lineage]
	// contains filtered or unexported fields
}

func (*Manager26) AddBook 

func (this *Manager26) AddBook(factory BookFactory) error

func (*Manager26) AddCandle 

func (this *Manager26) AddCandle(factory CandleFactory) error

func (*Manager26) AddData 

func (this *Manager26) AddData(factory DataFactory) error

func (*Manager26) AddSchedule 

func (this *Manager26) AddSchedule(factory ScheduleFactory) error

func (*Manager26) AddSymbol 

func (this *Manager26) AddSymbol(factory SymbolFactory) error

func (*Manager26) AddTrade 

func (this *Manager26) AddTrade(factory TradeFactory) error

func (*Manager26) Alive 

func (this *Manager26) Alive() int64

func (*Manager26) DaemonInfo 

func (this *Manager26) DaemonInfo(hidden bool, selector Selector) []DaemonInfo

func (*Manager26) Get 

func (this *Manager26) Get(id uuid.UUID) (Daemon, error)

func (*Manager26) Hide 

func (this *Manager26) Hide(selector Selector) error

func (*Manager26) Kill 

func (this *Manager26) Kill(id uuid.UUID) error

func (*Manager26) Pause 

func (this *Manager26) Pause(hidden bool, selector Selector) (err error)

func (*Manager26) PauseID 

func (this *Manager26) PauseID(id uuid.UUID) error

func (*Manager26) Restart 

func (this *Manager26) Restart(hidden bool, selector Selector) (err error)

func (*Manager26) Resume 

func (this *Manager26) Resume(hidden bool, selector Selector) (err error)

func (*Manager26) ResumeID 

func (this *Manager26) ResumeID(id uuid.UUID) error

func (*Manager26) Revive 

func (this *Manager26) Revive(id uuid.UUID) error

func (*Manager26) SetConfig 

func (this *Manager26) SetConfig(hidden bool, selector Selector, config []byte) error

func (*Manager26) Show 

func (this *Manager26) Show(selector Selector) error

func (*Manager26) Shutdown 

func (this *Manager26) Shutdown() (err error)

type Manager27 

type Manager27 struct {
	Lineage kit.CoarseMap[uuid.UUID, Lineage]
	// contains filtered or unexported fields
}

func (*Manager27) AddBook 

func (this *Manager27) AddBook(factory BookFactory) error

func (*Manager27) AddCandle 

func (this *Manager27) AddCandle(factory CandleFactory) error

func (*Manager27) AddData 

func (this *Manager27) AddData(factory DataFactory) error

func (*Manager27) AddSchedule 

func (this *Manager27) AddSchedule(factory ScheduleFactory) error

func (*Manager27) AddSymbol 

func (this *Manager27) AddSymbol(factory SymbolFactory) error

func (*Manager27) AddTrade 

func (this *Manager27) AddTrade(factory TradeFactory) error

func (*Manager27) Alive 

func (this *Manager27) Alive() int64

func (*Manager27) DaemonInfo 

func (this *Manager27) DaemonInfo(hidden bool, selector Selector) []DaemonInfo

func (*Manager27) Get 

func (this *Manager27) Get(id uuid.UUID) (Daemon, error)

func (*Manager27) Hide 

func (this *Manager27) Hide(selector Selector) error

func (*Manager27) Kill 

func (this *Manager27) Kill(id uuid.UUID) error

func (*Manager27) Pause 

func (this *Manager27) Pause(hidden bool, selector Selector) (err error)

func (*Manager27) PauseID 

func (this *Manager27) PauseID(id uuid.UUID) error

func (*Manager27) Restart 

func (this *Manager27) Restart(hidden bool, selector Selector) (err error)

func (*Manager27) Resume 

func (this *Manager27) Resume(hidden bool, selector Selector) (err error)

func (*Manager27) ResumeID 

func (this *Manager27) ResumeID(id uuid.UUID) error

func (*Manager27) Revive 

func (this *Manager27) Revive(id uuid.UUID) error

func (*Manager27) SetConfig 

func (this *Manager27) SetConfig(hidden bool, selector Selector, config []byte) error

func (*Manager27) Show 

func (this *Manager27) Show(selector Selector) error

func (*Manager27) Shutdown 

func (this *Manager27) Shutdown() (err error)

type Manager28 

type Manager28 struct {
	Lineage kit.CoarseMap[uuid.UUID, Lineage]
	// contains filtered or unexported fields
}

func (*Manager28) AddBook 

func (this *Manager28) AddBook(factory BookFactory) error

func (*Manager28) AddCandle 

func (this *Manager28) AddCandle(factory CandleFactory) error

func (*Manager28) AddData 

func (this *Manager28) AddData(factory DataFactory) error

func (*Manager28) AddSchedule 

func (this *Manager28) AddSchedule(factory ScheduleFactory) error

func (*Manager28) AddSymbol 

func (this *Manager28) AddSymbol(factory SymbolFactory) error

func (*Manager28) AddTrade 

func (this *Manager28) AddTrade(factory TradeFactory) error

func (*Manager28) Alive 

func (this *Manager28) Alive() int64

func (*Manager28) DaemonInfo 

func (this *Manager28) DaemonInfo(hidden bool, selector Selector) []DaemonInfo

func (*Manager28) Get 

func (this *Manager28) Get(id uuid.UUID) (Daemon, error)

func (*Manager28) Hide 

func (this *Manager28) Hide(selector Selector) error

func (*Manager28) Kill 

func (this *Manager28) Kill(id uuid.UUID) error

func (*Manager28) Pause 

func (this *Manager28) Pause(hidden bool, selector Selector) (err error)

func (*Manager28) PauseID 

func (this *Manager28) PauseID(id uuid.UUID) error

func (*Manager28) Restart 

func (this *Manager28) Restart(hidden bool, selector Selector) (err error)

func (*Manager28) Resume 

func (this *Manager28) Resume(hidden bool, selector Selector) (err error)

func (*Manager28) ResumeID 

func (this *Manager28) ResumeID(id uuid.UUID) error

func (*Manager28) Revive 

func (this *Manager28) Revive(id uuid.UUID) error

func (*Manager28) SetConfig 

func (this *Manager28) SetConfig(hidden bool, selector Selector, config []byte) error

func (*Manager28) Show 

func (this *Manager28) Show(selector Selector) error

func (*Manager28) Shutdown 

func (this *Manager28) Shutdown() (err error)

type Manager29 

type Manager29 struct {
	Lineage kit.CoarseMap[uuid.UUID, Lineage]
	// contains filtered or unexported fields
}

func (*Manager29) AddBook 

func (this *Manager29) AddBook(factory BookFactory) error

func (*Manager29) AddCandle 

func (this *Manager29) AddCandle(factory CandleFactory) error

func (*Manager29) AddData 

func (this *Manager29) AddData(factory DataFactory) error

func (*Manager29) AddSchedule 

func (this *Manager29) AddSchedule(factory ScheduleFactory) error

func (*Manager29) AddSymbol 

func (this *Manager29) AddSymbol(factory SymbolFactory) error

func (*Manager29) AddTrade 

func (this *Manager29) AddTrade(factory TradeFactory) error

func (*Manager29) Alive 

func (this *Manager29) Alive() int64

func (*Manager29) DaemonInfo 

func (this *Manager29) DaemonInfo(hidden bool, selector Selector) []DaemonInfo

func (*Manager29) Get 

func (this *Manager29) Get(id uuid.UUID) (Daemon, error)

func (*Manager29) Hide 

func (this *Manager29) Hide(selector Selector) error

func (*Manager29) Kill 

func (this *Manager29) Kill(id uuid.UUID) error

func (*Manager29) Pause 

func (this *Manager29) Pause(hidden bool, selector Selector) (err error)

func (*Manager29) PauseID 

func (this *Manager29) PauseID(id uuid.UUID) error

func (*Manager29) Restart 

func (this *Manager29) Restart(hidden bool, selector Selector) (err error)

func (*Manager29) Resume 

func (this *Manager29) Resume(hidden bool, selector Selector) (err error)

func (*Manager29) ResumeID 

func (this *Manager29) ResumeID(id uuid.UUID) error

func (*Manager29) Revive 

func (this *Manager29) Revive(id uuid.UUID) error

func (*Manager29) SetConfig 

func (this *Manager29) SetConfig(hidden bool, selector Selector, config []byte) error

func (*Manager29) Show 

func (this *Manager29) Show(selector Selector) error

func (*Manager29) Shutdown 

func (this *Manager29) Shutdown() (err error)

type Manager30 

type Manager30 struct {
	Lineage kit.CoarseMap[uuid.UUID, Lineage]
	// contains filtered or unexported fields
}

func (*Manager30) AddBook 

func (this *Manager30) AddBook(factory BookFactory) error

func (*Manager30) AddCandle 

func (this *Manager30) AddCandle(factory CandleFactory) error

func (*Manager30) AddData 

func (this *Manager30) AddData(factory DataFactory) error

func (*Manager30) AddSchedule 

func (this *Manager30) AddSchedule(factory ScheduleFactory) error

func (*Manager30) AddSymbol 

func (this *Manager30) AddSymbol(factory SymbolFactory) error

func (*Manager30) AddTrade 

func (this *Manager30) AddTrade(factory TradeFactory) error

func (*Manager30) Alive 

func (this *Manager30) Alive() int64

func (*Manager30) DaemonInfo 

func (this *Manager30) DaemonInfo(hidden bool, selector Selector) []DaemonInfo

func (*Manager30) Get 

func (this *Manager30) Get(id uuid.UUID) (Daemon, error)

func (*Manager30) Hide 

func (this *Manager30) Hide(selector Selector) error

func (*Manager30) Kill 

func (this *Manager30) Kill(id uuid.UUID) error

func (*Manager30) Pause 

func (this *Manager30) Pause(hidden bool, selector Selector) (err error)

func (*Manager30) PauseID 

func (this *Manager30) PauseID(id uuid.UUID) error

func (*Manager30) Restart 

func (this *Manager30) Restart(hidden bool, selector Selector) (err error)

func (*Manager30) Resume 

func (this *Manager30) Resume(hidden bool, selector Selector) (err error)

func (*Manager30) ResumeID 

func (this *Manager30) ResumeID(id uuid.UUID) error

func (*Manager30) Revive 

func (this *Manager30) Revive(id uuid.UUID) error

func (*Manager30) SetConfig 

func (this *Manager30) SetConfig(hidden bool, selector Selector, config []byte) error

func (*Manager30) Show 

func (this *Manager30) Show(selector Selector) error

func (*Manager30) Shutdown 

func (this *Manager30) Shutdown() (err error)

type Manager31 

type Manager31 struct {
	Lineage kit.CoarseMap[uuid.UUID, Lineage]
	// contains filtered or unexported fields
}

func (*Manager31) AddBook 

func (this *Manager31) AddBook(factory BookFactory) error

func (*Manager31) AddCandle 

func (this *Manager31) AddCandle(factory CandleFactory) error

func (*Manager31) AddData 

func (this *Manager31) AddData(factory DataFactory) error

func (*Manager31) AddSchedule 

func (this *Manager31) AddSchedule(factory ScheduleFactory) error

func (*Manager31) AddSymbol 

func (this *Manager31) AddSymbol(factory SymbolFactory) error

func (*Manager31) AddTrade 

func (this *Manager31) AddTrade(factory TradeFactory) error

func (*Manager31) Alive 

func (this *Manager31) Alive() int64

func (*Manager31) DaemonInfo 

func (this *Manager31) DaemonInfo(hidden bool, selector Selector) []DaemonInfo

func (*Manager31) Get 

func (this *Manager31) Get(id uuid.UUID) (Daemon, error)

func (*Manager31) Hide 

func (this *Manager31) Hide(selector Selector) error

func (*Manager31) Kill 

func (this *Manager31) Kill(id uuid.UUID) error

func (*Manager31) Pause 

func (this *Manager31) Pause(hidden bool, selector Selector) (err error)

func (*Manager31) PauseID 

func (this *Manager31) PauseID(id uuid.UUID) error

func (*Manager31) Restart 

func (this *Manager31) Restart(hidden bool, selector Selector) (err error)

func (*Manager31) Resume 

func (this *Manager31) Resume(hidden bool, selector Selector) (err error)

func (*Manager31) ResumeID 

func (this *Manager31) ResumeID(id uuid.UUID) error

func (*Manager31) Revive 

func (this *Manager31) Revive(id uuid.UUID) error

func (*Manager31) SetConfig 

func (this *Manager31) SetConfig(hidden bool, selector Selector, config []byte) error

func (*Manager31) Show 

func (this *Manager31) Show(selector Selector) error

func (*Manager31) Shutdown 

func (this *Manager31) Shutdown() (err error)

type Manager32 

type Manager32 struct {
	Lineage kit.CoarseMap[uuid.UUID, Lineage]
	// contains filtered or unexported fields
}

func (*Manager32) AddBook 

func (this *Manager32) AddBook(factory BookFactory) error

func (*Manager32) AddCandle 

func (this *Manager32) AddCandle(factory CandleFactory) error

func (*Manager32) AddData 

func (this *Manager32) AddData(factory DataFactory) error

func (*Manager32) AddSchedule 

func (this *Manager32) AddSchedule(factory ScheduleFactory) error

func (*Manager32) AddSymbol 

func (this *Manager32) AddSymbol(factory SymbolFactory) error

func (*Manager32) AddTrade 

func (this *Manager32) AddTrade(factory TradeFactory) error

func (*Manager32) Alive 

func (this *Manager32) Alive() int64

func (*Manager32) DaemonInfo 

func (this *Manager32) DaemonInfo(hidden bool, selector Selector) []DaemonInfo

func (*Manager32) Get 

func (this *Manager32) Get(id uuid.UUID) (Daemon, error)

func (*Manager32) Hide 

func (this *Manager32) Hide(selector Selector) error

func (*Manager32) Kill 

func (this *Manager32) Kill(id uuid.UUID) error

func (*Manager32) Pause 

func (this *Manager32) Pause(hidden bool, selector Selector) (err error)

func (*Manager32) PauseID 

func (this *Manager32) PauseID(id uuid.UUID) error

func (*Manager32) Restart 

func (this *Manager32) Restart(hidden bool, selector Selector) (err error)

func (*Manager32) Resume 

func (this *Manager32) Resume(hidden bool, selector Selector) (err error)

func (*Manager32) ResumeID 

func (this *Manager32) ResumeID(id uuid.UUID) error

func (*Manager32) Revive 

func (this *Manager32) Revive(id uuid.UUID) error

func (*Manager32) SetConfig 

func (this *Manager32) SetConfig(hidden bool, selector Selector, config []byte) error

func (*Manager32) Show 

func (this *Manager32) Show(selector Selector) error

func (*Manager32) Shutdown 

func (this *Manager32) Shutdown() (err error)

type Manager33 

type Manager33 struct {
	Lineage kit.CoarseMap[uuid.UUID, Lineage]
	// contains filtered or unexported fields
}

func (*Manager33) AddBook 

func (this *Manager33) AddBook(factory BookFactory) error

func (*Manager33) AddCandle 

func (this *Manager33) AddCandle(factory CandleFactory) error

func (*Manager33) AddData 

func (this *Manager33) AddData(factory DataFactory) error

func (*Manager33) AddSchedule 

func (this *Manager33) AddSchedule(factory ScheduleFactory) error

func (*Manager33) AddSymbol 

func (this *Manager33) AddSymbol(factory SymbolFactory) error

func (*Manager33) AddTrade 

func (this *Manager33) AddTrade(factory TradeFactory) error

func (*Manager33) Alive 

func (this *Manager33) Alive() int64

func (*Manager33) DaemonInfo 

func (this *Manager33) DaemonInfo(hidden bool, selector Selector) []DaemonInfo

func (*Manager33) Get 

func (this *Manager33) Get(id uuid.UUID) (Daemon, error)

func (*Manager33) Hide 

func (this *Manager33) Hide(selector Selector) error

func (*Manager33) Kill 

func (this *Manager33) Kill(id uuid.UUID) error

func (*Manager33) Pause 

func (this *Manager33) Pause(hidden bool, selector Selector) (err error)

func (*Manager33) PauseID 

func (this *Manager33) PauseID(id uuid.UUID) error

func (*Manager33) Restart 

func (this *Manager33) Restart(hidden bool, selector Selector) (err error)

func (*Manager33) Resume 

func (this *Manager33) Resume(hidden bool, selector Selector) (err error)

func (*Manager33) ResumeID 

func (this *Manager33) ResumeID(id uuid.UUID) error

func (*Manager33) Revive 

func (this *Manager33) Revive(id uuid.UUID) error

func (*Manager33) SetConfig 

func (this *Manager33) SetConfig(hidden bool, selector Selector, config []byte) error

func (*Manager33) Show 

func (this *Manager33) Show(selector Selector) error

func (*Manager33) Shutdown 

func (this *Manager33) Shutdown() (err error)

type Manager34 

type Manager34 struct {
	Lineage kit.CoarseMap[uuid.UUID, Lineage]
	// contains filtered or unexported fields
}

func (*Manager34) AddBook 

func (this *Manager34) AddBook(factory BookFactory) error

func (*Manager34) AddCandle 

func (this *Manager34) AddCandle(factory CandleFactory) error

func (*Manager34) AddData 

func (this *Manager34) AddData(factory DataFactory) error

func (*Manager34) AddSchedule 

func (this *Manager34) AddSchedule(factory ScheduleFactory) error

func (*Manager34) AddSymbol 

func (this *Manager34) AddSymbol(factory SymbolFactory) error

func (*Manager34) AddTrade 

func (this *Manager34) AddTrade(factory TradeFactory) error

func (*Manager34) Alive 

func (this *Manager34) Alive() int64

func (*Manager34) DaemonInfo 

func (this *Manager34) DaemonInfo(hidden bool, selector Selector) []DaemonInfo

func (*Manager34) Get 

func (this *Manager34) Get(id uuid.UUID) (Daemon, error)

func (*Manager34) Hide 

func (this *Manager34) Hide(selector Selector) error

func (*Manager34) Kill 

func (this *Manager34) Kill(id uuid.UUID) error

func (*Manager34) Pause 

func (this *Manager34) Pause(hidden bool, selector Selector) (err error)

func (*Manager34) PauseID 

func (this *Manager34) PauseID(id uuid.UUID) error

func (*Manager34) Restart 

func (this *Manager34) Restart(hidden bool, selector Selector) (err error)

func (*Manager34) Resume 

func (this *Manager34) Resume(hidden bool, selector Selector) (err error)

func (*Manager34) ResumeID 

func (this *Manager34) ResumeID(id uuid.UUID) error

func (*Manager34) Revive 

func (this *Manager34) Revive(id uuid.UUID) error

func (*Manager34) SetConfig 

func (this *Manager34) SetConfig(hidden bool, selector Selector, config []byte) error

func (*Manager34) Show 

func (this *Manager34) Show(selector Selector) error

func (*Manager34) Shutdown 

func (this *Manager34) Shutdown() (err error)

type Manager7 

type Manager7 struct {
	Lineage kit.CoarseMap[uuid.UUID, Lineage]
	// contains filtered or unexported fields
}

func (*Manager7) AddBook 

func (this *Manager7) AddBook(factory BookFactory) error

func (*Manager7) AddCandle 

func (this *Manager7) AddCandle(factory CandleFactory) error

func (*Manager7) AddData 

func (this *Manager7) AddData(factory DataFactory) error

func (*Manager7) AddSchedule 

func (this *Manager7) AddSchedule(factory ScheduleFactory) error

func (*Manager7) AddSymbol 

func (this *Manager7) AddSymbol(factory SymbolFactory) error

func (*Manager7) AddTrade 

func (this *Manager7) AddTrade(factory TradeFactory) error

func (*Manager7) Alive 

func (this *Manager7) Alive() int64

func (*Manager7) DaemonInfo 

func (this *Manager7) DaemonInfo(hidden bool, selector Selector) []DaemonInfo

func (*Manager7) Get 

func (this *Manager7) Get(id uuid.UUID) (Daemon, error)

func (*Manager7) Hide 

func (this *Manager7) Hide(selector Selector) error

func (*Manager7) Kill 

func (this *Manager7) Kill(id uuid.UUID) error

func (*Manager7) Pause 

func (this *Manager7) Pause(hidden bool, selector Selector) (err error)

func (*Manager7) PauseID 

func (this *Manager7) PauseID(id uuid.UUID) error

func (*Manager7) Restart 

func (this *Manager7) Restart(hidden bool, selector Selector) (err error)

func (*Manager7) Resume 

func (this *Manager7) Resume(hidden bool, selector Selector) (err error)

func (*Manager7) ResumeID 

func (this *Manager7) ResumeID(id uuid.UUID) error

func (*Manager7) Revive 

func (this *Manager7) Revive(id uuid.UUID) error

func (*Manager7) SetConfig 

func (this *Manager7) SetConfig(hidden bool, selector Selector, config []byte) error

func (*Manager7) Show 

func (this *Manager7) Show(selector Selector) error

func (*Manager7) Shutdown 

func (this *Manager7) Shutdown() (err error)

type Manager8 

type Manager8 struct {
	Lineage kit.CoarseMap[uuid.UUID, Lineage]
	// contains filtered or unexported fields
}

func (*Manager8) AddBook 

func (this *Manager8) AddBook(factory BookFactory) error

func (*Manager8) AddCandle 

func (this *Manager8) AddCandle(factory CandleFactory) error

func (*Manager8) AddData 

func (this *Manager8) AddData(factory DataFactory) error

func (*Manager8) AddSchedule 

func (this *Manager8) AddSchedule(factory ScheduleFactory) error

func (*Manager8) AddSymbol 

func (this *Manager8) AddSymbol(factory SymbolFactory) error

func (*Manager8) AddTrade 

func (this *Manager8) AddTrade(factory TradeFactory) error

func (*Manager8) Alive 

func (this *Manager8) Alive() int64

func (*Manager8) DaemonInfo 

func (this *Manager8) DaemonInfo(hidden bool, selector Selector) []DaemonInfo

func (*Manager8) Get 

func (this *Manager8) Get(id uuid.UUID) (Daemon, error)

func (*Manager8) Hide 

func (this *Manager8) Hide(selector Selector) error

func (*Manager8) Kill 

func (this *Manager8) Kill(id uuid.UUID) error

func (*Manager8) Pause 

func (this *Manager8) Pause(hidden bool, selector Selector) (err error)

func (*Manager8) PauseID 

func (this *Manager8) PauseID(id uuid.UUID) error

func (*Manager8) Restart 

func (this *Manager8) Restart(hidden bool, selector Selector) (err error)

func (*Manager8) Resume 

func (this *Manager8) Resume(hidden bool, selector Selector) (err error)

func (*Manager8) ResumeID 

func (this *Manager8) ResumeID(id uuid.UUID) error

func (*Manager8) Revive 

func (this *Manager8) Revive(id uuid.UUID) error

func (*Manager8) SetConfig 

func (this *Manager8) SetConfig(hidden bool, selector Selector, config []byte) error

func (*Manager8) Show 

func (this *Manager8) Show(selector Selector) error

func (*Manager8) Shutdown 

func (this *Manager8) Shutdown() (err error)

type Manager9 

type Manager9 struct {
	Lineage kit.CoarseMap[uuid.UUID, Lineage]
	// contains filtered or unexported fields
}

func (*Manager9) AddBook 

func (this *Manager9) AddBook(factory BookFactory) error

func (*Manager9) AddCandle 

func (this *Manager9) AddCandle(factory CandleFactory) error

func (*Manager9) AddData 

func (this *Manager9) AddData(factory DataFactory) error

func (*Manager9) AddSchedule 

func (this *Manager9) AddSchedule(factory ScheduleFactory) error

func (*Manager9) AddSymbol 

func (this *Manager9) AddSymbol(factory SymbolFactory) error

func (*Manager9) AddTrade 

func (this *Manager9) AddTrade(factory TradeFactory) error

func (*Manager9) Alive 

func (this *Manager9) Alive() int64

func (*Manager9) DaemonInfo 

func (this *Manager9) DaemonInfo(hidden bool, selector Selector) []DaemonInfo

func (*Manager9) Get 

func (this *Manager9) Get(id uuid.UUID) (Daemon, error)

func (*Manager9) Hide 

func (this *Manager9) Hide(selector Selector) error

func (*Manager9) Kill 

func (this *Manager9) Kill(id uuid.UUID) error

func (*Manager9) Pause 

func (this *Manager9) Pause(hidden bool, selector Selector) (err error)

func (*Manager9) PauseID 

func (this *Manager9) PauseID(id uuid.UUID) error

func (*Manager9) Restart 

func (this *Manager9) Restart(hidden bool, selector Selector) (err error)

func (*Manager9) Resume 

func (this *Manager9) Resume(hidden bool, selector Selector) (err error)

func (*Manager9) ResumeID 

func (this *Manager9) ResumeID(id uuid.UUID) error

func (*Manager9) Revive 

func (this *Manager9) Revive(id uuid.UUID) error

func (*Manager9) SetConfig 

func (this *Manager9) SetConfig(hidden bool, selector Selector, config []byte) error

func (*Manager9) Show 

func (this *Manager9) Show(selector Selector) error

func (*Manager9) Shutdown 

func (this *Manager9) Shutdown() (err error)

type Producer 

type Producer[T any] interface {
	Daemon
	Initialize(registry Registry[T]) error
}

type Provider 

type Provider[T UnixTimestamped] interface {
	Get() T
}

type Registry 

type Registry[T any] = common.Registry[Key, T]

type RegistryConfig 

type RegistryConfig struct {
	Symbol   int
	Book     int
	Candle   int
	Trade    int
	Schedule int
}

type ScheduleDaemon 

type ScheduleDaemon = Producer[EventLog[ScheduleEvent]]

type ScheduleEvent 

type ScheduleEvent struct {
	Symbol                 uint64
	Balance, Basis         uint64
	MinOrder, MinIncrement uint64
	EventUnixTime          int64
}

func (ScheduleEvent) UnixNano 

func (this ScheduleEvent) UnixNano() int64

type ScheduleFactory 

type ScheduleFactory = Factory[ScheduleDaemon]

type ScheduleLogRegistry 

type ScheduleLogRegistry = Registry[EventLog[ScheduleEvent]]

type Selector 

type Selector interface {
	Select(DaemonInfo) bool
}

type SymbolDaemon 

type SymbolDaemon = Control[EventLog[SymbolEvent]]

type SymbolEvent 

type SymbolEvent struct {
	Symbol uint64

	// Consider using IsOnline() helper. Negative value indicates online event.
	EventUnixTime int64
}

func (SymbolEvent) IsOnline added in v0.14.1 

func (this SymbolEvent) IsOnline() bool

func (SymbolEvent) UnixNano 

func (this SymbolEvent) UnixNano() int64

type SymbolFactory 

type SymbolFactory = Factory[SymbolDaemon]

type SymbolLogRegistry 

type SymbolLogRegistry = Registry[EventLog[SymbolEvent]]

type TradeDaemon 

type TradeDaemon = Producer[EventLog[TradeEvent]]

type TradeEvent 

type TradeEvent int64

func (TradeEvent) IsSell 

func (this TradeEvent) IsSell() bool

func (TradeEvent) UnixNano 

func (this TradeEvent) UnixNano() int64

type TradeFactory 

type TradeFactory = Factory[TradeDaemon]

type TradeLogRegistry 

type TradeLogRegistry = Registry[EventLog[TradeEvent]]

type UnixTimestamped 

type UnixTimestamped = common.UnixTimestamped

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.