Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewMdsQuoteStream ¶
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 }
Click to show internal directories.
Click to hide internal directories.