flowlog

package
v0.0.0-...-fec9766 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 26, 2023 License: Apache-2.0 Imports: 5 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ACLAction_name = map[int32]string{
		0: "ActionUnknown",
		1: "ActionDrop",
		2: "ActionAccept",
	}
	ACLAction_value = map[string]int32{
		"ActionUnknown": 0,
		"ActionDrop":    1,
		"ActionAccept":  2,
	}
)

Enum value maps for ACLAction.

View Source 
var File_flowlog_flowlog_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ACLAction 

type ACLAction int32
const (
	ACLAction_ActionUnknown ACLAction = 0
	ACLAction_ActionDrop    ACLAction = 1
	ACLAction_ActionAccept  ACLAction = 2
)

func (ACLAction) Descriptor 

func (ACLAction) Descriptor() protoreflect.EnumDescriptor

func (ACLAction) Enum 

func (x ACLAction) Enum() *ACLAction

func (ACLAction) EnumDescriptor deprecated 

func (ACLAction) EnumDescriptor() ([]byte, []int)

Deprecated: Use ACLAction.Descriptor instead.

func (ACLAction) Number 

func (x ACLAction) Number() protoreflect.EnumNumber

func (ACLAction) String 

func (x ACLAction) String() string

func (ACLAction) Type 

func (ACLAction) Type() protoreflect.EnumType

type DnsRequest 

type DnsRequest struct {
	HostName    string                 `protobuf:"bytes,1,opt,name=hostName,proto3" json:"hostName,omitempty"`       // Host name
	Addrs       []string               `protobuf:"bytes,2,rep,name=addrs,proto3" json:"addrs,omitempty"`             // Ipv4 or Ipv6 address
	RequestTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=requestTime,proto3" json:"requestTime,omitempty"` // Time of DNS request
	AclNum      int32                  `protobuf:"varint,4,opt,name=aclNum,proto3" json:"aclNum,omitempty"`          // ACL that resulted in DNS lookup
	// contains filtered or unexported fields
}

func (*DnsRequest) Descriptor deprecated 

func (*DnsRequest) Descriptor() ([]byte, []int)

Deprecated: Use DnsRequest.ProtoReflect.Descriptor instead.

func (*DnsRequest) GetAclNum 

func (x *DnsRequest) GetAclNum() int32

func (*DnsRequest) GetAddrs 

func (x *DnsRequest) GetAddrs() []string

func (*DnsRequest) GetHostName 

func (x *DnsRequest) GetHostName() string

func (*DnsRequest) GetRequestTime 

func (x *DnsRequest) GetRequestTime() *timestamppb.Timestamp

func (*DnsRequest) ProtoMessage 

func (*DnsRequest) ProtoMessage()

func (*DnsRequest) ProtoReflect 

func (x *DnsRequest) ProtoReflect() protoreflect.Message

func (*DnsRequest) Reset 

func (x *DnsRequest) Reset()

func (*DnsRequest) String 

func (x *DnsRequest) String() string

type FlowMessage 

type FlowMessage struct {
	DevId   string        `protobuf:"bytes,1,opt,name=devId,proto3" json:"devId,omitempty"` // Device UUID
	Scope   *ScopeInfo    `protobuf:"bytes,2,opt,name=scope,proto3" json:"scope,omitempty"`
	Flows   []*FlowRecord `protobuf:"bytes,3,rep,name=flows,proto3" json:"flows,omitempty"`
	DnsReqs []*DnsRequest `protobuf:"bytes,4,rep,name=dnsReqs,proto3" json:"dnsReqs,omitempty"`
	// contains filtered or unexported fields
}

 This is the request payload for POST /api/v1/edgeDevice/flowlog FlowMessage carries device logs to the controller. The message is assumed to be protected by a TLS session bound to the device certificate.

func (*FlowMessage) Descriptor deprecated 

func (*FlowMessage) Descriptor() ([]byte, []int)

Deprecated: Use FlowMessage.ProtoReflect.Descriptor instead.

func (*FlowMessage) GetDevId 

func (x *FlowMessage) GetDevId() string

func (*FlowMessage) GetDnsReqs 

func (x *FlowMessage) GetDnsReqs() []*DnsRequest

func (*FlowMessage) GetFlows 

func (x *FlowMessage) GetFlows() []*FlowRecord

func (*FlowMessage) GetScope 

func (x *FlowMessage) GetScope() *ScopeInfo

func (*FlowMessage) ProtoMessage 

func (*FlowMessage) ProtoMessage()

func (*FlowMessage) ProtoReflect 

func (x *FlowMessage) ProtoReflect() protoreflect.Message

func (*FlowMessage) Reset 

func (x *FlowMessage) Reset()

func (*FlowMessage) String 

func (x *FlowMessage) String() string

type FlowRecord 

type FlowRecord struct {
	Flow    *IpFlow `protobuf:"bytes,1,opt,name=flow,proto3" json:"flow,omitempty"`
	Inbound bool    `protobuf:"varint,2,opt,name=inbound,proto3" json:"inbound,omitempty"` // true if the connection originated from outside
	AclId   int32   `protobuf:"varint,3,opt,name=aclId,proto3" json:"aclId,omitempty"`     // Matching ACL
	AclName string  `protobuf:"bytes,4,opt,name=aclName,proto3" json:"aclName,omitempty"`  // Name of the ACL
	// deprecated = 5;
	StartTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=startTime,proto3" json:"startTime,omitempty"` // Always non-zero
	EndTime   *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=endTime,proto3" json:"endTime,omitempty"`     // Zero() if flow has not ended
	TxBytes   int64                  `protobuf:"varint,8,opt,name=txBytes,proto3" json:"txBytes,omitempty"`
	TxPkts    int64                  `protobuf:"varint,9,opt,name=txPkts,proto3" json:"txPkts,omitempty"`
	RxBytes   int64                  `protobuf:"varint,10,opt,name=rxBytes,proto3" json:"rxBytes,omitempty"`
	RxPkts    int64                  `protobuf:"varint,11,opt,name=rxPkts,proto3" json:"rxPkts,omitempty"`
	Action    ACLAction              `protobuf:"varint,12,opt,name=action,proto3,enum=org.lfedge.eve.flowlog.ACLAction" json:"action,omitempty"`
	// contains filtered or unexported fields
}

