Versions in this module Expand all Collapse all v0 v0.9.0 Oct 20, 2021retracted Changes in this version + const ContainerRuntimeContainerd + const ContainerRuntimeDocker + const ECSLaunchTypeEC2 + const ECSLaunchTypeFargate + const EventTypeSet + const EventTypeUnset + const KindContainer + const KindECSTask + const KindKubernetesPod + func RegisterCollector(id string, c collectorFactory) + type Collector interface + Pull func(context.Context) error + Start func(context.Context, Store) error + type CollectorEvent struct + Entity Entity + Source string + Type EventType + type Container struct + EnvVars map[string]string + Hostname string + Image ContainerImage + NetworkIPs map[string]string + PID int + Ports []ContainerPort + Runtime ContainerRuntime + State ContainerState + func (c *Container) Merge(e Entity) error + func (c Container) DeepCopy() Entity + func (c Container) GetID() EntityID + type ContainerImage struct + ID string + Name string + RawName string + ShortName string + Tag string + func NewContainerImage(imageName string) (ContainerImage, error) + type ContainerPort struct + Name string + Port int + Protocol string + type ContainerRuntime string + type ContainerState struct + FinishedAt time.Time + Running bool + StartedAt time.Time + type ECSLaunchType string + type ECSTask struct + AvailabilityZone string + ClusterName string + ContainerInstanceTags map[string]string + Containers []OrchestratorContainer + Family string + LaunchType ECSLaunchType + Region string + Tags map[string]string + Version string + func (t *ECSTask) Merge(e Entity) error + func (t ECSTask) DeepCopy() Entity + func (t ECSTask) GetID() EntityID + type Entity interface + DeepCopy func() Entity + GetID func() EntityID + Merge func(Entity) error + type EntityID struct + ID string + Kind Kind + func (i EntityID) DeepCopy() Entity + func (i EntityID) GetID() EntityID + func (i EntityID) Merge(e Entity) error + type EntityMeta struct + Annotations map[string]string + Labels map[string]string + Name string + Namespace string + type Event struct + Entity Entity + Sources []string + Type EventType + type EventBundle struct + Ch chan struct{} + Events []Event + type EventType int + type Filter struct + func NewFilter(kinds []Kind, sources []string) *Filter + func (f *Filter) Match(ev CollectorEvent) bool + func (f *Filter) MatchKind(k Kind) bool + func (f *Filter) MatchSource(source string) bool + func (f *Filter) SelectSources(sources []string) ([]string, bool) + type Kind string + type KubernetesPod struct + Containers []OrchestratorContainer + IP string + KubeServices []string + NamespaceLabels map[string]string + Owners []KubernetesPodOwner + PersistentVolumeClaimNames []string + Phase string + PriorityClass string + Ready bool + func (p *KubernetesPod) Merge(e Entity) error + func (p KubernetesPod) DeepCopy() Entity + func (p KubernetesPod) GetID() EntityID + type KubernetesPodOwner struct + ID string + Kind string + Name string + type OrchestratorContainer struct + ID string + Name string + type Store interface + GetContainer func(id string) (*Container, error) + GetECSTask func(id string) (*ECSTask, error) + GetKubernetesPod func(id string) (*KubernetesPod, error) + GetKubernetesPodForContainer func(containerID string) (*KubernetesPod, error) + Notify func(events []CollectorEvent) + Start func(ctx context.Context) + Subscribe func(name string, filter *Filter) chan EventBundle + Unsubscribe func(ch chan EventBundle) + func GetGlobalStore() Store + func NewStore(catalog map[string]collectorFactory) Store
Go to main page