httpserver

Documentation

Index

• Constants
• func CheckWebsocketEndpoint(endpoint string) bool
• func GetWebsocketEndpointCh(endpoint string) (string, string, chan struct{}, error)
• func RegisterEndpoint(endpoint string, method string, _ string) (string, chan struct{}, error)
• func RegisterWebSocketEndpoint(ctx api.StreamContext, endpoint string) (string, string, chan struct{}, error)
• func UnRegisterWebSocketEndpoint(endpoint string) error
• func UnregisterEndpoint(endpoint string)

Constants

const (
	TopicPrefix            = "$$httppush/"
	WebsocketTopicPrefix   = "$$websocket/"
	WebsocketServerDataKey = "$$websocket/server/data"
)

Functions

func CheckWebsocketEndpoint

func CheckWebsocketEndpoint(endpoint string) bool

func GetWebsocketEndpointCh

func GetWebsocketEndpointCh(endpoint string) (string, string, chan struct{}, error)

func RegisterEndpoint

func RegisterEndpoint(endpoint string, method string, _ string) (string, chan struct{}, error)

func RegisterWebSocketEndpoint

func RegisterWebSocketEndpoint(ctx api.StreamContext, endpoint string) (string, string, chan struct{}, error)

func UnRegisterWebSocketEndpoint

func UnRegisterWebSocketEndpoint(endpoint string) error

func UnregisterEndpoint

func UnregisterEndpoint(endpoint string)