apiclient

Documentation

Index

• Constants
• type Client
  • func NewClient(origin string, opts ...RequestOption) (*Client, error)
  • func (c *Client) Authenticate(email, password string, opts ...RequestOption) (token string, err error)
  • func (c *Client) Commit(branch, message, authorEmail, authorName string, file io.Reader, ...) (cr *payload.CommitResponse, err error)
  • func (c *Client) Diff(sum1, sum2 []byte, opts ...RequestOption) (dr *payload.DiffResponse, err error)
  • func (c *Client) ErrHTTP(resp *http.Response) error
  • func (c *Client) GetBlocks(sum []byte, start, end int, format payload.BlockFormat, opts ...RequestOption) (resp *http.Response, err error)
  • func (c *Client) GetCommit(sum []byte, opts ...RequestOption) (cr *payload.Commit, err error)
  • func (c *Client) GetCommits(ref string, minDepth, maxDepth int, opts ...RequestOption) (gcr *payload.GetCommitsResponse, err error)
  • func (c *Client) GetHead(branch string, opts ...RequestOption) (com *payload.Commit, err error)
  • func (c *Client) GetRefs(opts ...RequestOption) (m map[string][]byte, err error)
  • func (c *Client) GetRows(sum []byte, offsets []int, opts ...RequestOption) (resp *http.Response, err error)
  • func (c *Client) GetTable(sum []byte, opts ...RequestOption) (tr *payload.GetTableResponse, err error)
  • func (c *Client) PostMultipartForm(path string, value map[string][]string, files map[string]io.Reader, ...) (*http.Response, error)
  • func (c *Client) PostUpdatesToReceivePack(updates map[string]*payload.Update, opts ...RequestOption) (*http.Response, error)
  • func (c *Client) PostUploadPack(wants, haves [][]byte, done bool, opts ...RequestOption) (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 HTTPError
  • func NewHTTPError(code int, message string) *HTTPError
  • func (err *HTTPError) Error() string
• 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 RequestOption
  • func WithAuthorization(token string) RequestOption
  • func WithHeader(header http.Header) RequestOption
• 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, opts ...RequestOption) (*Client, error)

func (*Client) Authenticate

func (c *Client) Authenticate(email, password string, opts ...RequestOption) (token string, err error)

func (*Client) Commit

func (c *Client) Commit(branch, message, authorEmail, authorName string, file io.Reader, primaryKey []string, opts ...RequestOption) (cr *payload.CommitResponse, err error)

func (*Client) Diff

func (c *Client) Diff(sum1, sum2 []byte, opts ...RequestOption) (dr *payload.DiffResponse, err error)

func (*Client) ErrHTTP

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

func (*Client) GetBlocks

func (c *Client) GetBlocks(sum []byte, start, end int, format payload.BlockFormat, opts ...RequestOption) (resp *http.Response, err error)

func (*Client) GetCommit

func (c *Client) GetCommit(sum []byte, opts ...RequestOption) (cr *payload.Commit, err error)

func (*Client) GetCommits

func (c *Client) GetCommits(ref string, minDepth, maxDepth int, opts ...RequestOption) (gcr *payload.GetCommitsResponse, err error)

func (*Client) GetHead

func (c *Client) GetHead(branch string, opts ...RequestOption) (com *payload.Commit, err error)

func (*Client) GetRefs

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

func (*Client) GetRows

func (c *Client) GetRows(sum []byte, offsets []int, opts ...RequestOption) (resp *http.Response, err error)

func (*Client) GetTable

func (c *Client) GetTable(sum []byte, opts ...RequestOption) (tr *payload.GetTableResponse, err error)

func (*Client) PostMultipartForm

func (c *Client) PostMultipartForm(path string, value map[string][]string, files map[string]io.Reader, opts ...RequestOption) (*http.Response, error)

func (*Client) PostUpdatesToReceivePack

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

func (*Client) PostUploadPack

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

func (*Client) Request

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

type HTTPError

type HTTPError struct {
	Code    int
	Message string
}

func NewHTTPError

func NewHTTPError(code int, message string) *HTTPError

func (*HTTPError) Error

func (err *HTTPError) Error() string

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, opts ...RequestOption) (*ReceivePackSession, error)

func (*ReceivePackSession) Start

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

type RequestOption

type RequestOption func(r *http.Request)

func WithAuthorization

func WithAuthorization(token string) RequestOption

func WithHeader

func WithHeader(header http.Header) RequestOption

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, opts ...RequestOption) (*UploadPackSession, error)

func (*UploadPackSession) Start

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