utils

package

v1.1.1 Latest Latest Go to latest Published: Sep 25, 2020 License: MIT Imports: 13 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/cetic/kubeedge-edge-worker

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func AddDeviceCrds(scheme *runtime.Scheme) error
func GetTimeStamp() string
func NewCRDClient(MasterAdress, KubeConfigPath string) (*rest.RESTClient, error)
type Device
type K8SConfig
- func NewK8SConfig(MasterAdress, KubeConfigPath string) K8SConfig
- func (k *K8SConfig) Generate() (conf *rest.Config, err error)

Constants ¶

View Source

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

Variables ¶

This section is empty.

Functions ¶

func AddDeviceCrds ¶

func AddDeviceCrds(scheme *runtime.Scheme) error

func GetTimeStamp ¶

func GetTimeStamp() string

func NewCRDClient ¶

func NewCRDClient(MasterAdress, KubeConfigPath string) (*rest.RESTClient, error)

NewCRDClient is used to create a restClient for crd

Types ¶

type Device ¶

type Device struct {
	Status    ke.DeviceStatus `json:"status"`
	DeviceID  string          `json:"-"`
	Namespace string          `json:"-"`

	FSM      *fsm.FSM `json:"-"`
	Filename string
	Url      string
	// contains filtered or unexported fields
}

func (*Device) AddDesiredArg ¶

func (s *Device) AddDesiredArg(arg string)

func (*Device) AddDesiredJob ¶

func (s *Device) AddDesiredJob(job string)

func (*Device) GetStatus ¶

func (s *Device) GetStatus() string

func (*Device) InitDevice ¶

func (s *Device) InitDevice(id, ns string, crdClient *rest.RESTClient) error

func (*Device) Launch ¶

func (s *Device) Launch(filename, url string)

func (*Device) PatchStatus ¶

func (s *Device) PatchStatus() ([]byte, error)

func (*Device) SyncStatus ¶

func (s *Device) SyncStatus() error

type K8SConfig ¶

type K8SConfig struct {
	MasterAdress   string
	KubeConfigPath string
	QPS            float32
	Burst          int
	ContentType    string
}

func NewK8SConfig ¶

func NewK8SConfig(MasterAdress, KubeConfigPath string) K8SConfig

func (*K8SConfig) Generate ¶

func (k *K8SConfig) Generate() (conf *rest.Config, err error)

Source Files ¶

View all Source files

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