logdumper

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

type ErrorResponse struct {
	Message ErrorResponseMessage `json:"message"`
}

type ErrorResponseMessage struct {
	Details string `json:"details"`
	Code    string `json:"code"`
}

type Event struct {
	Message    string `json:"message" required:"true" max:"256KB"`
	Time       uint64 `json:"time" required:"true"`
	Path       string `json:"path" required:"true"`
	Ip         string `json:"ip" required:"true"`
	HostName   string `json:"host_name" required:"true"`
	LineNumber uint64 `json:"line_no"`
}

type FileEvent struct {
	IsWindowsOsLog            bool
	WindowsOsLogChannelState  windowslog.WindowsOsLogChannelState
	FileState                 file.FileState
	LogEvent                  LogEventMessage
	Offset                    uint64 //读取后的offset
	ErrRes                    ErrorResponse
	ResponseStr               string
	ResStatusCode             int
	SuccessPreProcessLogEvent bool //before send to server,log need to be marshaled and compressed,it's flaged the status
}

type LogEventMessage struct {
	LogEvents  []Event `json:"log_events" required:"true" len:"20"`
	LogTopicId string  `json:"log_topic_id" required:"true"`
	LogGroupId string  `json:"log_group_id" required:"true"`
}

type MetaData_ struct {
	HasEventsTooOld bool `json:"has_events_too_old"`
	IsLogTooLarge   bool `json:"is_log_too_large"`
	TopicNotExist   bool `json:"topic_or_group_not_exist"`
}

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

type Response struct {
	StatusCode      int       `json:_`
	MetaData        MetaData_ `json:"meta_data"`
	SuccessPutCount int       `json:"success_put_count"`
}