link

Documentation

Index

• func GetFlowBytesTransfered(f *pbFlow.Flow) uint64
• type Link
  • func FromFlowProto(f *pbFlow.Flow) *Link
  • func (l *Link) AccumulateFlow(f *pbFlow.Flow)
  • func (l *Link) AccumulateLink(rhs *Link) *Link
  • func (l *Link) DropStats() *Link
  • func (l *Link) Equals(rhs *Link) bool
  • func (l *Link) IntoFlow() *pbFlow.Flow
  • func (l *Link) String() string
  • func (l *Link) ToProto() *ui.ServiceLink
• type Map
  • func (m Map) Has(key string) bool
  • func (m Map) HasLink(l *Link) bool
  • func (m Map) Insert(l *Link) *Link
  • func (m Map) InsertMany(links ...*Link)
  • func (m Map) ProtoValues() []*ui.ServiceLink
  • func (m Map) Values() []*Link

Functions

func GetFlowBytesTransfered

func GetFlowBytesTransfered(f *pbFlow.Flow) uint64

Types

type Link

type Link struct {
	Id              string
	SourceId        string
	DestinationId   string
	DestinationPort uint32

	// TODO: this is bad; create domain types for this fields
	Verdict     pbFlow.Verdict
	IPProtocol  ui.IPProtocol
	AuthType    pbFlow.AuthType
	IsEncrypted bool

	FlowAmount      uint64
	LatenciesNs     []uint64
	BytesTransfered uint64
	// contains filtered or unexported fields
}

func FromFlowProto

func FromFlowProto(f *pbFlow.Flow) *Link

func (*Link) AccumulateFlow

func (l *Link) AccumulateFlow(f *pbFlow.Flow)

func (*Link) AccumulateLink

func (l *Link) AccumulateLink(rhs *Link) *Link

func (*Link) DropStats

func (l *Link) DropStats() *Link

func (*Link) Equals

func (l *Link) Equals(rhs *Link) bool

func (*Link) IntoFlow

func (l *Link) IntoFlow() *pbFlow.Flow

func (*Link) String

func (l *Link) String() string

func (*Link) ToProto

func (l *Link) ToProto() *ui.ServiceLink

type Map

type Map map[string]*Link

func (Map) Has

func (m Map) Has(key string) bool

func (Map) HasLink

func (m Map) HasLink(l *Link) bool

func (Map) Insert

func (m Map) Insert(l *Link) *Link

func (Map) InsertMany

func (m Map) InsertMany(links ...*Link)

func (Map) ProtoValues

func (m Map) ProtoValues() []*ui.ServiceLink

func (Map) Values

func (m Map) Values() []*Link