server

package

Go to main page

Versions in this module

v0

v0.28.0

Aug 17, 2021

v0.27.0

Dec 7, 2020

Changes in this version

+ var TopologyMarshallers = api.TopologyMarshallers

type CaptureAPIHandler

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

+ type EdgeAPIHandler struct

+ func RegisterEdgeAPI(apiServer *api.Server, g *graph.Graph, authBackend shttp.AuthenticationBackend) (*EdgeAPIHandler, error)

+ func (h *EdgeAPIHandler) Create(resource rest.Resource, createOpts *rest.CreateOptions) error

+ func (h *EdgeAPIHandler) Decorate(resource rest.Resource)

+ func (h *EdgeAPIHandler) Delete(id string) error

+ func (h *EdgeAPIHandler) Get(id string) (rest.Resource, bool)

+ func (h *EdgeAPIHandler) Index() map[string]rest.Resource

+ func (h *EdgeAPIHandler) Name() string

+ func (h *EdgeAPIHandler) New() rest.Resource

+ func (h *EdgeAPIHandler) Update(id string, resource rest.Resource) (rest.Resource, bool, error)

+ type EdgeResourceHandler struct

type EdgeRuleAPI

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

+ type NodeAPIHandler struct

+ func RegisterNodeAPI(apiServer *api.Server, g *graph.Graph, authBackend shttp.AuthenticationBackend) (*NodeAPIHandler, error)

+ func (h *NodeAPIHandler) Create(resource rest.Resource, createOpts *rest.CreateOptions) error

+ func (h *NodeAPIHandler) Decorate(resource rest.Resource)

+ func (h *NodeAPIHandler) Delete(id string) error

+ func (h *NodeAPIHandler) Get(id string) (rest.Resource, bool)

+ func (h *NodeAPIHandler) Index() map[string]rest.Resource

+ func (h *NodeAPIHandler) Name() string

+ func (h *NodeAPIHandler) New() rest.Resource

+ func (h *NodeAPIHandler) Update(id string, resource rest.Resource) (rest.Resource, bool, error)

+ type NodeResourceHandler struct

type NodeRuleAPI

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

type PacketInjectorAPI

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

v0.26.0

Nov 15, 2019

Changes in this version

type PcapAPI

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

v0.25.0

Sep 12, 2019

Changes in this version

+ var ErrDuplicatedResource = errors.New("Duplicated resource")

v0.24.0

Jul 16, 2019

Changes in this version

+ type CreateOptions struct

+ TTL time.Duration

type PcapAPI

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

v0.23.0

May 17, 2019

Changes in this version

+ func NewWorkflowRuntime(g *graph.Graph, tr *traversal.GremlinTraversalParser, server *Server) (*js.Runtime, error)

+ func RegisterWorkflowCallAPI(s *shttp.Server, authBackend shttp.AuthenticationBackend, apiServer *Server, ...) error

+ type WorkflowCallAPIHandler struct

v0.22.0

Mar 21, 2019

v0.21.0

Dec 3, 2018

v0.20.1

Dec 17, 2018

v0.20.0

Oct 9, 2018

v0.19.1

Sep 14, 2018

Changes in this version

+ type EdgeRuleAPI struct

+ Graph *graph.Graph

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

+ type EdgeRuleResourceHandler struct

+ func (erh *EdgeRuleResourceHandler) Name() string

+ func (erh *EdgeRuleResourceHandler) New() types.Resource

+ type NodeRuleAPI struct

+ Graph *graph.Graph

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

+ func (nra *NodeRuleAPI) Create(r types.Resource) error

+ type NodeRuleResourceHandler struct

+ func (nrh *NodeRuleResourceHandler) Name() string

+ func (nrh *NodeRuleResourceHandler) New() types.Resource

v0.19.0

Aug 8, 2018

Changes in this version

type PacketInjectorAPI

+ TrackingID chan string

+ type WorkflowAPIHandler struct

+ func RegisterWorkflowAPI(apiServer *Server, authBackend shttp.AuthenticationBackend) (*WorkflowAPIHandler, error)

+ func (w *WorkflowAPIHandler) Create(r types.Resource) error

+ func (w *WorkflowAPIHandler) Get(id string) (types.Resource, bool)

+ func (w *WorkflowAPIHandler) Index() map[string]types.Resource

+ type WorkflowResourceHandler struct

+ func (w *WorkflowResourceHandler) Name() string

+ func (w *WorkflowResourceHandler) New() types.Resource

v0.18.0

Jun 21, 2018

