diff --git a/bindings/servicebusqueues/servicebusqueues.go b/bindings/servicebusqueues/servicebusqueues.go index 82fe68c88..cee8c1457 100644 --- a/bindings/servicebusqueues/servicebusqueues.go +++ b/bindings/servicebusqueues/servicebusqueues.go @@ -15,12 +15,12 @@ import ( ) const ( - corellationID = "corellationID" + correlationID = "correlationID" label = "label" id = "id" ) -// AzureServiceBusQueues is an input/outbput binding reading from and sending events to Azure Service Bus queues +// AzureServiceBusQueues is an input/output binding reading from and sending events to Azure Service Bus queues type AzureServiceBusQueues struct { metadata *serviceBusQueuesMetadata client *servicebus.Queue @@ -79,7 +79,7 @@ func (a *AzureServiceBusQueues) Write(req *bindings.WriteRequest) error { if val, ok := req.Metadata[id]; ok && val != "" { msg.ID = val } - if val, ok := req.Metadata[corellationID]; ok && val != "" { + if val, ok := req.Metadata[correlationID]; ok && val != "" { msg.CorrelationID = val } err := a.client.Send(ctx, msg) @@ -90,7 +90,7 @@ func (a *AzureServiceBusQueues) Read(handler func(*bindings.ReadResponse) error) var sbHandler servicebus.HandlerFunc = func(ctx context.Context, msg *servicebus.Message) error { err := handler(&bindings.ReadResponse{ Data: msg.Data, - Metadata: map[string]string{id: msg.ID, corellationID: msg.CorrelationID, label: msg.Label}, + Metadata: map[string]string{id: msg.ID, correlationID: msg.CorrelationID, label: msg.Label}, }) if err == nil { return msg.Complete(ctx) diff --git a/state/retry_test.go b/state/retry_test.go index f76d0ea90..81059251c 100644 --- a/state/retry_test.go +++ b/state/retry_test.go @@ -12,7 +12,7 @@ import ( "github.com/stretchr/testify/assert" ) -func TestRetriPolicies(t *testing.T) { +func TestRetryPolicies(t *testing.T) { t.Run("set with no options", func(t *testing.T) { counter := 0 SetWithRetries(func(req *SetRequest) error { diff --git a/state/state_store.go b/state/state_store.go index 760af1785..043c3254d 100644 --- a/state/state_store.go +++ b/state/state_store.go @@ -5,6 +5,7 @@ package state +// StateStore is an interface to perform operations on store type StateStore interface { Init(metadata Metadata) error Delete(req *DeleteRequest) error diff --git a/state/transactional_state_store.go b/state/transactional_state_store.go index 3598d38ad..f48943d3d 100644 --- a/state/transactional_state_store.go +++ b/state/transactional_state_store.go @@ -5,6 +5,7 @@ package state +// TransactionalStateStore is an interface for initialization and support multiple transactional requests type TransactionalStateStore interface { Init(metadata Metadata) error Multi(reqs []TransactionalRequest) error