Documentation
¶
Index ¶
- func Fixtures() ([]testutils.Fixture, error)
- func NewTableClient(ctx context.Context, cfg Config) (chunk.TableClient, error)
- type Config
- type CustomPasswordAuthenticator
- type StorageClient
- func (s *StorageClient) BatchWrite(ctx context.Context, batch chunk.WriteBatch) error
- func (s *StorageClient) DeleteChunk(ctx context.Context, chunkID string) 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"`
Port int `yaml:"port"`
Keyspace string `yaml:"keyspace"`
Consistency string `yaml:"consistency"`
ReplicationFactor int `yaml:"replication_factor"`
DisableInitialHostLookup bool `yaml:"disable_initial_host_lookup"`
SSL bool `yaml:"SSL"`
HostVerification bool `yaml:"host_verification"`
CAPath string `yaml:"CA_path"`
Auth bool `yaml:"auth"`
Username string `yaml:"username"`
Password flagext.Secret `yaml:"password"`
PasswordFile string `yaml:"password_file"`
CustomAuthenticators flagext.StringSlice `yaml:"custom_authenticators"`
Timeout time.Duration `yaml:"timeout"`
ConnectTimeout time.Duration `yaml:"connect_timeout"`
Retries int `yaml:"max_retries"`
MaxBackoff time.Duration `yaml:"retry_max_backoff"`
MinBackoff time.Duration `yaml:"retry_min_backoff"`
}
Config for a StorageClient
func (*Config) RegisterFlags ¶
RegisterFlags adds the flags required to config this to the given FlagSet
type CustomPasswordAuthenticator ¶ added in v0.7.0
type CustomPasswordAuthenticator struct {
ApprovedAuthenticators []string
Username string
Password string
}
CustomPasswordAuthenticator provides the default behaviour for Username/Password authentication with Cassandra while allowing users to specify a non-default Authenticator to accept.
func (CustomPasswordAuthenticator) Challenge ¶ added in v0.7.0
func (p CustomPasswordAuthenticator) Challenge(req []byte) ([]byte, gocql.Authenticator, error)
Challenge verifies the name of the authenticator and formats the provided username and password into a response
func (CustomPasswordAuthenticator) Success ¶ added in v0.7.0
func (p CustomPasswordAuthenticator) Success(data []byte) error
Success returns nil by default, identical to the default PasswordAuthenticator
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) DeleteChunk ¶ added in v0.7.0
func (s *StorageClient) DeleteChunk(ctx context.Context, chunkID string) error
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.
Source Files