dynamodb

Documentation

Index

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

Types

type DynamoDB

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

DynamoDB provides handlers for gRPC endpoints Data is stored/retrieved from the Amazon DynamoDB NoSQL database.

func NewDynamoDB

func NewDynamoDB(conf config.DynamoDB) (*DynamoDB, error)

NewDynamoDB returns a new instance of DynamoDB, accessing the database at the given url, and including the given ServerConfig.

func (*DynamoDB) Close

func (db *DynamoDB) Close()

func (*DynamoDB) GetTask

func (db *DynamoDB) GetTask(ctx context.Context, req *tes.GetTaskRequest) (*tes.Task, error)

GetTask gets a task, which describes a running task

func (*DynamoDB) Init

func (db *DynamoDB) Init() error

Init creates tables in DynamoDB.

func (*DynamoDB) ListTasks

func (db *DynamoDB) ListTasks(ctx context.Context, req *tes.ListTasksRequest) (*tes.ListTasksResponse, error)

ListTasks returns a list of taskIDs

func (*DynamoDB) WriteEvent

func (db *DynamoDB) WriteEvent(ctx context.Context, e *events.Event) error

WriteEvent creates an event for the server to handle.