queue

package

Go to main page

Versions in this module

v1

v1.4.5

Nov 28, 2025

v1.4.4

Oct 15, 2025

v1.4.3

Sep 18, 2025

v1.4.2

Jul 28, 2025

v1.4.1

Dec 20, 2024

v1.4.0

Dec 17, 2024

Changes in this version

+ var ErrQueueNameRequired = errors.New("queue_name is required")

+ type QueueOption struct

+ ClusterRedis ClusterRedisQueueOption

+ ClusterRedisV7 ClusterRedisQueueOptionV7

+ MNS AliMNSClientOption

+ Provider cloud.Provider

+ Pulsar TencentCloudQueueOption

+ QueueName string

+ SQS cloud.AWSOption

+ StandaloneRedis StandaloneRedisQueueOption

+ StandaloneRedisV7 ClusterRedisQueueOptionV7

+ func (option QueueOption) Check() error

type QueueService

+ func GetQueueServiceWithOption(option QueueOption) (QueueService, error)

v1.3.7

Dec 11, 2024

Changes in this version

+ const AliMNSMessageDefaultPriority

+ const ContextKeyAliMNSLongPollingWaitSeconds

+ const ContextKeyAliMNSMessagePriority

+ var ErrAliMNSQueueNameEmpty = errors.New("mns queue name is empty")

+ type AliMNSClientOption struct

+ AccessKeyId string

+ AccessKeySecret string

+ CredentialType cloud.AliCloudCredentialType

+ EndPoint string

+ MaxConnsPerHost int

+ MessagePriority int

+ OIDCProviderArn string

+ OIDCTokenFilePath string

+ Policy string

+ QueueQPS int32

+ ReceiveMessageLongPollingWaitSeconds int

+ RoleArn string

+ RoleName string

+ RoleSessionExpiration int

+ RoleSessionName string

+ TimeoutSecond int64

+ func (option AliMNSClientOption) CheckAWS() error

+ func (option AliMNSClientOption) CheckAliCloudStorage() error

+ func (option AliMNSClientOption) CheckClusterRedis() error

+ func (option AliMNSClientOption) CheckStandaloneRedis() error

+ func (option AliMNSClientOption) CheckTencentCloud() error

+ func (option AliMNSClientOption) GetAssumeRegion() string

+ func (option AliMNSClientOption) GetAssumeRoleArn() string

+ func (option AliMNSClientOption) GetProvider() cloud.Provider

+ func (option AliMNSClientOption) GetRegion() string

+ func (option AliMNSClientOption) GetSecretID() string

+ func (option AliMNSClientOption) GetSecretKey() string

+ type AliMNSQueueMessage struct

+ func (message *AliMNSQueueMessage) Body() string

+ type AliMNSQueueService struct

+ func (service *AliMNSQueueService) AckMessage(ctx context.Context, message Message) error

+ func (service *AliMNSQueueService) Close() error

+ func (service *AliMNSQueueService) CreateConsumer() (Consumer, error)

+ func (service *AliMNSQueueService) CreateProducer() (Producer, error)

+ func (service *AliMNSQueueService) ReceiveMessages(ctx context.Context, maxCount int) ([]Message, error)

+ func (service *AliMNSQueueService) SendMessage(ctx context.Context, body string) error

v1.3.6

Sep 2, 2024

v1.3.5

Feb 27, 2024

v1.3.4

Jan 11, 2024

v1.3.3

Jan 2, 2024

Changes in this version

+ type ClusterRedisQueueOptionV7 struct

+ func (option ClusterRedisQueueOptionV7) GetProvider() cloud.Provider

+ type RedisQueueConsumerV7 struct

+ func (c *RedisQueueConsumerV7) AckMessage(ctx context.Context, message Message) error

+ func (c *RedisQueueConsumerV7) Close() error

+ func (c *RedisQueueConsumerV7) ReceiveMessages(ctx context.Context, maxCount int) ([]Message, error)

+ type RedisQueueMessageV7 struct

+ func (message *RedisQueueMessageV7) Body() string

+ type RedisQueueServiceV7 struct

+ func (service *RedisQueueServiceV7) Close() error

+ func (service *RedisQueueServiceV7) CreateConsumer() (Consumer, error)

+ func (service *RedisQueueServiceV7) CreateProducer() (Producer, error)

+ func (service *RedisQueueServiceV7) IfCreateMkStream(ctx context.Context) error

+ func (service *RedisQueueServiceV7) SendMessage(ctx context.Context, body string) error

+ type StandaloneRedisQueueOptionV7 struct

