controller

Documentation

Index

• Constants
• func AppendUsernames(ce *event.Event, manager *clientManager)
• func GetUsernames(usernamesMap map[string]*client) []string
• func SendCEViaHTTP(ce *cloudevents.Event, uri string)
• type Controller
  • func New(root string) *Controller
  • func (c *Controller) CeHandler(event cloudevents.Event)
  • func (c *Controller) Mux() *http.ServeMux
  • func (c *Controller) RootHandler(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) SetCEClient(client ceclient.Client)
  • func (c *Controller) WSHandler(ws *websocket.Conn)

Constants

const (
	ChatAppEventSource  = "gabo1208.knative-go-chat-app/source"
	FirstUserConnection = "gabo1208.knative-go-chat-app.FirstUserConnection"
	UserReconnected     = "gabo1208.knative-go-chat-app.UserReconnected"
	NewUserConnected    = "gabo1208.knative-go-chat-app.NewUserConnected"
	UserDisconnected    = "gabo1208.knative-go-chat-app.UserDisconnected"
	MessageFromUser     = "gabo1208.knative-go-chat-app.MessageFromUser"
	GetUsers            = "gabo1208.knative-go-chat-app.GetUsers"
	ExternalUsers       = "gabo1208.knative-go-chat-app.ExternalUsers"
	GetConnectedUsers   = "gabo1208.knative-go-chat-app.GetConnectedUsers"
)

Functions

func AppendUsernames

func AppendUsernames(ce *event.Event, manager *clientManager)

func GetUsernames

func GetUsernames(usernamesMap map[string]*client) []string

func SendCEViaHTTP

func SendCEViaHTTP(ce *cloudevents.Event, uri string)

Types

type Controller

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

func New

func New(root string) *Controller

func (*Controller) CeHandler

func (c *Controller) CeHandler(event cloudevents.Event)

func (*Controller) Mux

func (c *Controller) Mux() *http.ServeMux

func (*Controller) RootHandler

func (c *Controller) RootHandler(w http.ResponseWriter, r *http.Request)

func (*Controller) SetCEClient

func (c *Controller) SetCEClient(client ceclient.Client)

func (*Controller) WSHandler

func (c *Controller) WSHandler(ws *websocket.Conn)