core

Documentation

Index

• func GenerateResultsFromJSON(results []map[string]interface{}) string
• type A
• type Client
• type Core
  • func NewCore() *Core
  • func (c *Core) Init()
• type Hub
  • func InitWebSocketHub() *Hub
  • func (h *Hub) Run()
• type Message
  • func NewErrorMessage() Message
  • func NewErrorMessageWithContent(text string) Message
  • func NewInvalidFormatErrorMessage() Message
  • func NewIvalidTypeErrorMessage() Message
  • func NewMarshalJSONErrorMessage() Message
  • func NewMessage() Message
  • func (m Message) JSONMarshal() []byte

Functions

func GenerateResultsFromJSON

func GenerateResultsFromJSON(results []map[string]interface{}) string

Types

type A

type A struct {
	Title       string
	Description string
	Name        string
}

type Client

type Client struct {
	Hub *Hub

	// The websocket connection.
	Conn *websocket.Conn

	// Buffered channel of outbound messages.
	Send chan []byte
}

Client is a middleman between the websocket connection and the hub.

type Core

type Core struct{}

func NewCore

func NewCore() *Core

func (*Core) Init

func (c *Core) Init()

type Hub

type Hub struct {
	// Registered clients.
	Clients map[*Client]bool

	// Inbound messages from the clients.
	Broadcast chan []byte

	// Register requests from the clients.
	Register chan *Client

	// Unregister requests from clients.
	Unregister chan *Client
}

Hub maintains the set of active clients and broadcasts messages to the clients.

func InitWebSocketHub

func InitWebSocketHub() *Hub

InitWebSocketHub initialize websocket hub

func (*Hub) Run

func (h *Hub) Run()

type Message

type Message struct {
	ID        string      `json:"id"`
	Type      string      `json:"type"`
	Content   string      `json:"content"`
	Data      interface{} `json:"data"`
	Timestamp time.Time   `json:"timestamp"`
}

func NewErrorMessage

func NewErrorMessage() Message

func NewErrorMessageWithContent

func NewErrorMessageWithContent(text string) Message

func NewInvalidFormatErrorMessage

func NewInvalidFormatErrorMessage() Message

func NewIvalidTypeErrorMessage

func NewIvalidTypeErrorMessage() Message

func NewMarshalJSONErrorMessage

func NewMarshalJSONErrorMessage() Message

func NewMessage

func NewMessage() Message

func (Message) JSONMarshal

func (m Message) JSONMarshal() []byte