irreparable

Documentation

Index

• type DB
• type Inspector
  • func NewInspector(irrdb DB) *Inspector
  • func (srv *Inspector) ListIrreparableSegments(ctx context.Context, req *pb.ListIrreparableSegmentsRequest) (*pb.ListIrreparableSegmentsResponse, error)

Types

type DB

type DB interface {
	// IncrementRepairAttempts increments the repair attempts.
	IncrementRepairAttempts(ctx context.Context, segmentInfo *pb.IrreparableSegment) error
	// Get returns irreparable segment info based on segmentPath.
	Get(ctx context.Context, segmentPath []byte) (*pb.IrreparableSegment, error)
	// GetLimited number of segments from offset
	GetLimited(ctx context.Context, limit int, offset int64) ([]*pb.IrreparableSegment, error)
	// Delete removes irreparable segment info based on segmentPath.
	Delete(ctx context.Context, segmentPath []byte) error
}

DB stores information about repairs that have failed.

type Inspector

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

Inspector is a gRPC service for inspecting irreparable internals

func NewInspector

func NewInspector(irrdb DB) *Inspector

NewInspector creates an Inspector

func (*Inspector) ListIrreparableSegments

func (srv *Inspector) ListIrreparableSegments(ctx context.Context, req *pb.ListIrreparableSegmentsRequest) (*pb.ListIrreparableSegmentsResponse, error)

ListIrreparableSegments returns a number of irreparable segments by limit and offset