websocket

Documentation

Index

• type Event
• type Message
  • func ErrorMessage(err error) Message
  • func SubscriptionSuccess(resource, subscriptionId string) Message
  • func UnsubscribeSuccess() Message
• type MessageExecutor
  • func NewSubscribeCommandExecutor(manager *subscription.Manager, mappers mappings.Mappings) MessageExecutor
  • func NewUnsubscribeCommandExecutor(manager *subscription.Manager) MessageExecutor
• type Router
  • func NewRouter() *Router
  • func (r *Router) Add(messageType string, executor MessageExecutor)
  • func (r *Router) Handler() http.HandlerFunc

Types

type Event

type Event struct {
	Type     string      `json:"type"`
	Resource string      `json:"resource"`
	Event    interface{} `json:"event"`
}

type Message

type Message struct {
	Type     string      `json:"type"`
	Resource string      `json:"resource"`
	Message  interface{} `json:"message"`
}

func ErrorMessage

func ErrorMessage(err error) Message

func SubscriptionSuccess

func SubscriptionSuccess(resource, subscriptionId string) Message

func UnsubscribeSuccess

func UnsubscribeSuccess() Message

type MessageExecutor

type MessageExecutor interface {
	Execute(*websocket.Conn, []byte)
}

func NewSubscribeCommandExecutor

func NewSubscribeCommandExecutor(manager *subscription.Manager, mappers mappings.Mappings) MessageExecutor

func NewUnsubscribeCommandExecutor

func NewUnsubscribeCommandExecutor(manager *subscription.Manager) MessageExecutor

type Router

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

func NewRouter

func NewRouter() *Router

func (*Router) Add

func (r *Router) Add(messageType string, executor MessageExecutor)

func (*Router) Handler

func (r *Router) Handler() http.HandlerFunc