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 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 Issue169Msg1Message
  • func NewIssue169Msg1Message() Issue169Msg1Message
• type Issue169Msg1MessagePayload
• type Issue169Msg1MessagePayloadData
• type Issue169Msg2Message
  • func NewIssue169Msg2Message() Issue169Msg2Message
• type Issue169Msg2MessagePayload
• type Issue169Msg2MessagePayloadData
• type MessageWithCorrelationID

Constants

const (
	// Issue169Msg1Path is the constant representing the 'Issue169Msg1' channel path.
	Issue169Msg1Path = "issue169.msg1"
	// Issue169Msg2Path is the constant representing the 'Issue169Msg2' channel path.
	Issue169Msg2Path = "issue169.msg2"
)

const AsyncAPIVersion = "1.0.0"

AsyncAPIVersion is the version of the used AsyncAPI document

Variables

var ChannelsPaths = []string{
	Issue169Msg1Path,
	Issue169Msg2Path,
}

ChannelsPaths is an array of all channels paths

Types

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 Issue169Msg1Message

type Issue169Msg1Message struct {
	// Payload will be inserted in the message payload
	Payload Issue169Msg1MessagePayload
}

Issue169Msg1Message is the message expected for 'Issue169Msg1Message' channel.

func NewIssue169Msg1Message

func NewIssue169Msg1Message() Issue169Msg1Message

type Issue169Msg1MessagePayload

type Issue169Msg1MessagePayload struct {
	Data *Issue169Msg1MessagePayloadData `json:"data"`
}

Issue169Msg1MessagePayload is a schema from the AsyncAPI specification required in messages

type Issue169Msg1MessagePayloadData

type Issue169Msg1MessagePayloadData struct {
	Hello *string `json:"hello"`
	Id    *string `json:"id"`
}

Issue169Msg1MessagePayloadData is a schema from the AsyncAPI specification required in messages

type Issue169Msg2Message

type Issue169Msg2Message struct {
	// Payload will be inserted in the message payload
	Payload Issue169Msg2MessagePayload
}

Issue169Msg2Message is the message expected for 'Issue169Msg2Message' channel.

func NewIssue169Msg2Message

func NewIssue169Msg2Message() Issue169Msg2Message

type Issue169Msg2MessagePayload

type Issue169Msg2MessagePayload struct {
	Data *Issue169Msg2MessagePayloadData `json:"data"`
}

Issue169Msg2MessagePayload is a schema from the AsyncAPI specification required in messages

type Issue169Msg2MessagePayloadData

type Issue169Msg2MessagePayloadData struct {
	Bar *string `json:"bar"`
	Id  *string `json:"id"`
}

Issue169Msg2MessagePayloadData is a schema from the AsyncAPI specification required in messages

type MessageWithCorrelationID

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