spire

package

v0.11.2 Latest Latest Go to latest Published: Aug 9, 2023 License: AGPL-3.0 Imports: 15 Imported by: 0

Details

View Source

const AgentLoggerTag = "SPIRE_AGENT"

This section is empty.

This section is empty.

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

func (n *API) PublishPrice(arg *PublishPriceArg, _ *Nothing) error

func (n *API) PullPrice(arg *PullPriceArg, resp *PullPriceResp) error

func (n *API) PullPrices(arg *PullPricesArg, resp *PullPricesResp) error

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

func NewAgent(cfg AgentConfig) (*Agent, error)

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

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

Wait waits until agent's context is cancelled.

type AgentConfig struct {
	PriceStore *store.PriceStore
	Transport  transport.Service
	Address    string
	Logger     log.Logger
}

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

func NewClient(cfg ClientConfig) (*Client, error)

func (c *Client) PublishPrice(price *messages.Price) error

func (c *Client) PullPrice(assetPair string, feed string) (*messages.Price, error)

func (c *Client) PullPrices(assetPair string, feed string) ([]*messages.Price, error)

func (c *Client) Start(ctx context.Context) error

func (c *Client) Wait() <-chan error

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

type ClientConfig struct {
	Signer  wallet.Key
	Address string
}

type Nothing = struct{}

type PublishPriceArg struct {
	Price *messages.Price
}

type PullPriceArg struct {
	AssetPair string
	Feed      string
}

type PullPriceResp struct {
	Price *messages.Price
}

type PullPricesArg struct {
	FilterAssetPair string
	FilterFeed      string
}

type PullPricesResp struct {
	Prices []*messages.Price
}