Documentation
¶
Index ¶
- Constants
- func NewCrudClientFromConfig(authOptions *shttp.AuthenticationOpts) *shttp.CrudClient
- func RegisterFlowApi(s string, f *flow.FlowTable, st storage.Storage, r *shttp.Server)
- func RegisterTopologyApi(s string, g *graph.Graph, r *shttp.Server)
- type Alert
- type AlertHandler
- type ApiHandler
- type ApiResource
- type ApiResourceWatcher
- type ApiServer
- func (a *ApiServer) AsyncWatch(n string, f ApiWatcherCallback) StoppableWatcher
- func (a *ApiServer) Create(n string, resource ApiResource) error
- func (a *ApiServer) Delete(n string, id string) error
- func (a *ApiServer) Get(n string, id string) (ApiResource, bool)
- func (a *ApiServer) GetHandler(s string) ApiHandler
- func (a *ApiServer) Index(n string) map[string]ApiResource
- func (a *ApiServer) RegisterApiHandler(handler ApiHandler) error
- type ApiWatcherCallback
- type BasicApiHandler
- func (h *BasicApiHandler) AsyncWatch(f ApiWatcherCallback) StoppableWatcher
- func (h *BasicApiHandler) Create(resource ApiResource) error
- func (h *BasicApiHandler) Delete(id string) error
- func (h *BasicApiHandler) Get(id string) (ApiResource, bool)
- func (h *BasicApiHandler) Index() map[string]ApiResource
- func (h *BasicApiHandler) Name() string
- func (h *BasicApiHandler) New() ApiResource
- type BasicStoppableWatcher
- type Capture
- type CaptureHandler
- type FlowApi
- type HandlerFunc
- type ResourceHandler
- type StoppableWatcher
- type TopologyApi
Constants ¶
View Source
const ( FIXED = 1 + iota THRESHOLD )
Variables ¶
This section is empty.
Functions ¶
func NewCrudClientFromConfig ¶
func NewCrudClientFromConfig(authOptions *shttp.AuthenticationOpts) *shttp.CrudClient
func RegisterFlowApi ¶
Types ¶
type Alert ¶
type AlertHandler ¶
type AlertHandler struct {
}
func (*AlertHandler) Name ¶
func (a *AlertHandler) Name() string
func (*AlertHandler) New ¶
func (a *AlertHandler) New() ApiResource
type ApiHandler ¶
type ApiHandler interface {
Name() string
New() ApiResource
Index() map[string]ApiResource
Get(id string) (ApiResource, bool)
Create(resource ApiResource) error
Delete(id string) error
AsyncWatch(f ApiWatcherCallback) StoppableWatcher
}
type ApiResourceWatcher ¶
type ApiResourceWatcher interface {
AsyncWatch(f ApiWatcherCallback) StoppableWatcher
}
type ApiServer ¶
type ApiServer struct {
HTTPServer *shttp.Server
EtcdKeyAPI etcd.KeysAPI
// contains filtered or unexported fields
}
func (*ApiServer) AsyncWatch ¶
func (a *ApiServer) AsyncWatch(n string, f ApiWatcherCallback) StoppableWatcher
func (*ApiServer) Create ¶
func (a *ApiServer) Create(n string, resource ApiResource) error
func (*ApiServer) GetHandler ¶
func (a *ApiServer) GetHandler(s string) ApiHandler
func (*ApiServer) Index ¶
func (a *ApiServer) Index(n string) map[string]ApiResource
func (*ApiServer) RegisterApiHandler ¶
func (a *ApiServer) RegisterApiHandler(handler ApiHandler) error
type ApiWatcherCallback ¶
type ApiWatcherCallback func(action string, id string, resource ApiResource)
type BasicApiHandler ¶
type BasicApiHandler struct {
ResourceHandler ResourceHandler
EtcdKeyAPI etcd.KeysAPI
}
basic implementation of an ApiHandler, should be used as embeded struct for the most part of the resources
func (*BasicApiHandler) AsyncWatch ¶
func (h *BasicApiHandler) AsyncWatch(f ApiWatcherCallback) StoppableWatcher
func (*BasicApiHandler) Create ¶
func (h *BasicApiHandler) Create(resource ApiResource) error
func (*BasicApiHandler) Delete ¶
func (h *BasicApiHandler) Delete(id string) error
func (*BasicApiHandler) Get ¶
func (h *BasicApiHandler) Get(id string) (ApiResource, bool)
func (*BasicApiHandler) Index ¶
func (h *BasicApiHandler) Index() map[string]ApiResource
func (*BasicApiHandler) Name ¶
func (h *BasicApiHandler) Name() string
func (*BasicApiHandler) New ¶
func (h *BasicApiHandler) New() ApiResource
type BasicStoppableWatcher ¶
type BasicStoppableWatcher struct {
// contains filtered or unexported fields
}
func (*BasicStoppableWatcher) Stop ¶
func (s *BasicStoppableWatcher) Stop()
type Capture ¶
type CaptureHandler ¶
type CaptureHandler struct {
}
func (*CaptureHandler) Name ¶
func (c *CaptureHandler) Name() string
func (*CaptureHandler) New ¶
func (c *CaptureHandler) New() ApiResource
type FlowApi ¶
type HandlerFunc ¶
type HandlerFunc func(w http.ResponseWriter, r *http.Request)
type ResourceHandler ¶
type ResourceHandler interface {
Name() string
New() ApiResource
}
type StoppableWatcher ¶
type StoppableWatcher interface {
Stop()
}
Source Files
¶
- alert.go
- api.go
- capture.go
- flow.go
- handler.go
- topology.go
Click to show internal directories.
Click to hide internal directories.