bigtable

package
v0.0.0-...-71cd2e8 Latest Latest
Warning

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

Go to latest
Published: May 2, 2024 License: BSD-3-Clause Imports: 12 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL