configuration_command

Documentation

Index

• Constants
• func HandleChangePropertyCommand(commandMessage *axon_server.Command, ...) (*axon_utils.Error, error)
• type Projection
  • func RestoreProjection(aggregateIdentifier string, clientConnection *axon_utils.ClientConnection) *Projection
  • func (projection *Projection) Apply(event axon_utils.Event)
  • func (projection *Projection) GetAggregateState() axon_utils.AggregateState
• type PropertyChangedEvent
  • func (event *PropertyChangedEvent) ApplyTo(projectionWrapper interface{})

Constants

const AggregateIdentifier = "configuration-aggregate"

Functions

func HandleChangePropertyCommand

func HandleChangePropertyCommand(commandMessage *axon_server.Command, clientConnection *axon_utils.ClientConnection) (*axon_utils.Error, error)

Types

type Projection

type Projection struct {
	Configuration  map[string]string
	AggregateState axon_utils.AggregateState
}

func RestoreProjection

func RestoreProjection(aggregateIdentifier string, clientConnection *axon_utils.ClientConnection) *Projection

func (*Projection) Apply

func (projection *Projection) Apply(event axon_utils.Event)

func (*Projection) GetAggregateState

func (projection *Projection) GetAggregateState() axon_utils.AggregateState

type PropertyChangedEvent

type PropertyChangedEvent struct {
	grpc_example.PropertyChangedEvent
}

Redeclare event types, so that they can be extended with event handler methods.

func (*PropertyChangedEvent) ApplyTo

func (event *PropertyChangedEvent) ApplyTo(projectionWrapper interface{})