events

package
v0.0.0-...-3fba5e8 Latest Latest
Warning

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

Go to latest
Published: Aug 9, 2022 License: Apache-2.0 Imports: 5 Imported by: 0

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

func Service

func Service() (svc service.Service)

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

type Event

type Event struct {
}

func Consume

func Consume(ctx context.Context, argument ConsumeArgument) (result []*Event, err errors.CodeError)

Jump to

Keyboard shortcuts

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