sender

Documentation

Index

• type KafkaSender
  • func NewKafkaSender(config *config.KafkaConfig) (*KafkaSender, error)
  • func (d *KafkaSender) SendMessage(message *LogMessage) error
• type LogMessage
• type LogMessageSender

Types

type KafkaSender

type KafkaSender struct {
	Producer *kafka.Producer
}

func NewKafkaSender

func NewKafkaSender(config *config.KafkaConfig) (*KafkaSender, error)

func (*KafkaSender) SendMessage

func (d *KafkaSender) SendMessage(message *LogMessage) error

SendMessage 发送日志消息

type LogMessage

type LogMessage struct {
	Time    time.Time `json:"time"`
	Host    string    `json:"host"`
	AppId   string    `json:"app_id"`
	Content string    `json:"content"`
}

type LogMessageSender

type LogMessageSender interface {
	// SendMessage  发送日志
	SendMessage(message *LogMessage) error
}