gcppubsub

Mar 29, 2024

Changes in this version

+ func PublishRaw(ctx context.Context, topic *gpubsub.Topic, msg []byte) (string, error)

Mar 31, 2023

Changes in this version

type DoArgs

+ Synchronous bool

Mar 31, 2023

Changes in this version

+ func Do(ctx context.Context, args DoArgs) error

+ type DoArgs struct

+ AckDeadline time.Duration

+ MaxOutstandingMessages int

+ ProjectId string

+ ReceiveCallback func(context.Context, *pubsub.Message)

+ SubscriptionId string

+ TopicId string

Oct 4, 2022

Changes in this version

type Option

+ func WithMaxMessages(v int) Option

Sep 21, 2021

Changes in this version

type Option

+ func WithClient(v *pubsubv1.SubscriberClient) Option

Sep 21, 2021

Changes in this version

type Option

+ func WithNoExtend(v bool) Option

Nov 5, 2020

Changes in this version

+ func DelSubscription(project, name string) error

+ func GetPublisher(project, id string) (zpubsub.MultiPublisher, *gpubsub.Topic, error)

+ func GetSubscription(project, id string, topic *gpubsub.Topic, ackdeadline ...time.Duration) (*gpubsub.Subscription, error)

+ func GetTopic(project, id string) (*gpubsub.Topic, error)

+ type PubsubPublisher struct

+ func NewPubsubPublisher(projectId string, topicname string) (*PubsubPublisher, error)

+ func (p *PubsubPublisher) Publish(key string, data interface{}) error

+ func (p *PubsubPublisher) RawTopic() *gpubsub.Topic

+ func (p *PubsubPublisher) Test() error

Oct 22, 2020

Changes in this version

+ type Callback func(ctx interface{}, data []byte) error

+ type LengthySubscriber struct

+ func NewLengthySubscriber(ctx interface{}, project, subscription string, callback Callback, o ...Option) *LengthySubscriber

+ func (l *LengthySubscriber) Start(quit context.Context, done chan error) error

+ type Option interface

+ Apply func(*LengthySubscriber)

+ func WithDeadline(v int) Option

+ func WithLogger(v *log.Logger) Option