agent

package
v0.11.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 9, 2023 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Scheme

func Scheme(ctx context.Context) meta.Scheme

Types

type LoggingNode

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

func (*LoggingNode) AddConfigListener

func (l *LoggingNode) AddConfigListener(ch chan<- *node.LoggingCapabilityConfig)

func (*LoggingNode) GetHealth

func (l *LoggingNode) GetHealth(_ context.Context, _ *emptypb.Empty) (*corev1.Health, error)

Implements controlv1.HealthServer

func (*LoggingNode) Info

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 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)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL