handler

Documentation

Index

• Constants
• Variables
• func InitHandler(eventq *channelq.ChannelMessageQueue)
• type ExitCode
• type HandleFunc
• type MessageHandle
  • func (mh *MessageHandle) GetNodeCount() int
  • func (mh *MessageHandle) HandleServer(container *mux.MessageContainer, writer mux.ResponseWriter)
  • func (mh *MessageHandle) KeepaliveCheckLoop(hi hubio.CloudHubIO, info *model.HubInfo, stopServe chan ExitCode, ...)
  • func (mh *MessageHandle) ListMessageWriteLoop(hi hubio.CloudHubIO, info *model.HubInfo, stopServe chan ExitCode, ...)
  • func (mh *MessageHandle) MessageWriteLoop(hi hubio.CloudHubIO, info *model.HubInfo, stopServe chan ExitCode, ...)
  • func (mh *MessageHandle) OnRegister(connection conn.Connection)
  • func (mh *MessageHandle) PubToController(info *model.HubInfo, msg *beehiveModel.Message) error
  • func (mh *MessageHandle) RegisterNode(hi hubio.CloudHubIO, info *model.HubInfo) error
  • func (mh *MessageHandle) ServeConn(hi hubio.CloudHubIO, info *model.HubInfo)
  • func (mh *MessageHandle) UnregisterNode(hi hubio.CloudHubIO, info *model.HubInfo, code ExitCode)

Constants

const (
	MsgFormatError = "message format not correct"
	VolumePattern  = `^\w[-\w.+]*/` + constants.CSIResourceTypeVolume + `/\w[-\w.+]*`
)

constants for error message

Variables

var VolumeRegExp = regexp.MustCompile(VolumePattern)

VolumeRegExp is used to validate the volume resource

Functions

func InitHandler

func InitHandler(eventq *channelq.ChannelMessageQueue)

InitHandler create a handler for websocket and quic servers

Types

type ExitCode

type ExitCode int

ExitCode exit code

type HandleFunc

type HandleFunc func(hi hubio.CloudHubIO, info *model.HubInfo, exitServe chan ExitCode, stopSendMsg chan struct{})

type MessageHandle

type MessageHandle struct {
	KeepaliveInterval int
	WriteTimeout      int
	Nodes             sync.Map

	MessageQueue     *channelq.ChannelMessageQueue
	Handlers         []HandleFunc
	NodeLimit        int
	KeepaliveChannel map[string]chan struct{}
	MessageAcks      sync.Map
	// contains filtered or unexported fields
}

MessageHandle processes messages between cloud and edge

var CloudhubHandler *MessageHandle

CloudhubHandler the shared handler for both websocket and quic servers

func (*MessageHandle) GetNodeCount

func (mh *MessageHandle) GetNodeCount() int

GetNodeCount returns the number of connected Nodes

func (*MessageHandle) HandleServer

func (mh *MessageHandle) HandleServer(container *mux.MessageContainer, writer mux.ResponseWriter)

HandleServer handle all the request from node

func (*MessageHandle) KeepaliveCheckLoop

func (mh *MessageHandle) KeepaliveCheckLoop(hi hubio.CloudHubIO, info *model.HubInfo, stopServe chan ExitCode, stopSendMsg chan struct{})

KeepaliveCheckLoop checks whether the edge node is still alive

func (*MessageHandle) ListMessageWriteLoop

func (mh *MessageHandle) ListMessageWriteLoop(hi hubio.CloudHubIO, info *model.HubInfo, stopServe chan ExitCode, stopSendMsg chan struct{})

ListMessageWriteLoop processes all list type resource write requests

func (*MessageHandle) MessageWriteLoop

func (mh *MessageHandle) MessageWriteLoop(hi hubio.CloudHubIO, info *model.HubInfo, stopServe chan ExitCode, stopSendMsg chan struct{})

MessageWriteLoop processes all write requests

func (*MessageHandle) OnRegister

func (mh *MessageHandle) OnRegister(connection conn.Connection)

OnRegister register node on first connection

func (*MessageHandle) PubToController

func (mh *MessageHandle) PubToController(info *model.HubInfo, msg *beehiveModel.Message) error

func (*MessageHandle) RegisterNode

func (mh *MessageHandle) RegisterNode(hi hubio.CloudHubIO, info *model.HubInfo) error

RegisterNode register node in cloudhub for the incoming connection

func (*MessageHandle) ServeConn

func (mh *MessageHandle) ServeConn(hi hubio.CloudHubIO, info *model.HubInfo)

ServeConn starts serving the incoming connection

func (*MessageHandle) UnregisterNode

func (mh *MessageHandle) UnregisterNode(hi hubio.CloudHubIO, info *model.HubInfo, code ExitCode)

UnregisterNode unregister node in cloudhub