Documentation ¶
Index ¶
- Constants
- func Scheme(ctx context.Context) meta.Scheme
- type BatchingConfig
- type Plugin
- type 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
Constants ¶
View Source
const (
CondTopologySync = "Topology Sync"
)
Variables ¶
This section is empty.
Functions ¶
Types ¶
type BatchingConfig ¶
type BatchingConfig struct {
// contains filtered or unexported fields
}
type Plugin ¶
type Plugin struct {
// contains filtered or unexported fields
}
func (*Plugin) StreamServers ¶
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 *zap.SugaredLogger) *TopologyNode
func (*TopologyNode) AddConfigListener ¶
func (t *TopologyNode) AddConfigListener(ch chan<- *node.TopologyCapabilityConfig)
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 *zap.SugaredLogger) *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)
Click to show internal directories.
Click to hide internal directories.