This commit is contained in:
crusader 2018-04-26 18:01:49 +09:00
parent 14a9b28ed2
commit e6889911bb

View File

@ -2,7 +2,6 @@ package service
import ( import (
"reflect" "reflect"
"time"
cda "git.loafle.net/commons/di-go/annotation" cda "git.loafle.net/commons/di-go/annotation"
cdr "git.loafle.net/commons/di-go/registry" cdr "git.loafle.net/commons/di-go/registry"
@ -12,6 +11,7 @@ import (
// For annotation // For annotation
_ "git.loafle.net/overflow/commons-go/core/annotation" _ "git.loafle.net/overflow/commons-go/core/annotation"
"git.loafle.net/overflow/commons-go/core/util"
) )
var DiscoveryServiceType = reflect.TypeOf((*DiscoveryService)(nil)) var DiscoveryServiceType = reflect.TypeOf((*DiscoveryService)(nil))
@ -63,11 +63,11 @@ func (s *DiscoveryService) DiscoverService(requesterID string, port *ocmd.Port,
} }
// use by discovery // use by discovery
func (s *DiscoveryService) DiscoveryStart(requesterID string, t *time.Time) error { func (s *DiscoveryService) DiscoveryStart(requesterID string, t *util.Timestamp) error {
return s.ProbeClientService.Send("DiscoveryService.discoveryStart", requesterID, t) return s.ProbeClientService.Send("DiscoveryService.discoveryStart", requesterID, t)
} }
func (s *DiscoveryService) DiscoveryStop(requesterID string, t *time.Time) error { func (s *DiscoveryService) DiscoveryStop(requesterID string, t *util.Timestamp) error {
return s.ProbeClientService.Send("DiscoveryService.discoveryStop", requesterID, t) return s.ProbeClientService.Send("DiscoveryService.discoveryStop", requesterID, t)
} }