file

Documentation

Index

• type PodMetaWriter
  • func NewPodMetaWriter(directory string, retention time.Duration, logger *log.Logger) *PodMetaWriter
  • func (w *PodMetaWriter) Handle(event exporter.PodEvent) error

Types

type PodMetaWriter

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

PodMetaWriter is a PodMetaHandler that stores pod metadata in a specified directory. Files have a name format of `<namespace>_<pod_name>.meta` and are kept in `directory`.

func NewPodMetaWriter

func NewPodMetaWriter(directory string, retention time.Duration, logger *log.Logger) *PodMetaWriter

NewPodMetaWriter creates a new PodMetaWriter with specified directory and retention period.

func (*PodMetaWriter) Handle

func (w *PodMetaWriter) Handle(event exporter.PodEvent) error

Handle handles PodEvent. The exact behaviour depends on event type:

• ADDED event - creates or updates file with metadata
• MODIFIED event - creates or updates file with metadata
• DELETED event - marks file for cleanup

We need to update file on MODIFIED event because ADDED can be sent when pod is still in a Pending state. As a result Fluent Bit won't be able to get container_image and container_hash from it.