pubsub

package

v1.17.7 Latest Latest Go to latest Published: May 15, 2026 License: Apache-2.0 Imports: 13 Imported by: 2

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/dapr/dapr

Links

Documentation ¶

Index ¶

Variables
func NewGRPCPubSub(l logger.Logger, socket string) *grpcPubSub
type Registry
- func NewRegistry() *Registry
- func (p *Registry) Create(name, version, logName string) (pubsub.PubSub, error)
- func (p *Registry) RegisterComponent(componentFactory func(logger.Logger) pubsub.PubSub, names ...string)

Constants ¶

This section is empty.

Variables ¶

View Source

var ErrPausableUnimplemented = errors.New("pluggable pubsub does not support Pause/Resume")

ErrPausableUnimplemented signals that the remote pluggable server does not implement the optional Pause/Resume RPCs. Runtime falls back to close-first shutdown silently in that case.

Functions ¶

func NewGRPCPubSub ¶ added in v1.9.0

func NewGRPCPubSub(l logger.Logger, socket string) *grpcPubSub

NewGRPCPubSub creates a new grpc pubsub using the given socket factory.

Types ¶

type Registry ¶

type Registry struct {
	Logger logger.Logger
	// contains filtered or unexported fields
}

var DefaultRegistry *Registry = NewRegistry()

DefaultRegistry is the singleton with the registry.

func NewRegistry ¶

func NewRegistry() *Registry

NewRegistry returns a new pub sub registry.

func (*Registry) Create ¶ added in v0.4.0

func (p *Registry) Create(name, version, logName string) (pubsub.PubSub, error)

Create instantiates a pub/sub based on `name`.

func (*Registry) RegisterComponent ¶ added in v1.9.0

func (p *Registry) RegisterComponent(componentFactory func(logger.Logger) pubsub.PubSub, names ...string)

RegisterComponent adds a new message bus to the registry.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL