agent

Documentation

Index

• Constants
• func Scheme(ctx context.Context) meta.Scheme
• type ConditionStatus
  • func (s ConditionStatus) String() string
• type ConditionTracker
  • func NewConditionTracker(logger *zap.SugaredLogger) ConditionTracker
• type LoggingNode
  • func NewLoggingNode(ct ConditionTracker, lg *zap.SugaredLogger) *LoggingNode
  • func (m *LoggingNode) AddConfigListener(ch chan<- *node.LoggingCapabilityConfig)
  • func (l *LoggingNode) GetHealth(_ context.Context, _ *emptypb.Empty) (*corev1.Health, error)
  • func (m *LoggingNode) Info(_ context.Context, _ *emptypb.Empty) (*capabilityv1.InfoResponse, error)
  • func (m *LoggingNode) SetClient(client node.NodeLoggingCapabilityClient)
  • func (l *LoggingNode) SyncNow(_ context.Context, req *capabilityv1.Filter) (*emptypb.Empty, error)
• type Plugin
  • func NewPlugin(ctx context.Context) *Plugin
  • func (p *Plugin) StreamServers() []streamext.Server
  • func (p *Plugin) UseStreamClient(cc grpc.ClientConnInterface)

Constants

const (
	CondConfigSync = "Config Sync"
)

Functions

func Scheme

func Scheme(ctx context.Context) meta.Scheme

Types

type ConditionStatus

type ConditionStatus int32

const (
	StatusPending ConditionStatus = 0
	StatusFailure ConditionStatus = 1
)

func (ConditionStatus) String

func (s ConditionStatus) String() string

type ConditionTracker

type ConditionTracker interface {
	Set(key string, value ConditionStatus, reason string)
	Clear(key string, reason ...string)
	List() []string
}

func NewConditionTracker

func NewConditionTracker(logger *zap.SugaredLogger) ConditionTracker

type LoggingNode

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

func NewLoggingNode

func NewLoggingNode(ct ConditionTracker, lg *zap.SugaredLogger) *LoggingNode

func (*LoggingNode) AddConfigListener

func (m *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 (m *LoggingNode) Info(_ context.Context, _ *emptypb.Empty) (*capabilityv1.InfoResponse, error)

func (*LoggingNode) SetClient

func (m *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)