socket

Documentation

Index

• type Hub
• type SocketHandler
  • func GetHandler() *SocketHandler
  • func (sh *SocketHandler) Serve(w http.ResponseWriter, r *http.Request)
• type SocketMessage

Types

type Hub

type Hub struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type SocketHandler

type SocketHandler struct{}

func GetHandler

func GetHandler() *SocketHandler

call only once

func (*SocketHandler) Serve

func (sh *SocketHandler) Serve(w http.ResponseWriter, r *http.Request)

type SocketMessage

type SocketMessage struct {
	Action     string
	Topic      string
	Partitions []string
	From       time.Time
}