discoverk8s

Documentation

Index

• func BuildWithOption(info meta.ServiceInfo, log *blog.Logger, cli *bk8s.Client, ps module.IPubsub, ...) module.IDiscover
• type Option
  • func WithBlacklist(lst []string) Option
  • func WithNamespace(ns string) Option
  • func WithSelectorTag(tag string) Option
  • func WithServicePortPairs(pairs []ServicePortPair) Option
  • func WithSyncServiceInterval(interval time.Duration) Option
• type Parm
• type ServicePortPair

Functions

func BuildWithOption

func BuildWithOption(info meta.ServiceInfo, log *blog.Logger, cli *bk8s.Client, ps module.IPubsub, opts ...Option) module.IDiscover

Types

type Option

type Option func(*Parm)

Option consul discover config wrapper

func WithBlacklist

func WithBlacklist(lst []string) Option

func WithNamespace

func WithNamespace(ns string) Option

func WithSelectorTag

func WithSelectorTag(tag string) Option

func WithServicePortPairs

func WithServicePortPairs(pairs []ServicePortPair) Option

用于描述服务开放的端口号

func WithSyncServiceInterval

func WithSyncServiceInterval(interval time.Duration) Option

WithSyncServiceInterval 修改config中的interval

type Parm

type Parm struct {
	// 同步节点信息间隔
	SyncServicesInterval time.Duration

	Namespace string
	Tag       string

	ServicePortLst []ServicePortPair

	Blacklist []string
}

type ServicePortPair

type ServicePortPair struct {
	Name string
	Port int
}