Documentation
¶
Overview ¶
Package proxy provides a client for communicating with the FODC Proxy.
Package proxy provides connection management for the FODC Proxy client.
Index ¶
- type Client
- func (c *Client) Connect(ctx context.Context) error
- func (c *Client) Disconnect() error
- func (c *Client) RetrieveAndSendMetrics(_ context.Context, filter *MetricsRequestFilter) error
- func (c *Client) SendHeartbeat(_ context.Context) error
- func (c *Client) Start(ctx context.Context) error
- func (c *Client) StartClusterStateStream(ctx context.Context) error
- func (c *Client) StartConnManager(ctx context.Context)
- func (c *Client) StartLifecycleStream(ctx context.Context) error
- func (c *Client) StartMetricsStream(ctx context.Context) error
- func (c *Client) StartRegistrationStream(ctx context.Context) error
- type MetricsRequestFilter
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client manages connection and communication with the FODC Proxy.
func NewClient ¶
func NewClient( proxyAddr string, nodeRole string, podName string, containerNames []string, labels map[string]string, heartbeatInterval time.Duration, reconnectInterval time.Duration, flightRecorder *flightrecorder.FlightRecorder, clusterCollector *cluster.Collector, lifecycleCollector *lifecycle.Collector, logger *logger.Logger, ) *Client
NewClient creates a new Client instance.
func (*Client) Disconnect ¶
Disconnect closes connection to Proxy.
func (*Client) RetrieveAndSendMetrics ¶
func (c *Client) RetrieveAndSendMetrics(_ context.Context, filter *MetricsRequestFilter) error
RetrieveAndSendMetrics retrieves metrics from Flight Recorder when requested by Proxy.
func (*Client) SendHeartbeat ¶
SendHeartbeat sends heartbeat to Proxy.
func (*Client) StartClusterStateStream ¶
StartClusterStateStream establishes bi-directional cluster state stream with Proxy.
func (*Client) StartConnManager ¶
StartConnManager is useful for tests or scenarios where you want to manually control connection lifecycle.
func (*Client) StartLifecycleStream ¶ added in v0.10.1
StartLifecycleStream establishes bi-directional lifecycle stream with Proxy.
func (*Client) StartMetricsStream ¶
StartMetricsStream establishes bi-directional metrics stream with Proxy.
Source Files