server

Documentation

Index

• Variables
• func RegisterConfigAPI(r *shttp.Server, authBackend shttp.AuthenticationBackend)
• func RegisterPcapAPI(r *shttp.Server, store storage.Storage, ...)
• type CaptureAPIHandler
  • func RegisterCaptureAPI(apiServer *api.Server, g *graph.Graph, authBackend shttp.AuthenticationBackend) *CaptureAPIHandler
  • func (c *CaptureAPIHandler) Create(r rest.Resource, opts *rest.CreateOptions) error
  • func (c *CaptureAPIHandler) Decorate(resource rest.Resource)
  • func (c *CaptureAPIHandler) Update(id string, resource rest.Resource) (rest.Resource, bool, error)
• type CaptureResourceHandler
  • func (c *CaptureResourceHandler) Name() string
  • func (c *CaptureResourceHandler) New() rest.Resource
• type EdgeRuleAPI
  • func RegisterEdgeRuleAPI(apiServer *api.Server, g *graph.Graph, authBackend shttp.AuthenticationBackend) *EdgeRuleAPI
  • func (a *EdgeRuleAPI) Update(id string, resource rest.Resource) (rest.Resource, bool, error)
• type EdgeRuleResourceHandler
  • func (erh *EdgeRuleResourceHandler) Name() string
  • func (erh *EdgeRuleResourceHandler) New() rest.Resource
• type NodeRuleAPI
  • func RegisterNodeRuleAPI(apiServer *api.Server, g *graph.Graph, authBackend shttp.AuthenticationBackend) *NodeRuleAPI
  • func (a *NodeRuleAPI) Update(id string, resource rest.Resource) (rest.Resource, bool, error)
• type NodeRuleResourceHandler
  • func (nrh *NodeRuleResourceHandler) Name() string
  • func (nrh *NodeRuleResourceHandler) New() rest.Resource
• type PacketInjectorAPI
  • func RegisterPacketInjectorAPI(g *graph.Graph, apiServer *api.Server, authBackend shttp.AuthenticationBackend) *PacketInjectorAPI
  • func (pi *PacketInjectorAPI) Create(r rest.Resource, opts *rest.CreateOptions) error
  • func (pi *PacketInjectorAPI) Update(id string, resource rest.Resource) (rest.Resource, bool, error)
• type PcapAPI
  • func (p *PcapAPI) SendFlows(flows []*flow.Flow)
  • func (p *PcapAPI) SendStats(status flow.Stats)

Variables

var TopologyMarshallers = api.TopologyMarshallers{
	"text/vnd.graphviz":            dotMarshaller,
	"application/vnd.tcpdump.pcap": pcapMarshaller,
}

TopologyMarshallers hold the dot and pcap marshallers

Functions

func RegisterConfigAPI

func RegisterConfigAPI(r *shttp.Server, authBackend shttp.AuthenticationBackend)

RegisterConfigAPI registers a configuration endpoint (read only) in API server

func RegisterPcapAPI

func RegisterPcapAPI(r *shttp.Server, store storage.Storage, authBackend shttp.AuthenticationBackend)

RegisterPcapAPI registers a new pcap injector API

Types

type CaptureAPIHandler

type CaptureAPIHandler struct {
	rest.BasicAPIHandler
	Graph *graph.Graph
}

CaptureAPIHandler based on BasicAPIHandler

func RegisterCaptureAPI

func RegisterCaptureAPI(apiServer *api.Server, g *graph.Graph, authBackend shttp.AuthenticationBackend) *CaptureAPIHandler

RegisterCaptureAPI registers an new resource, capture

func (*CaptureAPIHandler) Create

func (c *CaptureAPIHandler) Create(r rest.Resource, opts *rest.CreateOptions) error

Create tests that resource GremlinQuery does not exists already

func (*CaptureAPIHandler) Decorate

func (c *CaptureAPIHandler) Decorate(resource rest.Resource)

Decorate populates the capture resource

