storage

Documentation

Index

• type MapRepository
  • func NewMapRepository() *MapRepository
  • func (r *MapRepository) Get(ctx context.Context, id string) (testkube.Execution, error)
  • func (r *MapRepository) Insert(ctx context.Context, result testkube.Execution) error
  • func (r *MapRepository) QueuePull(ctx context.Context) (testkube.Execution, error)
  • func (r *MapRepository) Update(ctx context.Context, result testkube.Execution) error
  • func (r *MapRepository) UpdateResult(ctx context.Context, id string, result testkube.ExecutionResult) error

Types

type MapRepository

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

func NewMapRepository

func NewMapRepository() *MapRepository

NewMapRepository creates a MapRepository

func (*MapRepository) Get

func (r *MapRepository) Get(ctx context.Context, id string) (testkube.Execution, error)

Get gets execution result by id

func (*MapRepository) Insert

func (r *MapRepository) Insert(ctx context.Context, result testkube.Execution) error

Insert inserts new execution result

func (*MapRepository) QueuePull

func (r *MapRepository) QueuePull(ctx context.Context) (testkube.Execution, error)

QueuePull pulls from queue and locks other clients to read (changes state from queued->pending)

func (*MapRepository) Update

func (r *MapRepository) Update(ctx context.Context, result testkube.Execution) error

Update updates execution result

func (*MapRepository) UpdateResult

func (r *MapRepository) UpdateResult(ctx context.Context, id string, result testkube.ExecutionResult) error

Update updates execution result