saga

package
v0.0.0-...-5c68854 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 23, 2020 License: GPL-3.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewDefaultSagaOrchestratorBuilder

func NewDefaultSagaOrchestratorBuilder() orchestrator.SagaOrchestratorBuilder

func NewDefaultSagaOrchestratorRegistration

func NewDefaultSagaOrchestratorRegistration() orchestrator.SagaOrchestratorRegistration

func NewDefaultSagaParticipantRegistry

func NewDefaultSagaParticipantRegistry() participant.SagaParticipantRegistration

Types

type CompensationProcessor

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

type DefaultSagaOrchestratorBuilder

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

func (*DefaultSagaOrchestratorBuilder) Add

func (*DefaultSagaOrchestratorBuilder) Build

func (*DefaultSagaOrchestratorBuilder) Name

func (*DefaultSagaOrchestratorBuilder) SetSagaId

func (*DefaultSagaOrchestratorBuilder) WithDeadline

type DefaultSagaOrchestratorRegistration

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

func (*DefaultSagaOrchestratorRegistration) AddSagaOrchestrator

func (*DefaultSagaOrchestratorRegistration) PublishTo

func (*DefaultSagaOrchestratorRegistration) Register

func (*DefaultSagaOrchestratorRegistration) WithKafkaConfig

func (*DefaultSagaOrchestratorRegistration) WithMysqlConfig

func (d *DefaultSagaOrchestratorRegistration) WithMysqlConfig(host, username, password, dbName string) orchestrator.SagaOrchestratorRegistration

type DefaultSagaOrchestratorRegistry

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

func (*DefaultSagaOrchestratorRegistry) Start

func (d *DefaultSagaOrchestratorRegistry) Start(sagaId string, data []byte) error

type DefaultSagaParticipantRegistry

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

func (*DefaultSagaParticipantRegistry) AddCompensationProcessor

func (d *DefaultSagaParticipantRegistry) AddCompensationProcessor(compensationType string, processor participant.Processor) participant.SagaParticipantRegistration

func (*DefaultSagaParticipantRegistry) AddTransactionProcessor

func (d *DefaultSagaParticipantRegistry) AddTransactionProcessor(transactionType string, processor participant.Processor) participant.SagaParticipantRegistration

func (*DefaultSagaParticipantRegistry) ListenTo

func (*DefaultSagaParticipantRegistry) Register

func (d *DefaultSagaParticipantRegistry) Register() error

func (*DefaultSagaParticipantRegistry) WithKafkaConfig

type SagaOrchestrator

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

type SagaWorkflowEvent

type SagaWorkflowEvent struct {
	Transaction  orchestrator.Transaction
	Compensation orchestrator.Compensation
	Deadline     int //in seconds
}

type TransactionProcessor

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL