bigtable

Sep 14, 2023

Changes in this version

+ func WithAdminClientMW(projectID, instanceName string) func(AdminClient) AdminClient

+ func WithInstanceAdminClientMW(projectID string) func(InstanceAdminClient) InstanceAdminClient

+ type AdminClientMW struct

+ func (o *AdminClientMW) TableInfo(ctx context.Context, table string) (res *bigtable.TableInfo, err error)

+ func (o *AdminClientMW) Tables(ctx context.Context) (res []string, err error)

+ type InstanceAdminClientMW struct

+ func (o *InstanceAdminClientMW) Instances(ctx context.Context) (res []*bigtable.InstanceInfo, err error)

Jun 23, 2023

Changes in this version

+ type AdminClient interface

+ TableInfo func(ctx context.Context, table string) (*bigtable.TableInfo, error)

+ Tables func(ctx context.Context) ([]string, error)

+ type InstanceAdminClient interface

+ Instances func(ctx context.Context) ([]*bigtable.InstanceInfo, error)

+ type NewAdminClientFunc func(ctx context.Context, instance string, config Config) (AdminClient, error)

+ type NewClientFunc func(ctx context.Context, cfg Config) (InstanceAdminClient, error)

May 5, 2023

Changes in this version

type Config

+ ServiceAccountBase64 string

Mar 16, 2023

Changes in this version

+ type Config struct

+ ProjectID string

+ type Extractor struct

+ func New(logger log.Logger) *Extractor

+ func (e *Extractor) Extract(ctx context.Context, emit plugins.Emit) (err error)

+ func (e *Extractor) Init(ctx context.Context, config plugins.Config) (err error)

+ type InstancesFetcher interface

+ Instances func(context.Context) ([]*bigtable.InstanceInfo, error)