interceptor

Documentation

Index

• type AbstractCommandInterceptor
• type CommandContext
  • func (c CommandContext) GetAgenda() agenda.CinderellaEngineAgenda
  • func (c CommandContext) GetProcessEngineConfiguration() engine.ProcessEngineConfiguration
  • func (c CommandContext) GetQuery() *query.Query
  • func (c *CommandContext) SetAgenda(agenda agenda.CinderellaEngineAgenda)
  • func (c *CommandContext) SetProcessEngineConfiguration(processEngineConfiguration engine.ProcessEngineConfiguration)
  • func (c CommandContext) WithQuery(q *query.Query) engine.Context
• type CommandContextFactory
  • func (factory CommandContextFactory) CreateCommandContext() engine.Context
• type CommandContextInterceptor
  • func (commandContextInterceptor CommandContextInterceptor) Execute(command engine.Command) (interface{}, error)
  • func (commandContextInterceptor *CommandContextInterceptor) SetNext(next engine.Interceptor)
• type CommandInvoker
  • func (commandInvoker CommandInvoker) Execute(command engine.Command) (result interface{}, err error)
  • func (commandInvoker *CommandInvoker) SetNext(next engine.Interceptor)
• type TransactionContextInterceptor
  • func (transactionContextInterceptor TransactionContextInterceptor) Execute(command engine.Command) (value interface{}, err error)
  • func (transactionContextInterceptor *TransactionContextInterceptor) SetNext(next engine.Interceptor)

Types

type AbstractCommandInterceptor

type AbstractCommandInterceptor struct {
	Next engine.Interceptor
}

type CommandContext

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

func (CommandContext) GetAgenda

func (c CommandContext) GetAgenda() agenda.CinderellaEngineAgenda

func (CommandContext) GetProcessEngineConfiguration

func (c CommandContext) GetProcessEngineConfiguration() engine.ProcessEngineConfiguration

func (CommandContext) GetQuery

func (c CommandContext) GetQuery() *query.Query

func (*CommandContext) SetAgenda

func (c *CommandContext) SetAgenda(agenda agenda.CinderellaEngineAgenda)

func (*CommandContext) SetProcessEngineConfiguration

func (c *CommandContext) SetProcessEngineConfiguration(processEngineConfiguration engine.ProcessEngineConfiguration)

func (CommandContext) WithQuery

func (c CommandContext) WithQuery(q *query.Query) engine.Context

type CommandContextFactory

type CommandContextFactory struct {
	ProcessEngineConfiguration engine.ProcessEngineConfiguration
}

func (CommandContextFactory) CreateCommandContext

func (factory CommandContextFactory) CreateCommandContext() engine.Context

type CommandContextInterceptor

type CommandContextInterceptor struct {
	Next                  engine.Interceptor
	CommandContextFactory engine.ICommandContextFactory
}

func (CommandContextInterceptor) Execute

func (commandContextInterceptor CommandContextInterceptor) Execute(command engine.Command) (interface{}, error)

func (*CommandContextInterceptor) SetNext

func (commandContextInterceptor *CommandContextInterceptor) SetNext(next engine.Interceptor)

type CommandInvoker

type CommandInvoker struct {
	Next engine.Interceptor
}

func (CommandInvoker) Execute

func (commandInvoker CommandInvoker) Execute(command engine.Command) (result interface{}, err error)

func (*CommandInvoker) SetNext

func (commandInvoker *CommandInvoker) SetNext(next engine.Interceptor)

type TransactionContextInterceptor

type TransactionContextInterceptor struct {
	Next engine.Interceptor
}

func (TransactionContextInterceptor) Execute

func (transactionContextInterceptor TransactionContextInterceptor) Execute(command engine.Command) (value interface{}, err error)

func (*TransactionContextInterceptor) SetNext

func (transactionContextInterceptor *TransactionContextInterceptor) SetNext(next engine.Interceptor)