pending_execution

Documentation

Index

• Variables
• type DdbTracker
  • func (t *DdbTracker) AddExecution(ctx context.Context, id string, user tempest.Snowflake) error
  • func (t *DdbTracker) GetExecution(ctx context.Context, id string) (tempest.Snowflake, error)
  • func (t *DdbTracker) RemoveExecution(ctx context.Context, id string) error
• type InMemoryTracker
  • func (t *InMemoryTracker) AddExecution(ctx context.Context, id string, user tempest.Snowflake) error
  • func (t *InMemoryTracker) GetExecution(ctx context.Context, id string) (tempest.Snowflake, error)
  • func (t *InMemoryTracker) RemoveExecution(ctx context.Context, id string) error
• type Tracker
  • func NewDdbTracker(table string, client *dynamodb.Client) Tracker
  • func NewInMemoryTracker() Tracker

Variables

var (
	ErrExecutionNotFound = errors.New("execution not found")
)

Types

type DdbTracker

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

func (*DdbTracker) AddExecution

func (t *DdbTracker) AddExecution(ctx context.Context, id string, user tempest.Snowflake) error

func (*DdbTracker) GetExecution

func (t *DdbTracker) GetExecution(ctx context.Context, id string) (tempest.Snowflake, error)

func (*DdbTracker) RemoveExecution

func (t *DdbTracker) RemoveExecution(ctx context.Context, id string) error

type InMemoryTracker

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

func (*InMemoryTracker) AddExecution

func (t *InMemoryTracker) AddExecution(ctx context.Context, id string, user tempest.Snowflake) error

func (*InMemoryTracker) GetExecution

func (t *InMemoryTracker) GetExecution(ctx context.Context, id string) (tempest.Snowflake, error)

func (*InMemoryTracker) RemoveExecution

func (t *InMemoryTracker) RemoveExecution(ctx context.Context, id string) error

type Tracker

type Tracker interface {
	AddExecution(ctx context.Context, id string, user tempest.Snowflake) error
	RemoveExecution(ctx context.Context, id string) error
	GetExecution(ctx context.Context, id string) (tempest.Snowflake, error)
}

func NewDdbTracker

func NewDdbTracker(table string, client *dynamodb.Client) Tracker

func NewInMemoryTracker

func NewInMemoryTracker() Tracker