turbo

Documentation

Index

• type BaseClient
  • func (self *BaseClient) Request(ctx context.Context) (*resty.Request, context.CancelFunc)
  • func (self *BaseClient) Reset()
  • func (self *BaseClient) SetPeers(peers []string)
• type Client
  • func NewClient(ctx context.Context, config *config.Bundlr) (self *Client)
  • func (self *Client) GetStatus(ctx context.Context, id string) (out *responses.Status, err error)
  • func (self *Client) Upload(ctx context.Context, item *bundlr.BundleItem) (out *responses.Upload, resp *resty.Response, err error)

Types

type BaseClient

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

func (*BaseClient) Request

func (self *BaseClient) Request(ctx context.Context) (*resty.Request, context.CancelFunc)

func (*BaseClient) Reset

func (self *BaseClient) Reset()

func (*BaseClient) SetPeers

func (self *BaseClient) SetPeers(peers []string)

Set the list of potential peers in order they should be used Uses only peers that are proper urls

type Client

type Client struct {
	*BaseClient
}

func NewClient

func NewClient(ctx context.Context, config *config.Bundlr) (self *Client)

func (*Client) GetStatus

func (self *Client) GetStatus(ctx context.Context, id string) (out *responses.Status, err error)

func (*Client) Upload

func (self *Client) Upload(ctx context.Context, item *bundlr.BundleItem) (out *responses.Upload, resp *resty.Response, err error)