Need support Amazon ElastiCache as broker or server
Author: nb150301Created Aug 25, 2026Updated Aug 25, 2026
AWS ElastiCache need custom CredentialsProviderContext example
import "github.com/redis/go-redis/v9"
...
opts.CredentialsProviderContext = func(ctx context.Context) (string, string, error) {
token, err := gen.generate(ctx)
if err != nil {
return "", "", err
}
return cfg.Username, token, nil
}
//...
client := redis.NewClient(opts)
But the func
func NewGR(cnf *config.Config, addrs []string, db int) iface.Broker { // Issue here, not support custom 'CredentialsProviderContext'
b := &BrokerGR{Broker: common.NewBroker(cnf)}
...Source: RichardKnop/machinery