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
diff --git a/pkg/kafka/client.go b/pkg/kafka/client.go
index d977e38..0d9e3a5 100755
--- a/pkg/kafka/client.go
+++ b/pkg/kafka/client.go
@@ -16,9 +16,9 @@
package kafka
import (
- "context"
- ca "github.com/opencord/voltha-protos/v3/go/inter_container"
"time"
+
+ ca "github.com/opencord/voltha-protos/v3/go/inter_container"
)
const (
@@ -61,15 +61,15 @@
// MsgClient represents the set of APIs a Kafka MsgClient must implement
type Client interface {
- Start(ctx context.Context) error
- Stop(ctx context.Context)
- CreateTopic(ctx context.Context, topic *Topic, numPartition int, repFactor int) error
- DeleteTopic(ctx context.Context, topic *Topic) error
- Subscribe(ctx context.Context, topic *Topic, kvArgs ...*KVArg) (<-chan *ca.InterContainerMessage, error)
- UnSubscribe(ctx context.Context, topic *Topic, ch <-chan *ca.InterContainerMessage) error
- SubscribeForMetadata(context.Context, func(fromTopic string, timestamp time.Time))
- Send(ctx context.Context, msg interface{}, topic *Topic, keys ...string) error
- SendLiveness(ctx context.Context) error
- EnableLivenessChannel(ctx context.Context, enable bool) chan bool
- EnableHealthinessChannel(ctx context.Context, enable bool) chan bool
+ Start() error
+ Stop()
+ CreateTopic(topic *Topic, numPartition int, repFactor int) error
+ DeleteTopic(topic *Topic) error
+ Subscribe(topic *Topic, kvArgs ...*KVArg) (<-chan *ca.InterContainerMessage, error)
+ UnSubscribe(topic *Topic, ch <-chan *ca.InterContainerMessage) error
+ SubscribeForMetadata(func(fromTopic string, timestamp time.Time))
+ Send(msg interface{}, topic *Topic, keys ...string) error
+ SendLiveness() error
+ EnableLivenessChannel(enable bool) chan bool
+ EnableHealthinessChannel(enable bool) chan bool
}