Versions in this module Expand all Collapse all v0 v0.1.2 Nov 17, 2020 Changes in this version + type Config struct + AltRoot string + BPFObject []byte + CRIEndpoint string + K8SEndpoint string + K8SNamespace string + type Hub struct + func NewHub(config *Config, observer topology.Observer) (*Hub, error) + func (h *Hub) AttachPath(name string, paths []string, cb func(string, *event.TraceEvent)) pubsub.Unsubscriber + func (h *Hub) AttachTrace(t *v1alpha1.Trace, cb func(n string, ev *event.TraceEvent)) pubsub.Unsubscriber + func (h *Hub) DeleteTrace(t *v1alpha1.Trace) error + func (h *Hub) MustRun(ctx context.Context) + func (h *Hub) MustRunJob(job *Job) + func (h *Hub) Probe() *kernel.Probe + func (h *Hub) PushJob(job *Job, ns, nr int) + func (h *Hub) Run(ctx context.Context) error + func (h *Hub) RunJob(job *Job) error + func (h *Hub) RunTrace(t *v1alpha1.Trace) error + func (h *Hub) Topology() *topology.Topology + func (h *Hub) WriteEvent(ev *event.TraceEvent) + type Job struct + func NewJob(t *v1alpha1.Trace) *Job + func (j *Job) AddContainer(pod, name string) + func (j *Job) Duration() time.Duration + func (j *Job) JobID() string + func (j *Job) MonitoredHosts(all bool) []string + func (j *Job) RemoveContainer(pod, name string) + func (j *Job) Run(h *Hub, done chan bool) error + func (j *Job) TraceSpec() *v1alpha1.TraceSpec + func (j *Job) TraceStatus() *v1alpha1.TraceStatus + func (j *Job) WriteEvent(h *Hub, ev *event.TraceEvent) + type JobContext struct + type JobList struct
Go to main page