cassandra

package

v0.11.0 Latest Latest Go to latest Published: Jul 31, 2023 License: Apache-2.0 Imports: 20 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

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, out chan string) error

func (i *IndexValidator) Stop()

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

ObjectClient implements chunk.ObjectClient for Cassandra.

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

NewObjectClient returns a new ObjectClient.

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

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

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

NewStorageClient returns a new StorageClient.

func (s *StorageClient) Stop()

Stop implement chunk.IndexClient.