tunnel

Documentation

Index

• Constants
• Variables
• func NewTunnelServer() *websocketDialer.Server
• func StartPeerManager(conf *config.UserMgrConfig, dialerServer *websocketDialer.Server) error
• type PeerRDiscover
• type RegisterCluster

Constants

const (
	// Module http tunnel header
	Module = "BCS-API-Tunnel-Module"
	// RegisterToken http tunnel header
	RegisterToken = "BCS-API-Tunnel-Token"
	// Params http tunnel header
	Params = "BCS-API-Tunnel-Params"
	// Cluster http tunnel header
	Cluster = "BCS-API-Tunnel-ClusterId"
	// KubeAgentModule http tunnel header
	KubeAgentModule = "kube-agent"
	// K8sDriverModule http tunnel header
	K8sDriverModule = "k8s-driver"
	// MesosDriverModule http tunnel header
	MesosDriverModule = "mesos-driver"
)

Variables

var (
	// DefaultTunnelServer default server implementation
	DefaultTunnelServer *websocketDialer.Server
)

Functions

func NewTunnelServer

func NewTunnelServer() *websocketDialer.Server

NewTunnelServer create websocket tunnel server

func StartPeerManager

func StartPeerManager(conf *config.UserMgrConfig, dialerServer *websocketDialer.Server) error

StartPeerManager manage mutual tunnel connection

Types

type PeerRDiscover

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

PeerRDiscover tunnel peer discovery

type RegisterCluster

type RegisterCluster struct {
	Address   string `json:"address"`
	UserToken string `json:"userToken"`
	CACert    string `json:"caCert"`
}

RegisterCluster definition of tunnel cluster info