apiclient

Documentation

Index

• Constants
• type Client
  • func NewClient(origin string) (*Client, error)
  • func (c *Client) ErrHTTP(resp *http.Response) error
  • func (c *Client) GetRefs() (m map[string][]byte, err error)
  • func (c *Client) PostUpdatesToReceivePack(updates map[string]*payload.Update) (*http.Response, error)
  • func (c *Client) PostUploadPack(wants, haves [][]byte, done bool) (acks [][]byte, pr *encoding.PackfileReader, err error)
  • func (c *Client) Request(method, path string, body io.Reader, headers map[string]string) (resp *http.Response, err error)
• type ReceivePackSession
  • func NewReceivePackSession(db objects.Store, rs ref.Store, c *Client, updates map[string]*payload.Update, ...) (*ReceivePackSession, error)
  • func (s *ReceivePackSession) Start() (updates map[string]*payload.Update, err error)
• type UploadPackSession
  • func NewUploadPackSession(db objects.Store, rs ref.Store, c *Client, advertised [][]byte, ...) (*UploadPackSession, error)
  • func (n *UploadPackSession) Start() ([][]byte, error)

Constants

const (
	CTJSON     = "application/json"
	CTPackfile = "application/x-wrgl-packfile"
)

Types

type Client

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

func NewClient

func NewClient(origin string) (*Client, error)

func (*Client) ErrHTTP

func (c *Client) ErrHTTP(resp *http.Response) error

func (*Client) GetRefs

func (c *Client) GetRefs() (m map[string][]byte, err error)

func (*Client) PostUpdatesToReceivePack

func (c *Client) PostUpdatesToReceivePack(updates map[string]*payload.Update) (*http.Response, error)

func (*Client) PostUploadPack

func (c *Client) PostUploadPack(wants, haves [][]byte, done bool) (acks [][]byte, pr *encoding.PackfileReader, err error)

func (*Client) Request

func (c *Client) Request(method, path string, body io.Reader, headers map[string]string) (resp *http.Response, err error)

type ReceivePackSession

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

func NewReceivePackSession

func NewReceivePackSession(db objects.Store, rs ref.Store, c *Client, updates map[string]*payload.Update, remoteRefs map[string][]byte, maxPackfileSize uint64) (*ReceivePackSession, error)

func (*ReceivePackSession) Start

func (s *ReceivePackSession) Start() (updates map[string]*payload.Update, err error)

type UploadPackSession

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

func NewUploadPackSession

func NewUploadPackSession(db objects.Store, rs ref.Store, c *Client, advertised [][]byte, havesPerRoundTrip int) (*UploadPackSession, error)

func (*UploadPackSession) Start

func (n *UploadPackSession) Start() ([][]byte, error)