Documentation
¶
Overview ¶
Package events @service events @title Events @description Events service @internal false
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type ConsumeArgument ¶
type ConsumeArgument struct {
// ConsumerId
// @title Consumer id
// @description Consumer id
ConsumerId uint64 `json:"consumerId" validate:"required" message:"consumerId is invalid"`
// AggregateName
// @title Aggregate name
// @description Which aggregate name to be consumed
AggregateName string `json:"aggregateName" validate:"required" message:"aggregateName is invalid"`
// Offset
// @title Offset
// @description Offset of aggregate domain events, 0 is next of last consumed,
Offset uint64 `json:"offset" validate:"required" message:"offset is invalid"`
// Mode
// @title Consume mode
// @enum PULL,PUSH
// @description Consume mode
Mode string `json:"mode" validate:"oneof=PULL PUSH" message:"mode is invalid"`
}
ConsumeArgument @title Consume events argument @description Consume events argument
Click to show internal directories.
Click to hide internal directories.