rpcconfig

Documentation

Index

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

Types

type Config

type Config struct {
	zrpc.RpcServerConf
	SinglePushConsumer    SinglePushConsumerConfig
	GroupPushConsumer     GroupPushConsumerConfig
	KickConnConsumerGroup KickConnConsumerConfig
	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
	KickConn   xkafka.ProducerConfig
}

type KickConnConsumerConfig

type KickConnConsumerConfig struct {
	xkafka.ProducerConfig
	KickConnGroupID string `json:",optional"`
}

func (KickConnConsumerConfig) GetGroupID

func (s KickConnConsumerConfig) GetGroupID() string

type SinglePushConsumerConfig

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

func (SinglePushConsumerConfig) GetGroupID

func (s SinglePushConsumerConfig) GetGroupID() string