remote

Documentation

Index

• Constants
• type Client
  • func NewClient(config *configuration.Configuration) *Client
  • func (client *Client) AdvertiseOffersNeighbor(ctx context.Context, fromTrader, toNeighborTrader, traderOffering *types.Node) error
  • func (client *Client) CreateOffer(ctx context.Context, fromNode, toNode *types.Node, offer *types.Offer) error
  • func (client *Client) GetOffers(ctx context.Context, fromNode, toTrader *types.Node, relay bool) ([]types.AvailableOffer, error)
  • func (client *Client) LaunchContainer(ctx context.Context, fromBuyer, toSupplier *types.Node, offer *types.Offer, ...) ([]types.ContainerStatus, error)
  • func (client *Client) ObtainConfiguration(c context.Context, systemsNode *types.Node) (*configuration.Configuration, error)
  • func (client *Client) RefreshOffer(ctx context.Context, fromTrader, toSupp *types.Node, offer *types.Offer) (bool, error)
  • func (client *Client) RemoveOffer(ctx context.Context, fromSupp, toTrader *types.Node, offer *types.Offer) error
  • func (client *Client) StopLocalContainer(ctx context.Context, toSupplier *types.Node, containerID string) error
• type Error
  • func NewRemoteClientError(err error) *Error
  • func (ce *Error) Error() string

Constants

const CaravelaInstanceUnavailable = 2

const Unknown = 1

Types

type Client

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

Client is used to contact the REST API of other nodes.

func NewClient

func NewClient(config *configuration.Configuration) *Client

func (*Client) AdvertiseOffersNeighbor

func (client *Client) AdvertiseOffersNeighbor(ctx context.Context, fromTrader, toNeighborTrader, traderOffering *types.Node) error

func (*Client) CreateOffer

func (client *Client) CreateOffer(ctx context.Context, fromNode, toNode *types.Node, offer *types.Offer) error

func (*Client) GetOffers

func (client *Client) GetOffers(ctx context.Context, fromNode, toTrader *types.Node, relay bool) ([]types.AvailableOffer, error)

func (*Client) LaunchContainer

func (client *Client) LaunchContainer(ctx context.Context, fromBuyer, toSupplier *types.Node, offer *types.Offer,
	containersConfigs []types.ContainerConfig) ([]types.ContainerStatus, error)

func (*Client) ObtainConfiguration

func (client *Client) ObtainConfiguration(c context.Context, systemsNode *types.Node) (*configuration.Configuration, error)

func (*Client) RefreshOffer

func (client *Client) RefreshOffer(ctx context.Context, fromTrader, toSupp *types.Node, offer *types.Offer) (bool, error)

func (*Client) RemoveOffer

func (client *Client) RemoveOffer(ctx context.Context, fromSupp, toTrader *types.Node, offer *types.Offer) error

func (*Client) StopLocalContainer

func (client *Client) StopLocalContainer(ctx context.Context, toSupplier *types.Node, containerID string) error

type Error

type Error struct {
	Code int
	// contains filtered or unexported fields
}

Error of CARAVELA's remote client.

func NewRemoteClientError

func NewRemoteClientError(err error) *Error

func (*Error) Error

func (ce *Error) Error() string