middleware

Documentation

Index

• func NewAuditSender(service string) restful.FilterFunction
• type AuditSenderConfig
  • func LoadConfigFromEnv() (*AuditSenderConfig, error)
  • func NewAuditSenderConfig() *AuditSenderConfig
  • func (k *AuditSenderConfig) GetWriter() *kafka.Writer
• type OperateAuditClient
  • func NewOperateAuditClient(service string, kafka *kafka.Writer) *OperateAuditClient
  • func (o *OperateAuditClient) Filter(req *restful.Request, w *restful.Response, next *restful.FilterChain)

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)