Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewAuditSender ¶
func NewAuditSender(service string) restful.FilterFunction
Types ¶
type AuditSenderConfig ¶
type AuditSenderConfig struct {
Borkers []string `toml:"brokers" env:"MAUDIT_KAFKA_BROKERS" envSeparator:","`
Topic string `toml:"topic" env:"MAUDIT_KAFKA_TOPIC"`
}
consumer kafka的配置 由maudit负责定义
func LoadConfigFromEnv ¶
func LoadConfigFromEnv() (*AuditSenderConfig, error)
func NewAuditSenderConfig ¶
func NewAuditSenderConfig() *AuditSenderConfig
func (*AuditSenderConfig) GetWriter ¶
func (k *AuditSenderConfig) 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.