Versions in this module Expand all Collapse all v3 v3.3.0 Nov 19, 2024 v3.2.1 Oct 17, 2024 v3.2.0 Sep 18, 2024 v3.1.2 Oct 17, 2024 v3.1.1 Aug 8, 2024 v3.1.0 Jul 2, 2024 v3.0.1 Aug 9, 2024 v3.0.0 Apr 8, 2024 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) IsRetryableErr(_ 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