subscriber

Documentation

Index

• func WithInitialHealth(health bool) func(*options)
• func WithListTopicSubscriptions(...) func(*options)
• type Option
• type Subscriber
  • func New(t *testing.T, fopts ...Option) *Subscriber
  • func (s *Subscriber) AssertBulkEventChanLen(t *testing.T, l int)
  • func (s *Subscriber) AssertEventChanLen(t *testing.T, l int)
  • func (s *Subscriber) Cleanup(t *testing.T)
  • func (s *Subscriber) ExpectPublishError(t *testing.T, ctx context.Context, daprd *daprd.Daprd, ...)
  • func (s *Subscriber) ExpectPublishNoReceive(t *testing.T, ctx context.Context, daprd *daprd.Daprd, ...)
  • func (s *Subscriber) ExpectPublishReceive(t *testing.T, ctx context.Context, daprd *daprd.Daprd, ...)
  • func (s *Subscriber) Port(t *testing.T) int
  • func (s *Subscriber) Receive(t *testing.T, ctx context.Context) *rtv1.TopicEventRequest
  • func (s *Subscriber) ReceiveBulk(t *testing.T, ctx context.Context) *rtv1.TopicEventBulkRequest
  • func (s *Subscriber) Run(t *testing.T, ctx context.Context)
  • func (s *Subscriber) SetHealth(healthy bool)

Functions

func WithInitialHealth

func WithInitialHealth(health bool) func(*options)

func WithListTopicSubscriptions

func WithListTopicSubscriptions(fn func(ctx context.Context, in *emptypb.Empty) (*rtv1.ListTopicSubscriptionsResponse, error)) func(*options)

Types

type Option

type Option func(*options)

type Subscriber

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

func New

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

func (*Subscriber) AssertBulkEventChanLen

func (s *Subscriber) AssertBulkEventChanLen(t *testing.T, l int)

func (*Subscriber) AssertEventChanLen

func (s *Subscriber) AssertEventChanLen(t *testing.T, l int)

func (*Subscriber) Cleanup

func (s *Subscriber) Cleanup(t *testing.T)

func (*Subscriber) ExpectPublishError

func (s *Subscriber) ExpectPublishError(t *testing.T, ctx context.Context, daprd *daprd.Daprd, req *rtv1.PublishEventRequest)

func (*Subscriber) ExpectPublishNoReceive

func (s *Subscriber) ExpectPublishNoReceive(t *testing.T, ctx context.Context, daprd *daprd.Daprd, req *rtv1.PublishEventRequest)

func (*Subscriber) ExpectPublishReceive

func (s *Subscriber) ExpectPublishReceive(t *testing.T, ctx context.Context, daprd *daprd.Daprd, req *rtv1.PublishEventRequest)

func (*Subscriber) Port

func (s *Subscriber) Port(t *testing.T) int

func (*Subscriber) Receive

func (s *Subscriber) Receive(t *testing.T, ctx context.Context) *rtv1.TopicEventRequest

func (*Subscriber) ReceiveBulk

func (s *Subscriber) ReceiveBulk(t *testing.T, ctx context.Context) *rtv1.TopicEventBulkRequest

func (*Subscriber) Run

func (s *Subscriber) Run(t *testing.T, ctx context.Context)

func (*Subscriber) SetHealth

func (s *Subscriber) SetHealth(healthy bool)