websockets

package

v0.1.6 Latest Latest Go to latest Published: Nov 17, 2021 License: AGPL-3.0 Imports: 9 Imported by: 0

Details

This section is empty.

View Source

var ProviderSet = wire.NewSet(CreateInitWebSocketFn)

func NewBroadcastSubject() *broadcastSubject

func NewUnicastSubject() *unicastSubject

type Actuator struct {
	Client
}

type ActuatorFetchProcess struct {
}

ActuatorFetchProcess defines messages for actuators to fetch processes.

type ActuatorReturnProcess struct {
}

type ActuatorStatus struct {
}

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

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

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

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

type InitWebsocketGroupFn func(r *gin.RouterGroup)

func CreateInitWebSocketFn() InitWebsocketGroupFn

type JudgeEnd struct {
}

type JudgeStart struct {
}

type Observer interface {
	Notify()
}

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

type User struct {
	Client
}