Documentation
¶
Overview ¶
Package rabbitmq provides a complete API to work with RabbitMQ.
Specifications leveraged:
- Topic
Index ¶
- Constants
- type Config
- type Handler
- func (h *Handler) Close() error
- func (h *Handler) Config() integration.Config
- func (h *Handler) ConfigMap() map[string]any
- func (h *Handler) Init() error
- func (h *Handler) IsReady() bool
- func (h *Handler) ListActivities() []string
- func (h *Handler) ListWorkflows() []string
- func (h *Handler) RegisterWithTopic(w worker.Worker, config topic.Config) error
- func (h *Handler) String() string
Constants ¶
const Integration string = "rabbitmq"
Integration is the string representation of the RabbitMQ integration.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
// Integration represents the common config shared across all integrations.
Integration integration.Config `json:"integration"`
}
Config is the configuration an end-user should set to configure the RabbitMQ integration.
type Handler ¶
type Handler struct {
// contains filtered or unexported fields
}
Handler handles the RabbitMQ integration and gives access to related workflows and activities.
func (*Handler) Close ¶
Close closes the integration and the specifications registered by the end-user. An error is returned in case the Handler has already been closed.
func (*Handler) Config ¶ added in v0.12.0
func (h *Handler) Config() integration.Config
Config returns the common integration's Config, which is the Config shared by all integrations.
func (*Handler) ConfigMap ¶
ConfigMap transforms the configuration to a map, including a "specifications" key with the configuration for each specification configured.
func (*Handler) Init ¶
Init initializes the integration and specifications the end-user wants to use. An error is returned in case the Handler has already been initialized.
func (*Handler) IsReady ¶
IsReady returns if the integration is ready to be consumed by the end-user. The integration must be initialized and must not be closed. This also ensures the specifications leveraged are ready to be consumed. If one of them is not, the integration would not be ready.
func (*Handler) ListActivities ¶
ListActivities returns a sorted list of activities' name registered by the integration (and the specifications leveraged if applicable).
func (*Handler) ListWorkflows ¶
ListWorkflows returns a sorted list of workflows' name registered by the integration (and the specifications leveraged if applicable).
func (*Handler) RegisterWithTopic ¶
RegisterWithTopic registers the topic specification within the RabbitMQ integration. End-users will have access to workflows and activities exposed by the topic specification.
Source Files