output

type KafkaAgentV1 struct {
	Timestamp uint64 `json:"timestamp,omitempty"`
	Agent     uint32 `json:"agent,omitempty"`
	Property  string `json:"property,omitempty"`
	Raw       string `json:"raw,omitempty"`
	Json      string `json:"json,omitempty"`
}

type KafkaAttributeV1 struct {
	Timestamp uint64 `json:"timestamp,omitempty"`
	Attribute uint32 `json:"attribute,omitempty"`
	Property  string `json:"property,omitempty"`
	Json      string `json:"json,omitempty"`
	Total     uint64 `json:"total,omitempty"`
}

type KafkaEventV1 struct {
	Timestamp uint64 `json:"timestamp,omitempty"`
	Event     uint64 `json:"event,omitempty"`
	Property  string `json:"property,omitempty"`
	Json      string `json:"json,omitempty"`
	Total     uint64 `json:"total,omitempty"`
}

type KafkaMessageV1 struct {
	Timestamp   uint64   `json:"timestamp,omitempty"`
	Origin      string   `json:"origin,omitempty"`
	IPv4        string   `json:"ipv4,omitempty"`
	Agent       uint32   `json:"agent,omitempty"`
	Session     string   `json:"session,omitempty"`
	Referrer    string   `json:"referrer,omitempty"`
	Country     string   `json:"country,omitempty"`
	Lang        string   `json:"lang,omitempty"`
	Fingerprint string   `json:"fingerprint,omitempty"`
	Provider    string   `json:"provider,omitempty"`
	Property    string   `json:"property,omitempty"`
	Events      []uint64 `json:"events,omitempty"`
	Attributes  []uint32 `json:"attributes,omitempty"`
}

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

type KafkaOutputOptions struct {
	Brokers            string
	ClientID           string
	FlushFrequency     int
	FlushMaxMessages   int
	NetMaxOpenRequests int
	NetDialTimeout     int
	NetReadTimeout     int
	NetWriteTimeout    int
}

type KafkaOutputTopicsV1 struct {
	DefaultPart string
	Messages    string
	Agents      string
	Events      string
	Attributes  string
}