gofer

Documentation

Index

• type AgentServices
  • func (s *AgentServices) Start(ctx context.Context) error
  • func (s *AgentServices) Wait() <-chan error
• type ClientServices
  • func (s *ClientServices) Start(ctx context.Context) error
  • func (s *ClientServices) Wait() <-chan error
• type Config
  • func (c *Config) ClientServices(ctx context.Context, baseLogger log.Logger, noRPC bool, ...) (*ClientServices, error)
  • func (c *Config) Services(baseLogger log.Logger) (pkgSupervisor.Service, error)

Types

type AgentServices

type AgentServices struct {
	PriceProvider provider.Provider
	Agent         *rpc.Agent
	Logger        log.Logger
	// contains filtered or unexported fields
}

AgentServices returns the services that are configured from the Config struct.

func (*AgentServices) Start

func (s *AgentServices) Start(ctx context.Context) error

Start implements the supervisor.Service interface.

func (*AgentServices) Wait

func (s *AgentServices) Wait() <-chan error

Wait implements the supervisor.Service interface.

type ClientServices

type ClientServices struct {
	PriceProvider provider.Provider
	PriceHook     provider.PriceHook
	Marshaller    marshal.Marshaller
	Logger        log.Logger
	// contains filtered or unexported fields
}

ClientServices returns the services that are configured from the Config struct.

func (*ClientServices) Start

func (s *ClientServices) Start(ctx context.Context) error

Start implements the supervisor.Service interface.

func (*ClientServices) Wait

func (s *ClientServices) Wait() <-chan error

Wait implements the supervisor.Service interface.

type Config

type Config struct {
	Gofer    priceProviderConfig.Config `hcl:"gofer,block"`
	Ethereum *ethereumConfig.Config     `hcl:"ethereum,block,optional"`
	Logger   *loggerConfig.Config       `hcl:"logger,block,optional"`

	// HCL fields:
	Remain  hcl.Body        `hcl:",remain"` // To ignore unknown blocks.
	Content hcl.BodyContent `hcl:",content"`
}

Config is the configuration for Gofer.

func (*Config) ClientServices

func (c *Config) ClientServices(
	ctx context.Context,
	baseLogger log.Logger,
	noRPC bool,
	format marshal.FormatType,
) (*ClientServices, error)

ClientServices returns the services configured for Gofer.

func (*Config) Services

func (c *Config) Services(baseLogger log.Logger) (pkgSupervisor.Service, error)

Services returns the services configured for Gofer Agent.