staticdata

Documentation

Index

• type GrpcConnection
• type ListingResult
• type ListingsResult
• type Source
  • func NewStaticDataSource(ctx context.Context) (*Source, error)
  • func (s *Source) GetListing(ctx context.Context, listingId int32, resultChan chan<- ListingResult)
  • func (s *Source) GetListingMatching(ctx context.Context, matchParams *services.ExactMatchParameters, ...)
  • func (s *Source) GetListingsWithSameInstrument(ctx context.Context, listingId int32, resultChan chan<- ListingsResult)

Types

type GrpcConnection

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

type ListingResult

type ListingResult struct {
	Listing *model.Listing
	Err     error
}

type ListingsResult

type ListingsResult struct {
	Listings []*model.Listing
	Err      error
}

type Source

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

Source is a source of static data that fetches data asynchronously from the static data service and has in-built retry behaviour

func NewStaticDataSource

func NewStaticDataSource(ctx context.Context) (*Source, error)

func (*Source) GetListing

func (s *Source) GetListing(ctx context.Context, listingId int32, resultChan chan<- ListingResult)

func (*Source) GetListingMatching

func (s *Source) GetListingMatching(ctx context.Context, matchParams *services.ExactMatchParameters, resultChan chan<- ListingResult)

func (*Source) GetListingsWithSameInstrument

func (s *Source) GetListingsWithSameInstrument(ctx context.Context, listingId int32, resultChan chan<- ListingsResult)