dapr

Documentation

Index

• Variables
• func NewDaprPublisher(config DaprPublisherConfig) *daprPublisher
• func NewDaprSubscriberRegistry(config DaprSubscriberRegistryConfig) *daprSubscriberRegistry
• type DaprPublisherConfig
• type DaprSubscriberRegistryConfig

Variables

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")
)

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

type DaprPublisherConfig struct {
	Host   string
	Pubsub string
}

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.