projectors

Documentation

Index

• func NewInvocationAggregate(invocationID string) fes.Aggregate
• func NewTaskRunAggregate(id string) fes.Aggregate
• func NewWorkflowAggregate(id string) fes.Aggregate
• type TaskRun
  • func NewTaskRun() *TaskRun
  • func (t *TaskRun) NewProjection(key fes.Aggregate) (fes.Entity, error)
  • func (t *TaskRun) Project(base fes.Entity, events ...*fes.Event) (updated fes.Entity, err error)
• type Workflow
  • func NewWorkflow() *Workflow
  • func (w *Workflow) NewProjection(key fes.Aggregate) (fes.Entity, error)
  • func (w *Workflow) Project(base fes.Entity, events ...*fes.Event) (updated fes.Entity, err error)
• type WorkflowInvocation
  • func NewWorkflowInvocation() *WorkflowInvocation
  • func (i *WorkflowInvocation) NewProjection(key fes.Aggregate) (fes.Entity, error)
  • func (i *WorkflowInvocation) Project(base fes.Entity, events ...*fes.Event) (updated fes.Entity, err error)

Functions

func NewInvocationAggregate

func NewInvocationAggregate(invocationID string) fes.Aggregate

func NewTaskRunAggregate

func NewTaskRunAggregate(id string) fes.Aggregate

func NewWorkflowAggregate

func NewWorkflowAggregate(id string) fes.Aggregate

Types

type TaskRun

type TaskRun struct {
}

func NewTaskRun

func NewTaskRun() *TaskRun

func (*TaskRun) NewProjection

func (t *TaskRun) NewProjection(key fes.Aggregate) (fes.Entity, error)

func (*TaskRun) Project

func (t *TaskRun) Project(base fes.Entity, events ...*fes.Event) (updated fes.Entity, err error)

type Workflow

type Workflow struct {
}

func NewWorkflow

func NewWorkflow() *Workflow

func (*Workflow) NewProjection

func (w *Workflow) NewProjection(key fes.Aggregate) (fes.Entity, error)

func (*Workflow) Project

func (w *Workflow) Project(base fes.Entity, events ...*fes.Event) (updated fes.Entity, err error)

type WorkflowInvocation

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

func NewWorkflowInvocation

func NewWorkflowInvocation() *WorkflowInvocation

func (*WorkflowInvocation) NewProjection

func (i *WorkflowInvocation) NewProjection(key fes.Aggregate) (fes.Entity, error)

func (*WorkflowInvocation) Project

func (i *WorkflowInvocation) Project(base fes.Entity, events ...*fes.Event) (updated fes.Entity, err error)