bigtable

package
v1.9.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 14, 2026 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const SourceType string = "bigtable"

Variables

This section is empty.

Functions

This section is empty.

Types

type Config 

type Config struct {
	Name     string `yaml:"name" validate:"required"`
	Type     string `yaml:"type" validate:"required"`
	Project  string `yaml:"project" validate:"required"`
	Instance string `yaml:"instance" validate:"required"`
}

func (Config) Initialize 

func (r Config) Initialize(ctx context.Context, tracer trace.Tracer) (sources.Source, error)

func (Config) SourceConfigType 

func (r Config) SourceConfigType() string

type Source 

type Source struct {
	Config
	Client        *bigtable.Client
	InstanceAdmin *bigtable.InstanceAdminClient
	Admin         *bigtable.AdminClient
}

func (*Source) BigtableAdminClient added in v1.9.0 

func (s *Source) BigtableAdminClient() *bigtable.AdminClient

func (*Source) BigtableClient 

func (s *Source) BigtableClient() *bigtable.Client

func (*Source) BigtableInstanceAdminClient added in v1.9.0 

func (s *Source) BigtableInstanceAdminClient() *bigtable.InstanceAdminClient

func (*Source) CreateCluster added in v1.9.0 

func (s *Source) CreateCluster(ctx context.Context, instanceId, clusterId, zone string, numNodes int32) (any, error)

func (*Source) CreateInstance added in v1.9.0 

func (s *Source) CreateInstance(ctx context.Context, instanceId, displayName, clusterId, zone string, numNodes int32) (any, error)

func (*Source) CreateLogicalView added in v1.9.0 

func (s *Source) CreateLogicalView(ctx context.Context, instanceId, logicalViewId, query string) (any, error)

func (*Source) CreateMaterializedView added in v1.9.0 

func (s *Source) CreateMaterializedView(ctx context.Context, instanceId, materializedViewId, query string) (any, error)

func (*Source) CreateTable added in v1.9.0 

func (s *Source) CreateTable(ctx context.Context, tableId, columnFamily string) (any, error)

func (*Source) DeleteCluster added in v1.9.0 

func (s *Source) DeleteCluster(ctx context.Context, instanceId, clusterId string) (any, error)

func (*Source) DeleteInstance added in v1.9.0 

func (s *Source) DeleteInstance(ctx context.Context, instanceId string) (any, error)

func (*Source) DeleteLogicalView added in v1.9.0 

func (s *Source) DeleteLogicalView(ctx context.Context, instanceId, logicalViewId string) (any, error)

func (*Source) DeleteMaterializedView added in v1.9.0 

func (s *Source) DeleteMaterializedView(ctx context.Context, instanceId, materializedViewId string) (any, error)

func (*Source) DeleteTable added in v1.9.0 

func (s *Source) DeleteTable(ctx context.Context, tableId string) (any, error)

func (*Source) GetCluster added in v1.9.0 

func (s *Source) GetCluster(ctx context.Context, instanceId, clusterId string) (any, error)

func (*Source) GetInstance added in v1.9.0 

func (s *Source) GetInstance(ctx context.Context, instanceId string) (any, error)

func (*Source) GetLogicalView added in v1.9.0 

func (s *Source) GetLogicalView(ctx context.Context, instanceId, logicalViewId string) (any, error)

func (*Source) GetMaterializedView added in v1.9.0 

func (s *Source) GetMaterializedView(ctx context.Context, instanceId, materializedViewId string) (any, error)

func (*Source) GetTable added in v1.9.0 

func (s *Source) GetTable(ctx context.Context, tableId string) (any, error)

func (*Source) InstanceID added in v1.9.0 

func (s *Source) InstanceID() string

func (*Source) ListClusters added in v1.9.0 

func (s *Source) ListClusters(ctx context.Context, instanceId string) (any, error)

func (*Source) ListInstances added in v1.9.0 

func (s *Source) ListInstances(ctx context.Context) (any, error)

func (*Source) ListLogicalViews added in v1.9.0 

func (s *Source) ListLogicalViews(ctx context.Context, instanceId string) (any, error)

func (*Source) ListMaterializedViews added in v1.9.0 

func (s *Source) ListMaterializedViews(ctx context.Context, instanceId string) (any, error)

func (*Source) ListTables added in v1.9.0 

func (s *Source) ListTables(ctx context.Context) (any, error)

func (*Source) ProjectID added in v1.9.0 

func (s *Source) ProjectID() string

func (*Source) RunSQL 

func (s *Source) RunSQL(ctx context.Context, statement string, configParam parameters.Parameters, params parameters.ParamValues) (any, error)

func (*Source) SourceType 

func (s *Source) SourceType() string

func (*Source) ToConfig 

func (s *Source) ToConfig() sources.SourceConfig

func (*Source) UpdateCluster added in v1.9.0 

func (s *Source) UpdateCluster(ctx context.Context, instanceId, clusterId string, serveNodes int32) (any, error)

func (*Source) UpdateInstance added in v1.9.0 

func (s *Source) UpdateInstance(ctx context.Context, instanceId, displayName string) (any, error)

func (*Source) UpdateLogicalView added in v1.9.0 

func (s *Source) UpdateLogicalView(ctx context.Context, instanceId, logicalViewId, query string) (any, error)

func (*Source) UpdateMaterializedView added in v1.9.0 

func (s *Source) UpdateMaterializedView(ctx context.Context, instanceId, materializedViewId, query string) (any, error)

func (*Source) UpdateTable added in v1.9.0 

func (s *Source) UpdateTable(ctx context.Context, tableId string, disableChangeStream bool) (any, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.