Documentation
¶
Index ¶
- type Broker
- func (b *Broker) Cleanup(t *testing.T)
- func (b *Broker) DaprdOptions(t *testing.T, componentName string, opts ...daprd.Option) []daprd.Option
- func (b *Broker) IsPaused() bool
- func (b *Broker) PauseCalled() int64
- func (b *Broker) PauseStarted() <-chan struct{}
- func (b *Broker) PubSub() *pubsub.PubSub
- func (b *Broker) PublishHelloWorld(topic string) <-chan *compv1.PullMessagesRequest
- func (b *Broker) Run(t *testing.T, ctx context.Context)
- func (b *Broker) Socket() *socket.Socket
- type Option
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Broker ¶
type Broker struct {
// contains filtered or unexported fields
}
func (*Broker) DaprdOptions ¶
func (*Broker) IsPaused ¶ added in v1.17.7
IsPaused reports whether the pluggable server is currently in the paused state.
func (*Broker) PauseCalled ¶ added in v1.17.7
PauseCalled reports how many times the runtime invoked Pause on the pluggable server. Used by tests asserting the pause-and-drain shutdown path was exercised.
func (*Broker) PauseStarted ¶ added in v1.17.7
func (b *Broker) PauseStarted() <-chan struct{}
PauseStarted returns a channel that is closed the first time Pause is called. Tests use this to wait for the runtime's shutdown path to invoke Pause without polling.
func (*Broker) PublishHelloWorld ¶
func (b *Broker) PublishHelloWorld(topic string) <-chan *compv1.PullMessagesRequest
type Option ¶ added in v1.17.7
type Option func(*brokerOptions)
Option configures broker creation.
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 majority of pubsub components.
Source Files
Click to show internal directories.
Click to hide internal directories.