cassandra

Documentation

Index

• type IndexValidator
  • func NewIndexValidator(cfg cassandra.Config, schema chunk.SchemaConfig, tenantID string) (*IndexValidator, error)
  • func (i *IndexValidator) IndexScan(ctx context.Context, table string, from model.Time, to model.Time, ...) error
  • func (i *IndexValidator) Stop()
• type ObjectClient
  • func NewObjectClient(cfg cassandra.Config, schemaCfg chunk.SchemaConfig, ...) (*ObjectClient, error)
• type StorageClient
  • func NewStorageClient(cfg cassandra.Config, schemaCfg chunk.SchemaConfig, ...) (*StorageClient, error)
  • func (s *StorageClient) Stop()

Types

type IndexValidator

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

func NewIndexValidator

func NewIndexValidator(
	cfg cassandra.Config,
	schema chunk.SchemaConfig,
	tenantID string,
) (*IndexValidator, error)

func (*IndexValidator) IndexScan

func (i *IndexValidator) IndexScan(ctx context.Context, table string, from model.Time, to model.Time, out chan string) error

func (*IndexValidator) Stop

func (i *IndexValidator) Stop()

type ObjectClient

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

ObjectClient implements chunk.ObjectClient for Cassandra.

func NewObjectClient

func NewObjectClient(cfg cassandra.Config, schemaCfg chunk.SchemaConfig, registerer prometheus.Registerer) (*ObjectClient, error)

NewObjectClient returns a new ObjectClient.

type StorageClient

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

StorageClient implements chunk.IndexClient and chunk.ObjectClient for Cassandra.

func NewStorageClient

func NewStorageClient(cfg cassandra.Config, schemaCfg chunk.SchemaConfig, registerer prometheus.Registerer) (*StorageClient, error)

NewStorageClient returns a new StorageClient.

func (*StorageClient) Stop

func (s *StorageClient) Stop()

Stop implement chunk.IndexClient.