pubsub

Documentation

Index

• type Option
  • func WithPubSub(pubsub pubsub.PubSub) Option
  • func WithPullMessagesChannel(ch <-chan *compv1pb.PullMessagesResponse) Option
  • func WithSocket(socket *socket.Socket) Option
• type PubSub
  • func New(t *testing.T, fopts ...Option) *PubSub
  • func (p *PubSub) Cleanup(t *testing.T)
  • func (p *PubSub) Run(t *testing.T, ctx context.Context)
  • func (p *PubSub) SocketName() string

Types

type Option

type Option func(*options)

Option is a function that configures the process.

func WithPubSub

func WithPubSub(pubsub pubsub.PubSub) Option

func WithPullMessagesChannel

func WithPullMessagesChannel(ch <-chan *compv1pb.PullMessagesResponse) Option

func WithSocket

func WithSocket(socket *socket.Socket) Option

type PubSub

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

PubSub is a pluggable pubsub component for Dapr.

func New

func New(t *testing.T, fopts ...Option) *PubSub

func (*PubSub) Cleanup

func (p *PubSub) Cleanup(t *testing.T)

func (*PubSub) Run

func (p *PubSub) Run(t *testing.T, ctx context.Context)

func (*PubSub) SocketName

func (p *PubSub) SocketName() string