Documentation
¶
Index ¶
- func BuildSubscriptionID(consumerID, topic string) string
- func NewGCPPubSub(logger logger.Logger) pubsub.PubSub
- type GCPAuthJSON
- type GCPPubSub
- func (g *GCPPubSub) Close() error
- func (g *GCPPubSub) Features() []pubsub.Feature
- func (g *GCPPubSub) GetComponentMetadata() (metadataInfo contribMetadata.MetadataMap)
- func (g *GCPPubSub) Init(ctx context.Context, meta pubsub.Metadata) error
- func (g *GCPPubSub) Publish(ctx context.Context, req *pubsub.PublishRequest) error
- func (g *GCPPubSub) Subscribe(parentCtx context.Context, req pubsub.SubscribeRequest, handler pubsub.Handler) error
- type WhatNow
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BuildSubscriptionID ¶ added in v1.11.0
Types ¶
type GCPAuthJSON ¶ added in v1.1.1
type GCPAuthJSON struct {
ProjectID string `json:"project_id"`
PrivateKeyID string `json:"private_key_id"`
PrivateKey string `json:"private_key"`
ClientEmail string `json:"client_email"`
ClientID string `json:"client_id"`
AuthURI string `json:"auth_uri"`
TokenURI string `json:"token_uri"`
AuthProviderCertURL string `json:"auth_provider_x509_cert_url"`
ClientCertURL string `json:"client_x509_cert_url"`
Type string `json:"type"`
}
type GCPPubSub ¶
type GCPPubSub struct {
// contains filtered or unexported fields
}
GCPPubSub type.
func (*GCPPubSub) GetComponentMetadata ¶ added in v1.11.0
func (g *GCPPubSub) GetComponentMetadata() (metadataInfo contribMetadata.MetadataMap)
GetComponentMetadata returns the metadata of the component.
Click to show internal directories.
Click to hide internal directories.