Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Option ¶
type Option func(*options)
Option is a function that configures the process.
func WithPausable ¶ added in v1.17.7
func WithPausable() Option
WithPausable opts the pluggable server in to the Pause/Resume RPCs. Default is non-pausable (returns codes.Unimplemented), matching the vast majority of pubsub components.
func WithPubSub ¶
func WithPullMessagesChannel ¶ added in v1.13.2
func WithPullMessagesChannel(reqCh chan<- *compv1pb.PullMessagesRequest, resCh <-chan *compv1pb.PullMessagesResponse) Option
func WithSocket ¶ added in v1.13.2
type PubSub ¶
type PubSub struct {
// contains filtered or unexported fields
}
PubSub is a pluggable pubsub component for Dapr.
func (*PubSub) IsPaused ¶ added in v1.17.7
IsPaused reports whether the pluggable server is currently in the paused state.
func (*PubSub) PauseCalled ¶ added in v1.17.7
PauseCalled reports how many times Pause was invoked on the pluggable server. Exposed for integration tests that assert the runtime's pause-and-drain shutdown path was exercised.
func (*PubSub) PauseStarted ¶ added in v1.17.7
func (p *PubSub) PauseStarted() <-chan struct{}
PauseStarted returns a channel closed the first time Pause is called.
func (*PubSub) SocketName ¶
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.