agent

Documentation

Index

• Constants
• func Scheme(ctx context.Context) meta.Scheme
• type BatchingConfig
• type Plugin
  • func NewPlugin(ctx context.Context) *Plugin
  • func (p *Plugin) StreamServers() []streamext.Server
  • func (p *Plugin) UseStreamClient(cc grpc.ClientConnInterface)
• type TopologyNode
  • func NewTopologyNode(ct health.ConditionTracker, lg *slog.Logger) *TopologyNode
  • func (t *TopologyNode) AddConfigListener(ch chan<- *node.TopologyCapabilityConfig)
  • func (t *TopologyNode) GetHealth(_ context.Context, _ *emptypb.Empty) (*corev1.Health, error)
  • func (t *TopologyNode) SetClient(client node.NodeTopologyCapabilityClient)
  • func (t *TopologyNode) SyncNow(_ context.Context, req *capabilityv1.Filter) (*emptypb.Empty, error)
• type TopologyStreamer
  • func NewTopologyStreamer(ct health.ConditionTracker, lg *slog.Logger) *TopologyStreamer
  • func (s *TopologyStreamer) Run(ctx context.Context, spec *node.TopologyCapabilitySpec) error
  • func (s *TopologyStreamer) SetIdentityClient(identityClient controlv1.IdentityClient)
  • func (s *TopologyStreamer) SetTopologyStreamClient(client stream.RemoteTopologyClient)

Constants

const (
	CondTopologySync = "Topology Sync"
)

Functions

func Scheme

func Scheme(ctx context.Context) meta.Scheme

Types

type BatchingConfig

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

type Plugin

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

func NewPlugin

func NewPlugin(ctx context.Context) *Plugin

func (*Plugin) StreamServers

func (p *Plugin) StreamServers() []streamext.Server

func (*Plugin) UseStreamClient

func (p *Plugin) UseStreamClient(cc grpc.ClientConnInterface)

type TopologyNode

type TopologyNode struct {
	capabilityv1.UnsafeNodeServer
	controlv1.UnsafeHealthServer
	// contains filtered or unexported fields
}

func NewTopologyNode

func NewTopologyNode(ct health.ConditionTracker, lg *slog.Logger) *TopologyNode

func (*TopologyNode) AddConfigListener

func (t *TopologyNode) AddConfigListener(ch chan<- *node.TopologyCapabilityConfig)

func (*TopologyNode) GetHealth

func (t *TopologyNode) GetHealth(_ context.Context, _ *emptypb.Empty) (*corev1.Health, error)

Implement controlv1.HealthServer

func (*TopologyNode) SetClient

func (t *TopologyNode) SetClient(client node.NodeTopologyCapabilityClient)

func (*TopologyNode) SyncNow

func (t *TopologyNode) SyncNow(_ context.Context, req *capabilityv1.Filter) (*emptypb.Empty, error)

Implements capabilityv1.NodeServer

type TopologyStreamer

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

func NewTopologyStreamer

func NewTopologyStreamer(ct health.ConditionTracker, lg *slog.Logger) *TopologyStreamer

func (*TopologyStreamer) Run

func (s *TopologyStreamer) Run(ctx context.Context, spec *node.TopologyCapabilitySpec) error

func (*TopologyStreamer) SetIdentityClient

func (s *TopologyStreamer) SetIdentityClient(identityClient controlv1.IdentityClient)

func (*TopologyStreamer) SetTopologyStreamClient

func (s *TopologyStreamer) SetTopologyStreamClient(client stream.RemoteTopologyClient)