internal

Mar 26, 2024

Changes in this version

type WSSender

+ func (s *WSSender) IsStopped() <-chan struct{}

+ func (s *WSSender) StoppingErr() error

Mar 25, 2024

Changes in this version

type ClientCommon

+ func (c *ClientCommon) SendCustomMessage(message *protobufs.CustomMessage) (messageSendingChannel chan struct{}, err error)

+ func (c *ClientCommon) SetCustomCapabilities(customCapabilities *protobufs.CustomCapabilities) error

type ClientSyncedState

+ func (s *ClientSyncedState) CustomCapabilities() *protobufs.CustomCapabilities

+ func (s *ClientSyncedState) HasCustomCapability(capability string) bool

+ func (s *ClientSyncedState) SetCustomCapabilities(capabilities *protobufs.CustomCapabilities) error

Jan 22, 2024

Changes in this version

type ClientCommon

+ func (c *ClientCommon) RequestConnectionSettings(request *protobufs.ConnectionSettingsRequest) error

Oct 17, 2023

Changes in this version

+ var ErrHealthMissing = errors.New("health is nil")

Jan 5, 2023

Changes in this version

type HTTPSender

+ func (h *HTTPSender) AddTLSConfig(config *tls.Config)

type MockServer

+ func StartTLSMockServer(t *testing.T) *MockServer

+ func (m *MockServer) GetHTTPTestServer() *httptest.Server

Sep 22, 2022

Changes in this version

+ var ErrAcceptsPackagesNotSet = errors.New("AcceptsPackages and ReportsPackageStatuses must be set")

+ var ErrPackagesStateProviderNotSet = errors.New("PackagesStateProvider must be set")

+ var ErrReportsEffectiveConfigNotSet = errors.New("ReportsEffectiveConfig capability is not set")

+ var ErrReportsRemoteConfigNotSet = errors.New("ReportsRemoteConfig capability is not set")

type ClientCommon

+ Capabilities protobufs.AgentCapabilities

type HTTPSender

+ func (h *HTTPSender) EnableCompression()

type MockServer

+ func (m *MockServer) EnableCompression()

+ type TCPProxy struct

+ func NewProxy(destHostPort string) *TCPProxy

+ func (p *TCPProxy) ClientToServerBytes() int

+ func (p *TCPProxy) IncomingEndpoint() string

+ func (p *TCPProxy) ServerToClientBytes() int

+ func (p *TCPProxy) Start() error

+ func (p *TCPProxy) Stop()

Jul 5, 2022

Changes in this version

+ var ErrAgentHealthMissing = errors.New("AgentHealth is nil")

type ClientCommon

+ func (c *ClientCommon) SetHealth(health *protobufs.AgentHealth) error

type ClientSyncedState

+ func (s *ClientSyncedState) Health() *protobufs.AgentHealth

+ func (s *ClientSyncedState) SetHealth(health *protobufs.AgentHealth) error

Jun 7, 2022

Changes in this version

+ const OpAMPPlainHTTPMethod

+ var ErrAgentDescriptionMissing = errors.New("AgentDescription is nil")

+ var ErrAgentDescriptionNoAttributes = errors.New("AgentDescription has no attributes defined")

+ func NewPackagesSyncer(logger types.Logger, available *protobufs.PackagesAvailable, sender Sender, ...) *packagesSyncer

+ func NewWSReceiver(logger types.Logger, callbacks types.Callbacks, conn *websocket.Conn, ...) *wsReceiver

+ type ClientCommon struct

+ Callbacks types.Callbacks

+ ClientSyncedState ClientSyncedState

+ Logger types.Logger

+ PackagesStateProvider types.PackagesStateProvider

+ func NewClientCommon(logger types.Logger, sender Sender) ClientCommon

+ func (c *ClientCommon) AgentDescription() *protobufs.AgentDescription

+ func (c *ClientCommon) IsStopping() bool

+ func (c *ClientCommon) PrepareFirstMessage(ctx context.Context) error

+ func (c *ClientCommon) PrepareStart(_ context.Context, settings types.StartSettings) error

+ func (c *ClientCommon) SetAgentDescription(descr *protobufs.AgentDescription) error

