pubsub

package

v1.5.2 Latest Latest Go to latest Published: Mar 25, 2022 License: MIT Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type GCPPubSub struct {
	// contains filtered or unexported fields
}

GCPPubSub is an input/output binding for GCP Pub Sub.

func NewGCPPubSub(logger logger.Logger) *GCPPubSub

NewGCPPubSub returns a new GCPPubSub instance.

func (g *GCPPubSub) Close() error

func (g *GCPPubSub) Init(metadata bindings.Metadata) error

Init parses metadata and creates a new Pub Sub client.

func (g *GCPPubSub) Invoke(req *bindings.InvokeRequest) (*bindings.InvokeResponse, error)

func (g *GCPPubSub) Operations() []bindings.OperationKind

func (g *GCPPubSub) Read(handler func(*bindings.ReadResponse) ([]byte, error)) error