btrefresh

Documentation

Index

• type BtDialer
• type RotatingTable
  • func NewRotatingTable(dialer BtDialer, table string, refresh time.Duration) (*RotatingTable, error)
  • func (r RotatingTable) BackgroundErrors() <-chan error
  • func (r RotatingTable) Close()

Types

type BtDialer

type BtDialer func() (*bigtable.Client, error)

BtDialer encapsulates making a connection to your bigtable. This way you can use any means for dialing/ getting credentials.

type RotatingTable

type RotatingTable struct {
	*bigtable.Table
	// contains filtered or unexported fields
}

RotatingTable is a bigtable.Table that automatically reconnects to Cloud Bigtable at a given interval.

func NewRotatingTable

func NewRotatingTable(dialer BtDialer, table string, refresh time.Duration) (*RotatingTable, error)

NewRotatingTable makes a new Table reference that will refresh itself in the background at the given interval.

func (RotatingTable) BackgroundErrors

func (r RotatingTable) BackgroundErrors() <-chan error

BackgroundErrors is a channel that will propagate errors that come from refreshing the connection. It can either be checked with select before performing ops or watched in a background thread.

func (RotatingTable) Close

func (r RotatingTable) Close()

Close will close the connections and stop rotating.