api

Documentation

Index

• Constants
• Variables
• func NewBadRequestError(msg string, a ...interface{}) error
• type BadRequestError
  • func (e *BadRequestError) Error() string
• type CommitHandler
  • func NewCommitHandler(db objects.Store, rs ref.Store) *CommitHandler
  • func (h *CommitHandler) ServeHTTP(rw http.ResponseWriter, r *http.Request)
• type DiffHandler
  • func NewDiffHandler(db objects.Store) *DiffHandler
  • func (h *DiffHandler) ServeHTTP(rw http.ResponseWriter, r *http.Request)
• type GetBlocksHandler
  • func NewGetBlocksHandler(db objects.Store) *GetBlocksHandler
  • func (h *GetBlocksHandler) ServeHTTP(rw http.ResponseWriter, r *http.Request)
• type GetCommitHandler
  • func NewGetCommitHandler(db objects.Store) *GetCommitHandler
  • func (h *GetCommitHandler) ServeHTTP(rw http.ResponseWriter, r *http.Request)
• type GetRefsHandler
  • func NewGetRefsHandler(rs ref.Store) *GetRefsHandler
  • func (h *GetRefsHandler) ServeHTTP(rw http.ResponseWriter, r *http.Request)
• type GetRowsHandler
  • func NewGetRowsHandler(db objects.Store) *GetRowsHandler
  • func (h *GetRowsHandler) ServeHTTP(rw http.ResponseWriter, r *http.Request)
• type GetTableHandler
  • func NewGetTableHandler(db objects.Store) *GetTableHandler
  • func (h *GetTableHandler) ServeHTTP(rw http.ResponseWriter, r *http.Request)
• type ReceivePackHandler
  • func NewReceivePackHandler(db objects.Store, rs ref.Store, c *conf.Config, ...) *ReceivePackHandler
  • func (h *ReceivePackHandler) ServeHTTP(rw http.ResponseWriter, r *http.Request)
• type ReceivePackSession
  • func NewReceivePackSession(db objects.Store, rs ref.Store, c *conf.Config, id uuid.UUID) *ReceivePackSession
  • func (s *ReceivePackSession) ServeHTTP(rw http.ResponseWriter, r *http.Request) bool
• type ReceivePackSessionMap
  • func NewReceivePackSessionMap() *ReceivePackSessionMap
  • func (m *ReceivePackSessionMap) Delete(sid uuid.UUID)
  • func (m *ReceivePackSessionMap) Get(sid uuid.UUID) (ses *ReceivePackSession, ok bool)
  • func (m *ReceivePackSessionMap) Set(sid uuid.UUID, ses *ReceivePackSession)
• type ReceivePackSessionStore
• type UploadPackHandler
  • func NewUploadPackHandler(db objects.Store, rs ref.Store, sessions UploadPackSessionStore, ...) *UploadPackHandler
  • func (h *UploadPackHandler) ServeHTTP(rw http.ResponseWriter, r *http.Request)
• type UploadPackSession
  • func NewUploadPackSession(db objects.Store, rs ref.Store, id uuid.UUID, maxPackfileSize uint64) *UploadPackSession
  • func (s *UploadPackSession) ServeHTTP(rw http.ResponseWriter, r *http.Request) bool
• type UploadPackSessionMap
  • func NewUploadPackSessionMap() *UploadPackSessionMap
  • func (m *UploadPackSessionMap) Delete(sid uuid.UUID)
  • func (m *UploadPackSessionMap) Get(sid uuid.UUID) (ses *UploadPackSession, ok bool)
  • func (m *UploadPackSessionMap) Set(sid uuid.UUID, ses *UploadPackSession)
• type UploadPackSessionStore

Constants

const (
	CTCSV          = "text/csv"
	CTBlocksBinary = "application/x-wrgl-blocks-binary"
)

const (
	CTUploadPackResult = "application/x-wrgl-upload-pack-result"
	CTPackfile         = "application/x-wrgl-packfile"
)

const (
	CTReceivePackResult = "application/x-wrgl-receive-pack-result"
)

const PathCommit = "/commits/"

const PathReceivePack = "/receive-pack/"

const PathRefs = "/refs/"

const PathUploadPack = "/upload-pack/"

Variables

var CTJSON = "application/json"

Functions

func NewBadRequestError

func NewBadRequestError(msg string, a ...interface{}) error

Types

type BadRequestError

type BadRequestError struct {
	Message string
}

func (*BadRequestError) Error

func (e *BadRequestError) Error() string

type CommitHandler

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

func NewCommitHandler

func NewCommitHandler(db objects.Store, rs ref.Store) *CommitHandler

func (*CommitHandler) ServeHTTP

func (h *CommitHandler) ServeHTTP(rw http.ResponseWriter, r *http.Request)

type DiffHandler

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

func NewDiffHandler

func NewDiffHandler(db objects.Store) *DiffHandler

