subscriber

Documentation

Index

• type Option
  • func WithBulkRoutes(routes ...string) Option
  • func WithHandlerFunc(path string, fn http.HandlerFunc) Option
  • func WithRoutes(routes ...string) Option
• type PublishBulkRequest
• type PublishBulkRequestEntry
• type PublishRequest
• type RouteEvent
• type Subscriber
  • func New(t *testing.T, fopts ...Option) *Subscriber
  • 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, req PublishRequest)
  • func (s *Subscriber) ExpectPublishNoReceive(t *testing.T, ctx context.Context, req PublishRequest)
  • func (s *Subscriber) ExpectPublishReceive(t *testing.T, ctx context.Context, req PublishRequest)
  • func (s *Subscriber) Port() int
  • func (s *Subscriber) Publish(t *testing.T, ctx context.Context, req PublishRequest)
  • func (s *Subscriber) PublishBulk(t *testing.T, ctx context.Context, req PublishBulkRequest)
  • func (s *Subscriber) Receive(t *testing.T, ctx context.Context) *RouteEvent
  • func (s *Subscriber) ReceiveBulk(t *testing.T, ctx context.Context) *pubsub.BulkSubscribeEnvelope
  • func (s *Subscriber) Run(t *testing.T, ctx context.Context)

Types

type Option

type Option func(*options)

func WithBulkRoutes

func WithBulkRoutes(routes ...string) Option

func WithHandlerFunc

func WithHandlerFunc(path string, fn http.HandlerFunc) Option

func WithRoutes

func WithRoutes(routes ...string) Option

type PublishBulkRequest

type PublishBulkRequest struct {
	Daprd      *daprd.Daprd
	PubSubName string
	Topic      string
	Entries    []PublishBulkRequestEntry
}

type PublishBulkRequestEntry

type PublishBulkRequestEntry struct {
	EntryID     string `json:"entryId"`
	Event       string `json:"event"`
	ContentType string `json:"contentType,omitempty"`
}

type PublishRequest

type PublishRequest struct {
	Daprd           *daprd.Daprd
	PubSubName      string
	Topic           string
	Data            string
	DataContentType *string
}

type RouteEvent

type RouteEvent struct {
	Route string
	*event.Event
}

type Subscriber

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

func New

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

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, req PublishRequest)

func (*Subscriber) ExpectPublishNoReceive

func (s *Subscriber) ExpectPublishNoReceive(t *testing.T, ctx context.Context, req PublishRequest)

func (*Subscriber) ExpectPublishReceive

func (s *Subscriber) ExpectPublishReceive(t *testing.T, ctx context.Context, req PublishRequest)

func (*Subscriber) Port

func (s *Subscriber) Port() int

func (*Subscriber) Publish

func (s *Subscriber) Publish(t *testing.T, ctx context.Context, req PublishRequest)

func (*Subscriber) PublishBulk

func (s *Subscriber) PublishBulk(t *testing.T, ctx context.Context, req PublishBulkRequest)

func (*Subscriber) Receive

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

func (*Subscriber) ReceiveBulk

func (s *Subscriber) ReceiveBulk(t *testing.T, ctx context.Context) *pubsub.BulkSubscribeEnvelope

func (*Subscriber) Run

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