grpcd

type Config struct {
	ListenType      string        `yaml:"ListenType,omitempty" mapstructure:"ListenType,omitempty"`
	ListenAddr      string        `yaml:"ListenAddr,omitempty" mapstructure:"ListenAddr,omitempty"`
	MonitorInterval util.Duration `yaml:"MonitorInterval,omitempty" mapstructure:"MonitorInterval,omitempty"`
}

type GRPCd struct {
	pb.UnimplementedSProxyServer

	Config  Config
	Logger  *zap.Logger
	Closing chan struct{}
	Closed  chan struct{}
	// contains filtered or unexported fields
}

type Pool struct {
	// contains filtered or unexported fields
}

type Reply struct {
	// contains filtered or unexported fields
}

type Statistics struct {
	KafkaReceived         uint64
	KafkaReceivedError    uint64
	InfluxdbReceived      uint64
	InfluxdbReceivedError uint64
}