memory

Documentation

Index

• type Client
  • func New() *Client
  • func (x *Client) Close() error
  • func (x *Client) GetAlert(ctx context.Context, id types.AlertID) (*model.Alert, error)
  • func (x *Client) GetAttrs(ctx context.Context, ns types.Namespace) (model.Attributes, error)
  • func (x *Client) GetWorkflow(ctx context.Context, id types.WorkflowID) (*model.WorkflowRecord, error)
  • func (x *Client) GetWorkflows(ctx context.Context, offset, limit int) ([]model.WorkflowRecord, error)
  • func (x *Client) Lock(ctx context.Context, ns types.Namespace, timeout time.Time) error
  • func (x *Client) PutAlert(ctx context.Context, alert model.Alert) error
  • func (x *Client) PutAttrs(ctx context.Context, ns types.Namespace, attrs model.Attributes) error
  • func (x *Client) PutWorkflow(ctx context.Context, workflow model.WorkflowRecord) error
  • func (x *Client) Unlock(ctx context.Context, ns types.Namespace) error

Types

type Client

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

func New

func New() *Client

func (*Client) Close

func (x *Client) Close() error

Close implements interfaces.Database.

func (*Client) GetAlert

func (x *Client) GetAlert(ctx context.Context, id types.AlertID) (*model.Alert, error)

func (*Client) GetAttrs

func (x *Client) GetAttrs(ctx context.Context, ns types.Namespace) (model.Attributes, error)

GetAttrs implements interfaces.Database.

func (*Client) GetWorkflow

func (x *Client) GetWorkflow(ctx context.Context, id types.WorkflowID) (*model.WorkflowRecord, error)

func (*Client) GetWorkflows

func (x *Client) GetWorkflows(ctx context.Context, offset, limit int) ([]model.WorkflowRecord, error)

func (*Client) Lock

func (x *Client) Lock(ctx context.Context, ns types.Namespace, timeout time.Time) error

Lock implements interfaces.Database.

func (*Client) PutAlert

func (x *Client) PutAlert(ctx context.Context, alert model.Alert) error

func (*Client) PutAttrs

func (x *Client) PutAttrs(ctx context.Context, ns types.Namespace, attrs model.Attributes) error

PutAttrs implements interfaces.Database.

func (*Client) PutWorkflow

func (x *Client) PutWorkflow(ctx context.Context, workflow model.WorkflowRecord) error

func (*Client) Unlock

func (x *Client) Unlock(ctx context.Context, ns types.Namespace) error

Unlock implements interfaces.Database.