dapr
/
components-contrib
mirror of https://github.com/dapr/components-contrib.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Remove `context.TODO()`s with passed context. (#2650) 

Signed-off-by: joshvanl <me@joshvanl.dev>
This commit is contained in:
Josh van Leeuwen 2023-03-08 17:53:02 +00:00 committed by GitHub
parent b86ac6e8a4
commit 4be795d812
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
bindings/azure/blobstorage/blobstorage.go
View File

@ -92,9 +92,9 @@ func NewAzureBlobStorage(logger logger.Logger) bindings.OutputBinding {
}
// Init performs metadata parsing.
func (a *AzureBlobStorage) Init(_ context.Context, metadata bindings.Metadata) error {
func (a *AzureBlobStorage) Init(ctx context.Context, metadata bindings.Metadata) error {
var err error
a.containerClient, a.metadata, err = storageinternal.CreateContainerStorageClient(context.TODO(), a.logger, metadata.Properties)
a.containerClient, a.metadata, err = storageinternal.CreateContainerStorageClient(ctx, a.logger, metadata.Properties)
if err != nil {
return err
}

4
state/azure/blobstorage/blobstorage.go
View File

@ -68,9 +68,9 @@ type StateStore struct {
}
// Init the connection to blob storage, optionally creates a blob container if it doesn't exist.
func (r *StateStore) Init(_ context.Context, metadata state.Metadata) error {
func (r *StateStore) Init(ctx context.Context, metadata state.Metadata) error {
var err error
r.containerClient, _, err = storageinternal.CreateContainerStorageClient(context.TODO(), r.logger, metadata.Properties)
r.containerClient, _, err = storageinternal.CreateContainerStorageClient(ctx, r.logger, metadata.Properties)
if err != nil {
return err
}

2
state/mongodb/mongodb.go
View File

@ -155,7 +155,7 @@ func (m *MongoDB) Init(ctx context.Context, metadata state.Metadata) error {
// values immediately when the TTL value is reached.
// MongoDB TTL Indexes: https://docs.mongodb.com/manual/core/index-ttl/
// TTL fields are deleted at most 60 seconds after the TTL value is reached.
_, err = m.collection.Indexes().CreateOne(context.TODO(), mongo.IndexModel{
_, err = m.collection.Indexes().CreateOne(ctx, mongo.IndexModel{
Keys: bson.M{ttl: 1},
Options: options.Index().SetExpireAfterSeconds(0),
})