server

Documentation

Index

• type DefaultIndexBuilder
  • func (b DefaultIndexBuilder) DeleteRepository(req DeleteRequest, callbackFunc callback.CallbackFunc, ...) error
  • func (b DefaultIndexBuilder) GetIndexDir() string
  • func (b DefaultIndexBuilder) IndexRepository(ctx context.Context, req IndexRequest, callbackFunc callback.CallbackFunc) error
• type DeleteRequest
• type GitalyConnectionInfo
• type IndexRequest
• type IndexServer
  • func (s *IndexServer) Router() *chi.Mux
  • func (s *IndexServer) StartFileCleaner(ctx context.Context) error
  • func (s *IndexServer) StartIndexingApi(httpServer *http.Server) error

Types

type DefaultIndexBuilder

type DefaultIndexBuilder struct {
	IndexDir string
}

func (DefaultIndexBuilder) DeleteRepository

func (b DefaultIndexBuilder) DeleteRepository(req DeleteRequest, callbackFunc callback.CallbackFunc, lock *indexing_lock.IndexingLock) error

func (DefaultIndexBuilder) GetIndexDir

func (b DefaultIndexBuilder) GetIndexDir() string

func (DefaultIndexBuilder) IndexRepository

func (b DefaultIndexBuilder) IndexRepository(ctx context.Context, req IndexRequest, callbackFunc callback.CallbackFunc) error

type DeleteRequest

type DeleteRequest struct {
	RepoID   uint32                   `json:"RepoID"`
	Callback *callback.CallbackParams `json:"Callback"`
}

type GitalyConnectionInfo

type GitalyConnectionInfo struct {
	Address string `json:"Address"`
	Token   string `json:"Token"`
	Storage string `json:"Storage"`
	Path    string `json:"Path"`
}

type IndexRequest

type IndexRequest struct {
	Timeout              string                   `json:"Timeout"`
	RepoID               uint32                   `json:"RepoID"`
	GitalyConnectionInfo *GitalyConnectionInfo    `json:"GitalyConnectionInfo"`
	FileSizeLimit        int                      `json:"FileSizeLimit"`
	Callback             *callback.CallbackParams `json:"Callback"`
	Force                bool                     `json:"Force"`
}

type IndexServer

type IndexServer struct {
	PathPrefix   string
	IndexBuilder indexBuilder

	IndexingLock *indexing_lock.IndexingLock
	CallbackApi  *callback.CallbackApi
	// contains filtered or unexported fields
}

func (*IndexServer) Router

func (s *IndexServer) Router() *chi.Mux

func (*IndexServer) StartFileCleaner

func (s *IndexServer) StartFileCleaner(ctx context.Context) error

func (*IndexServer) StartIndexingApi

func (s *IndexServer) StartIndexingApi(httpServer *http.Server) error