issue135

Documentation

Overview

Package "issue135" 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 GroupMessage
  • func NewGroupMessage() GroupMessage
• type InfoMessage
  • func NewInfoMessage() InfoMessage
• type MessageWithCorrelationID
• type ProjectMessage
  • func NewProjectMessage() ProjectMessage
• type ResourceMessage
  • func NewResourceMessage() ResourceMessage
• type StatusMessage
  • func NewStatusMessage() StatusMessage

Constants

const (
	// GroupPath is the constant representing the 'Group' channel path.
	GroupPath = "group"
	// InfoPath is the constant representing the 'Info' channel path.
	InfoPath = "info"
	// ProjectPath is the constant representing the 'Project' channel path.
	ProjectPath = "project"
	// ResourcePath is the constant representing the 'Resource' channel path.
	ResourcePath = "resource"
	// StatusPath is the constant representing the 'Status' channel path.
	StatusPath = "status"
)

const AsyncAPIVersion = "1.2.3"

AsyncAPIVersion is the version of the used AsyncAPI document

Variables

var ChannelsPaths = []string{
	GroupPath,
	InfoPath,
	ProjectPath,
	ResourcePath,
	StatusPath,
}

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 GroupMessage

type GroupMessage struct {
	// Payload will be inserted in the message payload
	Payload string
}

GroupMessage is the message expected for 'GroupMessage' channel.

func NewGroupMessage

func NewGroupMessage() GroupMessage

type InfoMessage

type InfoMessage struct {
	// Payload will be inserted in the message payload
	Payload string
}

InfoMessage is the message expected for 'InfoMessage' channel.

func NewInfoMessage

func NewInfoMessage() InfoMessage

type MessageWithCorrelationID

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

type ProjectMessage

type ProjectMessage struct {
	// Payload will be inserted in the message payload
	Payload string
}

ProjectMessage is the message expected for 'ProjectMessage' channel.

func NewProjectMessage

func NewProjectMessage() ProjectMessage

type ResourceMessage

type ResourceMessage struct {
	// Payload will be inserted in the message payload
	Payload string
}

ResourceMessage is the message expected for 'ResourceMessage' channel.

func NewResourceMessage

func NewResourceMessage() ResourceMessage

type StatusMessage

type StatusMessage struct {
	// Payload will be inserted in the message payload
	Payload string
}

StatusMessage is the message expected for 'StatusMessage' channel.

func NewStatusMessage

func NewStatusMessage() StatusMessage