Documentation
¶
Index ¶
- 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) Init(meta pubsub.Metadata) error
- func (g *GCPPubSub) Publish(ctx context.Context, req *pubsub.PublishRequest) error
- func (g *GCPPubSub) Subscribe(subscribeCtx context.Context, req pubsub.SubscribeRequest, ...) error
- type WhatNow
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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"`
}
Click to show internal directories.
Click to hide internal directories.