rpcconfig

Documentation

Index

• type Config
• type GroupPushConsumerConfig
  • func (s GroupPushConsumerConfig) GetGroupID() string
• type KafkaConfig
• type SinglePushConsumerConfig
  • func (s SinglePushConsumerConfig) GetGroupID() string

Types

type Config

type Config struct {
	zrpc.RpcServerConf
	SinglePushConsumer SinglePushConsumerConfig
	GroupPushConsumer  GroupPushConsumerConfig
	ImUserRpc          zrpc.RpcClientConf
	MsgPushRpc         zrpc.RpcClientConf
	Producer           KafkaConfig
}

type GroupPushConsumerConfig

type GroupPushConsumerConfig struct {
	xkafka.ProducerConfig
	GroupPushGroupID string `json:",optional"`
}

func (GroupPushConsumerConfig) GetGroupID

func (s GroupPushConsumerConfig) GetGroupID() string

type KafkaConfig

type KafkaConfig struct {
	SinglePush xkafka.ProducerConfig
	GroupPush  xkafka.ProducerConfig
}

type SinglePushConsumerConfig

type SinglePushConsumerConfig struct {
	xkafka.ProducerConfig
	SinglePushGroupID string `json:",optional"`
}

func (SinglePushConsumerConfig) GetGroupID

func (s SinglePushConsumerConfig) GetGroupID() string