service

Documentation

Index

• type ActionService
  • func NewActionService(db interfaces.Database) *ActionService
  • func (x *ActionService) Fetch(ctx context.Context, wfID types.WorkflowID) ([]model.ActionRecord, error)
• type Services
  • func New(db interfaces.Database) *Services
• type Workflow
  • func (x *Workflow) AddAction(ctx context.Context, action *model.Action) error
  • func (x *Workflow) UpdateLastAttrs(ctx context.Context, attrs model.Attributes) error
• type WorkflowService
  • func NewWorkflowService(db interfaces.Database) *WorkflowService
  • func (x *WorkflowService) Create(ctx context.Context, alert model.Alert) (*Workflow, error)
  • func (x *WorkflowService) Get(ctx context.Context, offset, limit *int) ([]model.WorkflowRecord, error)
  • func (x *WorkflowService) Lookup(ctx context.Context, id types.WorkflowID) (*model.WorkflowRecord, error)

Types

type ActionService

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

func NewActionService

func NewActionService(db interfaces.Database) *ActionService

func (*ActionService) Fetch

func (x *ActionService) Fetch(ctx context.Context, wfID types.WorkflowID) ([]model.ActionRecord, error)

type Services

type Services struct {
	Workflow *WorkflowService
}

func New

func New(db interfaces.Database) *Services

type Workflow

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

func (*Workflow) AddAction

func (x *Workflow) AddAction(ctx context.Context, action *model.Action) error

func (*Workflow) UpdateLastAttrs

func (x *Workflow) UpdateLastAttrs(ctx context.Context, attrs model.Attributes) error

type WorkflowService

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

func NewWorkflowService

func NewWorkflowService(db interfaces.Database) *WorkflowService

func (*WorkflowService) Create

func (x *WorkflowService) Create(ctx context.Context, alert model.Alert) (*Workflow, error)

func (*WorkflowService) Get

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

func (*WorkflowService) Lookup

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