Versions in this module Expand all Collapse all v2 v2.4.3 Feb 9, 2022 Changes in this version + var Fixtures = func() []testutils.Fixture { ... }() + func HashPrefix(input string) string + func NewBigtableObjectClient(ctx context.Context, cfg Config, schemaCfg chunk.SchemaConfig) (chunk.Client, error) + func NewStorageClientColumnKey(ctx context.Context, cfg Config, schemaCfg chunk.SchemaConfig) (chunk.IndexClient, error) + func NewStorageClientV1(ctx context.Context, cfg Config, schemaCfg chunk.SchemaConfig) (chunk.IndexClient, error) + func NewTableClient(ctx context.Context, cfg Config) (chunk.TableClient, error) + type ClientFactory func(ctx context.Context, opts ...option.ClientOption) (*storage.Client, error) + type Config struct + ColumnKey bool + DistributeKeys bool + GRPCClientConfig grpcclient.Config + Instance string + Project string + TableCacheEnabled bool + TableCacheExpiration time.Duration + func (cfg *Config) RegisterFlags(f *flag.FlagSet) + func (cfg *Config) Validate(log log.Logger) error + type GCSConfig struct + BucketName string + ChunkBufferSize int + EnableHTTP2 bool + EnableOpenCensus bool + Insecure bool + RequestTimeout time.Duration + func (cfg *GCSConfig) RegisterFlags(f *flag.FlagSet) + func (cfg *GCSConfig) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet) + type GCSObjectClient struct + func NewGCSObjectClient(ctx context.Context, cfg GCSConfig, hedgingCfg hedging.Config) (*GCSObjectClient, error) + func (s *GCSObjectClient) DeleteObject(ctx context.Context, objectKey string) error + func (s *GCSObjectClient) GetObject(ctx context.Context, objectKey string) (io.ReadCloser, int64, error) + func (s *GCSObjectClient) IsObjectNotFoundErr(err error) bool + func (s *GCSObjectClient) List(ctx context.Context, prefix, delimiter string) ([]chunk.StorageObject, []chunk.StorageCommonPrefix, error) + func (s *GCSObjectClient) PutObject(ctx context.Context, objectKey string, object io.ReadSeeker) error + func (s *GCSObjectClient) Stop()
Go to main page