Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrMessageForbidden = errors.New("message forbidden by access controls") ErrNoPubsubOrTopic = errors.New("no pubsub name or topic given") ErrDeliveryFailed = errors.New("delivery failed") ErrUnexpectedStatusCode = errors.New("unexpected status code") )
View Source
var (
ErrSubscriberNotFound = fmt.Errorf("subscriber not found")
)
Functions ¶
func NewDaprPublisher ¶
func NewDaprPublisher(config DaprPublisherConfig) *daprPublisher
NewDaprPublisher creates a new publisher instance.
func NewDaprSubscriberRegistry ¶
func NewDaprSubscriberRegistry(config DaprSubscriberRegistryConfig) *daprSubscriberRegistry
NewDaprSubscriberRegistry creates a new subscriber registry instance.
Types ¶
type DaprPublisherConfig ¶
DaprPublisherConfig is the configuration struct for a publisher.
type DaprSubscriberRegistryConfig ¶
type DaprSubscriberRegistryConfig struct {
App *fiber.App
Pubsub string
}
DaprSubscriberRegistryConfig is the configuration struct for a subscriber registry.
Source Files
Click to show internal directories.
Click to hide internal directories.