workloadmeta

type Collector interface {
	// Start starts a collector. The collector should run until the context
	// is done. It also gets a reference to the store that started it so it
	// can use Notify, or get access to other entities in the store.
	Start(context.Context, Store) error

	// Pull triggers an entity collection. To be used by collectors that
	// don't have streaming functionality, and called periodically by the
	// store.
	Pull(context.Context) error
}

type CollectorEvent struct {
	Type   EventType
	Source string
	Entity Entity
}

type Container struct {
	EntityID
	EntityMeta
	EnvVars    map[string]string
	Hostname   string
	Image      ContainerImage
	NetworkIPs map[string]string
	PID        int
	Ports      []ContainerPort
	Runtime    ContainerRuntime
	State      ContainerState
}

type ContainerImage struct {
	ID        string
	RawName   string
	Name      string
	ShortName string
	Tag       string
}

type ContainerPort struct {
	Name     string
	Port     int
	Protocol string
}

type ContainerRuntime string

type ContainerState struct {
	Running    bool
	StartedAt  time.Time
	FinishedAt time.Time
}

type ECSLaunchType string

type ECSTask struct {
	EntityID
	EntityMeta
	Tags                  map[string]string
	ContainerInstanceTags map[string]string
	ClusterName           string
	Region                string
	AvailabilityZone      string
	Family                string
	Version               string
	LaunchType            ECSLaunchType
	Containers            []OrchestratorContainer
}

type Entity interface {
	GetID() EntityID
	Merge(Entity) error
	DeepCopy() Entity
}

type EntityID struct {
	Kind Kind
	ID   string
}

type EntityMeta struct {
	Name        string
	Namespace   string
	Annotations map[string]string
	Labels      map[string]string
}

type Event struct {
	Type    EventType
	Sources []string
	Entity  Entity
}

type EventBundle struct {
	Events []Event
	Ch     chan struct{}
}

type EventType int

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

type Kind string

type KubernetesPod struct {
	EntityID
	EntityMeta
	Owners                     []KubernetesPodOwner
	PersistentVolumeClaimNames []string
	Containers                 []OrchestratorContainer
	Ready                      bool
	Phase                      string
	IP                         string
	PriorityClass              string
	KubeServices               []string
	NamespaceLabels            map[string]string
}

type KubernetesPodOwner struct {
	Kind string
	Name string
	ID   string
}

type OrchestratorContainer struct {
	ID   string
	Name string
}

type Store interface {
	Start(ctx context.Context)
	Subscribe(name string, filter *Filter) chan EventBundle
	Unsubscribe(ch chan EventBundle)
	GetContainer(id string) (*Container, error)
	GetKubernetesPod(id string) (*KubernetesPod, error)
	GetKubernetesPodForContainer(containerID string) (*KubernetesPod, error)
	GetECSTask(id string) (*ECSTask, error)
	Notify(events []CollectorEvent)
}