+ func (option StandaloneRedisQueueOptionV7) GetProvider() cloud.Provider

v1.3.2

Dec 27, 2023

v1.3.1

Nov 8, 2023

v1.3.0

Oct 26, 2023

Changes in this version

type ClusterRedisQueueOption

+ func (option ClusterRedisQueueOption) CheckAliCloudStorage() error

type StandaloneRedisQueueOption

+ func (option StandaloneRedisQueueOption) CheckAliCloudStorage() error

type TencentCloudQueueOption

+ func (option TencentCloudQueueOption) CheckAliCloudStorage() error

v1.2.2

Sep 14, 2023

v1.2.1

Sep 14, 2023

v1.2.0

Aug 23, 2023

Changes in this version

+ const DefaultGlobalIdle

+ const DefaultIdle

+ var ErrBaseRedisQueueNameEmpty = errors.New("standalone-redis queue name is empty")

+ var ErrClusterRedisQueueAddrsEmpty = errors.New("cluster-redis addrs is empty")

+ var ErrClusterRedisQueueConsumerGroupEmpty = errors.New("cluster-redis queue consumer group name is empty")

+ var ErrClusterRedisQueueNameEmpty = errors.New("cluster-redis queue name is empty")

+ var ErrStandaloneRedisQueueAddrEmpty = errors.New("standalone-redis addr is empty")

+ var ErrStandaloneRedisQueueConsumerGroupEmpty = errors.New("standalone-redis queue consumer group name is empty")

+ type BaseRedisQueueConsumer struct

+ func (c *BaseRedisQueueConsumer) AckMessage(ctx context.Context, message Message) error

+ func (c *BaseRedisQueueConsumer) Close() error

+ func (c *BaseRedisQueueConsumer) ReceiveMessages(ctx context.Context, maxCount int) ([]Message, error)

+ type BaseRedisQueueMessage struct

+ func (message *BaseRedisQueueMessage) Body() string

+ type BaseRedisQueueService struct

+ func (service *BaseRedisQueueService) Close() error

+ func (service *BaseRedisQueueService) CreateConsumer() (Consumer, error)

+ func (service *BaseRedisQueueService) CreateProducer() (Producer, error)

+ func (service *BaseRedisQueueService) IfCreateMkStream(ctx context.Context) error

+ func (service *BaseRedisQueueService) SendMessage(ctx context.Context, body string) error

+ type ClusterRedisQueueOption struct

+ Addrs []string

+ ConnMaxIdleTime *time.Duration

+ ConnMaxLifetime *time.Duration

+ ConsumerGroup string

+ DB *int

+ DialTimeout *time.Duration

+ GlobalIdle int

+ Idle int

+ MaxIdleConns *int

+ MaxRetries *int

+ MinIdleConns *int

+ Password string

+ PoolSize *int

+ ReadTimeout *time.Duration

+ WriteTimeout *time.Duration

+ func (option ClusterRedisQueueOption) CheckAWS() error

+ func (option ClusterRedisQueueOption) CheckClusterRedis() error

+ func (option ClusterRedisQueueOption) CheckStandaloneRedis() error

+ func (option ClusterRedisQueueOption) CheckTencentCloud() error

+ func (option ClusterRedisQueueOption) GetAssumeRegion() string

+ func (option ClusterRedisQueueOption) GetAssumeRoleArn() string

+ func (option ClusterRedisQueueOption) GetProvider() cloud.Provider

+ func (option ClusterRedisQueueOption) GetRegion() string

+ func (option ClusterRedisQueueOption) GetSecretID() string

+ func (option ClusterRedisQueueOption) GetSecretKey() string

type QueueService

+ func GetClusterRedisQueueService(queueName string, option cloud.Option) (QueueService, error)

+ func GetStandaloneRedisQueueService(queueName string, option cloud.Option) (QueueService, error)

+ type StandaloneRedisQueueOption struct

+ Addr string

+ ConnMaxIdleTime *time.Duration

+ ConnMaxLifetime *time.Duration

+ ConsumerGroup string

+ DB *int

+ DialTimeout *time.Duration

+ GlobalIdle int

+ Idle int

+ MaxIdleConns *int

+ MaxRetries *int

+ MinIdleConns *int

+ Password string

+ PoolSize *int

+ ReadTimeout *time.Duration

+ WriteTimeout *time.Duration

+ func (option StandaloneRedisQueueOption) CheckAWS() error

+ func (option StandaloneRedisQueueOption) CheckClusterRedis() error

+ func (option StandaloneRedisQueueOption) CheckStandaloneRedis() error

