Documentation
¶
Index ¶
- func WithInitialHealth(health bool) func(*options)
- func WithListTopicSubscriptions(...) func(*options)
- type Option
- type 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func WithInitialHealth ¶ added in v1.14.0
func WithInitialHealth(health bool) func(*options)
func WithListTopicSubscriptions ¶ added in v1.13.2
Types ¶
type Subscriber ¶
type Subscriber struct {
// contains filtered or unexported fields
}
func (*Subscriber) AssertBulkEventChanLen ¶ added in v1.13.2
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) Receive ¶
func (s *Subscriber) Receive(t *testing.T, ctx context.Context) *rtv1.TopicEventRequest
func (*Subscriber) ReceiveBulk ¶ added in v1.13.2
func (s *Subscriber) ReceiveBulk(t *testing.T, ctx context.Context) *rtv1.TopicEventBulkRequest
func (*Subscriber) SetHealth ¶ added in v1.14.0
func (s *Subscriber) SetHealth(healthy bool)
Source Files
Click to show internal directories.
Click to hide internal directories.