websockets

Documentation

Index

• Variables
• func NewBroadcastSubject() *broadcastSubject
• func NewUnicastSubject() *unicastSubject
• type Actuator
• type ActuatorFetchProcess
• type ActuatorReturnProcess
• type ActuatorStatus
• type Client
• type Hub
• type InitWebsocketGroupFn
  • func CreateInitWebSocketFn() InitWebsocketGroupFn
• type JudgeEnd
• type JudgeStart
• type Observer
• type Subject
• type User

Variables

var ProviderSet = wire.NewSet(CreateInitWebSocketFn)

Functions

func NewBroadcastSubject

func NewBroadcastSubject() *broadcastSubject

func NewUnicastSubject

func NewUnicastSubject() *unicastSubject

Types

type Actuator

type Actuator struct {
	Client
}

type ActuatorFetchProcess

type ActuatorFetchProcess struct {
}

ActuatorFetchProcess defines messages for actuators to fetch processes.

type ActuatorReturnProcess

type ActuatorReturnProcess struct {
}

type ActuatorStatus

type ActuatorStatus struct {
}

type Client

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

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

type Hub

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

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

type InitWebsocketGroupFn

type InitWebsocketGroupFn func(r *gin.RouterGroup)

func CreateInitWebSocketFn

func CreateInitWebSocketFn() InitWebsocketGroupFn

type JudgeEnd

type JudgeEnd struct {
}

type JudgeStart

type JudgeStart struct {
}

type Observer

type Observer interface {
	Notify()
}

type Subject

type Subject interface {
	AddObservers(observers ...Observer)
	NotifyObservers()
}

type User

type User struct {
	Client
}