pubsub

Documentation

Index

• Constants
• func NewCloudEvent(req *CloudEvent) (map[string]interface{}, error)
• type Adapter
• type CloudEvent
• type Expr
• type NotAllowedError
  • func (e NotAllowedError) Error() string
• type NotFoundError
  • func (e NotFoundError) Error() string
• type RoutesJSON
• type Rule
• type RuleJSON
• type Subscription
  • func DeclarativeKubernetes(client operatorv1pb.OperatorClient, log logger.Logger) []Subscription
  • func DeclarativeSelfHosted(componentsPath string, log logger.Logger) []Subscription
  • func GetSubscriptionsGRPC(channel runtimev1pb.AppCallbackClient, log logger.Logger) ([]Subscription, error)
  • func GetSubscriptionsHTTP(channel channel.AppChannel, log logger.Logger) ([]Subscription, error)
• type SubscriptionJSON

Constants

const (
	APIVersionV1alpha1 = "dapr.io/v1alpha1"
	APIVersionV2alpha1 = "dapr.io/v2alpha1"
)

Functions

func NewCloudEvent

func NewCloudEvent(req *CloudEvent) (map[string]interface{}, error)

NewCloudEvent encapusalates the creation of a Dapr cloudevent from an existing cloudevent or a raw payload.

Types

type Adapter

type Adapter interface {
	GetPubSub(pubsubName string) contrib_pubsub.PubSub
	Publish(req *contrib_pubsub.PublishRequest) error
}

Adapter is the interface for message buses.

type CloudEvent

type CloudEvent struct {
	ID              string
	Data            []byte
	Topic           string
	Pubsub          string
	DataContentType string
	TraceID         string
}

CloudEvent is a request object to create a Dapr compliant cloudevent.

type Expr

type Expr interface {
	Eval(variables map[string]interface{}) (interface{}, error)
}

type NotAllowedError

type NotAllowedError struct {
	Topic string
	ID    string
}

pubsub.NotAllowedError is returned by the runtime when publishing is forbidden.

func (NotAllowedError) Error

func (e NotAllowedError) Error() string

type NotFoundError

type NotFoundError struct {
	PubsubName string
}

pubsub.NotFoundError is returned by the runtime when the pubsub does not exist.

func (NotFoundError) Error

func (e NotFoundError) Error() string

type RoutesJSON

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

type Rule

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

type RuleJSON

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

type Subscription

type Subscription struct {
	PubsubName string            `json:"pubsubname"`
	Topic      string            `json:"topic"`
	Metadata   map[string]string `json:"metadata"`
	Rules      []*Rule           `json:"rules,omitempty"`
	Scopes     []string          `json:"scopes"`
}

func DeclarativeKubernetes

func DeclarativeKubernetes(client operatorv1pb.OperatorClient, log logger.Logger) []Subscription

DeclarativeKubernetes loads subscriptions from the operator when running in Kubernetes.

func DeclarativeSelfHosted

func DeclarativeSelfHosted(componentsPath string, log logger.Logger) []Subscription

DeclarativeSelfHosted loads subscriptions from the given components path.

func GetSubscriptionsGRPC

func GetSubscriptionsGRPC(channel runtimev1pb.AppCallbackClient, log logger.Logger) ([]Subscription, error)

func GetSubscriptionsHTTP

func GetSubscriptionsHTTP(channel channel.AppChannel, log logger.Logger) ([]Subscription, error)

type SubscriptionJSON

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