requestreply

package
v0.33.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 13, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

Package "requestreply" provides primitives to interact with the AsyncAPI specification.

Code generated by github.com/lerenn/asyncapi-codegen version (devel) DO NOT EDIT.

Index

Constants

View Source 
const (
	// PingChannelPath is the constant representing the 'PingChannel' channel path.
	PingChannelPath = "issue130.ping"
	// PingWithIDChannelPath is the constant representing the 'PingWithIDChannel' channel path.
	PingWithIDChannelPath = "issue130.pingWithID"
	// PongChannelPath is the constant representing the 'PongChannel' channel path.
	PongChannelPath = "issue130.pong"
	// PongWithIDChannelPath is the constant representing the 'PongWithIDChannel' channel path.
	PongWithIDChannelPath = "issue130.pongWithID"
)
View Source 
const AsyncAPIVersion = ""

AsyncAPIVersion is the version of the used AsyncAPI document

Variables

View Source 
var ChannelsPaths = []string{
	PingChannelPath,
	PingWithIDChannelPath,
	PongChannelPath,
	PongWithIDChannelPath,
}

ChannelsPaths is an array of all channels paths

Functions

This section is empty.

Types

type AppController 

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

AppController is the structure that provides sending 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) PublishPongOnPongChannel 

func (c *AppController) PublishPongOnPongChannel(
	ctx context.Context,
	msg PongMessage,
) error

NOTE: for now, this only support the first message from AsyncAPI list. If you need support for other messages, please raise an issue.

func (*AppController) PublishPongWithIDOnPongWithIDChannel 

func (c *AppController) PublishPongWithIDOnPongWithIDChannel(
	ctx context.Context,
	msg PongWithIDMessage,
) error

NOTE: for now, this only support the first message from AsyncAPI list. If you need support for other messages, please raise an issue.

func (*AppController) ReplyToPingWithIDWithPongWithIDOnPongWithIDChannel 

func (c *AppController) ReplyToPingWithIDWithPongWithIDOnPongWithIDChannel(ctx context.Context, recvMsg PingWithIDMessage, fn func(replyMsg *PongWithIDMessage)) error

ReplyToPingWithIDWithPongWithIDOnPongWithIDChannel is a helper function to reply to a PingWithID message with a PongWithID message on PongWithID channel.

func (*AppController) ReplyToPingWithPongOnPongChannel 

func (c *AppController) ReplyToPingWithPongOnPongChannel(ctx context.Context, recvMsg PingMessage, fn func(replyMsg *PongMessage)) error

ReplyToPingWithPongOnPongChannel is a helper function to reply to a Ping message with a Pong message on Pong channel.

func (*AppController) SubscribeToAllChannels 

func (c *AppController) SubscribeToAllChannels(ctx context.Context, as AppSubscriber) error

SubscribeToAllChannels will receive messages from channels where channel has no parameter on which the app is expecting messages. For channels with parameters, they should be subscribed independently.

func (*AppController) SubscribeToPingFromPingChannel 

func (c *AppController) SubscribeToPingFromPingChannel(ctx context.Context, fn func(ctx context.Context, msg PingMessage)) error

SubscribeToPingFromPingChannel will receive Ping messages from Ping channel.

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

NOTE: for now, this only support the first message from AsyncAPI list.

NOTE: for now, this only support the first message from AsyncAPI list. If you need support for other messages, please raise an issue.

func (*AppController) SubscribeToPingWithIDFromPingWithIDChannel 

func (c *AppController) SubscribeToPingWithIDFromPingWithIDChannel(ctx context.Context, fn func(ctx context.Context, msg PingWithIDMessage)) error

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

NOTE: for now, this only support the first message from AsyncAPI list.

NOTE: for now, this only support the first message from AsyncAPI list. If you need support for other messages, please raise an issue.

func (*AppController) UnsubscribeFromAllChannels 

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

UnsubscribeFromAllChannels will stop the subscription of all remaining subscribed channels

func (*AppController) UnsubscribeFromPingFromPingChannel 

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

UnsubscribeFromPingFromPingChannel will stop the reception of Ping messages from Ping channel. A timeout can be set in context to avoid blocking operation, if needed.

func (*AppController) UnsubscribeFromPingWithIDFromPingWithIDChannel 

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

UnsubscribeFromPingWithIDFromPingWithIDChannel will stop the reception of PingWithID messages from PingWithID channel. A timeout can be set in context to avoid blocking operation, if needed.

type AppSubscriber 

type AppSubscriber interface {
	// PingReceivedFromPingChannel receive all Ping messages from Ping channel.
	PingReceivedFromPingChannel(ctx context.Context, msg PingMessage)

	// PingWithIDReceivedFromPingWithIDChannel receive all PingWithID messages from PingWithID channel.
	PingWithIDReceivedFromPingWithIDChannel(ctx context.Context, msg PingWithIDMessage)
}

AppSubscriber contains all handlers that are listening messages for App

type ControllerOption 

type ControllerOption func(controller *controller)

ControllerOption is the type of the options that can be passed when creating a new Controller

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 PingMessage 

