Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type AuditSendorConfig ¶
type AuditSendorConfig struct {
Brokers []string `toml:"brokers" env:"MAUDIT_KAFKA_BROKERS" envSeparator:","`
Topic string `toml:"topic" env:"MAUDIT_KAFKA_TOPIC"`
}
consumer kakfa的配置 有 maudit负责这定义
func LoadConfigFromEnv ¶
func LoadConfigFromEnv() (*AuditSendorConfig, error)
func NewAuditSendorConfig ¶
func NewAuditSendorConfig() *AuditSendorConfig
func (*AuditSendorConfig) GetWriter ¶
func (k *AuditSendorConfig) GetWriter() *kafka.Writer
type OperateAuditClient ¶
type OperateAuditClient struct {
// contains filtered or unexported fields
}
func NewOperateAuditClient ¶
func NewOperateAuditClient(service string, kafka *kafka.Writer) *OperateAuditClient
func (*OperateAuditClient) Filter ¶
func (o *OperateAuditClient) Filter( req *restful.Request, w *restful.Response, next *restful.FilterChain)
Source Files
Click to show internal directories.
Click to hide internal directories.