Documentation
¶
Index ¶
- type SecurityAdvisorFlow
- type SecurityAdvisorFlowLayer
- type Storage
- func (s *Storage) DeleteObject(objectKey *string) error
- func (s *Storage) ListObjects() ([]*string, error)
- func (s *Storage) OnStructMessage(c ws.Speaker, msg *ws.StructMessage)
- func (s *Storage) ReadObjectFlows(objectKey *string, objectFlows interface{}) error
- func (s *Storage) StoreFlows(flows []*flow.Flow) error
- type Subscriber
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SecurityAdvisorFlow ¶ added in v0.23.0
type SecurityAdvisorFlow struct {
UUID string `json:"UUID,omitempty"`
LayersPath string `json:"LayersPath,omitempty"`
Version string `json:"Version,omitempty"`
Status string `json:"Status,omitempty"`
FinishType string `json:"FinishType,omitempty"`
Network *SecurityAdvisorFlowLayer `json:"Network,omitempty"`
Transport *SecurityAdvisorFlowLayer `json:"Transport,omitempty"`
LastUpdateMetric *flow.FlowMetric `json:"LastUpdateMetric,omitempty"`
Metric *flow.FlowMetric `json:"Metric,omitempty"`
Start int64 `json:"Start"`
Last int64 `json:"Last"`
UpdateCount int64 `json:"UpdateCount"`
NodeType string `json:"NodeType,omitempty"`
}
SecurityAdvisorFlow represents a security advisor flow
type SecurityAdvisorFlowLayer ¶ added in v0.23.0
type SecurityAdvisorFlowLayer struct {
Protocol string `json:"Protocol,omitempty"`
A string `json:"A,omitempty"`
B string `json:"B,omitempty"`
AName string `json:"A_Name,omitempty"`
BName string `json:"B_Name,omitempty"`
}
SecurityAdvisorFlowLayer is the flow layer for a security advisor flow
type Storage ¶ added in v0.23.0
type Storage struct {
// contains filtered or unexported fields
}
Storage allows writing flows to an object storage service
func (*Storage) DeleteObject ¶ added in v0.23.0
DeleteObject deletes an object
func (*Storage) ListObjects ¶ added in v0.23.0
ListObjects lists all stored objects
func (*Storage) OnStructMessage ¶ added in v0.23.0
func (s *Storage) OnStructMessage(c ws.Speaker, msg *ws.StructMessage)
OnStructMessage is triggered when WS server sends us a message.
func (*Storage) ReadObjectFlows ¶ added in v0.23.0
ReadObjectFlows reads flows from object
type Subscriber ¶
type Subscriber struct {
// contains filtered or unexported fields
}
Subscriber represents a flow subscriber writing to object store
func NewSubscriberFromConfig ¶ added in v0.23.0
func NewSubscriberFromConfig(cfg *viper.Viper) (*Subscriber, error)
NewSubscriberFromConfig returns a new flow subscriber writing to object store
func (*Subscriber) GetStorage ¶ added in v0.23.0
func (s *Subscriber) GetStorage() *Storage
GetStorage returns the backing storage client
func (*Subscriber) Start ¶ added in v0.23.0
func (s *Subscriber) Start()
Start starts the object store flow subscriber
func (*Subscriber) Stop ¶ added in v0.23.0
func (s *Subscriber) Stop()
Stop stops the object store flow subscriber
Source Files
¶
- client.go
- flowclassifier.go
- flowtransformer.go
- objectstore.go
- secadvisor.go
- subscriber.go
Click to show internal directories.
Click to hide internal directories.