api

Documentation

Index

• Constants
• func NewCrudClientFromConfig(authOptions *shttp.AuthenticationOpts) *shttp.CrudClient
• func NewRestClientFromConfig(authOptions *shttp.AuthenticationOpts) *shttp.RestClient
• func RegisterFlowApi(s string, f *flow.Table, st storage.Storage, r *shttp.Server)
• func RegisterTopologyApi(s string, g *graph.Graph, r *shttp.Server, tc *flow.TableClient, ...)
• type Alert
  • func NewAlert() *Alert
  • func (a *Alert) ID() string
  • func (a *Alert) SetID(i string)
• type AlertHandler
  • func (a *AlertHandler) Name() string
  • func (a *AlertHandler) New() ApiResource
• type ApiHandler
• type ApiResource
• type ApiResourceWatcher
• type ApiServer
  • func NewApi(server *shttp.Server, kapi etcd.KeysAPI) (*ApiServer, error)
  • 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
  • func (s *BasicStoppableWatcher) Stop()
• type Capture
  • func NewCapture(query string, bpfFilter string) *Capture
  • func (c *Capture) ID() string
  • func (c *Capture) SetID(i string)
• type CaptureHandler
  • func (c *CaptureHandler) Name() string
  • func (c *CaptureHandler) New() ApiResource
• type FlowApi
• type HandlerFunc
• type ResourceHandler
• type StoppableWatcher
• type Topology
• type TopologyApi

Constants

const (
	FIXED = 1 + iota
	THRESHOLD
)

Functions

func NewCrudClientFromConfig

func NewCrudClientFromConfig(authOptions *shttp.AuthenticationOpts) *shttp.CrudClient

func NewRestClientFromConfig

func NewRestClientFromConfig(authOptions *shttp.AuthenticationOpts) *shttp.RestClient

func RegisterFlowApi

func RegisterFlowApi(s string, f *flow.Table, st storage.Storage, r *shttp.Server)

func RegisterTopologyApi

func RegisterTopologyApi(s string, g *graph.Graph, r *shttp.Server, tc *flow.TableClient, st storage.Storage)

Types

type Alert

type Alert struct {
	UUID        string
	Name        string
	Description string
	Select      string `valid:"nonzero"`
	Test        string `valid:"nonzero"`
	Action      string `valid:"nonzero"`
	Type        int
	Count       int
	CreateTime  time.Time
}

func NewAlert

func NewAlert() *Alert

func (*Alert) ID

func (a *Alert) ID() string

func (*Alert) SetID

func (a *Alert) SetID(i string)

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 ApiResource

type ApiResource interface {
	ID() string
	SetID(string)
}

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 NewApi

func NewApi(server *shttp.Server, kapi etcd.KeysAPI) (*ApiServer, error)

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) Delete

func (a *ApiServer) Delete(n string, id string) error

func (*ApiServer) Get

func (a *ApiServer) Get(n string, id string) (ApiResource, bool)

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 Capture struct {
	UUID         string
	GremlinQuery string `json:"GremlinQuery,omitempty" valid:"isGremlinExpr"`
	BPFFilter    string `json:"BPFFilter,omitempty"`
	Name         string `json:"Name,omitempty"`
	Description  string `json:"Description,omitempty"`
	Type         string `json:"Type,omitempty"`
}

func NewCapture

func NewCapture(query string, bpfFilter string) *Capture

func (*Capture) ID

func (c *Capture) ID() string

func (*Capture) SetID

func (c *Capture) SetID(i string)

type CaptureHandler

type CaptureHandler struct {
}

func (*CaptureHandler) Name

func (c *CaptureHandler) Name() string

func (*CaptureHandler) New

func (c *CaptureHandler) New() ApiResource

type FlowApi

type FlowApi struct {
	Service   string
	FlowTable *flow.Table
	Storage   storage.Storage
}

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()
}

type Topology

type Topology struct {
	GremlinQuery string `json:"GremlinQuery,omitempty" valid:"isGremlinExpr"`
}

type TopologyApi

type TopologyApi struct {
	Service     string
	Graph       *graph.Graph
	TableClient *flow.TableClient
	Storage     storage.Storage
}