v0.17.0

Apr 12, 2018

v0.16.0

Jan 29, 2018

Changes in this version

+ func RegisterConfigAPI(r *shttp.Server)

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

+ func RegisterStatusAPI(s *shttp.Server, r StatusReporter)

+ func RegisterTopologyAPI(r *shttp.Server, g *graph.Graph, parser *traversal.GremlinTraversalParser)

+ type AlertAPIHandler struct

+ func RegisterAlertAPI(apiServer *Server) (*AlertAPIHandler, error)

+ type AlertResourceHandler struct

+ func (a *AlertResourceHandler) Name() string

+ func (a *AlertResourceHandler) New() types.Resource

+ type BasicAPIHandler struct

+ EtcdKeyAPI etcd.KeysAPI

+ ResourceHandler ResourceHandler

+ func (h *BasicAPIHandler) AsyncWatch(f WatcherCallback) StoppableWatcher

+ func (h *BasicAPIHandler) Create(resource types.Resource) error

+ func (h *BasicAPIHandler) Decorate(resource types.Resource)

+ func (h *BasicAPIHandler) Delete(id string) error

+ func (h *BasicAPIHandler) Get(id string) (types.Resource, bool)

+ func (h *BasicAPIHandler) Index() map[string]types.Resource

+ func (h *BasicAPIHandler) Name() string

+ func (h *BasicAPIHandler) New() types.Resource

+ func (h *BasicAPIHandler) Unmarshal(b []byte) (resource types.Resource, err error)

+ func (h *BasicAPIHandler) Update(id string, resource types.Resource) error

+ type BasicStoppableWatcher struct

+ func (s *BasicStoppableWatcher) Stop()

+ type CaptureAPIHandler struct

+ Graph *graph.Graph

+ func RegisterCaptureAPI(apiServer *Server, g *graph.Graph) (*CaptureAPIHandler, error)

+ func (c *CaptureAPIHandler) Create(r types.Resource) error

+ func (c *CaptureAPIHandler) Decorate(resource types.Resource)

+ type CaptureResourceHandler struct

+ func (c *CaptureResourceHandler) Name() string

+ func (c *CaptureResourceHandler) New() types.Resource

+ type Handler interface

+ AsyncWatch func(f WatcherCallback) StoppableWatcher

+ Create func(resource types.Resource) error

+ Decorate func(resource types.Resource)

+ Delete func(id string) error

+ Get func(id string) (types.Resource, bool)

+ Index func() map[string]types.Resource

+ Name func() string

+ New func() types.Resource

+ type HandlerFunc func(w http.ResponseWriter, r *http.Request)

+ type Info struct

+ Host string

+ Service string

+ Version string

+ type PacketInjectorAPI struct

+ Graph *graph.Graph

+ TrackingId chan string

+ func RegisterPacketInjectorAPI(g *graph.Graph, apiServer *Server) (*PacketInjectorAPI, error)

+ func (pi *PacketInjectorAPI) Create(r types.Resource) error

+ type PacketInjectorResourceHandler struct

+ func (pirh *PacketInjectorResourceHandler) Name() string

+ func (pirh *PacketInjectorResourceHandler) New() types.Resource

+ type PcapAPI struct

+ Storage storage.Storage

+ type ResourceHandler interface

+ Name func() string

+ New func() types.Resource

+ type ResourceWatcher interface

+ AsyncWatch func(f WatcherCallback) StoppableWatcher

+ type Server struct

+ EtcdKeyAPI etcd.KeysAPI

+ HTTPServer *shttp.Server

+ ServiceType common.ServiceType

+ func NewAPI(server *shttp.Server, kapi etcd.KeysAPI, serviceType common.ServiceType) (*Server, error)

+ func (a *Server) GetHandler(hname string) Handler

+ func (a *Server) RegisterAPIHandler(handler Handler) error

+ type StatusReporter interface

+ GetStatus func() interface{}

+ type StoppableWatcher interface

+ Stop func()

+ type TopologyAPI struct

+ type UserMetadataAPIHandler struct

+ Graph *graph.Graph

+ func RegisterUserMetadataAPI(apiServer *Server, g *graph.Graph) (*UserMetadataAPIHandler, error)

+ func (m *UserMetadataAPIHandler) Create(r types.Resource) error

+ type UserMetadataResourceHandler struct

+ func (m *UserMetadataResourceHandler) Name() string

+ func (m *UserMetadataResourceHandler) New() types.Resource

+ type WatcherCallback func(action string, id string, resource types.Resource)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL