executiondb

Documentation

Index

• type ExecutionDB
  • func NewExecutionDB(h *db.DBHandle) *ExecutionDB
  • func (d *ExecutionDB) InsertOrUpdateExecution(ctx context.Context, executionID string, stage repb.ExecutionStage_Value, ...) error
  • func (d *ExecutionDB) ReadExecution(ctx context.Context, executionID string) (*tables.Execution, error)

Types

type ExecutionDB

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

func NewExecutionDB

func NewExecutionDB(h *db.DBHandle) *ExecutionDB

func (*ExecutionDB) InsertOrUpdateExecution

func (d *ExecutionDB) InsertOrUpdateExecution(ctx context.Context, executionID string, stage repb.ExecutionStage_Value, op *longrunning.Operation) error

func (*ExecutionDB) ReadExecution

func (d *ExecutionDB) ReadExecution(ctx context.Context, executionID string) (*tables.Execution, error)