gcppubsub

Documentation

Index

• func NewClient(opts *cli.Options) (*pubsub.Client, error)
• func Read(opts *cli.Options) error
• func Relay(opts *cli.Options) error
• func Write(opts *cli.Options) error
• type GCPPubSub
  • func (g *GCPPubSub) Read() error
  • func (g *GCPPubSub) Write(ctx context.Context, value []byte) error

Functions

func NewClient

func NewClient(opts *cli.Options) (*pubsub.Client, error)

func Read

func Read(opts *cli.Options) error

func Relay

func Relay(opts *cli.Options) error

func Write

func Write(opts *cli.Options) error

Write is the entry point function for performing write operations in GCP PubSub.

This is where we verify that the passed args and flags combo makes sense, attempt to establish a connection, parse protobuf before finally attempting to perform the write.

Types

type GCPPubSub

type GCPPubSub struct {
	Options *cli.Options
	MsgDesc *desc.MessageDescriptor
	Client  *pubsub.Client
	// contains filtered or unexported fields
}

func (*GCPPubSub) Read

func (g *GCPPubSub) Read() error

func (*GCPPubSub) Write

func (g *GCPPubSub) Write(ctx context.Context, value []byte) error

Write is a wrapper for amqp Publish method. We wrap it so that we can mock it in tests, add logging etc.