events

type DockerSpec struct {
	ContainerId string `json:"container_id"`
}

type KubernetesSpec struct {
	NamespaceName string     `json:"namespace_name"`
	PodId         string     `json:"pod_id"`
	PodName       string     `json:"pod_name"`
	ContainerName string     `json:"container_name"`
	Labels        LabelsSpec `json:"labels"`
	Host          string     `json:"host"`
}

type LabelsSpec struct {
	Name            string `json:"name"`
	PodTemplateHash string `json:"pod-template-hash"`
}

type LogConsumer struct {
	AppLogs      chan *kafka.Message
	BuildLogs    chan *kafka.Message
	WebLogs      chan *kafka.Message
	IstioWebLogs chan *kafka.Message
	IsOpen       bool
	// contains filtered or unexported fields
}

type LogProducer struct {
	IsOpen bool
	// contains filtered or unexported fields
}

type LogSpec struct {
	Log        string         `json:"log"`
	Stream     string         `json:"stream"`
	Time       time.Time      `json:"time"`
	Space      string         `json:"space"`
	Docker     DockerSpec     `json:"docker"`
	Kubernetes KubernetesSpec `json:"kubernetes"`
	Topic      string         `json:"topic"`
	Tag        string         `json:"tag"`
	Site       string         `json:"site,omitempty"`
	SitePath   string         `json:"site,omitempty"`
	Path       string         `json:"site,omitempty"`
}

type Process struct {
	App  string `json:"app"`
	Type string `json:"type"`
}