subscriber

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

type Option func(*options)

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

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

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

type RouteEvent struct {
	Route string
	*event.Event
}

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

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

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

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"`
}