subscriber

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
  • func NewSubscriberFromConfig(cfg *viper.Viper) (*Subscriber, error)
  • func (s *Subscriber) GetStorage() *Storage
  • func (s *Subscriber) Start()
  • func (s *Subscriber) Stop()

Types

type SecurityAdvisorFlow

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

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

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

Storage allows writing flows to an object storage service

func (*Storage) DeleteObject

func (s *Storage) DeleteObject(objectKey *string) error

DeleteObject deletes an object

func (*Storage) ListObjects

func (s *Storage) ListObjects() ([]*string, error)

ListObjects lists all stored objects

func (*Storage) OnStructMessage

func (s *Storage) OnStructMessage(c ws.Speaker, msg *ws.StructMessage)

OnStructMessage is triggered when WS server sends us a message.

func (*Storage) ReadObjectFlows

func (s *Storage) ReadObjectFlows(objectKey *string, objectFlows interface{}) error

ReadObjectFlows reads flows from object

func (*Storage) StoreFlows

func (s *Storage) StoreFlows(flows []*flow.Flow) error

StoreFlows store flows in memory, before being written to the object store

type Subscriber

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

Subscriber represents a flow subscriber writing to object store

func NewSubscriberFromConfig

func NewSubscriberFromConfig(cfg *viper.Viper) (*Subscriber, error)

NewSubscriberFromConfig returns a new flow subscriber writing to object store

func (*Subscriber) GetStorage

func (s *Subscriber) GetStorage() *Storage

GetStorage returns the backing storage client

func (*Subscriber) Start

func (s *Subscriber) Start()

Start starts the object store flow subscriber

func (*Subscriber) Stop

func (s *Subscriber) Stop()

Stop stops the object store flow subscriber