如何构建简单的 Linkerd 命名器插件?
How to build simple Linkerd namer plugin?
我正在尝试 运行 使用一些自定义命名器插件进行 linkerd,但启动失败。
我得到了 io.l5d.fs 的源代码并切断了所有业务逻辑以获得一些带有硬编码地址的简约示例。
初始化器:
package com.consg
import io.buoyant.namer.NamerInitializer
class MyInitializer extends NamerInitializer {
val configClass = classOf[MyConfig]
override def configId = "com.consg.MyConfig"
}
object MyInitializer extends MyInitializer
配置:
package com.consg
import com.fasterxml.jackson.annotation.JsonIgnore
import com.twitter.finagle.{Path, Stack}
import io.buoyant.config.types.Directory
import io.buoyant.namer.NamerConfig
case class MyConfig(rootDir: Directory) extends NamerConfig {
@JsonIgnore
override def defaultPrefix: Path = Path.read("/my.namer")
@JsonIgnore
def newNamer(params: Stack.Params) = {
println("params: " + params)
new MyNamer(rootDir.path, prefix)
}
}
姓名:
package com.consg
import java.nio.file.{Path => NioPath}
import com.twitter.finagle._
import com.twitter.util._
import io.buoyant.namer.EnumeratingNamer
class MyNamer(rootDir: NioPath, prefix: Path) extends EnumeratingNamer {
def lookup(path: Path): Activity[NameTree[Name]] = {
println("lookup path: " + path)
val address1 = Address("127.0.0.1", 7777)
val addr = Addr.Bound(Set(address1), Addr.Metadata.empty)
val varr = Var.apply(addr)
Activity.value(NameTree.Leaf(Name.Bound(varr, path, path)))
}
override def getAllNames: Activity[Set[Path]] = {
println("getAllNames!")
Activity.value(Set.apply(Path.read("animal")))
}
}
build.sbt
name := "plug"
version := "1"
scalaVersion := "2.12.1"
libraryDependencies += "io.buoyant" % "linkerd-core_2.12" % "1.3.2" % "provided"
另外我在META-INF/services/io下暴露了"com.consg.MyInitializer"服务。buoyant.namer.NamerInitializer
然后我构建插件 jar 并将其放在插件 (linkerd-1.3.1/plugins) 下
现在我正在尝试 运行 linkerd 与配置:
namers:
- kind: com.consg.MyConfig
rootDir: disco
routers:
- protocol: http
dtab: /svc => /#/my.namer;
servers:
- port: 8080
结果我得到了:
com.fasterxml.jackson.databind.exc.InvalidTypeIdException: Could not resolve type id 'com.consg.MyConfig' into a subtype of [simple type, class io.buoyant.namer.NamerConfig]: known type ids = [NamerConfig, io.l5d.consul, io.l5d.curator, io.l5d.dnssrv, io.l5d.fs, io.l5d.k8s, io.l5d.k8s.external, io.l5d.k8s.ns, io.l5d.marathon, io.l5d.rewrite, io.l5d.serversets, io.l5d.zkLeader]
看来插件根本没有加载。需要一些帮助。
看来我的问题是未定义的 $L5D_HOME 环境变量。
设置好后,插件就启用了。
我正在尝试 运行 使用一些自定义命名器插件进行 linkerd,但启动失败。 我得到了 io.l5d.fs 的源代码并切断了所有业务逻辑以获得一些带有硬编码地址的简约示例。
初始化器:
package com.consg
import io.buoyant.namer.NamerInitializer
class MyInitializer extends NamerInitializer {
val configClass = classOf[MyConfig]
override def configId = "com.consg.MyConfig"
}
object MyInitializer extends MyInitializer
配置:
package com.consg
import com.fasterxml.jackson.annotation.JsonIgnore
import com.twitter.finagle.{Path, Stack}
import io.buoyant.config.types.Directory
import io.buoyant.namer.NamerConfig
case class MyConfig(rootDir: Directory) extends NamerConfig {
@JsonIgnore
override def defaultPrefix: Path = Path.read("/my.namer")
@JsonIgnore
def newNamer(params: Stack.Params) = {
println("params: " + params)
new MyNamer(rootDir.path, prefix)
}
}
姓名:
package com.consg
import java.nio.file.{Path => NioPath}
import com.twitter.finagle._
import com.twitter.util._
import io.buoyant.namer.EnumeratingNamer
class MyNamer(rootDir: NioPath, prefix: Path) extends EnumeratingNamer {
def lookup(path: Path): Activity[NameTree[Name]] = {
println("lookup path: " + path)
val address1 = Address("127.0.0.1", 7777)
val addr = Addr.Bound(Set(address1), Addr.Metadata.empty)
val varr = Var.apply(addr)
Activity.value(NameTree.Leaf(Name.Bound(varr, path, path)))
}
override def getAllNames: Activity[Set[Path]] = {
println("getAllNames!")
Activity.value(Set.apply(Path.read("animal")))
}
}
build.sbt
name := "plug"
version := "1"
scalaVersion := "2.12.1"
libraryDependencies += "io.buoyant" % "linkerd-core_2.12" % "1.3.2" % "provided"
另外我在META-INF/services/io下暴露了"com.consg.MyInitializer"服务。buoyant.namer.NamerInitializer
然后我构建插件 jar 并将其放在插件 (linkerd-1.3.1/plugins) 下
现在我正在尝试 运行 linkerd 与配置:
namers:
- kind: com.consg.MyConfig
rootDir: disco
routers:
- protocol: http
dtab: /svc => /#/my.namer;
servers:
- port: 8080
结果我得到了:
com.fasterxml.jackson.databind.exc.InvalidTypeIdException: Could not resolve type id 'com.consg.MyConfig' into a subtype of [simple type, class io.buoyant.namer.NamerConfig]: known type ids = [NamerConfig, io.l5d.consul, io.l5d.curator, io.l5d.dnssrv, io.l5d.fs, io.l5d.k8s, io.l5d.k8s.external, io.l5d.k8s.ns, io.l5d.marathon, io.l5d.rewrite, io.l5d.serversets, io.l5d.zkLeader]
看来插件根本没有加载。需要一些帮助。
看来我的问题是未定义的 $L5D_HOME 环境变量。 设置好后,插件就启用了。