commit e6685957f4f7f1d9bc6c8aa9f193f2bbffdd54b6
author Scott Baker <scottb@opennetworking.org> Tue Jun 23 04:05:39 2020 +0000
committer Scott Baker <smbaker@gmail.com> Mon Jun 22 21:23:22 2020 -0700
tree d548b0ea1e9ad3788d5abc0068d6fc4b429f3118
parent 3c425fbeabed17ec8dad437678b4d105deaf2fbe

Revert "[VOL-3069]Pass Context in methods which are performing logging and need the context"

This reverts commit 3c425fbeabed17ec8dad437678b4d105deaf2fbe.

Reason for revert: Merging higher-priority patches first.

Change-Id: Iaa03a5977357dcd86de358d76e90cc54cd6b1fa5

pkg/mocks/kafka/endpoint_manager.go

diff --git a/pkg/mocks/kafka/endpoint_manager.go b/pkg/mocks/kafka/endpoint_manager.go
index 8b8e7f6..fedbebf 100644
--- a/pkg/mocks/kafka/endpoint_manager.go
+++ b/pkg/mocks/kafka/endpoint_manager.go
@@ -17,7 +17,6 @@
 package kafka
 
 import (
-	"context"
 	"github.com/opencord/voltha-lib-go/v3/pkg/kafka"
 )
 
@@ -28,16 +27,16 @@
 	return mock
 }
 
-func (em *EndpointManager) GetEndpoint(ctx context.Context, deviceID string, serviceType string) (kafka.Endpoint, error) {
+func (em *EndpointManager) GetEndpoint(deviceID string, serviceType string) (kafka.Endpoint, error) {
 	// TODO add mocks call and args
 	return kafka.Endpoint(serviceType), nil
 }
 
-func (em *EndpointManager) IsDeviceOwnedByService(ctx context.Context, deviceID string, serviceType string, replicaNumber int32) (bool, error) {
+func (em *EndpointManager) IsDeviceOwnedByService(deviceID string, serviceType string, replicaNumber int32) (bool, error) {
 	// TODO add mocks call and args
 	return true, nil
 }
 
-func (em *EndpointManager) GetReplicaAssignment(ctx context.Context, deviceID string, serviceType string) (kafka.ReplicaID, error) {
+func (em *EndpointManager) GetReplicaAssignment(deviceID string, serviceType string) (kafka.ReplicaID, error) {
 	return kafka.ReplicaID(1), nil
 }