service_discovery

type EtcdServiceDiscovery struct {
	// contains filtered or unexported fields
}

type ItermInfo struct {
	// contains filtered or unexported fields
}

type Operate int8

type ServiceDiscoveryConfig struct {
	EtcdAddr               []string
	ZkAddr                 []string
	CustomServiceDiscovery []string
	LocalServiceName       string
	Ip                     string
	Host                   string
}

type ServiceDiscoveryLog interface {
	Debugf(f string, args ...interface{})
	Infof(f string, args ...interface{})
	Warnf(f string, args ...interface{})
	Errorf(f string, args ...interface{})
}

type ServiceDiscoveryManager interface {
	// Service registe
	ServiceRegister(ctx context.Context) error

	// The ServiceHeartbeat method maintains the
	// heartbeat behavior of the service and registry
	ServiceHeartbeat(ctx context.Context) error

	// If you choose the service discovery method,
	// you must consume the chan include `ItermInfo` it returns.
	ServiceDiscovery(ctx context.Context, service string) (chan ItermInfo, error)

	// Close ServiceDiscoveryManager
	Close(ctx context.Context) error
}