internal

Documentation

Index

• type BaseGrpc
  • func NewBaseGrpc() *BaseGrpc
  • func (p *BaseGrpc) Connection(ctx context.Context, nodeUrl string) (*grpc.ClientConn, error)
  • func (p *BaseGrpc) GetCallOption() grpc.CallOption
• type RESTfulProvider
  • func NewRESTfulProvider(exchange string, symbols []string, interval int, timeout int, ...) (*RESTfulProvider, error)
  • func (p *RESTfulProvider) GetPrices() map[string]types.PriceByPair
• type WebsocketProvider
  • func NewWebsocketProvider(exchange string, symbols []string, stopCh <-chan struct{}) (*WebsocketProvider, error)
  • func (p *WebsocketProvider) GetPrices() map[string]types.PriceByPair

Types

type BaseGrpc

type BaseGrpc struct {
}

func NewBaseGrpc

func NewBaseGrpc() *BaseGrpc

func (*BaseGrpc) Connection

func (p *BaseGrpc) Connection(
	ctx context.Context,
	nodeUrl string,
) (*grpc.ClientConn, error)

func (*BaseGrpc) GetCallOption

func (p *BaseGrpc) GetCallOption() grpc.CallOption

type RESTfulProvider

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

func NewRESTfulProvider

func NewRESTfulProvider(exchange string, symbols []string, interval int, timeout int, stopCh <-chan struct{}) (*RESTfulProvider, error)

func (*RESTfulProvider) GetPrices

func (p *RESTfulProvider) GetPrices() map[string]types.PriceByPair

type WebsocketProvider

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

func NewWebsocketProvider

func NewWebsocketProvider(exchange string, symbols []string, stopCh <-chan struct{}) (*WebsocketProvider, error)

func (*WebsocketProvider) GetPrices

func (p *WebsocketProvider) GetPrices() map[string]types.PriceByPair