stream

Documentation

Index

• func Close() error
• func Deregister(stream string) (err error)
• func Register(stream string, handler func(msg interface{})) (err error)
• func SetDataStream(streamName string)
• type Stream
• type Unified

Functions

func Close

func Close() error

Close gracefully closes all streams

func Deregister

func Deregister(stream string) (err error)

Deregister a handler for a given stream, Alpaca or Polygon.

func Register

func Register(stream string, handler func(msg interface{})) (err error)

Register a handler for a given stream, Alpaca or Polygon.

func SetDataStream

func SetDataStream(streamName string)

Types

type Stream

type Stream interface {
	Subscribe(key string, handler func(msg interface{})) error
	Unsubscribe(key string) error
	Close() error
}

Stream is the generic streaming interface implemented by both alpaca and polygon.

type Unified

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

Unified is the unified streaming structure combining the interfaces from polygon and alpaca.