package bigtable

import "github.com/influxdata/flux/dependencies/bigtable"

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 ErrorProvider
• func (ErrorProvider) NewClient(ctx context.Context, project, instance string, opts ...option.ClientOption) (*bigtable.Client, error)
• 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 ErrorProvider ¶

type ErrorProvider struct{}

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

func (ErrorProvider) NewClient ¶

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

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

Source Files ¶

bigtable.go