xconf

Documentation

Index

• type Discovery
  • func (c Discovery) AsZrpcClientConf() zrpc.RpcClientConf
• type KfkConf
  • func (kc KfkConf) AsKqConf() kq.KqConf

Types

type Discovery

type Discovery struct {
	Hosts []string `json:"hosts"`
	Key   string   `json:"key"`
}

func (Discovery) AsZrpcClientConf

func (c Discovery) AsZrpcClientConf() zrpc.RpcClientConf

type KfkConf

type KfkConf struct {
	Brokers      []string `json:"brokers"`
	Topic        string   `json:"topic"`
	ConsumeGroup string   `json:"consume_group"`
	NumConsumers int      `json:"num_consumers"`
	Offset       string   `json:"offset"`
}

func (KfkConf) AsKqConf

func (kc KfkConf) AsKqConf() kq.KqConf