Versions in this module Expand all Collapse all v0 v0.0.3 Aug 26, 2024 Changes in this version + const DriverTypeAliMns + const DriverTypeAliyunMq + const DriverTypeRedis + const DriverTypeRocketMq + func Register(driverType string, driver Instance) + type Instance func(diName string) Queue + type Queue interface + AckMsg func(ctx context.Context, key string, token string) (bool, error) + BatchEnqueue func(ctx context.Context, key string, messages []string) (bool, error) + Dequeue func(ctx context.Context, key string) (message string, tag string, token string, dequeueCount int64, err error) + Enqueue func(ctx context.Context, key string, message string) (bool, error) + func GetQueue(diName string, driverType string) Queue
Go to main page