dataset

Documentation

Index

• Constants
• func New(cc *runtime.ControllerContext) (runtime.FeatureControllerI, error)
• type Controller
  • func (c *Controller) Run(stopCh <-chan struct{})
  • func (c *Controller) SetDownstreamSendFunc(f runtime.DownstreamSendFunc) error
  • func (c *Controller) SetUpstreamHandler(addFunc runtime.UpstreamHandlerAddFunc) error

Constants

const (
	// KindName is the kind name of CR this controller controls
	KindName = "Dataset"

	// Name is this controller name
	Name = "Dataset"
)

Functions

func New

func New(cc *runtime.ControllerContext) (runtime.FeatureControllerI, error)

New creates a dataset controller

Types

type Controller

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

Controller handles all dataset objects including: syncing to edge and update from edge.

func (*Controller) Run

func (c *Controller) Run(stopCh <-chan struct{})

func (*Controller) SetDownstreamSendFunc

func (c *Controller) SetDownstreamSendFunc(f runtime.DownstreamSendFunc) error

func (*Controller) SetUpstreamHandler

func (c *Controller) SetUpstreamHandler(addFunc runtime.UpstreamHandlerAddFunc) error