agent

Documentation

Index

• Variables
• type Agent
  • func NewAgent(options *Options) (*Agent, error)
  • func (agent *Agent) Close() error
  • func (agent *Agent) Run() error
  • func (agent *Agent) Start(ctx context.Context) error
  • func (agent *Agent) Wait() error
• type Config
  • func (c *Config) Marshal() ([]byte, error)
  • func (c *Config) Unmarshal(b []byte) error
• type Options

Variables

var ErrNotInCluster = errors.New("unable to load in-cluster configuration, KUBERNETES_SERVICE_HOST and KUBERNETES_SERVICE_PORT must be defined")

Types

type Agent

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

func NewAgent

func NewAgent(options *Options) (*Agent, error)

func (*Agent) Close

func (agent *Agent) Close() error

func (*Agent) Run

func (agent *Agent) Run() error

func (*Agent) Start

func (agent *Agent) Start(ctx context.Context) error

func (*Agent) Wait

func (agent *Agent) Wait() error

type Config

type Config struct {
	// Protocol version
	Version string

	// Name of the agent
	Name string

	// Token used to authenticate with proxy server
	Token string

	// Kubernetes apiserver host
	KubernetesSvcHost string

	// KubeSphere apigateway host
	KubeSphereSvcHost string

	// agent certificates
	// CertData holds PEM-encoded bytes (typically read from a client certificate file).
	CertData []byte `json:",omitempty"`
	// KeyData holds PEM-encoded bytes (typically read from a client certificate key file).
	KeyData []byte `json:",omitempty"`
	// CAData holds PEM-encoded bytes (typically read from a root certificates bundle).
	CAData []byte `json:",omitempty"`

	// Server requires Bearer authentication. This client will not attempt to use
	// refresh tokens for an OAuth2 flow.
	BearerToken []byte `json:",omitempty"`
}

func (*Config) Marshal

func (c *Config) Marshal() ([]byte, error)

func (*Config) Unmarshal

func (c *Config) Unmarshal(b []byte) error

type Options

type Options struct {
	KeepAlive              time.Duration
	MaxRetryCount          int
	MaxRetryInterval       time.Duration
	KubernetesApiserverSvc string
	KubesphereApiserverSvc string
	Server                 string
	Name                   string
	Token                  string

	Kubeconfig string
}