pod

Documentation

Index

• type ConnStatus
• type Opts
• type Pod
  • func NewPod(id string, serviceType service.Type, listen string, podEndpoint string, ...) (*Pod, error)
  • func (p *Pod) APIServer() *api.Server
  • func (p *Pod) ClientPool() *websocket.StructClientPool
  • func (p *Pod) Forwarder() *clients.Forwarder
  • func (p *Pod) GetStatus() interface{}
  • func (p *Pod) GremlinTraversalParser() *traversal.GremlinTraversalParser
  • func (p *Pod) HTTPServer() *shttp.Server
  • func (p *Pod) Start() error
  • func (p *Pod) Stop()
  • func (p *Pod) SubscriberServer() *websocket.StructServer
• type Status

Types

type ConnStatus

type ConnStatus struct {
	websocket.ConnStatus
	IsMaster bool
}

ConnStatus represents the status of a connection to a hub

type Opts

type Opts struct {
	Version             string
	Hubs                []service.Address
	WebsocketOpts       websocket.ServerOpts
	WebsocketClientOpts websocket.ClientOpts
	APIValidator        api.Validator
	GraphValidator      schema.Validator
	TopologyMarshallers api.TopologyMarshallers
	StatusReporter      api.StatusReporter
	TLSConfig           *tls.Config
	APIAuthBackend      shttp.AuthenticationBackend
	Logger              logging.Logger
}

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(id string, serviceType service.Type, listen string, podEndpoint string, g *graph.Graph, opts Opts) (*Pod, error)

NewPod returns a new pod

func (*Pod) APIServer

func (p *Pod) APIServer() *api.Server

APIServer returns the pod API server

func (*Pod) ClientPool

func (p *Pod) ClientPool() *websocket.StructClientPool

ClientPool returns the WebSocket client pool

func (*Pod) Forwarder

func (p *Pod) Forwarder() *clients.Forwarder

Forwarder returns the pod topology forwarder

func (*Pod) GetStatus

func (p *Pod) GetStatus() interface{}

GetStatus returns the status of the pod

func (*Pod) GremlinTraversalParser

func (p *Pod) GremlinTraversalParser() *traversal.GremlinTraversalParser

GremlinTraversalParser returns the pod Gremlin traversal parser

func (*Pod) HTTPServer

func (p *Pod) HTTPServer() *shttp.Server

HTTPServer returns the pod HTTP server

func (*Pod) Start

func (p *Pod) Start() error

Start the pod

func (*Pod) Stop

func (p *Pod) Stop()

Stop the 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