asyncapi

Documentation

Index

• Constants
• func AddReplyToSuffix(address string) string
• type LoggerWrapper
  • func (lw LoggerWrapper) Error(ctx context.Context, msg string, info ...extensions.LogInfo)
  • func (lw LoggerWrapper) Info(ctx context.Context, msg string, info ...extensions.LogInfo)
  • func (lw LoggerWrapper) Warning(ctx context.Context, msg string, info ...extensions.LogInfo)

Constants

const (
	// RandomSuffixSize is the suffix size used to generate a random replyTo channel
	RandomSuffixSize = 1024
)

Functions

func AddReplyToSuffix

func AddReplyToSuffix(address string) string

AddReplyToSuffix adds a random suffix to the replyTo channel name.

Types

type LoggerWrapper

type LoggerWrapper struct {
}

func (LoggerWrapper) Error

func (lw LoggerWrapper) Error(ctx context.Context, msg string, info ...extensions.LogInfo)

func (LoggerWrapper) Info

func (lw LoggerWrapper) Info(ctx context.Context, msg string, info ...extensions.LogInfo)

func (LoggerWrapper) Warning

func (lw LoggerWrapper) Warning(ctx context.Context, msg string, info ...extensions.LogInfo)