pubsub

Documentation

Index

• type GCPPubSub
  • func NewGCPPubSub(logger logger.Logger) *GCPPubSub
  • func (g *GCPPubSub) Close() error
  • func (g *GCPPubSub) Init(metadata bindings.Metadata) error
  • 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

Types

type GCPPubSub

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

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

func NewGCPPubSub

func NewGCPPubSub(logger logger.Logger) *GCPPubSub

NewGCPPubSub returns a new GCPPubSub instance.

func (*GCPPubSub) Close

func (g *GCPPubSub) Close() error

func (*GCPPubSub) Init

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

Init parses metadata and creates a new Pub Sub client.

func (*GCPPubSub) Invoke

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

func (*GCPPubSub) Operations

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

func (*GCPPubSub) Read

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