observer

Documentation

Index

• Variables
• type LocalObserverServer
  • func NewLocalServer(payloadParser *parser.Parser, logger logrus.FieldLogger, ...) (*LocalObserverServer, error)
  • func (s *LocalObserverServer) GetAgentEvents(req *observerpb.GetAgentEventsRequest, ...) (err error)
  • func (s *LocalObserverServer) GetDebugEvents(req *observerpb.GetDebugEventsRequest, ...) (err error)
  • func (s *LocalObserverServer) GetEventsChannel() chan *observerTypes.MonitorEvent
  • func (s *LocalObserverServer) GetFlows(req *observerpb.GetFlowsRequest, server observerpb.Observer_GetFlowsServer) (err error)
  • func (s *LocalObserverServer) GetLogger() logrus.FieldLogger
  • func (s *LocalObserverServer) GetNodes(ctx context.Context, req *observerpb.GetNodesRequest) (*observerpb.GetNodesResponse, error)
  • func (s *LocalObserverServer) GetOptions() observeroption.Options
  • func (s *LocalObserverServer) GetPayloadParser() *parser.Parser
  • func (s *LocalObserverServer) GetRingBuffer() *container.Ring
  • func (s *LocalObserverServer) GetStopped() chan struct{}
  • func (s *LocalObserverServer) ServerStatus(ctx context.Context, req *observerpb.ServerStatusRequest) (*observerpb.ServerStatusResponse, error)
  • func (s *LocalObserverServer) Start()

Variables

var DefaultOptions []observeroption.Option

DefaultOptions to include in the server. Other packages may extend this in their init() function.

Types

type LocalObserverServer

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

LocalObserverServer is an implementation of the server.Observer interface that's meant to be run embedded inside the Cilium process. It ignores all the state change events since the state is available locally.

func NewLocalServer

func NewLocalServer(
	payloadParser *parser.Parser,
	logger logrus.FieldLogger,
	options ...observeroption.Option,
) (*LocalObserverServer, error)

NewLocalServer returns a new local observer server.

func (*LocalObserverServer) GetAgentEvents

func (s *LocalObserverServer) GetAgentEvents(
	req *observerpb.GetAgentEventsRequest,
	server observerpb.Observer_GetAgentEventsServer,
) (err error)

GetAgentEvents implements observerpb.ObserverClient.GetAgentEvents.

func (*LocalObserverServer) GetDebugEvents

func (s *LocalObserverServer) GetDebugEvents(
	req *observerpb.GetDebugEventsRequest,
	server observerpb.Observer_GetDebugEventsServer,
) (err error)

GetDebugEvents implements observerpb.ObserverClient.GetDebugEvents.

func (*LocalObserverServer) GetEventsChannel

func (s *LocalObserverServer) GetEventsChannel() chan *observerTypes.MonitorEvent

GetEventsChannel returns the event channel to receive flowpb.Payload events.

func (*LocalObserverServer) GetFlows

func (s *LocalObserverServer) GetFlows(
	req *observerpb.GetFlowsRequest,
	server observerpb.Observer_GetFlowsServer,
) (err error)

GetFlows implements the proto method for client requests.

func (*LocalObserverServer) GetLogger

func (s *LocalObserverServer) GetLogger() logrus.FieldLogger

GetLogger implements GRPCServer.GetLogger.

func (*LocalObserverServer) GetNodes

func (s *LocalObserverServer) GetNodes(ctx context.Context, req *observerpb.GetNodesRequest) (*observerpb.GetNodesResponse, error)

GetNodes implements observerpb.ObserverClient.GetNodes.

func (*LocalObserverServer) GetOptions

func (s *LocalObserverServer) GetOptions() observeroption.Options

GetOptions implements serveroptions.Server.GetOptions.

func (*LocalObserverServer) GetPayloadParser

func (s *LocalObserverServer) GetPayloadParser() *parser.Parser

GetPayloadParser implements GRPCServer.GetPayloadParser.

func (*LocalObserverServer) GetRingBuffer

func (s *LocalObserverServer) GetRingBuffer() *container.Ring

GetRingBuffer implements GRPCServer.GetRingBuffer.

func (*LocalObserverServer) GetStopped

func (s *LocalObserverServer) GetStopped() chan struct{}

GetStopped implements GRPCServer.GetStopped.

func (*LocalObserverServer) ServerStatus

func (s *LocalObserverServer) ServerStatus(
	ctx context.Context, req *observerpb.ServerStatusRequest,
) (*observerpb.ServerStatusResponse, error)

ServerStatus should have a comment, apparently. It returns the server status.

func (*LocalObserverServer) Start

func (s *LocalObserverServer) Start()

Start implements GRPCServer.Start.