issue175

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
• func CheckGeneration()
• type ArrayPayloadSchema
• type ControllerOption
  • func WithErrorHandler(handler extensions.ErrorHandler) ControllerOption
  • func WithLogger(logger extensions.Logger) ControllerOption
  • func WithMiddlewares(middlewares ...extensions.Middleware) ControllerOption
• type Error
  • func (e *Error) Error() string
• type ItemFromArrayPayloadSchema
• type ItemFromType1MessagePayload
• type MessageWithCorrelationID
• type Type1Message
  • func NewType1Message() Type1Message
• type Type1MessagePayload
• type Type2Message
  • func NewType2Message() Type2Message
• type Type3Message
  • func NewType3Message() Type3Message
• type Type3MessagePayload

Constants

const AsyncAPIVersion = ""

AsyncAPIVersion is the version of the used AsyncAPI document

Functions

func CheckGeneration

func CheckGeneration()

CheckGeneration is just to test that the generation is correct.

Types

type ArrayPayloadSchema

type ArrayPayloadSchema []ItemFromArrayPayloadSchema

ArrayPayloadSchema 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 ItemFromArrayPayloadSchema

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

ItemFromArrayPayloadSchema is a schema from the AsyncAPI specification required in messages

type ItemFromType1MessagePayload

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

ItemFromType1MessagePayload is a schema from the AsyncAPI specification required in messages

type MessageWithCorrelationID

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

type Type1Message

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

Type1Message is the message expected for 'Type1Message' channel.

func NewType1Message

func NewType1Message() Type1Message

type Type1MessagePayload

type Type1MessagePayload []ItemFromType1MessagePayload

Type1MessagePayload 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