forkresolver

Documentation

Index

• Variables
• type ForkResolver
  • func NewForkResolver(blocksStore dstore.Store, dmeshClient dmeshClient.SearchClient, ...) *ForkResolver
  • func (f *ForkResolver) Check(ctx context.Context, in *pbhealth.HealthCheckRequest) (*pbhealth.HealthCheckResponse, error)
  • func (f *ForkResolver) Launch()
  • func (f *ForkResolver) StreamUndoMatches(req *pbsearch.ForkResolveRequest, ...) error

Variables

var MaxLookupBlocks = uint64(10000)

var ShutdownDelayOnFileNotFound = time.Second

Types

type ForkResolver

type ForkResolver struct {
	*shutter.Shutter
	// contains filtered or unexported fields
}

func NewForkResolver

func NewForkResolver(
	blocksStore dstore.Store,
	dmeshClient dmeshClient.SearchClient,
	searchPeer *dmesh.SearchPeer,
	grpcListenAddr string,
	httpListenAddr string,
	mapper search.BlockMapper,
	indicesPath string) *ForkResolver

func (*ForkResolver) Check

func (f *ForkResolver) Check(ctx context.Context, in *pbhealth.HealthCheckRequest) (*pbhealth.HealthCheckResponse, error)

func (*ForkResolver) Launch

func (f *ForkResolver) Launch()

func (*ForkResolver) StreamUndoMatches

func (f *ForkResolver) StreamUndoMatches(req *pbsearch.ForkResolveRequest, stream pbsearch.ForkResolver_StreamUndoMatchesServer) error