Documentation ¶
Index ¶
- func Scheme(ctx context.Context) meta.Scheme
- type LoggingNode
- func (l *LoggingNode) AddConfigListener(ch chan<- *node.LoggingCapabilityConfig)
- func (l *LoggingNode) GetHealth(_ context.Context, _ *emptypb.Empty) (*corev1.Health, error)
- func (l *LoggingNode) Info(_ context.Context, _ *emptypb.Empty) (*capabilityv1.Details, error)
- func (l *LoggingNode) SetClient(client node.NodeLoggingCapabilityClient)
- func (l *LoggingNode) SyncNow(_ context.Context, req *capabilityv1.Filter) (*emptypb.Empty, error)
- type Plugin
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type LoggingNode ¶
type LoggingNode struct { capabilityv1.UnsafeNodeServer controlv1.UnsafeHealthServer // contains filtered or unexported fields }
func NewLoggingNode ¶
func NewLoggingNode(ct health.ConditionTracker, lg *zap.SugaredLogger) *LoggingNode
func (*LoggingNode) AddConfigListener ¶
func (l *LoggingNode) AddConfigListener(ch chan<- *node.LoggingCapabilityConfig)
func (*LoggingNode) Info ¶
func (l *LoggingNode) Info(_ context.Context, _ *emptypb.Empty) (*capabilityv1.Details, error)
func (*LoggingNode) SetClient ¶
func (l *LoggingNode) SetClient(client node.NodeLoggingCapabilityClient)
func (*LoggingNode) SyncNow ¶
func (l *LoggingNode) SyncNow(_ context.Context, req *capabilityv1.Filter) (*emptypb.Empty, error)
Implements capabilityv1.NodeServer
type Plugin ¶
type Plugin struct {
// contains filtered or unexported fields
}
func (*Plugin) StreamDisconnected ¶ added in v0.6.1
func (p *Plugin) StreamDisconnected()
func (*Plugin) StreamServers ¶
func (*Plugin) UseStreamClient ¶
func (p *Plugin) UseStreamClient(cc grpc.ClientConnInterface)
Click to show internal directories.
Click to hide internal directories.