controller

Documentation

Index

• Constants
• type DeviceStatus
• type DownstreamController
  • func NewDownstreamController(crdInformerFactory crdinformers.SharedInformerFactory) (*DownstreamController, error)
  • func (dc *DownstreamController) Start() error
• type UpstreamController
  • func NewUpstreamController(dc *DownstreamController) (*UpstreamController, error)
  • func (uc *UpstreamController) Start() error

Constants

const (
	// MergePatchType is patch type
	MergePatchType = "application/merge-patch+json"
	// ResourceTypeDevices is plural of device resource in apiserver
	ResourceTypeDevices = "devices"
)

Types

type DeviceStatus

type DeviceStatus struct {
	Status v1alpha2.DeviceStatus `json:"status"`
}

DeviceStatus is structure to patch device status

type DownstreamController

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

DownstreamController watch kubernetes api server and send change to edge

func NewDownstreamController

func NewDownstreamController(crdInformerFactory crdinformers.SharedInformerFactory) (*DownstreamController, error)

NewDownstreamController create a DownstreamController from config

func (*DownstreamController) Start

func (dc *DownstreamController) Start() error

Start DownstreamController

type UpstreamController

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

UpstreamController subscribe messages from edge and sync to k8s api server

func NewUpstreamController

func NewUpstreamController(dc *DownstreamController) (*UpstreamController, error)

NewUpstreamController create UpstreamController from config

func (*UpstreamController) Start

func (uc *UpstreamController) Start() error

Start UpstreamController