indexcheckpoint

Documentation

Index

• type Checkpoints
  • func New(dir string, logger logrus.FieldLogger) (*Checkpoints, error)
  • func (c *Checkpoints) Close()
  • func (c *Checkpoints) Delete(shardID string) error
  • func (c *Checkpoints) Filename() string
  • func (c *Checkpoints) Get(shardID string) (uint64, error)
  • func (c *Checkpoints) Update(shardID string, id uint64) error

Types

type Checkpoints

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

Checkpoints keeps track of the last indexed vector id for each shard. It stores the ids in a BoltDB file.

func New

func New(dir string, logger logrus.FieldLogger) (*Checkpoints, error)

func (*Checkpoints) Close

func (c *Checkpoints) Close()

Close the underlying DB

func (*Checkpoints) Delete

func (c *Checkpoints) Delete(shardID string) error

func (*Checkpoints) Filename

func (c *Checkpoints) Filename() string

func (*Checkpoints) Get

func (c *Checkpoints) Get(shardID string) (uint64, error)

func (*Checkpoints) Update

func (c *Checkpoints) Update(shardID string, id uint64) error