Versions in this module Expand all Collapse all v2 v2.6.2 Aug 12, 2022 Changes in this version + var Fixtures = func() []testutils.Fixture { ... }() + func HashPrefix(input string) string + func NewBigtableObjectClient(ctx context.Context, cfg Config, schemaCfg config.SchemaConfig) (client.Client, error) + func NewStorageClientColumnKey(ctx context.Context, cfg Config, schemaCfg config.SchemaConfig) (index.Client, error) + func NewStorageClientV1(ctx context.Context, cfg Config, schemaCfg config.SchemaConfig) (index.Client, error) + func NewTableClient(ctx context.Context, cfg Config) (index.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 + ServiceAccount flagext.Secret + 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) ([]client.StorageObject, []client.StorageCommonPrefix, error) + func (s *GCSObjectClient) PutObject(ctx context.Context, objectKey string, object io.ReadSeeker) error + func (s *GCSObjectClient) Stop()