Versions in this module Expand all Collapse all v0 v0.3.0 Jan 9, 2019 Changes in this version + func GenerateSubName(cs *eventduck.ChannelSubscriberSpec) string + func GenerateTopicName(channelNamespace, channelName string) string + func GetCredentials(ctx context.Context, client client.Client, secretRef *v1.ObjectReference, ...) (*google.Credentials, error) + type PubSubClient interface + CreateSubscription func(ctx context.Context, id string, topic PubSubTopic) (PubSubSubscription, error) + CreateTopic func(ctx context.Context, id string) (PubSubTopic, error) + SubscriptionInProject func(id, projectId string) PubSubSubscription + Topic func(id string) PubSubTopic + func GcpPubSubClientCreator(ctx context.Context, creds *google.Credentials, googleCloudProject string) (PubSubClient, error) + type PubSubClientCreator func(ctx context.Context, creds *google.Credentials, googleCloudProject string) (PubSubClient, error) + type PubSubMessage interface + Ack func() + Attributes func() map[string]string + Data func() []byte + ID func() string + Nack func() + type PubSubPublishResult interface + Get func(ctx context.Context) (serverID string, err error) + Ready func() <-chan struct{} + type PubSubSubscription interface + Delete func(ctx context.Context) error + Exists func(ctx context.Context) (bool, error) + ID func() string + Receive func(ctx context.Context, f func(context.Context, PubSubMessage)) error + type PubSubTopic interface + Delete func(ctx context.Context) error + Exists func(ctx context.Context) (bool, error) + ID func() string + Publish func(ctx context.Context, msg *pubsub.Message) PubSubPublishResult + Stop func()
Go to main page