gcppubsub

Oct 5, 2021

Changes in this version

+ var ErrMissingCredentials = errors.New("Either --credentials-file or --credentials-json must be specified")

+ var ErrMissingGCPOptions = errors.New("GCP PubSub options cannot be nil")

+ var ErrMissingOptions = errors.New("options cannot be nil")

Jun 24, 2021

Changes in this version

type Relayer

+ ShutdownCtx context.Context

Jun 22, 2021

Changes in this version

+ func Dynamic(opts *cli.Options) error

Apr 1, 2021

Changes in this version

+ const RetryReadInterval

Jan 25, 2021

Changes in this version

+ type Relayer struct

+ Client *pubsub.Client

+ Options *cli.Options

+ RelayCh chan interface{}

+ func (r *Relayer) Relay() error

Sep 21, 2020

Changes in this version

+ func Relay(opts *cli.Options) error

Aug 2, 2020

Changes in this version

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

+ func Read(c *cli.Context) error

+ func Write(c *cli.Context) error

+ type GCPPubSub struct

+ Client *pubsub.Client

+ MsgDesc *desc.MessageDescriptor

+ Options *Options

+ func (g *GCPPubSub) Read() error

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

+ type Options struct

+ Ack bool

+ Convert string

+ Follow bool

+ InputData string

+ InputFile string

+ InputType string

+ LineNumbers bool

+ OutputType string

+ ProjectId string

+ ProtobufDir string

+ ProtobufRootMessage string

+ SubscriptionId string

+ TopicId string