datastore

Documentation

Index

• type Datastore
  • func NewDatastore(conf config.Datastore) (*Datastore, error)
  • func (db *Datastore) Close()
  • func (d *Datastore) GetTask(ctx context.Context, req *tes.GetTaskRequest) (*tes.Task, error)
  • func (db *Datastore) Init() error
  • func (d *Datastore) ListTasks(ctx context.Context, req *tes.ListTasksRequest) (*tes.ListTasksResponse, error)
  • func (d *Datastore) WriteEvent(ctx context.Context, e *events.Event) error

Types

type Datastore

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

Datastore provides a task database on Google Cloud Datastore.

func NewDatastore

func NewDatastore(conf config.Datastore) (*Datastore, error)

NewDatastore returns a new Datastore instance with the given config.

func (*Datastore) Close

func (db *Datastore) Close()

func (*Datastore) GetTask

func (d *Datastore) GetTask(ctx context.Context, req *tes.GetTaskRequest) (*tes.Task, error)

GetTask implements the TES GetTask interface.

func (*Datastore) Init

func (db *Datastore) Init() error

Init is a noop action for Datastore.

func (*Datastore) ListTasks

func (d *Datastore) ListTasks(ctx context.Context, req *tes.ListTasksRequest) (*tes.ListTasksResponse, error)

ListTasks implements the TES ListTasks interface.

func (*Datastore) WriteEvent

func (d *Datastore) WriteEvent(ctx context.Context, e *events.Event) error

WriteEvent writes a task event to the database.