Documentation
¶
Index ¶
- Constants
- Variables
- type API
- type Agent
- type AgentConfig
- type FeedArg
- type FeedResp
- type Gofer
- 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 ¶
View Source
const AgentLoggerTag = "GOFER_AGENT"
Variables ¶
View Source
var ErrNotStarted = errors.New("gofer RPC client is not started")
Functions ¶
This section is empty.
Types ¶
type Agent ¶
type Agent struct {
// contains filtered or unexported fields
}
Agent creates and manages an RPC server for remote Gofer calls.
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 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.
Click to show internal directories.
Click to hide internal directories.