func (*CaptureAPIHandler) Update

func (c *CaptureAPIHandler) Update(id string, resource rest.Resource) (rest.Resource, bool, error)

Update a capture

type CaptureResourceHandler

type CaptureResourceHandler struct {
	rest.ResourceHandler
}

CaptureResourceHandler describes a capture ressouce handler

func (*CaptureResourceHandler) Name

func (c *CaptureResourceHandler) Name() string

Name returns "capture"

func (*CaptureResourceHandler) New

func (c *CaptureResourceHandler) New() rest.Resource

New creates a new capture resource

type EdgeRuleAPI

type EdgeRuleAPI struct {
	rest.BasicAPIHandler
	Graph *graph.Graph
}

EdgeRuleAPI based on BasicAPIHandler

func RegisterEdgeRuleAPI

func RegisterEdgeRuleAPI(apiServer *api.Server, g *graph.Graph, authBackend shttp.AuthenticationBackend) *EdgeRuleAPI

RegisterEdgeRuleAPI registers an EdgeRule's API to a designated API Server

func (*EdgeRuleAPI) Update

func (a *EdgeRuleAPI) Update(id string, resource rest.Resource) (rest.Resource, bool, error)

Update an edge rule

type EdgeRuleResourceHandler

type EdgeRuleResourceHandler struct {
	rest.ResourceHandler
}

EdgeRuleResourceHandler describes a edge rule resource handler

func (*EdgeRuleResourceHandler) Name

func (erh *EdgeRuleResourceHandler) Name() string

Name returns resource name "edgerule"

func (*EdgeRuleResourceHandler) New

func (erh *EdgeRuleResourceHandler) New() rest.Resource

New creates a new EdgeRule

type NodeRuleAPI

type NodeRuleAPI struct {
	rest.BasicAPIHandler
	Graph *graph.Graph
}

NodeRuleAPI based on BasicAPIHandler

func RegisterNodeRuleAPI

func RegisterNodeRuleAPI(apiServer *api.Server, g *graph.Graph, authBackend shttp.AuthenticationBackend) *NodeRuleAPI

RegisterNodeRuleAPI register a new node rule api handler

func (*NodeRuleAPI) Update

func (a *NodeRuleAPI) Update(id string, resource rest.Resource) (rest.Resource, bool, error)

Update an edge rule

type NodeRuleResourceHandler

type NodeRuleResourceHandler struct {
	rest.ResourceHandler
}

NodeRuleResourceHandler describes a node resource handler

func (*NodeRuleResourceHandler) Name

func (nrh *NodeRuleResourceHandler) Name() string

Name returns resource name "noderule"

func (*NodeRuleResourceHandler) New

func (nrh *NodeRuleResourceHandler) New() rest.Resource

New creates a new node rule

type PacketInjectorAPI

type PacketInjectorAPI struct {
	rest.BasicAPIHandler
	Graph *graph.Graph
}

PacketInjectorAPI exposes the packet injector API

func RegisterPacketInjectorAPI

func RegisterPacketInjectorAPI(g *graph.Graph, apiServer *api.Server, authBackend shttp.AuthenticationBackend) *PacketInjectorAPI

RegisterPacketInjectorAPI registers a new packet injector resource in the API

func (*PacketInjectorAPI) Create

func (pi *PacketInjectorAPI) Create(r rest.Resource, opts *rest.CreateOptions) error

Create allocates a new packet injection

func (*PacketInjectorAPI) Update

func (pi *PacketInjectorAPI) Update(id string, resource rest.Resource) (rest.Resource, bool, error)

Update a packet injection

type PcapAPI

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

PcapAPI exposes the pcap injector API

func (*PcapAPI) SendFlows

func (p *PcapAPI) SendFlows(flows []*flow.Flow)

SendFlows implements the flow Sender interface

func (*PcapAPI) SendStats

func (p *PcapAPI) SendStats(status flow.Stats)

SendStats implements the flow Sender interface