httpq

Documentation

Index

• type WebsocketGateway
  • func (o *WebsocketGateway) Broadcast(message *qtiny.Message, discovery qtiny.Discovery) error
  • func (o *WebsocketGateway) GetMeta() map[string]interface{}
  • func (o *WebsocketGateway) GetType() string
  • func (o *WebsocketGateway) Init(config map[string]interface{}) error
  • func (o *WebsocketGateway) Multicast(message *qtiny.Message, discovery qtiny.Discovery) error
  • func (o *WebsocketGateway) Post(message *qtiny.Message, discovery qtiny.Discovery) error
  • func (o *WebsocketGateway) ServeHTTP(response http.ResponseWriter, request *http.Request)
  • func (o *WebsocketGateway) Start(config map[string]interface{}) error
  • func (o *WebsocketGateway) Stop(config map[string]interface{}) error

Types

type WebsocketGateway

type WebsocketGateway struct {
	memory.MemGateway

	Port int

	Endpoints []string
	IPS       []string
	// contains filtered or unexported fields
}

func (*WebsocketGateway) Broadcast

func (o *WebsocketGateway) Broadcast(message *qtiny.Message, discovery qtiny.Discovery) error

func (*WebsocketGateway) GetMeta

func (o *WebsocketGateway) GetMeta() map[string]interface{}

func (*WebsocketGateway) GetType

func (o *WebsocketGateway) GetType() string

func (*WebsocketGateway) Init

func (o *WebsocketGateway) Init(config map[string]interface{}) error

func (*WebsocketGateway) Multicast

func (o *WebsocketGateway) Multicast(message *qtiny.Message, discovery qtiny.Discovery) error

func (*WebsocketGateway) Post

func (o *WebsocketGateway) Post(message *qtiny.Message, discovery qtiny.Discovery) error

func (*WebsocketGateway) ServeHTTP

func (o *WebsocketGateway) ServeHTTP(response http.ResponseWriter, request *http.Request)

func (*WebsocketGateway) Start

func (o *WebsocketGateway) Start(config map[string]interface{}) error

func (*WebsocketGateway) Stop

func (o *WebsocketGateway) Stop(config map[string]interface{}) error