server

Documentation

Index

• type FakeObserver
  • func (f *FakeObserver) AddTracingPolicy(ctx context.Context, tp tracingpolicy.TracingPolicy) error
  • func (f *FakeObserver) DelTracingPolicy(ctx context.Context, sensorName string) error
  • func (f *FakeObserver) DisableSensor(ctx context.Context, name string) error
  • func (f *FakeObserver) EnableSensor(ctx context.Context, name string) error
  • func (f *FakeObserver) GetSensorConfig(ctx context.Context, k string, v string) (string, error)
  • func (f *FakeObserver) GetTreeProto(ctx context.Context, tname string) (*tetragon.StackTraceNode, error)
  • func (f *FakeObserver) ListSensors(ctx context.Context) (*[]sensors.SensorStatus, error)
  • func (f *FakeObserver) RemoveSensor(ctx context.Context, sensorName string) error
  • func (f *FakeObserver) SetSensorConfig(ctx context.Context, name string, cfgkey string, cfgval string) error
• type Listener
• type Server
  • func NewServer(ctx context.Context, cleanupWg *sync.WaitGroup, notifier notifier, ...) *Server
  • func (s *Server) AddTracingPolicy(ctx context.Context, req *tetragon.AddTracingPolicyRequest) (*tetragon.AddTracingPolicyResponse, error)
  • func (s *Server) DelTracingPolicy(ctx context.Context, req *tetragon.DeleteTracingPolicyRequest) (*tetragon.DeleteTracingPolicyResponse, error)
  • func (s *Server) DisableSensor(ctx context.Context, req *tetragon.DisableSensorRequest) (*tetragon.DisableSensorResponse, error)
  • func (s *Server) EnableSensor(ctx context.Context, req *tetragon.EnableSensorRequest) (*tetragon.EnableSensorResponse, error)
  • func (s *Server) GetEvents(request *tetragon.GetEventsRequest, ...) error
  • func (s *Server) GetEventsWG(request *tetragon.GetEventsRequest, ...) error
  • func (s *Server) GetHealth(ctx context.Context, request *tetragon.GetHealthStatusRequest) (*tetragon.GetHealthStatusResponse, error)
  • func (s *Server) GetSensorConfig(ctx context.Context, req *tetragon.GetSensorConfigRequest) (*tetragon.GetSensorConfigResponse, error)
  • func (s *Server) GetStackTraceTree(ctx context.Context, req *tetragon.GetStackTraceTreeRequest) (*tetragon.GetStackTraceTreeResponse, error)
  • func (s *Server) GetVersion(ctx context.Context, req *tetragon.GetVersionRequest) (*tetragon.GetVersionResponse, error)
  • func (s *Server) ListSensors(ctx context.Context, request *tetragon.ListSensorsRequest) (*tetragon.ListSensorsResponse, error)
  • func (s *Server) NotifyListeners(original interface{}, processed *tetragon.GetEventsResponse)
  • func (s *Server) RemoveSensor(ctx context.Context, req *tetragon.RemoveSensorRequest) (*tetragon.RemoveSensorResponse, error)
  • func (s *Server) RuntimeHook(ctx context.Context, req *tetragon.RuntimeHookRequest) (*tetragon.RuntimeHookResponse, error)
  • func (s *Server) SetSensorConfig(ctx context.Context, req *tetragon.SetSensorConfigRequest) (*tetragon.SetSensorConfigResponse, error)

Types

type FakeObserver

type FakeObserver struct{}

func (*FakeObserver) AddTracingPolicy

func (f *FakeObserver) AddTracingPolicy(ctx context.Context, tp tracingpolicy.TracingPolicy) error

func (*FakeObserver) DelTracingPolicy

func (f *FakeObserver) DelTracingPolicy(ctx context.Context, sensorName string) error

func (*FakeObserver) DisableSensor

func (f *FakeObserver) DisableSensor(ctx context.Context, name string) error

func (*FakeObserver) EnableSensor

