forwarder

type Config struct {
	// ForwarderTopic is a topic on which the forwarder will be listening to enveloped messages to forward.
	// Defaults to `forwarder_topic`.
	ForwarderTopic string

	// Middlewares are used to decorate forwarder's handler function.
	Middlewares []message.HandlerMiddleware

	// CloseTimeout determines how long router should work for handlers when closing.
	CloseTimeout time.Duration

	// AckWhenCannotUnwrap enables acking of messages which cannot be unwrapped from an envelope.
	AckWhenCannotUnwrap bool

	// Router is a router used by the forwarder.
	// If not provided, a new router will be created.
	//
	// If router is provided, it's not necessary to call `Forwarder.Run()` if the router is started with `router.Run()`.
	Router *message.Router

	// Marshaler is used to deserialize envelopes received on ForwarderTopic.
	// It must match the Marshaler used by the decorated Publisher.
	// Defaults to DefaultMarshaler, which uses encoding/json.
	Marshaler Marshaler
}

type DefaultMarshaler struct{}

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

type Marshaler interface {
	Marshal(v any) ([]byte, error)
	Unmarshal(data []byte, v any) error
}

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

type PublisherConfig struct {
	// ForwarderTopic is a topic which the forwarder is listening to. Publisher will send enveloped messages to this topic.
	// Defaults to `forwarder_topic`.
	ForwarderTopic string

	// Marshaler is used to serialize envelopes sent to ForwarderTopic.
	// It must match the Marshaler used by the Forwarder consuming the topic.
	// Defaults to DefaultMarshaler, which uses encoding/json.
	Marshaler Marshaler
}