Merge branch 'master' into upgrade_redis_client_to_v8

This commit is contained in:
Phil Kedy 2021-04-12 19:52:16 -04:00 committed by GitHub
commit 814145dca3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 2 additions and 1 deletions

View File

@ -18,7 +18,7 @@ Input binding:
```go
type InputBinding interface {
Init(metadata Metadata) error
Read(handler func(*ReadResponse) ([]byte, error) error
Read(handler func(*ReadResponse) ([]byte, error)) error
}
```

View File

@ -178,6 +178,7 @@ func (r *StateStore) newClient(m metadata) *redis.Client {
func (r *StateStore) newFailoverClient(m metadata) *redis.Client {
opts := &redis.FailoverOptions{
MasterName: r.metadata.sentinelMasterName,
Password: m.password,
SentinelAddrs: []string{r.metadata.host},
DB: defaultDB,
MaxRetries: m.maxRetries,