Documentation
¶
Index ¶
- func Fixtures() ([]testutils.Fixture, error)
- func NewTableClient(ctx context.Context, cfg Config) (chunk.TableClient, error)
- type Config
- type StorageClient
- func (s *StorageClient) BatchWrite(ctx context.Context, batch chunk.WriteBatch) error
- func (s *StorageClient) GetChunks(ctx context.Context, input []chunk.Chunk) ([]chunk.Chunk, error)
- func (s *StorageClient) NewWriteBatch() chunk.WriteBatch
- func (s *StorageClient) PutChunks(ctx context.Context, chunks []chunk.Chunk) error
- func (s *StorageClient) QueryPages(ctx context.Context, queries []chunk.IndexQuery, ...) error
- func (s *StorageClient) Stop()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewTableClient ¶
NewTableClient returns a new TableClient.
Types ¶
type Config ¶
type Config struct {
Addresses string `yaml:"addresses,omitempty"`
Port int `yaml:"port,omitempty"`
Keyspace string `yaml:"keyspace,omitempty"`
Consistency string `yaml:"consistency,omitempty"`
ReplicationFactor int `yaml:"replication_factor,omitempty"`
DisableInitialHostLookup bool `yaml:"disable_initial_host_lookup,omitempty"`
SSL bool `yaml:"SSL,omitempty"`
HostVerification bool `yaml:"host_verification,omitempty"`
CAPath string `yaml:"CA_path,omitempty"`
Auth bool `yaml:"auth,omitempty"`
Username string `yaml:"username,omitempty"`
Password string `yaml:"password,omitempty"`
Timeout time.Duration `yaml:"timeout,omitempty"`
ConnectTimeout time.Duration `yaml:"connect_timeout,omitempty"`
}
Config for a StorageClient
func (*Config) RegisterFlags ¶
RegisterFlags adds the flags required to config this to the given FlagSet
type StorageClient ¶
type StorageClient struct {
// contains filtered or unexported fields
}
StorageClient implements chunk.IndexClient and chunk.ObjectClient for Cassandra.
func NewStorageClient ¶
func NewStorageClient(cfg Config, schemaCfg chunk.SchemaConfig) (*StorageClient, error)
NewStorageClient returns a new StorageClient.
func (*StorageClient) BatchWrite ¶
func (s *StorageClient) BatchWrite(ctx context.Context, batch chunk.WriteBatch) error
BatchWrite implement chunk.IndexClient.
func (*StorageClient) NewWriteBatch ¶
func (s *StorageClient) NewWriteBatch() chunk.WriteBatch
NewWriteBatch implement chunk.IndexClient.
func (*StorageClient) QueryPages ¶
func (s *StorageClient) QueryPages(ctx context.Context, queries []chunk.IndexQuery, callback func(chunk.IndexQuery, chunk.ReadBatch) bool) error
QueryPages implement chunk.IndexClient.
Click to show internal directories.
Click to hide internal directories.