quotestream

Documentation

Index

• func NewMdsQuoteStream(id string, targetAddress string, maxReconnectInterval time.Duration, ...) (*mdsQuoteStream, error)
• func NewMdsQuoteStreamFromFn(id string, targetAddress string, out chan *model.ClobQuote, ...) (*mdsQuoteStream, error)
• type GetMdsClientFn
• type GrpcConnection

Functions

func NewMdsQuoteStream

func NewMdsQuoteStream(id string, targetAddress string, maxReconnectInterval time.Duration,
	quoteBufferSize int) (*mdsQuoteStream, error)

func NewMdsQuoteStreamFromFn

func NewMdsQuoteStreamFromFn(id string, targetAddress string, out chan *model.ClobQuote,
	getConnection GetMdsClientFn) (*mdsQuoteStream, error)

Types

type GetMdsClientFn

type GetMdsClientFn = func(targetAddress string) (marketdatasource.MarketDataSourceClient, GrpcConnection, error)

type GrpcConnection

type GrpcConnection interface {
	GetState() connectivity.State
	WaitForStateChange(ctx context.Context, sourceState connectivity.State) bool
}