diff --git a/internal/data/data_manager.go b/internal/data/data_manager.go index d807698fda..3510bed66c 100644 --- a/internal/data/data_manager.go +++ b/internal/data/data_manager.go @@ -201,7 +201,7 @@ func (dm *dataManager) GetMessageWithDataCached(ctx context.Context, msgID *ffty return msg, data, foundAllData, err } -// GetMessageData looks for all the data attached to the message, including caching. +// GetMessageDataCached looks for all the data attached to the message, including caching. // It only returns persistence errors. // For all cases where the data is not found (or the hashes mismatch) func (dm *dataManager) GetMessageDataCached(ctx context.Context, msg *core.Message, options ...CacheReadOption) (data core.DataArray, foundAll bool, err error) { diff --git a/internal/operations/manager.go b/internal/operations/manager.go index 1c9c1ae27d..b0e6b0d9f9 100644 --- a/internal/operations/manager.go +++ b/internal/operations/manager.go @@ -78,7 +78,7 @@ type operationsManager struct { cache cache.CInterface } -// SubmitBulkOperationUpdate implements Manager. +// SubmitBulkOperationUpdates implements Manager. func (om *operationsManager) SubmitBulkOperationUpdates(ctx context.Context, updates []*core.OperationUpdate) error { for _, update := range updates { errString := ""