server

Documentation

Index

• func ConvertAnyValueToString(value *protobufs.AnyValue) string
• func StartOpAmpServer(ctx context.Context, logger logr.Logger, mgr ctrl.Manager, ...) error
• type ConnectionHandlers
  • func (c *ConnectionHandlers) OnAgentToServerMessage(ctx context.Context, request *protobufs.AgentToServer, ...) (*protobufs.ServerToAgent, error)
  • func (c *ConnectionHandlers) OnConnectionClosed(ctx context.Context, connectionInfo *connection.ConnectionInfo)
  • func (c *ConnectionHandlers) OnConnectionNoHeartbeat(ctx context.Context, connectionInfo *connection.ConnectionInfo) error
  • func (c *ConnectionHandlers) OnNewConnection(ctx context.Context, firstMessage *protobufs.AgentToServer) (*connection.ConnectionInfo, *protobufs.ServerToAgent, error)
  • func (c *ConnectionHandlers) UpdateInstrumentationInstanceStatus(ctx context.Context, message *protobufs.AgentToServer, ...) error

Functions

func ConvertAnyValueToString

func ConvertAnyValueToString(value *protobufs.AnyValue) string

func StartOpAmpServer

func StartOpAmpServer(ctx context.Context, logger logr.Logger, mgr ctrl.Manager, kubeClientSet *kubernetes.Clientset, nodeName string, odigosNs string) error

Types

type ConnectionHandlers

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

func (*ConnectionHandlers) OnAgentToServerMessage

func (c *ConnectionHandlers) OnAgentToServerMessage(ctx context.Context, request *protobufs.AgentToServer, connectionInfo *connection.ConnectionInfo) (*protobufs.ServerToAgent, error)

func (*ConnectionHandlers) OnConnectionClosed

func (c *ConnectionHandlers) OnConnectionClosed(ctx context.Context, connectionInfo *connection.ConnectionInfo)

func (*ConnectionHandlers) OnConnectionNoHeartbeat

func (c *ConnectionHandlers) OnConnectionNoHeartbeat(ctx context.Context, connectionInfo *connection.ConnectionInfo) error

func (*ConnectionHandlers) OnNewConnection

func (c *ConnectionHandlers) OnNewConnection(ctx context.Context, firstMessage *protobufs.AgentToServer) (*connection.ConnectionInfo, *protobufs.ServerToAgent, error)

func (*ConnectionHandlers) UpdateInstrumentationInstanceStatus

func (c *ConnectionHandlers) UpdateInstrumentationInstanceStatus(ctx context.Context, message *protobufs.AgentToServer, connectionInfo *connection.ConnectionInfo) error