indexer

Documentation

Index

• Constants
• type DefaultIndexWriter
  • func (w *DefaultIndexWriter) Write(ctx context.Context, p *IndexParams) (*IndexingResult, error)
• type IndexParams
• type Indexer
  • func (i *Indexer) CurrentSHA() (string, bool, error)
  • func (i *Indexer) IndexRepository(ctx context.Context) (*IndexingResult, error)
• type IndexingResult
  • func IndexingFailureFallback(ix *Indexer, ctx context.Context, err error) (*IndexingResult, error)

Constants

const MAX_FAILURES = 1

Types

type DefaultIndexWriter

type DefaultIndexWriter struct{}

func (*DefaultIndexWriter) Write

func (w *DefaultIndexWriter) Write(ctx context.Context, p *IndexParams) (*IndexingResult, error)

type IndexParams

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

type Indexer

type Indexer struct {
	IndexDir           string
	ProjectID          uint32
	CorrelationID      string
	GitalyAddress      string
	GitalyToken        string
	GitalyStorageName  string
	GitalyRelativePath string

	LimitFileSize      int
	TargetSHA          string
	ForceReindex       bool
	Writer             indexWriter
	OnRetryableFailure func(*Indexer, context.Context, error) (*IndexingResult, error)
	NumFailures        int
	Initialized        bool
	// contains filtered or unexported fields
}

func (*Indexer) CurrentSHA

func (i *Indexer) CurrentSHA() (string, bool, error)

func (*Indexer) IndexRepository

func (i *Indexer) IndexRepository(ctx context.Context) (*IndexingResult, error)

type IndexingResult

type IndexingResult struct {
	ModifiedFilesCount uint
	DeletedFilesCount  uint
}

func IndexingFailureFallback

func IndexingFailureFallback(ix *Indexer, ctx context.Context, err error) (*IndexingResult, error)