Versions in this module Expand all Collapse all v1 v1.7.8 Nov 10, 2022 Changes in this version + type AckAllRequest struct + Channel string + ClientID string + WaitTimeSeconds int32 + func NewAckAllRequest() *AckAllRequest + func (req *AckAllRequest) SetChannel(channel string) *AckAllRequest + func (req *AckAllRequest) SetClientId(clientId string) *AckAllRequest + func (req *AckAllRequest) SetWaitTimeSeconds(wait int) *AckAllRequest + type AckAllResponse struct + AffectedMessages uint64 + Error string + IsError bool + RequestID string + type GrpcClient struct + func NewGrpcClient(ctx context.Context, op ...Option) (*GrpcClient, error) + func (g *GrpcClient) Close() error + func (g *GrpcClient) GlobalClientId() string + func (g *GrpcClient) Ping(ctx context.Context) (*pb.PingResult, error) + type Option interface + func WithAddress(host string, port int) Option + func WithAuthToken(token string) Option + func WithAutoReconnect(value bool) Option + func WithCertificate(certData, serverOverrideDomain string) Option + func WithCheckConnection(value bool) Option + func WithClientId(id string) Option + func WithConnectionNotificationFunc(fn func(msg string)) Option + func WithCredentials(certFile, serverOverrideDomain string) Option + func WithDefaultCacheTTL(ttl time.Duration) Option + func WithDefaultChannel(channel string) Option + func WithMaxReconnects(value int) Option + func WithReceiveBufferSize(size int) Option + func WithReconnectInterval(duration time.Duration) Option + type Options struct + func GetDefaultOptions() *Options + func (o *Options) Validate() error + type PollRequest struct + AutoAck bool + Channel string + MaxItems int + OnComplete func() + OnErrorFunc func(err error) + WaitTimeout int + func NewPollRequest() *PollRequest + func (p *PollRequest) SetAutoAck(autoAck bool) *PollRequest + func (p *PollRequest) SetChannel(channel string) *PollRequest + func (p *PollRequest) SetMaxItems(maxItems int) *PollRequest + func (p *PollRequest) SetOnComplete(onComplete func()) *PollRequest + func (p *PollRequest) SetOnErrorFunc(onErrorFunc func(err error)) *PollRequest + func (p *PollRequest) SetWaitTimeout(waitTimeout int) *PollRequest + type PollResponse struct + Messages []*QueueMessage + func (p *PollResponse) HasMessages() bool + func (r PollResponse) AckAll() error + func (r PollResponse) AckOffsets(offsets ...int64) error + func (r PollResponse) Close() error + func (r PollResponse) NAckAll() error + func (r PollResponse) NAckOffsets(offsets ...int64) error + func (r PollResponse) ReQueueAll(channel string) error + func (r PollResponse) ReQueueOffsets(channel string, offsets ...int64) error + type QueueInfo struct + Bytes int64 + Delivered int64 + FirstSequence int64 + LastSequence int64 + Messages int64 + Name string + Sent int64 + Subscribers int + Waiting int64 + type QueueMessage struct + func NewQueueMessage() *QueueMessage + func (qm *QueueMessage) Ack() error + func (qm *QueueMessage) AddTag(key, value string) *QueueMessage + func (qm *QueueMessage) NAck() error + func (qm *QueueMessage) ReQueue(channel string) error + func (qm *QueueMessage) SetBody(body []byte) *QueueMessage + func (qm *QueueMessage) SetChannel(channel string) *QueueMessage + func (qm *QueueMessage) SetClientId(clientId string) *QueueMessage + func (qm *QueueMessage) SetId(id string) *QueueMessage + func (qm *QueueMessage) SetMetadata(metadata string) *QueueMessage + func (qm *QueueMessage) SetPolicyDelaySeconds(sec int) *QueueMessage + func (qm *QueueMessage) SetPolicyExpirationSeconds(sec int) *QueueMessage + func (qm *QueueMessage) SetPolicyMaxReceiveCount(max int) *QueueMessage + func (qm *QueueMessage) SetPolicyMaxReceiveQueue(channel string) *QueueMessage + func (qm *QueueMessage) SetTags(tags map[string]string) *QueueMessage + func (r QueueMessage) AckAll() error + func (r QueueMessage) AckOffsets(offsets ...int64) error + func (r QueueMessage) Close() error + func (r QueueMessage) NAckAll() error + func (r QueueMessage) NAckOffsets(offsets ...int64) error + func (r QueueMessage) ReQueueAll(channel string) error + func (r QueueMessage) ReQueueOffsets(channel string, offsets ...int64) error + type QueuesInfo struct + Delivered int64 + Queues []*QueueInfo + Sent int64 + TotalQueues int + Waiting int64 + type QueuesStreamClient struct + func NewQueuesStreamClient(ctx context.Context, op ...Option) (*QueuesStreamClient, error) + func (q *QueuesStreamClient) AckAll(ctx context.Context, request *AckAllRequest) (*AckAllResponse, error) + func (q *QueuesStreamClient) Close() error + func (q *QueuesStreamClient) Poll(ctx context.Context, request *PollRequest) (*PollResponse, error) + func (q *QueuesStreamClient) QueuesInfo(ctx context.Context, filter string) (*QueuesInfo, error) + func (q *QueuesStreamClient) Send(ctx context.Context, messages ...*QueueMessage) (*SendResult, error) + type SendResult struct + Results []*pb.SendQueueMessageResult + type SubscribeRequest struct + AutoAck bool + Channels []string + MaxItems int + WaitTimeout int + func NewSubscribeRequest() *SubscribeRequest + func (s *SubscribeRequest) SetAutoAck(autoAck bool) *SubscribeRequest + func (s *SubscribeRequest) SetChannels(channels ...string) *SubscribeRequest + func (s *SubscribeRequest) SetMaxItems(maxItems int) *SubscribeRequest + func (s *SubscribeRequest) SetWaitTimeout(waitTimeout int) *SubscribeRequest + type SubscribeResponse struct + Messages []*QueueMessage + func NewSubscribeResponse() *SubscribeResponse + func (r SubscribeResponse) AckAll() error + func (r SubscribeResponse) AckOffsets(offsets ...int64) error + func (r SubscribeResponse) Close() error + func (r SubscribeResponse) NAckAll() error + func (r SubscribeResponse) NAckOffsets(offsets ...int64) error + func (r SubscribeResponse) ReQueueAll(channel string) error + func (r SubscribeResponse) ReQueueOffsets(channel string, offsets ...int64) error