Documentation
¶
Overview ¶
Package "issue190" provides primitives to interact with the AsyncAPI specification.
Code generated by github.com/akmalsyrf/asyncapi-codegen version (devel) DO NOT EDIT.
Index ¶
Constants ¶
const ( // V2Issue190Msg1Path is the constant representing the 'V2Issue190Msg1' channel path. V2Issue190Msg1Path = "v2.issue190.msg1" // V2Issue190Msg2Path is the constant representing the 'V2Issue190Msg2' channel path. V2Issue190Msg2Path = "v2.issue190.msg2" )
const AsyncAPIVersion = "1.0.0"
AsyncAPIVersion is the version of the used AsyncAPI document
Variables ¶
var ChannelsPaths = []string{ V2Issue190Msg1Path, V2Issue190Msg2Path, }
ChannelsPaths is an array of all channels paths
Functions ¶
This section is empty.
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 V2Issue190Msg1Message ¶
type V2Issue190Msg1Message struct {
// Payload will be inserted in the message payload
Payload V2Issue190Msg1MessagePayload
}
V2Issue190Msg1Message is the message expected for 'V2Issue190Msg1Message' channel.
func NewV2Issue190Msg1Message ¶
func NewV2Issue190Msg1Message() V2Issue190Msg1Message
type V2Issue190Msg1MessagePayload ¶
type V2Issue190Msg1MessagePayload struct {
Data *V2Issue190Msg1MessagePayloadData `json:"data,omitempty"`
}
V2Issue190Msg1MessagePayload is a schema from the AsyncAPI specification required in messages
type V2Issue190Msg1MessagePayloadData ¶
type V2Issue190Msg1MessagePayloadData struct {
Hello *string `json:"hello,omitempty"`
Id *string `json:"id,omitempty"`
}
V2Issue190Msg1MessagePayloadData is a schema from the AsyncAPI specification required in messages
type V2Issue190Msg2Message ¶
type V2Issue190Msg2Message struct {
// Payload will be inserted in the message payload
Payload V2Issue190Msg2MessagePayload
}
V2Issue190Msg2Message is the message expected for 'V2Issue190Msg2Message' channel.
func NewV2Issue190Msg2Message ¶
func NewV2Issue190Msg2Message() V2Issue190Msg2Message
type V2Issue190Msg2MessagePayload ¶
type V2Issue190Msg2MessagePayload struct {
Data *V2Issue190Msg2MessagePayloadData `json:"data,omitempty"`
}
V2Issue190Msg2MessagePayload is a schema from the AsyncAPI specification required in messages
type V2Issue190Msg2MessagePayloadData ¶
type V2Issue190Msg2MessagePayloadData struct {
Bar *string `json:"bar,omitempty"`
Id *string `json:"id,omitempty"`
}
V2Issue190Msg2MessagePayloadData is a schema from the AsyncAPI specification required in messages
Source Files