func (*DiffHandler) ServeHTTP

func (h *DiffHandler) ServeHTTP(rw http.ResponseWriter, r *http.Request)

type GetBlocksHandler

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

func NewGetBlocksHandler

func NewGetBlocksHandler(db objects.Store) *GetBlocksHandler

func (*GetBlocksHandler) ServeHTTP

func (h *GetBlocksHandler) ServeHTTP(rw http.ResponseWriter, r *http.Request)

type GetCommitHandler

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

func NewGetCommitHandler

func NewGetCommitHandler(db objects.Store) *GetCommitHandler

func (*GetCommitHandler) ServeHTTP

func (h *GetCommitHandler) ServeHTTP(rw http.ResponseWriter, r *http.Request)

type GetRefsHandler

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

func NewGetRefsHandler

func NewGetRefsHandler(rs ref.Store) *GetRefsHandler

func (*GetRefsHandler) ServeHTTP

func (h *GetRefsHandler) ServeHTTP(rw http.ResponseWriter, r *http.Request)

type GetRowsHandler

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

func NewGetRowsHandler

func NewGetRowsHandler(db objects.Store) *GetRowsHandler

func (*GetRowsHandler) ServeHTTP

func (h *GetRowsHandler) ServeHTTP(rw http.ResponseWriter, r *http.Request)

type GetTableHandler

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

func NewGetTableHandler

func NewGetTableHandler(db objects.Store) *GetTableHandler

func (*GetTableHandler) ServeHTTP

func (h *GetTableHandler) ServeHTTP(rw http.ResponseWriter, r *http.Request)

type ReceivePackHandler

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

func NewReceivePackHandler

func NewReceivePackHandler(db objects.Store, rs ref.Store, c *conf.Config, sessions ReceivePackSessionStore) *ReceivePackHandler

func (*ReceivePackHandler) ServeHTTP

func (h *ReceivePackHandler) ServeHTTP(rw http.ResponseWriter, r *http.Request)

type ReceivePackSession

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

func NewReceivePackSession

func NewReceivePackSession(db objects.Store, rs ref.Store, c *conf.Config, id uuid.UUID) *ReceivePackSession

func (*ReceivePackSession) ServeHTTP

func (s *ReceivePackSession) ServeHTTP(rw http.ResponseWriter, r *http.Request) bool

ServeHTTP receives, saves objects and update refs, returns true when session is finished and can be removed.

type ReceivePackSessionMap

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

func NewReceivePackSessionMap

func NewReceivePackSessionMap() *ReceivePackSessionMap

func (*ReceivePackSessionMap) Delete

func (m *ReceivePackSessionMap) Delete(sid uuid.UUID)

func (*ReceivePackSessionMap) Get

func (m *ReceivePackSessionMap) Get(sid uuid.UUID) (ses *ReceivePackSession, ok bool)

func (*ReceivePackSessionMap) Set

func (m *ReceivePackSessionMap) Set(sid uuid.UUID, ses *ReceivePackSession)

type ReceivePackSessionStore

type ReceivePackSessionStore interface {
	Set(sid uuid.UUID, ses *ReceivePackSession)
	Get(sid uuid.UUID) (ses *ReceivePackSession, ok bool)
	Delete(sid uuid.UUID)
}

type UploadPackHandler

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

func NewUploadPackHandler

func NewUploadPackHandler(db objects.Store, rs ref.Store, sessions UploadPackSessionStore, maxPackfileSize uint64) *UploadPackHandler

func (*UploadPackHandler) ServeHTTP

func (h *UploadPackHandler) ServeHTTP(rw http.ResponseWriter, r *http.Request)

type UploadPackSession

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

func NewUploadPackSession

func NewUploadPackSession(db objects.Store, rs ref.Store, id uuid.UUID, maxPackfileSize uint64) *UploadPackSession

func (*UploadPackSession) ServeHTTP

func (s *UploadPackSession) ServeHTTP(rw http.ResponseWriter, r *http.Request) bool

ServeHTTP negotiates which commits to be sent and send them in one or more packfiles, returns true when this session is completed and should be removed.

type UploadPackSessionMap

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

func NewUploadPackSessionMap

func NewUploadPackSessionMap() *UploadPackSessionMap

func (*UploadPackSessionMap) Delete

func (m *UploadPackSessionMap) Delete(sid uuid.UUID)

func (*UploadPackSessionMap) Get

func (m *UploadPackSessionMap) Get(sid uuid.UUID) (ses *UploadPackSession, ok bool)

func (*UploadPackSessionMap) Set

func (m *UploadPackSessionMap) Set(sid uuid.UUID, ses *UploadPackSession)

type UploadPackSessionStore

type UploadPackSessionStore interface {
	Set(sid uuid.UUID, ses *UploadPackSession)
	Get(sid uuid.UUID) (ses *UploadPackSession, ok bool)
	Delete(sid uuid.UUID)
}