pubsub

Documentation

Index

• 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
  • func GetSubscriptionsHTTP(channel channel.AppChannel, log logger.Logger) []Subscription

Types

type Subscription

type Subscription struct {
	PubsubName string            `json:"pubsubname"`
	Topic      string            `json:"topic"`
	Route      string            `json:"route"`
	Metadata   map[string]string `json:"metadata"`
	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

func GetSubscriptionsHTTP

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