broker

package

v1.16.21 Latest Latest Go to latest Published: Oct 21, 2026 License: Apache-2.0 Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Broker struct {
	// contains filtered or unexported fields
}

func New(t *testing.T) *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) 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