issue131

Documentation

Overview

Package "issue131" 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 AppController
  • func NewAppController(bc extensions.BrokerController, options ...ControllerOption) (*AppController, error)
  • func (c *AppController) Close(ctx context.Context)
  • func (c *AppController) PublishV2Issue131Test(ctx context.Context, msg V2Issue131TestMessage) error
• 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 MessageWithCorrelationID
• type TestSchema
• type UserController
  • func NewUserController(bc extensions.BrokerController, options ...ControllerOption) (*UserController, error)
  • func (c *UserController) Close(ctx context.Context)
  • func (c *UserController) SubscribeAll(ctx context.Context, as UserSubscriber) error
  • func (c *UserController) SubscribeV2Issue131Test(ctx context.Context, ...) error
  • func (c *UserController) UnsubscribeAll(ctx context.Context)
  • func (c *UserController) UnsubscribeV2Issue131Test(ctx context.Context)
• type UserSubscriber
• type V2Issue131TestMessage
  • func NewV2Issue131TestMessage() V2Issue131TestMessage

Constants

const AsyncAPIVersion = "1.2.3"

AsyncAPIVersion is the version of the used AsyncAPI document

const (
	// V2Issue131TestPath is the constant representing the 'V2Issue131Test' channel path.
	V2Issue131TestPath = "v2.issue131.test"
)

Variables

var ChannelsPaths = []string{
	V2Issue131TestPath,
}

ChannelsPaths is an array of all channels paths

Types

type AppController

type AppController struct {
	// contains filtered or unexported fields
}

AppController is the structure that provides publishing capabilities to the developer and and connect the broker with the App

func NewAppController

func NewAppController(bc extensions.BrokerController, options ...ControllerOption) (*AppController, error)

NewAppController links the App to the broker

func (*AppController) Close

func (c *AppController) Close(ctx context.Context)

Close will clean up any existing resources on the controller

func (*AppController) PublishV2Issue131Test

func (c *AppController) PublishV2Issue131Test(
	ctx context.Context,
	msg V2Issue131TestMessage,
) error

PublishV2Issue131Test will publish messages to 'v2.issue131.test' channel

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 MessageWithCorrelationID

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

type TestSchema

type TestSchema struct {
	ArrayProp            []string `json:"ArrayProp,omitempty" validate:"omitempty,min=2,max=5,unique"`
	ConstProp            *string  `json:"ConstProp,omitempty" validate:"omitempty,eq=Canada"`
	EnumProp             *string  `json:"EnumProp,omitempty" validate:"omitempty,oneof=red amber green"`
	FloatProp            *float64 `json:"FloatProp,omitempty" validate:"omitempty,gte=2.5,lte=5.5"`
	IntegerExclusiveProp *int64   `json:"IntegerExclusiveProp,omitempty" validate:"omitempty,gt=2,lt=5"`
	IntegerProp          *int64   `json:"IntegerProp,omitempty" validate:"omitempty,gte=2,lte=5"`
	RequiredProp         string   `json:"RequiredProp"`
	StringProp           *string  `json:"StringProp,omitempty" validate:"omitempty,min=2,max=5"`
}

TestSchema is a schema from the AsyncAPI specification required in messages

type UserController

type UserController struct {
	// contains filtered or unexported fields
}

UserController is the structure that provides publishing capabilities to the developer and and connect the broker with the User

func NewUserController

func NewUserController(bc extensions.BrokerController, options ...ControllerOption) (*UserController, error)

NewUserController links the User to the broker

func (*UserController) Close

func (c *UserController) Close(ctx context.Context)

Close will clean up any existing resources on the controller

func (*UserController) SubscribeAll

func (c *UserController) SubscribeAll(ctx context.Context, as UserSubscriber) error

SubscribeAll will subscribe to channels without parameters on which the app is expecting messages. For channels with parameters, they should be subscribed independently.

func (*UserController) SubscribeV2Issue131Test

func (c *UserController) SubscribeV2Issue131Test(
	ctx context.Context,
	fn func(ctx context.Context, msg V2Issue131TestMessage) error,
) error

SubscribeV2Issue131Test will subscribe to new messages from 'v2.issue131.test' channel.

Callback function 'fn' will be called each time a new message is received.

func (*UserController) UnsubscribeAll

func (c *UserController) UnsubscribeAll(ctx context.Context)

UnsubscribeAll will unsubscribe all remaining subscribed channels

func (*UserController) UnsubscribeV2Issue131Test

func (c *UserController) UnsubscribeV2Issue131Test(ctx context.Context)

UnsubscribeV2Issue131Test will unsubscribe messages from 'v2.issue131.test' channel. A timeout can be set in context to avoid blocking operation, if needed.

type UserSubscriber

type UserSubscriber interface {
	// V2Issue131Test subscribes to messages placed on the 'v2.issue131.test' channel
	V2Issue131Test(ctx context.Context, msg V2Issue131TestMessage) error
}

UserSubscriber represents all handlers that are expecting messages for User

type V2Issue131TestMessage

type V2Issue131TestMessage struct {
	// Payload will be inserted in the message payload
	Payload TestSchema
}

V2Issue131TestMessage is the message expected for 'V2Issue131TestMessage' channel.

func NewV2Issue131TestMessage

func NewV2Issue131TestMessage() V2Issue131TestMessage