testing

Documentation

Index

• type Store
  • func NewStore() *Store
  • func (s *Store) Dump(verbose bool) workloadmeta.WorkloadDumpResponse
  • func (s *Store) GetContainer(id string) (*workloadmeta.Container, error)
  • func (s *Store) GetECSTask(id string) (*workloadmeta.ECSTask, error)
  • func (s *Store) GetKubernetesPod(id string) (*workloadmeta.KubernetesPod, error)
  • func (s *Store) GetKubernetesPodForContainer(containerID string) (*workloadmeta.KubernetesPod, error)
  • func (s *Store) ListContainers() ([]*workloadmeta.Container, error)
  • func (s *Store) Notify(events []workloadmeta.CollectorEvent)
  • func (s *Store) Set(entity workloadmeta.Entity)
  • func (s *Store) Start(ctx context.Context)
  • func (s *Store) Subscribe(name string, filter *workloadmeta.Filter) chan workloadmeta.EventBundle
  • func (s *Store) Unset(entity workloadmeta.Entity)
  • func (s *Store) Unsubscribe(ch chan workloadmeta.EventBundle)

Types

type Store

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

Store is a testing store that satisfies the workloadmeta.Store interface.

func NewStore

func NewStore() *Store

NewStore creates a new workload metadata store for testing.

func (*Store) Dump

func (s *Store) Dump(verbose bool) workloadmeta.WorkloadDumpResponse

Dump is not implemented in the testing store.

func (*Store) GetContainer

func (s *Store) GetContainer(id string) (*workloadmeta.Container, error)

GetContainer returns metadata about a container.

func (*Store) GetECSTask

func (s *Store) GetECSTask(id string) (*workloadmeta.ECSTask, error)

GetECSTask returns metadata about an ECS task.

func (*Store) GetKubernetesPod

func (s *Store) GetKubernetesPod(id string) (*workloadmeta.KubernetesPod, error)

GetKubernetesPod returns metadata about a Kubernetes pod.

func (*Store) GetKubernetesPodForContainer

func (s *Store) GetKubernetesPodForContainer(containerID string) (*workloadmeta.KubernetesPod, error)

GetKubernetesPodForContainer returns a KubernetesPod that contains the specified containerID.

func (*Store) ListContainers

func (s *Store) ListContainers() ([]*workloadmeta.Container, error)

ListContainers returns metadata about all known containers.

func (*Store) Notify

func (s *Store) Notify(events []workloadmeta.CollectorEvent)

Notify is not implemented in the testing store.

func (*Store) Set

func (s *Store) Set(entity workloadmeta.Entity)

Set sets an entity in the store.

func (*Store) Start

func (s *Store) Start(ctx context.Context)

Start is not implemented in the testing store.

func (*Store) Subscribe

func (s *Store) Subscribe(name string, filter *workloadmeta.Filter) chan workloadmeta.EventBundle

Subscribe is not implemented in the testing store.

func (*Store) Unset

func (s *Store) Unset(entity workloadmeta.Entity)

Unset removes an entity from the store.

func (*Store) Unsubscribe

func (s *Store) Unsubscribe(ch chan workloadmeta.EventBundle)

Unsubscribe is not implemented in the testing store.