Versions in this module Expand all Collapse all v1 v1.0.1 Nov 9, 2023 v1.0.0 Nov 9, 2023 Changes in this version + func CreateInboundPod(ctx context.Context, factory cmdutil.Factory, clientset *kubernetes.Clientset, ...) error + func DetectAndDisableConflictDevice(origin string) error + func Start(ctx context.Context, r Route) (chan error, error) + type ConnectOptions struct + Ctx context.Context + KubeconfigBytes []byte + KubeconfigPath string + Namespace string + Uid string + Workloads []string + func (c *ConnectOptions) ConnectPingRemote() bool + func (c *ConnectOptions) DoConnect(ctx context.Context) (chan error, error) + func (c *ConnectOptions) DoReverse(ctx context.Context) error + func (c *ConnectOptions) GenerateTunIP(ctx context.Context) error + func (c *ConnectOptions) GetClientSet() *kubernetes.Clientset + func (c *ConnectOptions) GetLogger() *log.Logger + func (c *ConnectOptions) GetUnstructuredObject(workload string) (*resource.Info, error) + func (c *ConnectOptions) InitClient(ctx context.Context) (err error) + func (c *ConnectOptions) InitDHCP(ctx context.Context) error + func (c *ConnectOptions) IsEmpty() bool + func (c *ConnectOptions) IsSameUid(another *ConnectOptions) bool + func (c *ConnectOptions) Prepare(ctx context.Context) error + func (c *ConnectOptions) ReleaseIP() error + func (c *ConnectOptions) RemoveInboundPod() error + func (c *ConnectOptions) RentIP(random bool) (ip *net.IPNet, err error) + func (c *ConnectOptions) ReverePingLocal() bool + func (c *ConnectOptions) SetLogger(logger *log.Logger) + func (c *ConnectOptions) Shell(_ context.Context, workload string) (string, error) + func (c *ConnectOptions) WaitTrafficManagerToAssignAnIP(log *log.Logger) error + type Route struct + ChainNode string + Retries int + ServeNodes []string + func (r *Route) GenRouters() ([]router, error)