stub

Documentation

Index

• Variables
• func GetStubAddress(clientIp string, clientId string) string
• type Client
• type StubConnection
  • func NewStubConnection(address string, conn pb.MsmControlPlane_SendServer) *StubConnection
• type StubHandler
  • func NewStubHandler(cfg *config.Cfg) *StubHandler
  • func (s *StubHandler) OnAdd(conn pb.MsmControlPlane_SendServer, stream *pb.Message)
  • func (s *StubHandler) OnDelete(connectionKey model.ConnectionKey, conn pb.MsmControlPlane_SendServer)
  • func (s *StubHandler) OnRegistration(conn pb.MsmControlPlane_SendServer, proxyIp string)

Variables

var StubMap *sync.Map

Functions

func GetStubAddress

func GetStubAddress(clientIp string, clientId string) string

Types

type Client

type Client struct {
	ClientId string
	ClientIp string
	Port     uint32
}

type StubConnection

type StubConnection struct {
	Address string
	Conn    pb.MsmControlPlane_SendServer
	Clients map[string]Client
}

func NewStubConnection

func NewStubConnection(address string, conn pb.MsmControlPlane_SendServer) *StubConnection

type StubHandler

type StubHandler struct {
	StubChannels map[string]*model2.StubChannel
	// contains filtered or unexported fields
}

func NewStubHandler

func NewStubHandler(cfg *config.Cfg) *StubHandler

func (*StubHandler) OnAdd

func (s *StubHandler) OnAdd(conn pb.MsmControlPlane_SendServer, stream *pb.Message)

Call when receive ADD event

func (*StubHandler) OnDelete

func (s *StubHandler) OnDelete(connectionKey model.ConnectionKey, conn pb.MsmControlPlane_SendServer)

Call when receive DELETE event

func (*StubHandler) OnRegistration

func (s *StubHandler) OnRegistration(conn pb.MsmControlPlane_SendServer, proxyIp string)

Call when receive REGISTRATION event