agent

Documentation

Index

• Constants
• func ParseJSONFile(content []byte) (map[string]string, error)
• func ParseKV(file string) (map[string]string, error)
• func ParseKVFile(content []byte) (map[string]string, error)
• func ParseToMaps(list []string) map[string]string
• func ReadManufacture(options *options.AgentOptions, clientID string) (map[string]string, error)
• func Run(ctx context.Context, options *options.AgentOptions) error
• type AgentAPI
  • func (a *AgentAPI) Run(ctx context.Context, listen string) error
• type EdgeAgent
  • func (ea *EdgeAgent) RunKeepAliveRouter(ctx context.Context, duration time.Duration, ...) error

Constants

const ClientIDSecret = "kubegems-edge-agent-id"

Functions

func ParseJSONFile

func ParseJSONFile(content []byte) (map[string]string, error)

func ParseKV

func ParseKV(file string) (map[string]string, error)

func ParseKVFile

func ParseKVFile(content []byte) (map[string]string, error)

ParseKVFile parse kv from FOO="bar" likes file

func ParseToMaps

func ParseToMaps(list []string) map[string]string

func ReadManufacture

func ReadManufacture(options *options.AgentOptions, clientID string) (map[string]string, error)

func Run

func Run(ctx context.Context, options *options.AgentOptions) error

Types

type AgentAPI

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

func (*AgentAPI) Run

func (a *AgentAPI) Run(ctx context.Context, listen string) error

type EdgeAgent

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

func (*EdgeAgent) RunKeepAliveRouter

func (ea *EdgeAgent) RunKeepAliveRouter(ctx context.Context, duration time.Duration, annotationsfunc func(ctx context.Context) tunnel.Annotations) error