+ func (c *ClientCommon) SetPackageStatuses(statuses *protobufs.PackageStatuses) error

+ func (c *ClientCommon) SetRemoteConfigStatus(status *protobufs.RemoteConfigStatus) error

+ func (c *ClientCommon) StartConnectAndRun(runner func(ctx context.Context))

+ func (c *ClientCommon) Stop(ctx context.Context) error

+ func (c *ClientCommon) UpdateEffectiveConfig(ctx context.Context) error

+ type ClientSyncedState struct

+ func (s *ClientSyncedState) AgentDescription() *protobufs.AgentDescription

+ func (s *ClientSyncedState) PackageStatuses() *protobufs.PackageStatuses

+ func (s *ClientSyncedState) RemoteConfigStatus() *protobufs.RemoteConfigStatus

+ func (s *ClientSyncedState) SetAgentDescription(descr *protobufs.AgentDescription) error

+ func (s *ClientSyncedState) SetPackageStatuses(status *protobufs.PackageStatuses) error

+ func (s *ClientSyncedState) SetRemoteConfigStatus(status *protobufs.RemoteConfigStatus) error

+ type HTTPSender struct

+ func NewHTTPSender(logger types.Logger) *HTTPSender

+ func (h *HTTPSender) Run(ctx context.Context, url string, callbacks types.Callbacks, ...)

+ func (h *HTTPSender) SetPollingInterval(duration time.Duration)

+ func (h *HTTPSender) SetRequestHeader(header http.Header)

+ type InMemPackagesStore struct

+ func NewInMemPackagesStore() *InMemPackagesStore

+ func (l *InMemPackagesStore) AllPackagesHash() ([]byte, error)

+ func (l *InMemPackagesStore) CreatePackage(packageName string, typ protobufs.PackageAvailable_PackageType) error

+ func (l *InMemPackagesStore) DeletePackage(packageName string) error

+ func (l *InMemPackagesStore) FileContentHash(packageName string) ([]byte, error)

+ func (l *InMemPackagesStore) GetContent() map[string][]byte

+ func (l *InMemPackagesStore) LastReportedStatuses() (*protobufs.PackageStatuses, error)

+ func (l *InMemPackagesStore) PackageState(packageName string) (state types.PackageState, err error)

+ func (l *InMemPackagesStore) Packages() ([]string, error)

+ func (l *InMemPackagesStore) SetAllPackagesHash(hash []byte) error

+ func (l *InMemPackagesStore) SetLastReportedStatuses(statuses *protobufs.PackageStatuses) error

+ func (l *InMemPackagesStore) SetPackageState(packageName string, state types.PackageState) error

+ func (l *InMemPackagesStore) UpdateContent(_ context.Context, packageName string, data io.Reader, contentHash []byte) error

+ type MockServer struct

+ Endpoint string

+ OnConnect func(r *http.Request)

+ OnMessage func(msg *protobufs.AgentToServer) *protobufs.ServerToAgent

+ OnRequest func(w http.ResponseWriter, r *http.Request)

+ OnWSConnect func(conn *websocket.Conn)

+ func StartMockServer(t *testing.T) *MockServer

+ func (m *MockServer) Close()

+ func (m *MockServer) EnableExpectMode()

+ func (m *MockServer) EventuallyExpect(msg string, ...)

+ func (m *MockServer) Expect(handler receivedMessageHandler)

+ type NextMessage struct

+ func NewNextMessage() NextMessage

+ func (s *NextMessage) PopPending() *protobufs.AgentToServer

+ func (s *NextMessage) Update(modifier func(msg *protobufs.AgentToServer))

+ type Sender interface

+ NextMessage func() *NextMessage

+ ScheduleSend func()

+ SetInstanceUid func(instanceUid string) error

+ type SenderCommon struct

+ func NewSenderCommon() SenderCommon

+ func (h *SenderCommon) NextMessage() *NextMessage

+ func (h *SenderCommon) ScheduleSend()

+ func (h *SenderCommon) SetInstanceUid(instanceUid string) error

+ type WSSender struct

+ func NewSender(logger types.Logger) *WSSender

+ func (s *WSSender) Start(ctx context.Context, conn *websocket.Conn) error

+ func (s *WSSender) WaitToStop()