bigtable

Documentation

Index

• func Inject(ctx context.Context, provider Provider) context.Context
• type Client
• type DefaultProvider
  • func (d DefaultProvider) NewClient(ctx context.Context, project, instance string, opts ...option.ClientOption) (*bigtable.Client, error)
• type Dependency
  • func (d Dependency) Inject(ctx context.Context) context.Context
• type Filter
  • func ChainFilters(sub ...Filter) Filter
  • func FamilyFilter(pattern string) Filter
  • func PassAllFilter() Filter
  • func TimestampRangeFilter(startTime, endTime time.Time) Filter
• type Provider
  • func GetProvider(ctx context.Context) Provider
• type ReadItem
• type ReadOption
  • func LimitRows(limit int64) ReadOption
  • func RowFilter(f Filter) ReadOption
• type Row
• type RowRange
  • func InfiniteRange(start string) RowRange
  • func NewRange(begin, end string) RowRange
  • func PrefixRange(prefix string) RowRange
• type RowSet
  • func SingleRow(row string) RowSet
• type Table

Functions

func Inject

func Inject(ctx context.Context, provider Provider) context.Context

Inject will inject this Provider into the dependency chain.

Types

type Client

type Client = bigtable.Client

type DefaultProvider

type DefaultProvider struct{}

DefaultProvider is the default provider that uses the default bigtable client.

func (DefaultProvider) NewClient

func (d DefaultProvider) NewClient(ctx context.Context, project, instance string, opts ...option.ClientOption) (*bigtable.Client, error)

type Dependency

type Dependency struct {
	Provider Provider
}

Dependency will inject the Provider into the dependency chain.

func (Dependency) Inject

func (d Dependency) Inject(ctx context.Context) context.Context

Inject will inject the Dialer into the dependency chain.

type Filter

type Filter = bigtable.Filter

func ChainFilters

func ChainFilters(sub ...Filter) Filter

func FamilyFilter

func FamilyFilter(pattern string) Filter

func PassAllFilter

func PassAllFilter() Filter

func TimestampRangeFilter

func TimestampRangeFilter(startTime, endTime time.Time) Filter

type Provider

type Provider interface {
	NewClient(ctx context.Context, project, instance string, opts ...option.ClientOption) (*bigtable.Client, error)
}

Provider provides a method to create a new bigtable.Client.

func GetProvider

func GetProvider(ctx context.Context) Provider

GetProvider will return the Provider for the current context. If no Provider has been injected into the dependencies, this will return a default provider.

type ReadItem

type ReadItem = bigtable.ReadItem

type ReadOption

type ReadOption = bigtable.ReadOption

func LimitRows

func LimitRows(limit int64) ReadOption

func RowFilter

func RowFilter(f Filter) ReadOption

type Row

type Row = bigtable.Row

type RowRange

type RowRange = bigtable.RowRange

func InfiniteRange

func InfiniteRange(start string) RowRange

func NewRange

func NewRange(begin, end string) RowRange

func PrefixRange

func PrefixRange(prefix string) RowRange

type RowSet

type RowSet = bigtable.RowSet

func SingleRow

func SingleRow(row string) RowSet

type Table

type Table = bigtable.Table