subscriber

Documentation

Index

• type BulkSubscribeJSON
• type Option
  • func WithBulkRoutes(routes ...string) Option
  • func WithHandlerFunc(path string, fn http.HandlerFunc) Option
  • func WithInitialHealth(health bool) Option
  • func WithProgrammaticSubscriptions(subs ...SubscriptionJSON) Option
  • func WithRoutes(routes ...string) Option
• type PublishBulkRequest
• type PublishBulkRequestEntry
• type PublishRequest
• type RouteEvent
• type RoutesJSON
• type RuleJSON
• type Subscriber
  • func New(t *testing.T, fopts ...Option) *Subscriber
  • func (s *Subscriber) AssertEventChanLen(t assert.TestingT, 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)
  • func (s *Subscriber) SetHealth(health bool)
• type SubscriptionJSON

Types

type BulkSubscribeJSON

type BulkSubscribeJSON struct {
	Enabled            bool  `json:"enabled"`
	MaxMessagesCount   int32 `json:"maxMessagesCount,omitempty"`
	MaxAwaitDurationMs int32 `json:"maxAwaitDurationMs,omitempty"`
}

type Option

type Option func(*options)

func WithBulkRoutes

func WithBulkRoutes(routes ...string) Option

func WithHandlerFunc

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

func WithInitialHealth

func WithInitialHealth(health bool) Option

func WithProgrammaticSubscriptions

func WithProgrammaticSubscriptions(subs ...SubscriptionJSON) 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 RoutesJSON

type RoutesJSON struct {
	Rules   []*RuleJSON `json:"rules,omitempty"`
	Default string      `json:"default,omitempty"`
}

type RuleJSON

type RuleJSON struct {
	Match string `json:"match"`
	Path  string `json:"path"`
}

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 assert.TestingT, 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)

func (*Subscriber) SetHealth

func (s *Subscriber) SetHealth(health bool)

type SubscriptionJSON

type SubscriptionJSON struct {
	PubsubName      string            `json:"pubsubname"`
	Topic           string            `json:"topic"`
	DeadLetterTopic string            `json:"deadLetterTopic"`
	Metadata        map[string]string `json:"metadata,omitempty"`
	Route           string            `json:"route"`  // Single route from v1alpha1
	Routes          RoutesJSON        `json:"routes"` // Multiple routes from v2alpha1
	BulkSubscribe   BulkSubscribeJSON `json:"bulkSubscribe,omitempty"`
}