+ func (option StandaloneRedisQueueOption) CheckTencentCloud() error

+ func (option StandaloneRedisQueueOption) GetAssumeRegion() string

+ func (option StandaloneRedisQueueOption) GetAssumeRoleArn() string

+ func (option StandaloneRedisQueueOption) GetProvider() cloud.Provider

+ func (option StandaloneRedisQueueOption) GetRegion() string

+ func (option StandaloneRedisQueueOption) GetSecretID() string

+ func (option StandaloneRedisQueueOption) GetSecretKey() string

type TencentCloudQueueOption

+ func (option TencentCloudQueueOption) CheckClusterRedis() error

+ func (option TencentCloudQueueOption) CheckStandaloneRedis() error

v1.1.3

Jun 20, 2023

Changes in this version

type TencentCloudQueueOption

+ func (option TencentCloudQueueOption) GetAssumeRegion() string

+ func (option TencentCloudQueueOption) GetAssumeRoleArn() string

v1.1.2

Nov 12, 2021

v1.1.1

Nov 10, 2021

v1.1.0

Nov 5, 2021

Changes in this version

+ var ErrAWSQueueNameEmpty = errors.New("aws queue name is empty")

+ var ErrTencentCloudQueueServiceEmptySubscriptionName = errors.New("subscription name for tencentcloud queue service is empty")

+ var ErrTencentCloudQueueServiceEmptyTopic = errors.New("topic name for tencentcloud queue service is empty")

+ var ErrTencentCloudQueueServiceTokenEmpty = errors.New("token for tencentcloud queue service is empty")

+ var ErrTencentCloudQueueServiceURLEmpty = errors.New("url for tencentcloud queue service is empty")

+ func GenerateTopicAndSubName(topic, subscription string) string

+ type AWSQueueMessage struct

+ func (message *AWSQueueMessage) Body() string

+ type AWSQueueService struct

+ func (service *AWSQueueService) AckMessage(ctx context.Context, message Message) error

+ func (service *AWSQueueService) Close() error

+ func (service *AWSQueueService) CreateConsumer() (Consumer, error)

+ func (service *AWSQueueService) CreateProducer() (Producer, error)

+ func (service *AWSQueueService) ReceiveMessages(ctx context.Context, maxCount int) ([]Message, error)

+ func (service *AWSQueueService) SendMessage(ctx context.Context, body string) error

+ type Consumer interface

+ AckMessage func(ctx context.Context, message Message) error

+ Close func() error

+ ReceiveMessages func(ctx context.Context, maxCount int) ([]Message, error)

+ type Message interface

+ Body func() string

+ type Producer interface

+ Close func() error

+ SendMessage func(ctx context.Context, body string) error

+ type QueueService interface

+ Close func() error

+ CreateConsumer func() (Consumer, error)

+ CreateProducer func() (Producer, error)

+ func GetAWSQueueService(queueName string, option cloud.Option) (QueueService, error)

+ func GetQueueService(queueOrTopicSubName string, option cloud.Option) (QueueService, error)

+ func GetTencentCloudQueueService(topicSubName string, option cloud.Option) (QueueService, error)

+ type TencentCloudQueueConsumer struct

+ func (consumer *TencentCloudQueueConsumer) AckMessage(ctx context.Context, message Message) error

+ func (consumer *TencentCloudQueueConsumer) Close() error

+ func (consumer *TencentCloudQueueConsumer) ReceiveMessages(ctx context.Context, maxCount int) ([]Message, error)

+ type TencentCloudQueueMessage struct

+ func (message *TencentCloudQueueMessage) Body() string

+ type TencentCloudQueueOption struct

+ Token string

+ URL string

+ func (option TencentCloudQueueOption) CheckAWS() error

+ func (option TencentCloudQueueOption) CheckTencentCloud() error

+ func (option TencentCloudQueueOption) GetProvider() cloud.Provider

+ func (option TencentCloudQueueOption) GetRegion() string

+ func (option TencentCloudQueueOption) GetSecretID() string

+ func (option TencentCloudQueueOption) GetSecretKey() string

+ type TencentCloudQueueProducer struct

+ func (producer *TencentCloudQueueProducer) Close() error

+ func (producer *TencentCloudQueueProducer) SendMessage(ctx context.Context, body string) error

+ type TencentCloudQueueService struct

+ func (service *TencentCloudQueueService) Close() error

+ func (service *TencentCloudQueueService) CreateConsumer() (Consumer, error)

+ func (service *TencentCloudQueueService) CreateProducer() (Producer, error)

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