issue175

package
v0.35.6 Latest Latest
Warning

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

Go to latest
Published: Apr 7, 2024 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Overview

Package "issue175" provides primitives to interact with the AsyncAPI specification.

Code generated by github.com/lerenn/asyncapi-codegen version (devel) DO NOT EDIT.

Index

Constants

View Source
const AsyncAPIVersion = ""

AsyncAPIVersion is the version of the used AsyncAPI document

Variables

This section is empty.

Functions

func CheckGeneration

func CheckGeneration()

CheckGeneration is just to test that the generation is correct.

Types

type ArrayPayloadSchema

type ArrayPayloadSchema []ArrayPayloadSchemaItem

ArrayPayloadSchema is a schema from the AsyncAPI specification required in messages

type ArrayPayloadSchemaItem

type ArrayPayloadSchemaItem struct {
	Age   *int64  `json:"age"`
	Email *string `json:"email"`
	Name  *string `json:"name"`
}

ArrayPayloadSchemaItem is a schema from the AsyncAPI specification required in messages

type ControllerOption

type ControllerOption func(controller *controller)

ControllerOption is the type of the options that can be passed when creating a new Controller

func WithErrorHandler

func WithErrorHandler(handler extensions.ErrorHandler) ControllerOption

WithErrorHandler attaches a errorhandler to handle errors from subscriber functions

func WithLogger

func WithLogger(logger extensions.Logger) ControllerOption

WithLogger attaches a logger to the controller

func WithMiddlewares

func WithMiddlewares(middlewares ...extensions.Middleware) ControllerOption

WithMiddlewares attaches middlewares that will be executed when sending or receiving messages

type Error

type Error struct {
	Channel string
	Err     error
}

func (*Error) Error

func (e *Error) Error() string

type MessageWithCorrelationID

type MessageWithCorrelationID interface {
	CorrelationID() string
	SetCorrelationID(id string)
}

type Type1Message

type Type1Message struct {
	// Payload will be inserted in the message payload
	Payload []Type1MessagePayloadItem
}

Type1Message is the message expected for 'Type1Message' channel.

func NewType1Message

func NewType1Message() Type1Message

type Type1MessagePayload

type Type1MessagePayload []Type1MessagePayloadItem

Type1MessagePayload is a schema from the AsyncAPI specification required in messages

type Type1MessagePayloadItem

type Type1MessagePayloadItem struct {
	Age   *int64  `json:"age"`
	Email *string `json:"email"`
	Name  *string `json:"name"`
}

Type1MessagePayloadItem is a schema from the AsyncAPI specification required in messages

type Type2Message

type Type2Message struct {
	// Payload will be inserted in the message payload
	Payload ArrayPayloadSchema
}

Type2Message is the message expected for 'Type2Message' channel.

func NewType2Message

func NewType2Message() Type2Message

type Type3Message

type Type3Message struct {
	// Payload will be inserted in the message payload
	Payload []string
}

Type3Message is the message expected for 'Type3Message' channel.

func NewType3Message

func NewType3Message() Type3Message

type Type3MessagePayload

type Type3MessagePayload []string

Type3MessagePayload is a schema from the AsyncAPI specification required in messages

Jump to

Keyboard shortcuts

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