event

Documentation

Index

• Variables
• type Event
  • func NewPriceEvent(t time.Time, content tick.Tick) Event
  • func NewStatusEvent(t time.Time, content Status) Event
  • func OnlyKeepEarliestSameTimeEvents(evts []Event, endTime time.Time) (earliestTime time.Time, filtered []Event)
  • func PriceEventFromCandlestick(exchange, pair string, currentPriceType candlestick.Price, t time.Time, ...) (Event, error)
  • func (e Event) MarshalBinary() ([]byte, error)
  • func (e *Event) UnmarshalBinary(data []byte) error
• type PricesSubscription
• type Status
• type Type
  • func (t Type) MarshalBinary() ([]byte, error)
  • func (t Type) String() string
  • func (t *Type) UnmarshalBinary(data []byte) error

Variables

var (
	ErrUnknownType     = errors.New("unknown type")
	ErrMismatchingType = errors.New("mismatching type")
)

Types

type Event

type Event struct {
	Type    Type
	Time    time.Time
	Content interface{}
}

func NewPriceEvent

func NewPriceEvent(t time.Time, content tick.Tick) Event

func NewStatusEvent

func NewStatusEvent(t time.Time, content Status) Event

func OnlyKeepEarliestSameTimeEvents

func OnlyKeepEarliestSameTimeEvents(evts []Event, endTime time.Time) (earliestTime time.Time, filtered []Event)

func PriceEventFromCandlestick

func PriceEventFromCandlestick(
	exchange, pair string,
	currentPriceType candlestick.Price,
	t time.Time,
	cs candlestick.Candlestick,
) (Event, error)

func (Event) MarshalBinary

func (e Event) MarshalBinary() ([]byte, error)

func (*Event) UnmarshalBinary

func (e *Event) UnmarshalBinary(data []byte) error

type PricesSubscription

type PricesSubscription struct {
	Exchange string `json:"exchange"`
	Pair     string `json:"pair"`
}

type Status

type Status struct {
	Finished bool `json:"finished"`
}

type Type

type Type string

const (
	TypeIsPrice Type = "price"
	// Backtest specific
	TypeIsStatus Type = "status"
)

func (Type) MarshalBinary

func (t Type) MarshalBinary() ([]byte, error)

func (Type) String

func (t Type) String() string

func (*Type) UnmarshalBinary

func (t *Type) UnmarshalBinary(data []byte) error