index_builder

Documentation

Index

• type IndexBuilder
  • func NewIndexBuilder(logger *zap.Logger, handler bstream.Handler, ...) *IndexBuilder
  • func (app *IndexBuilder) Check(ctx context.Context, in *pbhealth.HealthCheckRequest) (*pbhealth.HealthCheckResponse, error)
  • func (app *IndexBuilder) Launch()
  • func (app *IndexBuilder) Watch(req *pbhealth.HealthCheckRequest, stream pbhealth.Health_WatchServer) error

Types

type IndexBuilder

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

func NewIndexBuilder

func NewIndexBuilder(logger *zap.Logger, handler bstream.Handler, startBlockNum, stopBlockNum uint64, blockStore dstore.Store) *IndexBuilder

func (*IndexBuilder) Check

func (app *IndexBuilder) Check(ctx context.Context, in *pbhealth.HealthCheckRequest) (*pbhealth.HealthCheckResponse, error)

Check is basic GRPC Healthcheck

func (*IndexBuilder) Launch

func (app *IndexBuilder) Launch()

func (*IndexBuilder) Watch

func (app *IndexBuilder) Watch(req *pbhealth.HealthCheckRequest, stream pbhealth.Health_WatchServer) error

Watch is basic GRPC Healthcheck as a stream