type PingMessage struct {
	// Payload will be inserted in the message payload
	Payload struct {
		Event *string `json:"event"`
	}
}

PingMessage is the golang representation of the AsyncAPI message

func NewPingMessage 

func NewPingMessage() PingMessage

type PingWithIDMessage 

type PingWithIDMessage struct {
	// Headers will be used to fill the message headers
	Headers struct {
		// Description: Correlation ID set by user
		CorrelationId *string `json:"correlation_id"`
	}

	// Payload will be inserted in the message payload
	Payload struct {
		Event *string `json:"event"`
	}
}

PingWithIDMessage is the golang representation of the AsyncAPI message

func NewPingWithIDMessage 

func NewPingWithIDMessage() PingWithIDMessage

func (PingWithIDMessage) CorrelationID 

func (msg PingWithIDMessage) CorrelationID() string

CorrelationID will give the correlation ID of the message, based on AsyncAPI spec

func (*PingWithIDMessage) SetAsResponseFrom 

func (msg *PingWithIDMessage) SetAsResponseFrom(req MessageWithCorrelationID)

SetAsResponseFrom will correlate the message with the one passed in parameter. It will assign the 'req' message correlation ID to the message correlation ID, both specified in AsyncAPI spec.

func (*PingWithIDMessage) SetCorrelationID 

func (msg *PingWithIDMessage) SetCorrelationID(id string)

SetCorrelationID will set the correlation ID of the message, based on AsyncAPI spec

type PongMessage 

type PongMessage struct {
	// Payload will be inserted in the message payload
	Payload struct {
		Event *string `json:"event"`
	}
}

PongMessage is the golang representation of the AsyncAPI message

func NewPongMessage 

func NewPongMessage() PongMessage

type PongWithIDMessage 

type PongWithIDMessage struct {
	// Headers will be used to fill the message headers
	Headers struct {
		// Description: Correlation ID set by user
		CorrelationId *string `json:"correlation_id"`
	}

	// Payload will be inserted in the message payload
	Payload struct {
		Event *string `json:"event"`
	}
}

PongWithIDMessage is the golang representation of the AsyncAPI message

func NewPongWithIDMessage 

func NewPongWithIDMessage() PongWithIDMessage

func (PongWithIDMessage) CorrelationID 

func (msg PongWithIDMessage) CorrelationID() string

CorrelationID will give the correlation ID of the message, based on AsyncAPI spec

func (*PongWithIDMessage) SetAsResponseFrom 

func (msg *PongWithIDMessage) SetAsResponseFrom(req MessageWithCorrelationID)

SetAsResponseFrom will correlate the message with the one passed in parameter. It will assign the 'req' message correlation ID to the message correlation ID, both specified in AsyncAPI spec.

func (*PongWithIDMessage) SetCorrelationID 

func (msg *PongWithIDMessage) SetCorrelationID(id string)

SetCorrelationID will set the correlation ID of the message, based on AsyncAPI spec

type Suite 

type Suite struct {
	suite.Suite
	// contains filtered or unexported fields
}

func NewSuite 

func NewSuite(broker extensions.BrokerController) *Suite

func (*Suite) SetupTest 

func (suite *Suite) SetupTest()

func (*Suite) TearDownTest 

func (suite *Suite) TearDownTest()

func (*Suite) TestRequestReply 

func (suite *Suite) TestRequestReply()

func (*Suite) TestRequestReplyWithID 

func (suite *Suite) TestRequestReplyWithID()

type UserController 

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

UserController is the structure that provides sending 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) PublishPingOnPingChannel 

func (c *UserController) PublishPingOnPingChannel(
	ctx context.Context,
	msg PingMessage,
) error

PublishPingOnPingChannel will send a Ping message on Ping channel. NOTE: this won't wait for reply, use the normal version to get the reply or do the catching reply manually.

NOTE: for now, this only support the first message from AsyncAPI list. If you need support for other messages, please raise an issue.

func (*UserController) PublishPingWithIDOnPingWithIDChannel 

func (c *UserController) PublishPingWithIDOnPingWithIDChannel(
	ctx context.Context,
	msg PingWithIDMessage,
) error

PublishPingWithIDOnPingWithIDChannel will send a PingWithID message on PingWithID channel. NOTE: this won't wait for reply, use the normal version to get the reply or do the catching reply manually.

NOTE: for now, this only support the first message from AsyncAPI list. If you need support for other messages, please raise an issue.

func (*UserController) RequestPongOnPongChannelWithPingOnPingChannel 

func (c *UserController) RequestPongOnPongChannelWithPingOnPingChannel(
	ctx context.Context,
	msg PingMessage,
) (PongMessage, error)

func (*UserController) RequestPongWithIDOnPongWithIDChannelWithPingWithIDOnPingWithIDChannel 

func (c *UserController) RequestPongWithIDOnPongWithIDChannelWithPingWithIDOnPingWithIDChannel(
	ctx context.Context,
	msg PingWithIDMessage,
) (PongWithIDMessage, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.