mq

package

v0.13.2 Latest Latest Go to latest Published: Sep 11, 2025 License: Apache-2.0 Imports: 1 Imported by: 3

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/skirrund/gcloud

Links

Open Source Insights

Documentation ¶

Index ¶

type ACKMode
type Consumer
type ConsumerOptions
type IClient
type Message
type NatsOpts
type SubscriptionType

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type ACKMode ¶

type ACKMode uint32

const (
	ACK_AUTO ACKMode = iota
	ACK_MANUAL
)

type Consumer ¶ added in v0.13.2

type Consumer interface {
	OnMessage(message Message) error
}

type ConsumerOptions ¶

type ConsumerOptions struct {
	Topic                 string
	SubscriptionName      string
	SubscriptionType      SubscriptionType
	MessageListener       Consumer
	ACKMode               ACKMode
	RetryTimes            uint32
	MaxMessageChannelSize uint32
	NatsOpts              NatsOpts
}

type IClient ¶ added in v0.5.0

type IClient interface {
	Send(msg *Message) error
	SendDelay(msg *Message, delay time.Duration) error
	SendDelayAt(msg *Message, delayAt time.Time) error
	SendAsync(msg *Message) error
	SendDelayAsync(msg *Message, delay time.Duration) error
	Subscribes(options ...ConsumerOptions)
	Subscribe(options ConsumerOptions)
	Close()
}

type Message ¶ added in v0.13.2

type Message struct {
	Topic           string
	Header          map[string]string
	Payload         []byte
	RedeliveryCount uint32
}

type NatsOpts ¶ added in v0.13.2

type NatsOpts struct {
	Stream string
}

type SubscriptionType ¶ added in v0.5.0

type SubscriptionType int

const (

	// Exclusive there can be only 1 consumer on the same topic with the same subscription name
	Exclusive SubscriptionType = iota

	// Shared subscription mode, multiple consumer will be able to use the same subscription name
	// and the messages will be dispatched according to
	// a round-robin rotation between the connected consumers
	Shared

	// Failover subscription mode, multiple consumer will be able to use the same subscription name
	// but only 1 consumer will receive the messages.
	// If that consumer disconnects, one of the other connected consumers will start receiving messages.
	Failover

	// KeyShared subscription mode, multiple consumer will be able to use the same
	// subscription and all messages with the same key will be dispatched to only one consumer
	KeyShared
)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL