Documentation ¶
Index ¶
- func NewDefaultSagaOrchestratorBuilder() orchestrator.SagaOrchestratorBuilder
- func NewDefaultSagaOrchestratorRegistration() orchestrator.SagaOrchestratorRegistration
- func NewDefaultSagaParticipantRegistry() participant.SagaParticipantRegistration
- type CompensationProcessor
- type DefaultSagaOrchestratorBuilder
- func (d *DefaultSagaOrchestratorBuilder) Add(transaction orchestrator.Transaction, compensation orchestrator.Compensation) orchestrator.SagaOrchestratorBuilder
- func (d *DefaultSagaOrchestratorBuilder) Build() SagaOrchestrator
- func (d *DefaultSagaOrchestratorBuilder) Name(name string) orchestrator.SagaOrchestratorBuilder
- func (d *DefaultSagaOrchestratorBuilder) SetSagaId(sagaId string) orchestrator.SagaOrchestratorBuilder
- func (d *DefaultSagaOrchestratorBuilder) WithDeadline(deadline int64) orchestrator.SagaOrchestratorBuilder
- type DefaultSagaOrchestratorRegistration
- func (d *DefaultSagaOrchestratorRegistration) AddSagaOrchestrator(saga SagaOrchestrator) orchestrator.SagaOrchestratorRegistration
- func (d *DefaultSagaOrchestratorRegistration) PublishTo(channel string) orchestrator.SagaOrchestratorRegistration
- func (d *DefaultSagaOrchestratorRegistration) Register() (orchestrator.SagaOrchestratorRegistry, error)
- func (d *DefaultSagaOrchestratorRegistration) WithKafkaConfig(brokerHosts []string) orchestrator.SagaOrchestratorRegistration
- func (d *DefaultSagaOrchestratorRegistration) WithMysqlConfig(host, username, password, dbName string) orchestrator.SagaOrchestratorRegistration
- type DefaultSagaOrchestratorRegistry
- type DefaultSagaParticipantRegistry
- func (d *DefaultSagaParticipantRegistry) AddCompensationProcessor(compensationType string, processor participant.Processor) participant.SagaParticipantRegistration
- func (d *DefaultSagaParticipantRegistry) AddTransactionProcessor(transactionType string, processor participant.Processor) participant.SagaParticipantRegistration
- func (d *DefaultSagaParticipantRegistry) ListenTo(channel string) participant.SagaParticipantRegistration
- func (d *DefaultSagaParticipantRegistry) Register() error
- func (d *DefaultSagaParticipantRegistry) WithKafkaConfig(brokerHosts []string) participant.SagaParticipantRegistration
- type SagaOrchestrator
- type SagaWorkflowEvent
- type TransactionProcessor
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 (d *DefaultSagaOrchestratorBuilder) Add(transaction orchestrator.Transaction, compensation orchestrator.Compensation) orchestrator.SagaOrchestratorBuilder
func (*DefaultSagaOrchestratorBuilder) Build ¶
func (d *DefaultSagaOrchestratorBuilder) Build() SagaOrchestrator
func (*DefaultSagaOrchestratorBuilder) Name ¶
func (d *DefaultSagaOrchestratorBuilder) Name(name string) orchestrator.SagaOrchestratorBuilder
func (*DefaultSagaOrchestratorBuilder) SetSagaId ¶
func (d *DefaultSagaOrchestratorBuilder) SetSagaId(sagaId string) orchestrator.SagaOrchestratorBuilder
func (*DefaultSagaOrchestratorBuilder) WithDeadline ¶
func (d *DefaultSagaOrchestratorBuilder) WithDeadline(deadline int64) orchestrator.SagaOrchestratorBuilder
type DefaultSagaOrchestratorRegistration ¶
type DefaultSagaOrchestratorRegistration struct {
// contains filtered or unexported fields
}
func (*DefaultSagaOrchestratorRegistration) AddSagaOrchestrator ¶
func (d *DefaultSagaOrchestratorRegistration) AddSagaOrchestrator(saga SagaOrchestrator) orchestrator.SagaOrchestratorRegistration
func (*DefaultSagaOrchestratorRegistration) PublishTo ¶
func (d *DefaultSagaOrchestratorRegistration) PublishTo(channel string) orchestrator.SagaOrchestratorRegistration
func (*DefaultSagaOrchestratorRegistration) Register ¶
func (d *DefaultSagaOrchestratorRegistration) Register() (orchestrator.SagaOrchestratorRegistry, error)
func (*DefaultSagaOrchestratorRegistration) WithKafkaConfig ¶
func (d *DefaultSagaOrchestratorRegistration) WithKafkaConfig(brokerHosts []string) orchestrator.SagaOrchestratorRegistration
func (*DefaultSagaOrchestratorRegistration) WithMysqlConfig ¶
func (d *DefaultSagaOrchestratorRegistration) WithMysqlConfig(host, username, password, dbName string) orchestrator.SagaOrchestratorRegistration
type DefaultSagaOrchestratorRegistry ¶
type DefaultSagaOrchestratorRegistry struct {
// contains filtered or unexported fields
}
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 (d *DefaultSagaParticipantRegistry) ListenTo(channel string) participant.SagaParticipantRegistration
func (*DefaultSagaParticipantRegistry) Register ¶
func (d *DefaultSagaParticipantRegistry) Register() error
func (*DefaultSagaParticipantRegistry) WithKafkaConfig ¶
func (d *DefaultSagaParticipantRegistry) WithKafkaConfig(brokerHosts []string) participant.SagaParticipantRegistration
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
}
Click to show internal directories.
Click to hide internal directories.