api

type Alert struct {
	Resource
	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 {
	ResourceHandler
}

type BasicAPIHandler struct {
	ResourceHandler ResourceHandler
	EtcdKeyAPI      etcd.KeysAPI
}

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

type Capture struct {
	UUID           string
	GremlinQuery   string `json:"GremlinQuery,omitempty" valid:"isGremlinExpr"`
	BPFFilter      string `json:"BPFFilter,omitempty" valid:"isBPFFilter"`
	Name           string `json:"Name,omitempty"`
	Description    string `json:"Description,omitempty"`
	Type           string `json:"Type,omitempty"`
	Count          int    `json:"Count,omitempty"`
	PCAPSocket     string `json:"PCAPSocket,omitempty"`
	Port           int    `json:"Port,omitempty"`
	RawPacketLimit int    `json:"RawPacketLimit,omitempty" valid:"isValidRawPacketLimit"`
	HeaderSize     int    `json:"HeaderSize,omitempty" valid:"isValidCaptureHeaderSize"`
}

type CaptureAPIHandler struct {
	BasicAPIHandler
	Graph *graph.Graph
}

type CaptureResourceHandler struct {
	ResourceHandler
}

type Handler interface {
	Name() string
	New() Resource
	Index() map[string]Resource
	Get(id string) (Resource, bool)
	Decorate(resource Resource)
	Create(resource Resource) error
	Delete(id string) error
	AsyncWatch(f WatcherCallback) StoppableWatcher
}

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

type Info struct {
	Host    string
	Version string
	Service string
}

type PacketInjectorAPI struct {
	PIClient *packet_injector.PacketInjectorClient
	Graph    *graph.Graph
}

type PacketParamsReq struct {
	Src        string
	Dst        string
	SrcIP      string
	DstIP      string
	SrcMAC     string
	DstMAC     string
	SrcPort    int64
	DstPort    int64
	Type       string
	Payload    string
	TrackingID string
	ID         int64
	Count      int64
	Interval   int64
}

type PcapAPI struct {
	Storage storage.Storage
}

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

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

type ResourceWatcher interface {
	AsyncWatch(f WatcherCallback) StoppableWatcher
}

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

type StoppableWatcher interface {
	Stop()
}

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

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

type WatcherCallback func(action string, id string, resource Resource)