issue190

Documentation

Overview

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

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

Index

• Constants
• Variables
• type BarMessageFromFooChannel
  • func NewBarMessageFromFooChannel() BarMessageFromFooChannel
• type BarMessageFromFooChannelPayload
• type ControllerOption
  • func WithErrorHandler(handler extensions.ErrorHandler) ControllerOption
  • func WithLogger(logger extensions.Logger) ControllerOption
  • func WithMiddlewares(middlewares ...extensions.Middleware) ControllerOption
• type DataPropertyFromBarMessageFromFooChannelPayload
• type DataPropertyFromSayHelloMessageFromHelloChannelPayload
• type Error
  • func (e *Error) Error() string
• type MessageWithCorrelationID
• type SayHelloMessageFromHelloChannel
  • func NewSayHelloMessageFromHelloChannel() SayHelloMessageFromHelloChannel
• type SayHelloMessageFromHelloChannelPayload

Constants

const (
	// FooChannelPath is the constant representing the 'FooChannel' channel path.
	FooChannelPath = "v3.issue190.foo"
	// HelloChannelPath is the constant representing the 'HelloChannel' channel path.
	HelloChannelPath = "v3.issue190.hello"
)

const AsyncAPIVersion = "0.1.0"

AsyncAPIVersion is the version of the used AsyncAPI document

Variables

var ChannelsPaths = []string{
	FooChannelPath,
	HelloChannelPath,
}

ChannelsPaths is an array of all channels paths

Types

type BarMessageFromFooChannel

type BarMessageFromFooChannel struct {
	// Payload will be inserted in the message payload
	Payload BarMessageFromFooChannelPayload
}

BarMessageFromFooChannel is the message expected for 'BarMessageFromFooChannel' channel.

func NewBarMessageFromFooChannel

func NewBarMessageFromFooChannel() BarMessageFromFooChannel

type BarMessageFromFooChannelPayload

type BarMessageFromFooChannelPayload struct {
	Data *DataPropertyFromBarMessageFromFooChannelPayload `json:"data,omitempty"`
}

BarMessageFromFooChannelPayload 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 DataPropertyFromBarMessageFromFooChannelPayload

type DataPropertyFromBarMessageFromFooChannelPayload struct {
	Bar *string `json:"bar,omitempty"`
	Id  *string `json:"id,omitempty"`
}

DataPropertyFromBarMessageFromFooChannelPayload is a schema from the AsyncAPI specification required in messages

type DataPropertyFromSayHelloMessageFromHelloChannelPayload

type DataPropertyFromSayHelloMessageFromHelloChannelPayload struct {
	Hello *string `json:"hello,omitempty"`
	Id    *string `json:"id,omitempty"`
}

DataPropertyFromSayHelloMessageFromHelloChannelPayload is a schema from the AsyncAPI specification required in 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 SayHelloMessageFromHelloChannel

type SayHelloMessageFromHelloChannel struct {
	// Payload will be inserted in the message payload
	Payload SayHelloMessageFromHelloChannelPayload
}

SayHelloMessageFromHelloChannel is the message expected for 'SayHelloMessageFromHelloChannel' channel.

func NewSayHelloMessageFromHelloChannel

func NewSayHelloMessageFromHelloChannel() SayHelloMessageFromHelloChannel

type SayHelloMessageFromHelloChannelPayload

type SayHelloMessageFromHelloChannelPayload struct {
	Data *DataPropertyFromSayHelloMessageFromHelloChannelPayload `json:"data,omitempty"`
}

SayHelloMessageFromHelloChannelPayload is a schema from the AsyncAPI specification required in messages