metastore

Documentation

Index

• type Config
  • func (cfg *Config) RegisterFlags(f *flag.FlagSet)
• type FSM
  • func (fsm *FSM) Apply(l *raft.Log) interface{}
  • func (fsm *FSM) Restore(snapshot io.ReadCloser) error
  • func (fsm *FSM) Snapshot() (raft.FSMSnapshot, error)
• type Metastore
  • func New(config Config, logger log.Logger, reg prometheus.Registerer, hs health.Service) (*Metastore, error)
  • func (m *Metastore) AddBlock(_ context.Context, req *metastorepb.AddBlockRequest) (*metastorepb.AddBlockResponse, error)
  • func (m *Metastore) ListBlocksForQuery(ctx context.Context, request *metastorepb.ListBlocksForQueryRequest) (*metastorepb.ListBlocksForQueryResponse, error)
  • func (m *Metastore) Shutdown() error
• type RaftConfig
  • func (cfg *RaftConfig) RegisterFlags(f *flag.FlagSet)

Types

type Config

type Config struct {
	DataDir string     `yaml:"data_dir"`
	Raft    RaftConfig `yaml:"raft"`
}

func (*Config) RegisterFlags

func (cfg *Config) RegisterFlags(f *flag.FlagSet)

type FSM

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

func (*FSM) Apply

func (fsm *FSM) Apply(l *raft.Log) interface{}

func (*FSM) Restore

func (fsm *FSM) Restore(snapshot io.ReadCloser) error

func (*FSM) Snapshot

func (fsm *FSM) Snapshot() (raft.FSMSnapshot, error)

type Metastore

type Metastore struct {
	services.Service
	metastorepb.MetastoreServiceServer
	// contains filtered or unexported fields
}

func New

func New(config Config, logger log.Logger, reg prometheus.Registerer, hs health.Service) (*Metastore, error)

func (*Metastore) AddBlock

func (m *Metastore) AddBlock(_ context.Context, req *metastorepb.AddBlockRequest) (*metastorepb.AddBlockResponse, error)

func (*Metastore) ListBlocksForQuery

func (m *Metastore) ListBlocksForQuery(
	ctx context.Context,
	request *metastorepb.ListBlocksForQueryRequest,
) (
	*metastorepb.ListBlocksForQueryResponse, error,
)

func (*Metastore) Shutdown

func (m *Metastore) Shutdown() error

type RaftConfig

type RaftConfig struct {
	Dir string `yaml:"dir"`

	BootstrapPeers   []string `yaml:"bootstrap_peers"`
	ServerID         string   `yaml:"server_id"`
	BindAddress      string   `yaml:"bind_address"`
	AdvertiseAddress string   `yaml:"advertise_address"`

	ApplyTimeout time.Duration `yaml:"apply_timeout" doc:"hidden"`
}

func (*RaftConfig) RegisterFlags

func (cfg *RaftConfig) RegisterFlags(f *flag.FlagSet)