apiserver

package
v0.3.10 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 8, 2021 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

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

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)
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL