Documentation
¶
Index ¶
- func NewGCPPubSub(logger logger.Logger) bindings.InputOutputBinding
- type GCPAuthJSON
- type GCPPubSub
- func (g *GCPPubSub) Close() error
- func (g *GCPPubSub) GetComponentMetadata() (metadataInfo contribMetadata.MetadataMap)
- func (g *GCPPubSub) Init(ctx context.Context, metadata bindings.Metadata) error
- func (g *GCPPubSub) Invoke(ctx context.Context, req *bindings.InvokeRequest) (*bindings.InvokeResponse, error)
- func (g *GCPPubSub) Operations() []bindings.OperationKind
- func (g *GCPPubSub) Read(ctx context.Context, handler bindings.Handler) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewGCPPubSub ¶
func NewGCPPubSub(logger logger.Logger) bindings.InputOutputBinding
NewGCPPubSub returns a new GCPPubSub instance.
Types ¶
type GCPAuthJSON ¶ added in v1.16.0
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 is an input/output binding for GCP Pub Sub.
func (*GCPPubSub) GetComponentMetadata ¶ added in v1.11.0
func (g *GCPPubSub) GetComponentMetadata() (metadataInfo contribMetadata.MetadataMap)
GetComponentMetadata returns the metadata of the component.
func (*GCPPubSub) Invoke ¶
func (g *GCPPubSub) Invoke(ctx context.Context, req *bindings.InvokeRequest) (*bindings.InvokeResponse, error)
func (*GCPPubSub) Operations ¶
func (g *GCPPubSub) Operations() []bindings.OperationKind
Click to show internal directories.
Click to hide internal directories.