api

type Alert struct {
	UUID        string
	Name        string `json:",omitempty"`
	Description string `json:",omitempty"`
	Expression  string `json:",omitempty" valid:"nonzero"`
	Action      string `json:",omitempty" valid:"regexp=^(|http://|https://|file://).*$"`
	Trigger     string `json:",omitempty" valid:"regexp=^(graph|duration:.+|)$"`
	CreateTime  time.Time
}

type AlertApiHandler struct {
	BasicApiHandler
}

type AlertResourceHandler struct {
}

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 interface {
	ID() string
	SetID(string)
}

type ApiResourceWatcher interface {
	AsyncWatch(f ApiWatcherCallback) StoppableWatcher
}

type ApiServer struct {
	HTTPServer *shttp.Server
	EtcdKeyAPI etcd.KeysAPI
	// contains filtered or unexported fields
}

type ApiWatcherCallback func(action string, id string, resource ApiResource)

type BasicApiHandler struct {
	ResourceHandler ResourceHandler
	EtcdKeyAPI      etcd.KeysAPI
}

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

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"`
	Count        int    `json:"Count,omitempty"`
}

type CaptureApiHandler struct {
	BasicApiHandler
	Graph *graph.Graph
}

type CaptureResourceHandler struct {
}

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

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

type PacketInjectorApi struct {
	Service  string
	PIClient *packet_injector.PacketInjectorClient
	Graph    *graph.Graph
}

type PacketParamsReq struct {
	Src     string `valid:"isGremlinExpr"`
	Dst     string `valid:"isGremlinExpr"`
	Type    string
	Payload string
	Count   int
}

type ResourceHandler interface {
	Name() string
	New() ApiResource
}

type StoppableWatcher interface {
	Stop()
}

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

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