func (*FlowRecord) Descriptor deprecated 

func (*FlowRecord) Descriptor() ([]byte, []int)

Deprecated: Use FlowRecord.ProtoReflect.Descriptor instead.

func (*FlowRecord) GetAclId 

func (x *FlowRecord) GetAclId() int32

func (*FlowRecord) GetAclName 

func (x *FlowRecord) GetAclName() string

func (*FlowRecord) GetAction 

func (x *FlowRecord) GetAction() ACLAction

func (*FlowRecord) GetEndTime 

func (x *FlowRecord) GetEndTime() *timestamppb.Timestamp

func (*FlowRecord) GetFlow 

func (x *FlowRecord) GetFlow() *IpFlow

func (*FlowRecord) GetInbound 

func (x *FlowRecord) GetInbound() bool

func (*FlowRecord) GetRxBytes 

func (x *FlowRecord) GetRxBytes() int64

func (*FlowRecord) GetRxPkts 

func (x *FlowRecord) GetRxPkts() int64

func (*FlowRecord) GetStartTime 

func (x *FlowRecord) GetStartTime() *timestamppb.Timestamp

func (*FlowRecord) GetTxBytes 

func (x *FlowRecord) GetTxBytes() int64

func (*FlowRecord) GetTxPkts 

func (x *FlowRecord) GetTxPkts() int64

func (*FlowRecord) ProtoMessage 

func (*FlowRecord) ProtoMessage()

func (*FlowRecord) ProtoReflect 

func (x *FlowRecord) ProtoReflect() protoreflect.Message

func (*FlowRecord) Reset 

func (x *FlowRecord) Reset()

func (*FlowRecord) String 

func (x *FlowRecord) String() string

type IpFlow 

type IpFlow struct {
	Src      string `protobuf:"bytes,1,opt,name=src,proto3" json:"src,omitempty"`            // Source address
	SrcPort  int32  `protobuf:"varint,2,opt,name=srcPort,proto3" json:"srcPort,omitempty"`   // Source port
	Dest     string `protobuf:"bytes,3,opt,name=dest,proto3" json:"dest,omitempty"`          // Destination address
	DestPort int32  `protobuf:"varint,4,opt,name=destPort,proto3" json:"destPort,omitempty"` // Destination port
	Protocol int32  `protobuf:"varint,5,opt,name=protocol,proto3" json:"protocol,omitempty"` // Protocol
	// contains filtered or unexported fields
}

func (*IpFlow) Descriptor deprecated 

func (*IpFlow) Descriptor() ([]byte, []int)

Deprecated: Use IpFlow.ProtoReflect.Descriptor instead.

func (*IpFlow) GetDest 

func (x *IpFlow) GetDest() string

func (*IpFlow) GetDestPort 

func (x *IpFlow) GetDestPort() int32

func (*IpFlow) GetProtocol 

func (x *IpFlow) GetProtocol() int32

func (*IpFlow) GetSrc 

func (x *IpFlow) GetSrc() string

func (*IpFlow) GetSrcPort 

func (x *IpFlow) GetSrcPort() int32

func (*IpFlow) ProtoMessage 

func (*IpFlow) ProtoMessage()

func (*IpFlow) ProtoReflect 

func (x *IpFlow) ProtoReflect() protoreflect.Message

func (*IpFlow) Reset 

func (x *IpFlow) Reset()

func (*IpFlow) String 

func (x *IpFlow) String() string

type ScopeInfo 

type ScopeInfo struct {
	Uuid        string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`               // UUID of the instance or device
	Intf        string `protobuf:"bytes,2,opt,name=intf,proto3" json:"intf,omitempty"`               // User visible name
	LocalIntf   string `protobuf:"bytes,3,opt,name=localIntf,proto3" json:"localIntf,omitempty"`     // Internal name of the interface
	NetInstUUID string `protobuf:"bytes,4,opt,name=netInstUUID,proto3" json:"netInstUUID,omitempty"` // UUID of the network instance
	// contains filtered or unexported fields
}

func (*ScopeInfo) Descriptor deprecated 

func (*ScopeInfo) Descriptor() ([]byte, []int)

Deprecated: Use ScopeInfo.ProtoReflect.Descriptor instead.

func (*ScopeInfo) GetIntf 

func (x *ScopeInfo) GetIntf() string

func (*ScopeInfo) GetLocalIntf 

func (x *ScopeInfo) GetLocalIntf() string

func (*ScopeInfo) GetNetInstUUID 

func (x *ScopeInfo) GetNetInstUUID() string

func (*ScopeInfo) GetUuid 

func (x *ScopeInfo) GetUuid() string

func (*ScopeInfo) ProtoMessage 

func (*ScopeInfo) ProtoMessage()

func (*ScopeInfo) ProtoReflect 

func (x *ScopeInfo) ProtoReflect() protoreflect.Message

func (*ScopeInfo) Reset 

func (x *ScopeInfo) Reset()

func (*ScopeInfo) String 

func (x *ScopeInfo) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.