output

type EventType string

type Events struct {
	gormutils.ModelUnscoped

	Cluster   string    `json:"cluster" gorm:"type:varchar(64);index"`
	EventTime time.Time `json:"event_time" gorm:"index"`
	Source    string    `json:"source" gorm:"type:varchar(64);index"`
	EventType string    `json:"event_type" gorm:"type:varchar(64);index"`

	APIVersion string `json:"api_version" gorm:"type:varchar(64);index"`
	Kind       string `json:"kind" gorm:"type:varchar(64);index"`
	Namespace  string `json:"namespace" gorm:"type:varchar(64);index"`
	Name       string `json:"name" gorm:"type:varchar(64);index"`
	UID        string `json:"uid" gorm:"type:varchar(64);index"`

	Fields  datatypes.JSON `json:"fields"`
	Message string         `json:"message" gorm:"type:text"`

	Object    datatypes.JSON `json:"object"`
	Diff      string         `json:"diff" gorm:"type:text"`
	JsonPatch datatypes.JSON `json:"json_patch"`
}

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

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

type Output interface {
	Name() string
	Write(out OutputStruct) error
}

type OutputStruct struct {
	EventTime time.Time `json:"event_time"`

	ObjectRef corev1.ObjectReference

	EventType EventType      `json:"event_type"`
	Source    SourceType     `json:"source"`
	Object    map[string]any `json:"object"`
	Diff      string         `json:"diff"`
	JsonPatch string         `json:"json_patch"`
	Fields    map[string]any `json:"fields"`
	Message   string         `json:"message"` // event message
}

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

type SourceType string