Versions in this module Expand all Collapse all v2 v2.0.0 Jun 14, 2023 Changes in this version + const HostPolicyRoundRobin + const HostPolicyTokenAware + func Fixtures() []testutils.Fixture + func NewTableClient(_ context.Context, cfg Config, registerer prometheus.Registerer) (index.TableClient, error) + type Config struct + Addresses string + Auth bool + CAPath string + CertPath string + ConnectTimeout time.Duration + Consistency string + ConvictHosts bool + CustomAuthenticators flagext.StringSlice + DisableInitialHostLookup bool + HostSelectionPolicy string + HostVerification bool + KeyPath string + Keyspace string + MaxBackoff time.Duration + MinBackoff time.Duration + NumConnections int + Password flagext.Secret + PasswordFile string + Port int + QueryConcurrency int + ReconnectInterval time.Duration + ReplicationFactor int + Retries int + SSL bool + TableOptions string + Timeout time.Duration + Username string + func (cfg *Config) RegisterFlags(f *flag.FlagSet) + func (cfg *Config) Validate() error + type CustomPasswordAuthenticator struct + ApprovedAuthenticators []string + Password string + Username string + func (p CustomPasswordAuthenticator) Challenge(req []byte) ([]byte, gocql.Authenticator, error) + func (p CustomPasswordAuthenticator) Success(_ []byte) error + type ObjectClient struct + func NewObjectClient(cfg Config, schemaCfg config.SchemaConfig, registerer prometheus.Registerer, ...) (*ObjectClient, error) + func (s *ObjectClient) DeleteChunk(ctx context.Context, userID, chunkID string) error + func (s *ObjectClient) GetChunks(ctx context.Context, input []chunk.Chunk) ([]chunk.Chunk, error) + func (s *ObjectClient) IsChunkNotFoundErr(_ error) bool + func (s *ObjectClient) PutChunks(ctx context.Context, chunks []chunk.Chunk) error + func (s *ObjectClient) Stop() + type StorageClient struct + func NewStorageClient(cfg Config, schemaCfg config.SchemaConfig, registerer prometheus.Registerer) (*StorageClient, error) + func (s *StorageClient) BatchWrite(ctx context.Context, batch index.WriteBatch) error + func (s *StorageClient) GetReadSession() *gocql.Session + func (s *StorageClient) NewWriteBatch() index.WriteBatch + func (s *StorageClient) QueryPages(ctx context.Context, queries []index.Query, callback index.QueryPagesCallback) error + func (s *StorageClient) Stop()
Go to main page