Versions in this module Expand all Collapse all v0 v0.3.8 Jul 6, 2026 v0.3.2 May 13, 2026 Changes in this version + func DefaultBusConn() (*nats.Conn, error) + func GetBusURI(instanceName string) (string, bool) + func GetCluster(instanceName string) (*eventbusv1.ClusterConfig, bool) + func GetConsumer(instanceName string) (*eventbusv1.ConsumerConfig, bool) + func GetConsumerByName(durableName string) (*eventbusv1.ConsumerConfig, bool) + func GetNATSConn(instanceName string) (*nats.Conn, bool) + func GetOrDialNATSConn(instanceName string) (*nats.Conn, error) + func GetStream(instanceName string) (*eventbusv1.StreamConfig, bool) + func LookupBrokerInstance(name string) (*clusterModule, bool) + func LookupRuntime(name string) (providers.RuntimeBroker, providers.Connection, error) + func LookupRuntimeWithFallback(brokerRef string) (providers.RuntimeBroker, providers.Connection, error) + func NewClusterModule(instanceName string, cfg *eventbusv1.ClusterConfig) (sdk.ModuleInstance, error) + func NewConsumerModule(instanceName string, cfg *eventbusv1.ConsumerConfig) (sdk.ModuleInstance, error) + func NewStreamModule(instanceName string, cfg *eventbusv1.StreamConfig) (sdk.ModuleInstance, error) + func NewSubscribeTrigger(instanceName string, cfg *eventbusv1.ConsumerConfig, cb sdk.TriggerCallback) (sdk.ModuleInstance, error) + func RegisterBrokerInstance(name string, m *clusterModule) + func RegisterBusURI(instanceName, uri string) + func RegisterCluster(instanceName string, cfg *eventbusv1.ClusterConfig) + func RegisterConsumer(instanceName string, cfg *eventbusv1.ConsumerConfig) + func RegisterNATSConn(instanceName string, conn *nats.Conn) + func RegisterStream(instanceName string, cfg *eventbusv1.StreamConfig) + func UnregisterBrokerInstance(name string) + func UnregisterBusURI(instanceName string) + func UnregisterCluster(instanceName string) + func UnregisterConsumer(instanceName string) + func UnregisterNATSConn(instanceName string) + func UnregisterStream(instanceName string) + type ClusterModuleFactory struct + func (f *ClusterModuleFactory) CreateTypedModule(typeName, name string, config *anypb.Any) (sdk.ModuleInstance, error) + func (f *ClusterModuleFactory) TypedModuleTypes() []string + type ConsumerModuleFactory struct + func (f *ConsumerModuleFactory) CreateTypedModule(typeName, name string, config *anypb.Any) (sdk.ModuleInstance, error) + func (f *ConsumerModuleFactory) TypedModuleTypes() []string + type StreamModuleFactory struct + func (f *StreamModuleFactory) CreateTypedModule(typeName, name string, config *anypb.Any) (sdk.ModuleInstance, error) + func (f *StreamModuleFactory) TypedModuleTypes() []string + type SubscribeTriggerModuleFactory struct + func (f *SubscribeTriggerModuleFactory) CreateTypedModule(typeName, name string, config *anypb.Any) (sdk.ModuleInstance, error) + func (f *SubscribeTriggerModuleFactory) TypedModuleTypes() []string
Go to main page