rpc

Documentation

Index

• Constants
• Variables
• type API
  • func (n *API) Models(arg *NodesArg, resp *NodesResp) error
  • func (n *API) Pairs(_ *Nothing, resp *PairsResp) error
  • func (n *API) Prices(arg *PricesArg, resp *PricesResp) error
• type Agent
  • func NewAgent(ctx context.Context, cfg AgentConfig) (*Agent, error)
  • func (s *Agent) Start() error
  • func (s *Agent) Wait() chan error
• type AgentConfig
• type FeedArg
• type FeedResp
• type Gofer
  • func NewGofer(ctx context.Context, network, address string) (*Gofer, error)
  • func (g *Gofer) Models(pairs ...gofer.Pair) (map[gofer.Pair]*gofer.Model, error)
  • func (g *Gofer) Pairs() ([]gofer.Pair, error)
  • func (g *Gofer) Price(pair gofer.Pair) (*gofer.Price, error)
  • func (g *Gofer) Prices(pairs ...gofer.Pair) (map[gofer.Pair]*gofer.Price, error)
  • func (g *Gofer) Start() error
  • func (g *Gofer) Wait() chan error
• type NodesArg
• type NodesResp
• type Nothing
• type PairsResp
• type PricesArg
• type PricesResp

Constants

const AgentLoggerTag = "GOFER_AGENT"

Variables

var ErrNotStarted = errors.New("gofer RPC client is not started")

Types

type API

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

func (*API) Models

func (n *API) Models(arg *NodesArg, resp *NodesResp) error

func (*API) Pairs

func (n *API) Pairs(_ *Nothing, resp *PairsResp) error

func (*API) Prices

func (n *API) Prices(arg *PricesArg, resp *PricesResp) error

type Agent

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

Agent creates and manages an RPC server for remote Gofer calls.

func NewAgent

func NewAgent(ctx context.Context, cfg AgentConfig) (*Agent, error)

NewAgent returns a new Agent instance.

func (*Agent) Start

func (s *Agent) Start() error

Start starts the RPC server.

func (*Agent) Wait

func (s *Agent) Wait() chan error

Wait waits until the context is canceled or until an error occurs.

type AgentConfig

type AgentConfig struct {
	// Gofer instance which will be used by the agent. If this instance
	// implements the gofer.StartableGofer interface, the Start and Stop
	// methods are called whenever corresponding Agent's Start and
	// Stop are called.
	Gofer gofer.Gofer
	// Network is used for the rpc.Listener function.
	Network string
	// Address is used for the rpc.Listener function.
	Address string
	Logger  log.Logger
}

type FeedArg

type FeedArg struct {
	Pairs []gofer.Pair
}

type FeedResp

type FeedResp struct {
	Warnings feeder.Warnings
}

type Gofer

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

Gofer implements the gofer.Gofer interface. It uses a remote RPC server to fetch prices and models.

func NewGofer

func NewGofer(ctx context.Context, network, address string) (*Gofer, error)

NewGofer returns a new Gofer instance.

func (*Gofer) Models

func (g *Gofer) Models(pairs ...gofer.Pair) (map[gofer.Pair]*gofer.Model, error)

Models implements the gofer.Gofer interface.

func (*Gofer) Pairs

func (g *Gofer) Pairs() ([]gofer.Pair, error)

Pairs implements the gofer.Gofer interface.

func (*Gofer) Price

func (g *Gofer) Price(pair gofer.Pair) (*gofer.Price, error)

Price implements the gofer.Gofer interface.

func (*Gofer) Prices

func (g *Gofer) Prices(pairs ...gofer.Pair) (map[gofer.Pair]*gofer.Price, error)

Prices implements the gofer.Gofer interface.

func (*Gofer) Start

func (g *Gofer) Start() error

Start implements the gofer.StartableGofer interface.

func (*Gofer) Wait

func (g *Gofer) Wait() chan error

Wait implements the gofer.StartableGofer interface.

type NodesArg

type NodesArg struct {
	Format marshal.FormatType
	Pairs  []gofer.Pair
}

type NodesResp

type NodesResp struct {
	Pairs map[gofer.Pair]*gofer.Model
}

type Nothing

type Nothing = struct{}

type PairsResp

type PairsResp struct {
	Pairs []gofer.Pair
}

type PricesArg

type PricesArg struct {
	Pairs []gofer.Pair
}

type PricesResp

type PricesResp struct {
	Prices map[gofer.Pair]*gofer.Price
}