proxy

package

v0.141.0 Latest Latest Go to latest Published: Dec 9, 2025 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation ¶

Index ¶

type Agent
- func NewAgent(logger logr.Logger, agentId uuid.UUID, conn types.Connection) *Agent
type OpAMPProxy
- func NewOpAMPProxy(l logr.Logger, endpoint string) *OpAMPProxy
type Server

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Agent ¶

type Agent struct {

	// Agent's instance id. This is an immutable field.
	InstanceId uuid.UUID

	// Agent's current status.
	Status *protobufs.AgentToServer
	// contains filtered or unexported fields
}

func NewAgent ¶

func NewAgent(logger logr.Logger, agentId uuid.UUID, conn types.Connection) *Agent

func (*Agent) GetConfiguration ¶

func (a *Agent) GetConfiguration() *protobufs.EffectiveConfig

func (*Agent) GetHealth ¶

func (a *Agent) GetHealth() *protobufs.ComponentHealth

func (*Agent) GetHostname ¶ added in v0.132.0

func (a *Agent) GetHostname() string

func (*Agent) UpdateStatus ¶

func (a *Agent) UpdateStatus(newStatus *protobufs.AgentToServer, response *protobufs.ServerToAgent) bool

type OpAMPProxy ¶

type OpAMPProxy struct {
	server.OpAMPServer
	// contains filtered or unexported fields
}

func NewOpAMPProxy ¶

func NewOpAMPProxy(l logr.Logger, endpoint string) *OpAMPProxy

func (*OpAMPProxy) GetAgentsByHostname ¶ added in v0.132.0

func (s *OpAMPProxy) GetAgentsByHostname() map[string]uuid.UUID

GetAgentsByHostname implements Server.

func (*OpAMPProxy) GetConfigurations ¶

func (s *OpAMPProxy) GetConfigurations() map[uuid.UUID]*protobufs.EffectiveConfig

GetConfigurations implements Server.

func (*OpAMPProxy) GetHealth ¶

func (s *OpAMPProxy) GetHealth() map[uuid.UUID]*protobufs.ComponentHealth

GetHealth implements Server.

func (*OpAMPProxy) HasUpdates ¶

func (s *OpAMPProxy) HasUpdates() <-chan struct{}

HasUpdates implements Server.

func (*OpAMPProxy) Start ¶

func (s *OpAMPProxy) Start() error

func (*OpAMPProxy) Stop ¶

func (s *OpAMPProxy) Stop(ctx context.Context) error

type Server ¶

type Server interface {
	GetAgentsByHostname() map[string]uuid.UUID
	GetConfigurations() map[uuid.UUID]*protobufs.EffectiveConfig
	GetHealth() map[uuid.UUID]*protobufs.ComponentHealth
	HasUpdates() <-chan struct{}
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL