tunnel

Dec 3, 2024

Changes in this version

type MockTunnel

+ func (m *MockTunnel) RegisterNode(initData model.NodeInfo)

+ func (m *MockTunnel) UnRegisterNode(nodeName string)

+ type OnBaseDiscovered func(model.NodeInfo)

+ type OnBaseStatusArrived func(string, model.NodeStatusData)

type Tunnel

+ RegisterNode func(initData model.NodeInfo)

+ UnRegisterNode func(nodeName string)

Nov 12, 2024

Changes in this version

type MockTunnel

+ func (m *MockTunnel) GetBizUniqueKey(container *corev1.Container) string

+ func (m *MockTunnel) QueryAllBizStatusData(ctx context.Context, nodeID string) error

+ func (m *MockTunnel) StartBiz(ctx context.Context, nodeID, podKey string, container *corev1.Container) error

+ func (m *MockTunnel) StopBiz(ctx context.Context, nodeID, podKey string, container *corev1.Container) error

+ func (m *MockTunnel) UpdateBizStatus(ctx context.Context, nodeID, containerKey string, data model.BizStatusData)

+ type OnAllBizStatusArrived func(string, []model.BizStatusData)

+ type OnSingleBizStatusArrived func(string, model.BizStatusData)

type Tunnel

+ GetBizUniqueKey func(container *v1.Container) string

+ QueryAllBizStatusData func(ctx context.Context, nodeID string) error

+ StartBiz func(ctx context.Context, nodeID, podKey string, container *v1.Container) error

+ StopBiz func(ctx context.Context, nodeID, podKey string, container *v1.Container) error

Oct 17, 2024

Changes in this version

type MockTunnel

+ NodeNotReady map[string]bool

+ func (m *MockTunnel) OnNodeNotReady(ctx context.Context, info model.UnreachableNodeInfo)

type Tunnel

+ OnNodeNotReady func(ctx context.Context, info model.UnreachableNodeInfo)

Sep 11, 2024

Changes in this version

+ type MockTunnel struct

+ func (m *MockTunnel) DeleteNode(nodeID string)

+ func (m *MockTunnel) FetchHealthData(ctx context.Context, nodeID string) error

+ func (m *MockTunnel) GetContainerUniqueKey(podKey string, container *corev1.Container) string

+ func (m *MockTunnel) Key() string

+ func (m *MockTunnel) OnNodeStart(ctx context.Context, nodeID string)

+ func (m *MockTunnel) OnNodeStop(ctx context.Context, nodeID string)

+ func (m *MockTunnel) PutContainer(nodeID, containerKey string, data model.ContainerStatusData)

+ func (m *MockTunnel) PutNode(nodeID string, node Node)

+ func (m *MockTunnel) QueryAllContainerStatusData(ctx context.Context, nodeID string) error

+ func (m *MockTunnel) Ready() bool

+ func (m *MockTunnel) RegisterCallback(discovered OnNodeDiscovered, onNodeStatusDataArrived OnNodeStatusDataArrived, ...)

+ func (m *MockTunnel) ShutdownContainer(ctx context.Context, nodeID, podKey string, container *corev1.Container) error

+ func (m *MockTunnel) Start(ctx context.Context, clientID string, env string) error

+ func (m *MockTunnel) StartContainer(ctx context.Context, nodeID, podKey string, container *corev1.Container) error

+ type Node struct

+ type OnNodeDiscovered func(string, model.NodeInfo, Tunnel)

+ type OnNodeStatusDataArrived func(string, model.NodeStatusData)

+ type OnQueryAllContainerStatusDataArrived func(string, []model.ContainerStatusData)

+ type OnSingleContainerStatusChanged func(string, model.ContainerStatusData)

type Tunnel

+ GetContainerUniqueKey func(podKey string, container *v1.Container) string

+ Key func() string

+ OnNodeStart func(ctx context.Context, nodeID string)

+ OnNodeStop func(ctx context.Context, nodeID string)

+ QueryAllContainerStatusData func(ctx context.Context, nodeID string) error

+ Ready func() bool

+ RegisterCallback func(OnNodeDiscovered, OnNodeStatusDataArrived, ...)

+ ShutdownContainer func(ctx context.Context, nodeID, podKey string, container *v1.Container) error

+ Start func(ctx context.Context, clientID string, env string) error

+ StartContainer func(ctx context.Context, nodeID, podKey string, container *v1.Container) error

Jul 29, 2024

Changes in this version

+ type BaseDiscoveredCallback func(string, model.HeartBeatData, Tunnel)

+ type HealthDataArrivedCallback func(string, ark.HealthData)

+ type QueryAllBizDataArrivedCallback func(string, []ark.ArkBizInfo)

+ type Tunnel interface

+ FetchHealthData func(context.Context, string) error

+ InstallBiz func(context.Context, string, *ark.BizModel) error

+ Name func() string

+ OnBaseStart func(context.Context, string)

+ OnBaseStop func(context.Context, string)

+ QueryAllBizData func(context.Context, string) error

+ Register func(context.Context, string, BaseDiscoveredCallback, HealthDataArrivedCallback, ...) error

+ UninstallBiz func(context.Context, string, *ark.BizModel) error