goalstateprocessor

package
v1.15.22 Latest Latest
Warning

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

Go to latest
Published: Feb 12, 2024 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ErrPodOrNodeNameNil = fmt.Errorf("both pod and node name must be set")

Functions

This section is empty.

Types

type GoalStateProcessor

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

func NewGoalStateProcessor

func NewGoalStateProcessor(
	ctx context.Context,
	nodeID string,
	podName string,
	inputChan chan *protos.Events,
	dp dataplane.GenericDataplane) (*GoalStateProcessor, error)

func (*GoalStateProcessor) Start

func (gsp *GoalStateProcessor) Start(stopCh <-chan struct{})

Start kicks off the GoalStateProcessor

func (*GoalStateProcessor) Stop

func (gsp *GoalStateProcessor) Stop()

Stop stops the GoalStateProcessor

Jump to

Keyboard shortcuts

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