goalstateprocessor

Documentation

Index

• Variables
• type GoalStateProcessor
  • func NewGoalStateProcessor(ctx context.Context, nodeID string, podName string, ...) (*GoalStateProcessor, error)
  • func (gsp *GoalStateProcessor) Start(stopCh <-chan struct{})
  • func (gsp *GoalStateProcessor) Stop()

Variables

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

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