domain

Documentation

Index

• func Boot(ctx context.Context) (<-chan struct{}, error)
• type BootParam
• type EntrypointDto
• type OperationDto
• type SagaDto
• type SagaServiceConfig
• type Service
  • func GetSagaService() Service
• type StepDto

Functions

func Boot

func Boot(ctx context.Context) (<-chan struct{}, error)

Prepares domain layer

Types

type BootParam

type BootParam string

const (
	BootSagaServiceConfig BootParam = "sagaServiceConfig"

	BootLog BootParam = "log"
	BootPub BootParam = "pub"
	BootSub BootParam = "sub"
)

type EntrypointDto

type EntrypointDto struct {
	Msg  string `yaml:"msg" json:"msg"`
	Bus  string `yaml:"bus" json:"bus"`
	Step string `yaml:"step" json:"step"`
}

type OperationDto

type OperationDto struct {
	Name   string `yaml:"name,omitempty" json:"name,omitempty"`
	Bus    string `yaml:"bus" json:"bus"`
	OnDone string `yaml:"onDone" json:"onDone,omitempty"`
	OnFail string `yaml:"onFail" json:"onFail,omitempty"`
}

type SagaDto

type SagaDto struct {
	Kind        string          `yaml:"kind" json:"-"`
	Id          string          `yaml:"id" json:"id"`
	Name        string          `yaml:"name,omitempty" json:"name,omitempty"`
	Bus         string          `yaml:"bus" json:"bus"`
	Timeout     string          `yaml:"timeout,omitempty" json:"timeout,omitempty"`
	Entrypoints []EntrypointDto `yaml:"entrypoints" json:"entrypoints,omitempty"`
	Steps       []StepDto       `yaml:"steps" json:"steps,omitempty"`
}

type SagaServiceConfig

type SagaServiceConfig struct {
	Dir string `config:"sagas-dir,required"`
	Ext string `config:"sagas-ext,required"`
}

type Service

type Service interface {
	Register(dto SagaDto) error
}

func GetSagaService

func GetSagaService() Service

type StepDto

type StepDto struct {
	Id         string         `yaml:"id" json:"id"`
	Name       string         `yaml:"name,omitempty" json:"name,omitempty"`
	Timeout    string         `yaml:"timeout,omitempty" json:"timeout,omitempty"`
	Skip       []string       `yaml:"skip,omitempty" json:"skip,omitempty"`
	Operations []OperationDto `yaml:"operations" json:"operations"`
	After      string         `yaml:"after" json:"after,omitempty"`
}