| commit | 504b480d39b560297d7e6038db235beec7063346 | [log] [tgz] |
|---|---|---|
| author | Scott Baker <smbaker@gmail.com> | Fri Apr 17 10:12:20 2020 -0700 |
| committer | Scott Baker <smbaker@gmail.com> | Tue Apr 21 15:01:20 2020 -0700 |
| tree | a2d590efef9287023a7ab9e7b55dd7ec43a4d759 | |
| parent | 8ad299522ff380ab3960a517eaa73cca6e0a3a66 [diff] [blame] |
VOL-2861 replace uint64 kafka interadapter timestamps with timestamp proto Change-Id: I7bf9abbdb590ac193b1d769f46cddc01b0ac2efb
diff --git a/vendor/github.com/opencord/voltha-lib-go/v3/pkg/mocks/kafka/kafka_client.go b/vendor/github.com/opencord/voltha-lib-go/v3/pkg/mocks/kafka/kafka_client.go index 5922ce2..7c5508b 100644 --- a/vendor/github.com/opencord/voltha-lib-go/v3/pkg/mocks/kafka/kafka_client.go +++ b/vendor/github.com/opencord/voltha-lib-go/v3/pkg/mocks/kafka/kafka_client.go
@@ -18,6 +18,7 @@ import ( "fmt" "sync" + "time" "github.com/opencord/voltha-lib-go/v3/pkg/kafka" "github.com/opencord/voltha-lib-go/v3/pkg/log" @@ -111,7 +112,7 @@ return nil } -func (kc *KafkaClient) SubscribeForMetadata(_ func(fromTopic string, timestamp int64)) { +func (kc *KafkaClient) SubscribeForMetadata(_ func(fromTopic string, timestamp time.Time)) { logger.Debug("SubscribeForMetadata - unimplemented") }