discov

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

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

type DefaultEtcdKvBuilder struct{}

type DefaultEtcdKvResolver struct{}

type EtcdKvBuilder interface {
	// BuildKey builds the etcd key according to the name and
	// the address of the service.
	BuildKey(srvName, srvAddr string) (key string)
	// BuildValue builds the etcd value according to the name
	// and the address of the service.
	BuildValue(srvName, srvAddr string) (value string)
}

type EtcdKvResolver interface {
	// GetKeyPrefixForSrv generates the key prefix for etcdResolver to watch.
	// srvName is the endpoint in the target that passed to the grpc Dial method.
	GetKeyPrefixForSrv(srvName string) (prefix string)
	// ResolveSrvAddr resolves the service address from the value corresponding
	// to the etcd key that be watched.
	ResolveSrvAddr(value []byte) (srvAddr string)
}

type EtcdSrvRecord interface {
	// Register registers the record to etcd.
	// This method should be called when the service starts.
	Register()
	// Unregister unregisters the record from etcd.
	// This method should be called when the service is closed.
	Unregister(context.Context) error
	// CatchRuntimeErrors catches runtime errors.
	// Since the EtcdSrvRecord spawns goroutines to keep heartbeat
	// to etcd after calling Register, some errors may occur at runtime.
	CatchRuntimeErrors() <-chan error
	// RegisterKvBuilder injects an EtcdKvBuilder to custom the
	// format of key and value to store.
	RegisterKvBuilder(EtcdKvBuilder)
}