controller

package
v1.23.0-cx Latest Latest
Warning

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

Go to latest
Published: Apr 24, 2026 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Index

Constants

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

Variables

This section is empty.

Functions

This section is empty.

Types

type DeviceStatus

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

DeviceStatus is structure to patch device status

type DeviceStatusCRDPatch

type DeviceStatusCRDPatch struct {
	Status DeviceStatusStatusPatch `json:"status"`
}

DeviceStatusCRDPatch is structure to patch device status CRD with Extensions excluded

type DeviceStatusStatusPatch

type DeviceStatusStatusPatch struct {
	Twins          []v1beta1.Twin `json:"twins,omitempty"`
	State          string         `json:"state,omitempty"`
	LastOnlineTime string         `json:"lastOnlineTime,omitempty"`
}

DeviceStatusStatusPatch is structure to patch device status status with Extensions excluded

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

Jump to

Keyboard shortcuts

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