mq

Documentation

Index

• Constants
• func InitConsumer(ctx context.Context, redisClient *redis.Client, logger *zap.Logger, ...) (*redisqueue.Consumer, error)
• func InitProducer(ctx context.Context, client *redis.Client) (*redisqueue.Producer, error)

Constants

const (
	PushMessageStreamKey = "push_message_stream"
	PushMessageGroupKey  = "push_message_group"
)

Functions

func InitConsumer

func InitConsumer(
	ctx context.Context,
	redisClient *redis.Client,
	logger *zap.Logger,
	stream, group string,
	consumerFunc redisqueue.ConsumerFunc,
) (*redisqueue.Consumer, error)

func InitProducer

func InitProducer(ctx context.Context, client *redis.Client) (*redisqueue.Producer, error)