messaging

Documentation

Index

• Variables
• type MessagingProvider
• type SendAndReceiveResponse

Variables

var (
	TimeoutErr = errors.New("Timeout error")
)

Types

type MessagingProvider

type MessagingProvider interface {
	SendAndReceive(
		requestTopic string,
		responseTopic string,
		payload []byte,
		headers []byte,
	) (*SendAndReceiveResponse, error)
}

type SendAndReceiveResponse

type SendAndReceiveResponse struct {
	Payload []byte
	Headers []byte
}