pubsub

Documentation

Index

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

func GetSubscriptionsGRPC

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

func GetSubscriptionsHTTP

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