Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConnStatus ¶
type ConnStatus struct {
websocket.ConnStatus
IsMaster bool
}
ConnStatus represents the status of a connection to a hub
type Opts ¶ added in v0.23.0
type Opts struct {
ServerOpts websocket.ServerOpts
Validator validator.Validator
}
Opts defines pod server options
type Pod ¶
type Pod struct {
// contains filtered or unexported fields
}
Pod describes a graph pod. It maintains a local graph in memory and forward any event to graph hubs
func NewPod ¶
func NewPod(server *api.Server, clientPool *websocket.StructClientPool, g *graph.Graph, apiAuthBackend shttp.AuthenticationBackend, clusterAuthOptions *shttp.AuthenticationOpts, tr *traversal.GremlinTraversalParser, opts Opts) (*Pod, error)
NewPod returns a new pod
func (*Pod) SubscriberServer ¶
func (p *Pod) SubscriberServer() *websocket.StructServer
SubscriberServer returns the websocket server dedicated to subscribers
type Status ¶
type Status struct {
Subscribers map[string]websocket.ConnStatus
Hubs map[string]ConnStatus
}
Status describes the status of a pod
Click to show internal directories.
Click to hide internal directories.