bigtable

Documentation

Index

• type BTDB
  • func NewBigTableDB(ctx context.Context, project, instance string, ts oauth2.TokenSource) (*BTDB, error)
  • func (d *BTDB) Close() error
  • func (d *BTDB) GetMessagesForTaskDriver(ctx context.Context, id string) ([]*td.Message, error)
  • func (d *BTDB) GetTaskDriver(ctx context.Context, id string) (*db.TaskDriverRun, error)
  • func (d *BTDB) UpdateTaskDriver(ctx context.Context, id string, msg *td.Message) error

Types

type BTDB

type BTDB struct {
	// contains filtered or unexported fields
}

BTDB is an implementation of db.DB which uses BigTable.

func NewBigTableDB

func NewBigTableDB(ctx context.Context, project, instance string, ts oauth2.TokenSource) (*BTDB, error)

NewBigTableDB returns a db.DB instance which uses BigTable.

func (*BTDB) Close

func (d *BTDB) Close() error

See documentation for db.DB interface.

func (*BTDB) GetMessagesForTaskDriver

func (d *BTDB) GetMessagesForTaskDriver(ctx context.Context, id string) ([]*td.Message, error)

GetMessagesForTaskDriver returns all td.Messages sent for the Task Driver with the given ID.

func (*BTDB) GetTaskDriver

func (d *BTDB) GetTaskDriver(ctx context.Context, id string) (*db.TaskDriverRun, error)

See documentation for db.DB interface.

func (*BTDB) UpdateTaskDriver

func (d *BTDB) UpdateTaskDriver(ctx context.Context, id string, msg *td.Message) error

See documentation for db.DB interface.