httpserver

package
v2.4.0-beta.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 2, 2026 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	SseTopicPrefix = "$$sse/"
)
View Source 
const (
	TopicPrefix = "$$httppush/"
)
View Source 
const (
	WebsocketTopicPrefix = "$$websocket/"
)

Variables

This section is empty.

Functions

func CreateConnection 

func CreateConnection(_ api.StreamContext) modules.Connection

func CreateSSEConnection 

func CreateSSEConnection(ctx api.StreamContext) modules.Connection

func CreateWebsocketConnection 

func CreateWebsocketConnection(ctx api.StreamContext) modules.Connection

func InitGlobalServerManager 

func InitGlobalServerManager(ip string, port int, tlsConf *model.TlsConf)

func RegisterEndpoint 

func RegisterEndpoint(endpoint string, method string) (string, error)

func RegisterSSEEndpoint 

func RegisterSSEEndpoint(ctx api.StreamContext, endpoint string) (string, string, error)

func RegisterWebSocketEndpoint 

func RegisterWebSocketEndpoint(ctx api.StreamContext, endpoint string) (string, string, error)

func ShutDown 

func ShutDown()

func UnRegisterSSEEndpoint 

func UnRegisterSSEEndpoint(endpoint string)

func UnRegisterWebSocketEndpoint 

func UnRegisterWebSocketEndpoint(endpoint string)

func UnregisterEndpoint 

func UnregisterEndpoint(endpoint, method string)

Types

type GlobalServerManager 

type GlobalServerManager struct {
	syncx.RWMutex
	// contains filtered or unexported fields
}

func (*GlobalServerManager) AddEndpointConnection 

func (m *GlobalServerManager) AddEndpointConnection(endpoint string, c *websocket.Conn, cancel context.CancelFunc) *sync.WaitGroup

func (*GlobalServerManager) AddSSEConnection 

func (m *GlobalServerManager) AddSSEConnection(endpoint string, connID int64, cancel context.CancelFunc) (*sync.WaitGroup, bool)

func (*GlobalServerManager) CloseEndpointConnection 

func (m *GlobalServerManager) CloseEndpointConnection(endpoint string, c *websocket.Conn)

func (*GlobalServerManager) CloseSSEConnection 

func (m *GlobalServerManager) CloseSSEConnection(endpoint string, connID int64)

func (*GlobalServerManager) FetchInstanceID 

func (m *GlobalServerManager) FetchInstanceID() int

func (*GlobalServerManager) RegisterEndpoint 

func (m *GlobalServerManager) RegisterEndpoint(endpoint string, method string) (string, error)

func (*GlobalServerManager) RegisterSSEEndpoint 

func (m *GlobalServerManager) RegisterSSEEndpoint(ctx api.StreamContext, endpoint string) (string, string, error)

func (*GlobalServerManager) RegisterWebSocketEndpoint 

func (m *GlobalServerManager) RegisterWebSocketEndpoint(ctx api.StreamContext, endpoint string) (string, string, error)

func (*GlobalServerManager) Shutdown 

func (m *GlobalServerManager) Shutdown()

func (*GlobalServerManager) UnRegisterSSEEndpoint 

func (m *GlobalServerManager) UnRegisterSSEEndpoint(endpoint string) *sseEndpointContext

func (*GlobalServerManager) UnRegisterWebSocketEndpoint 

func (m *GlobalServerManager) UnRegisterWebSocketEndpoint(endpoint string) *websocketEndpointContext

func (*GlobalServerManager) UnregisterEndpoint 

func (m *GlobalServerManager) UnregisterEndpoint(endpoint, method string)

type HttpPushConnection 

type HttpPushConnection struct {
	// contains filtered or unexported fields
}

func (*HttpPushConnection) Close 

func (h *HttpPushConnection) Close(ctx api.StreamContext) error

func (*HttpPushConnection) DetachSub 

func (h *HttpPushConnection) DetachSub(ctx api.StreamContext)

func (*HttpPushConnection) Dial 

func (h *HttpPushConnection) Dial(ctx api.StreamContext) error

func (*HttpPushConnection) GetId 

func (h *HttpPushConnection) GetId(ctx api.StreamContext) string

func (*HttpPushConnection) GetTopic 

func (h *HttpPushConnection) GetTopic() string

func (*HttpPushConnection) Ping 

func (h *HttpPushConnection) Ping(ctx api.StreamContext) error

func (*HttpPushConnection) Provision 

func (h *HttpPushConnection) Provision(ctx api.StreamContext, conId string, props map[string]any) error

type SSEConnection 

type SSEConnection struct {
	RecvTopic string
	SendTopic string
	// contains filtered or unexported fields
}

func (*SSEConnection) Close 

func (s *SSEConnection) Close(ctx api.StreamContext) error

func (*SSEConnection) Dial 

func (s *SSEConnection) Dial(ctx api.StreamContext) error

func (*SSEConnection) GetId 

func (s *SSEConnection) GetId(ctx api.StreamContext) string

func (*SSEConnection) Ping 

func (s *SSEConnection) Ping(ctx api.StreamContext) error

func (*SSEConnection) Provision 

func (s *SSEConnection) Provision(ctx api.StreamContext, conId string, props map[string]any) error

type WebsocketClient 

type WebsocketClient struct {
	RecvTopic string
	SendTopic string
	// contains filtered or unexported fields
}

func NewWebsocketClient 

func NewWebsocketClient(scheme, addr, path string, tlsConfig *tls.Config, requestHeader map[string][]string) *WebsocketClient

func (*WebsocketClient) Close 

func (c *WebsocketClient) Close(ctx api.StreamContext) error

func (*WebsocketClient) Connect 

func (c *WebsocketClient) Connect() error

func (*WebsocketClient) Run 

func (c *WebsocketClient) Run(ctx api.StreamContext) (string, string)

type WebsocketConnection 

type WebsocketConnection struct {
	RecvTopic string
	SendTopic string
	// contains filtered or unexported fields
}

func (*WebsocketConnection) Close 

func (w *WebsocketConnection) Close(ctx api.StreamContext) error

func (*WebsocketConnection) Dial 

func (w *WebsocketConnection) Dial(ctx api.StreamContext) error

func (*WebsocketConnection) GetId 

func (w *WebsocketConnection) GetId(ctx api.StreamContext) string

func (*WebsocketConnection) Ping 

func (w *WebsocketConnection) Ping(ctx api.StreamContext) error

func (*WebsocketConnection) Provision 

func (w *WebsocketConnection) Provision(ctx api.StreamContext, conId string, props map[string]any) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.