func (f *FakeObserver) EnableSensor(ctx context.Context, name string) error

func (*FakeObserver) GetSensorConfig

func (f *FakeObserver) GetSensorConfig(ctx context.Context, k string, v string) (string, error)

func (*FakeObserver) GetTreeProto

func (f *FakeObserver) GetTreeProto(ctx context.Context, tname string) (*tetragon.StackTraceNode, error)

func (*FakeObserver) ListSensors

func (f *FakeObserver) ListSensors(ctx context.Context) (*[]sensors.SensorStatus, error)

func (*FakeObserver) RemoveSensor

func (f *FakeObserver) RemoveSensor(ctx context.Context, sensorName string) error

func (*FakeObserver) SetSensorConfig

func (f *FakeObserver) SetSensorConfig(ctx context.Context, name string, cfgkey string, cfgval string) error

type Listener

type Listener interface {
	Notify(res *tetragon.GetEventsResponse)
}

type Server

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

func NewServer

func NewServer(ctx context.Context, cleanupWg *sync.WaitGroup, notifier notifier, observer observer, hookRunner hookRunner) *Server

func (*Server) AddTracingPolicy

func (s *Server) AddTracingPolicy(ctx context.Context, req *tetragon.AddTracingPolicyRequest) (*tetragon.AddTracingPolicyResponse, error)

func (*Server) DelTracingPolicy

func (s *Server) DelTracingPolicy(ctx context.Context, req *tetragon.DeleteTracingPolicyRequest) (*tetragon.DeleteTracingPolicyResponse, error)

func (*Server) DisableSensor

func (s *Server) DisableSensor(ctx context.Context, req *tetragon.DisableSensorRequest) (*tetragon.DisableSensorResponse, error)

func (*Server) EnableSensor

func (s *Server) EnableSensor(ctx context.Context, req *tetragon.EnableSensorRequest) (*tetragon.EnableSensorResponse, error)

func (*Server) GetEvents

func (s *Server) GetEvents(request *tetragon.GetEventsRequest, server tetragon.FineGuidanceSensors_GetEventsServer) error

func (*Server) GetEventsWG

func (s *Server) GetEventsWG(request *tetragon.GetEventsRequest, server tetragon.FineGuidanceSensors_GetEventsServer, closer io.Closer, readyWG *sync.WaitGroup) error

func (*Server) GetHealth

func (s *Server) GetHealth(ctx context.Context, request *tetragon.GetHealthStatusRequest) (*tetragon.GetHealthStatusResponse, error)

func (*Server) GetSensorConfig

func (s *Server) GetSensorConfig(ctx context.Context, req *tetragon.GetSensorConfigRequest) (*tetragon.GetSensorConfigResponse, error)

func (*Server) GetStackTraceTree

func (s *Server) GetStackTraceTree(ctx context.Context, req *tetragon.GetStackTraceTreeRequest) (*tetragon.GetStackTraceTreeResponse, error)

func (*Server) GetVersion

func (s *Server) GetVersion(ctx context.Context, req *tetragon.GetVersionRequest) (*tetragon.GetVersionResponse, error)

func (*Server) ListSensors

func (s *Server) ListSensors(ctx context.Context, request *tetragon.ListSensorsRequest) (*tetragon.ListSensorsResponse, error)

func (*Server) NotifyListeners

func (s *Server) NotifyListeners(original interface{}, processed *tetragon.GetEventsResponse)

func (*Server) RemoveSensor

func (s *Server) RemoveSensor(ctx context.Context, req *tetragon.RemoveSensorRequest) (*tetragon.RemoveSensorResponse, error)

func (*Server) RuntimeHook

func (s *Server) RuntimeHook(ctx context.Context, req *tetragon.RuntimeHookRequest) (*tetragon.RuntimeHookResponse, error)

func (*Server) SetSensorConfig

func (s *Server) SetSensorConfig(ctx context.Context, req *tetragon.SetSensorConfigRequest) (*tetragon.SetSensorConfigResponse, error)