archivist

Documentation

Index

• type Archivist
  • func New(store store.StoreInterface, idx store.IndexInterface, st *stats.Stats, ...) (*Archivist, error)
  • func (ar *Archivist) SendPacket(ctx context.Context, batch *pb.PacketBatch) (*pb.SendPacketResp, error)
  • func (ar *Archivist) Start(address string) error

Types

type Archivist

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

func New

func New(store store.StoreInterface, idx store.IndexInterface, st *stats.Stats, cfg *config.ArchivistConfig) (*Archivist, error)

func (*Archivist) SendPacket

func (ar *Archivist) SendPacket(ctx context.Context, batch *pb.PacketBatch) (*pb.SendPacketResp, error)

func (*Archivist) Start

func (ar *Archivist) Start(address string) error