flow

package
v0.8.20 Latest Latest
Warning

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

Go to latest
Published: Mar 14, 2023 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var EventType_name = map[int32]string{
	0: "UNKNOWN",
	9: "EventSample",
	2: "RecordLost",
}
View Source
var EventType_value = map[string]int32{
	"UNKNOWN":     0,
	"EventSample": 9,
	"RecordLost":  2,
}
View Source
var FlowType_name = map[int32]string{
	0: "UNKNOWN_TYPE",
	1: "L3_L4",
	2: "L7",
}
View Source
var FlowType_value = map[string]int32{
	"UNKNOWN_TYPE": 0,
	"L3_L4":        1,
	"L7":           2,
}
View Source
var IPVersion_name = map[int32]string{
	0: "IP_NOT_USED",
	1: "IPv4",
	2: "IPv6",
}
View Source
var IPVersion_value = map[string]int32{
	"IP_NOT_USED": 0,
	"IPv4":        1,
	"IPv6":        2,
}
View Source
var L7FlowType_name = map[int32]string{
	0: "UNKNOWN_L7_TYPE",
	1: "REQUEST",
	2: "RESPONSE",
	3: "SAMPLE",
}
View Source
var L7FlowType_value = map[string]int32{
	"UNKNOWN_L7_TYPE": 0,
	"REQUEST":         1,
	"RESPONSE":        2,
	"SAMPLE":          3,
}
View Source
var Verdict_name = map[int32]string{
	0: "VERDICT_UNKNOWN",
	1: "FORWARDED",
	2: "DROPPED",
	3: "ERROR",
}
View Source
var Verdict_value = map[string]int32{
	"VERDICT_UNKNOWN": 0,
	"FORWARDED":       1,
	"DROPPED":         2,
	"ERROR":           3,
}

Functions

This section is empty.

Types

type CiliumEventType

type CiliumEventType struct {
	// type of event the flow originated from, i.e.
	// github.com/cilium/cilium/pkg/monitor/api.MessageType*
	Type int32 `protobuf:"varint,1,opt,name=type,proto3" json:"type,omitempty"`
	// sub_type may indicate more details depending on type, e.g.
	// - github.com/cilium/cilium/pkg/monitor/api.Trace*
	// - github.com/cilium/cilium/pkg/monitor/api.Drop*
	SubType              int32    `protobuf:"varint,2,opt,name=sub_type,json=subType,proto3" json:"sub_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CiliumEventType from which the flow originated

func (*CiliumEventType) Descriptor

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

func (*CiliumEventType) GetSubType

func (m *CiliumEventType) GetSubType() int32

func (*CiliumEventType) GetType

func (m *CiliumEventType) GetType() int32

func (*CiliumEventType) MarshalJSON

func (msg *CiliumEventType) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*CiliumEventType) ProtoMessage

func (*CiliumEventType) ProtoMessage()

func (*CiliumEventType) Reset

func (m *CiliumEventType) Reset()

func (*CiliumEventType) String

func (m *CiliumEventType) String() string

func (*CiliumEventType) UnmarshalJSON

func (msg *CiliumEventType) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*CiliumEventType) Validate

func (m *CiliumEventType) Validate() error

Validate checks the field values on CiliumEventType with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*CiliumEventType) XXX_DiscardUnknown

func (m *CiliumEventType) XXX_DiscardUnknown()

func (*CiliumEventType) XXX_Marshal

func (m *CiliumEventType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CiliumEventType) XXX_Merge

func (m *CiliumEventType) XXX_Merge(src proto.Message)

func (*CiliumEventType) XXX_Size

func (m *CiliumEventType) XXX_Size() int

func (*CiliumEventType) XXX_Unmarshal

func (m *CiliumEventType) XXX_Unmarshal(b []byte) error

type CiliumEventTypeValidationError

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

CiliumEventTypeValidationError is the validation error returned by CiliumEventType.Validate if the designated constraints aren't met.

func (CiliumEventTypeValidationError) Cause

Cause function returns cause value.

func (CiliumEventTypeValidationError) Error

Error satisfies the builtin error interface

func (CiliumEventTypeValidationError) ErrorName

func (e CiliumEventTypeValidationError) ErrorName() string

ErrorName returns error name.

func (CiliumEventTypeValidationError) Field

Field function returns field value.

func (CiliumEventTypeValidationError) Key

Key function returns key value.

func (CiliumEventTypeValidationError) Reason

Reason function returns reason value.

type DNS

type DNS struct {
	// DNS name that's being looked up: e.g. "isovalent.com."
	Query string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	// List of IP addresses in the DNS response.
	Ips []string `protobuf:"bytes,2,rep,name=ips,proto3" json:"ips,omitempty"`
	// TTL in the DNS response.
	Ttl uint32 `protobuf:"varint,3,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// List of CNames in the DNS response.
	Cnames []string `protobuf:"bytes,4,rep,name=cnames,proto3" json:"cnames,omitempty"`
	// Corresponds to DNSDataSource defined in:
	//   https://github.com/cilium/cilium/blob/04f3889d627774f79e56d14ddbc165b3169e2d01/pkg/proxy/accesslog/record.go#L253
	ObservationSource string `protobuf:"bytes,5,opt,name=observation_source,json=observationSource,proto3" json:"observation_source,omitempty"`
	// Return code of the DNS request defined in:
	//   https://www.iana.org/assignments/dns-parameters/dns-parameters.xhtml#dns-parameters-6
	Rcode uint32 `protobuf:"varint,6,opt,name=rcode,proto3" json:"rcode,omitempty"`
	// String representation of qtypes defined in:
	//   https://tools.ietf.org/html/rfc1035#section-3.2.3
	Qtypes []string `protobuf:"bytes,7,rep,name=qtypes,proto3" json:"qtypes,omitempty"`
	// String representation of rrtypes defined in:
	// https://www.iana.org/assignments/dns-parameters/dns-parameters.xhtml#dns-parameters-4
	Rrtypes              []string `protobuf:"bytes,8,rep,name=rrtypes,proto3" json:"rrtypes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

DNS flow. This is basically directly mapped from Cilium's LogRecordDNS:

https://github.com/cilium/cilium/blob/04f3889d627774f79e56d14ddbc165b3169e2d01/pkg/proxy/accesslog/record.go#L264

func (*DNS) Descriptor

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

func (*DNS) GetCnames

func (m *DNS) GetCnames() []string

func (*DNS) GetIps

func (m *DNS) GetIps() []string

func (*DNS) GetObservationSource

func (m *DNS) GetObservationSource() string

func (*DNS) GetQtypes

func (m *DNS) GetQtypes() []string

func (*DNS) GetQuery

func (m *DNS) GetQuery() string

func (*DNS) GetRcode

func (m *DNS) GetRcode() uint32

func (*DNS) GetRrtypes

func (m *DNS) GetRrtypes() []string

func (*DNS) GetTtl

func (m *DNS) GetTtl() uint32

func (*DNS) MarshalJSON

func (msg *DNS) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*DNS) ProtoMessage

func (*DNS) ProtoMessage()

func (*DNS) Reset

func (m *DNS) Reset()

func (*DNS) String

func (m *DNS) String() string

func (*DNS) UnmarshalJSON

func (msg *DNS) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*DNS) Validate

func (m *DNS) Validate() error

Validate checks the field values on DNS with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*DNS) XXX_DiscardUnknown

func (m *DNS) XXX_DiscardUnknown()

func (*DNS) XXX_Marshal

func (m *DNS) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DNS) XXX_Merge

func (m *DNS) XXX_Merge(src proto.Message)

func (*DNS) XXX_Size

func (m *DNS) XXX_Size() int

func (*DNS) XXX_Unmarshal

func (m *DNS) XXX_Unmarshal(b []byte) error

type DNSValidationError

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

DNSValidationError is the validation error returned by DNS.Validate if the designated constraints aren't met.

func (DNSValidationError) Cause

func (e DNSValidationError) Cause() error

Cause function returns cause value.

func (DNSValidationError) Error

func (e DNSValidationError) Error() string

Error satisfies the builtin error interface

func (DNSValidationError) ErrorName

func (e DNSValidationError) ErrorName() string

ErrorName returns error name.

func (DNSValidationError) Field

func (e DNSValidationError) Field() string

Field function returns field value.

func (DNSValidationError) Key

func (e DNSValidationError) Key() bool

Key function returns key value.

func (DNSValidationError) Reason

func (e DNSValidationError) Reason() string

Reason function returns reason value.

type Endpoint

type Endpoint struct {
	ID        uint64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Identity  uint64 `protobuf:"varint,2,opt,name=identity,proto3" json:"identity,omitempty"`
	Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// labels in `foo=bar` format.
	Labels               []string `protobuf:"bytes,4,rep,name=labels,proto3" json:"labels,omitempty"`
	PodName              string   `protobuf:"bytes,5,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Endpoint) Descriptor

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

func (*Endpoint) GetID

func (m *Endpoint) GetID() uint64

func (*Endpoint) GetIdentity

func (m *Endpoint) GetIdentity() uint64

func (*Endpoint) GetLabels

func (m *Endpoint) GetLabels() []string

func (*Endpoint) GetNamespace

func (m *Endpoint) GetNamespace() string

func (*Endpoint) GetPodName

func (m *Endpoint) GetPodName() string

func (*Endpoint) MarshalJSON

func (msg *Endpoint) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*Endpoint) ProtoMessage

func (*Endpoint) ProtoMessage()

func (*Endpoint) Reset

func (m *Endpoint) Reset()

func (*Endpoint) String

func (m *Endpoint) String() string

func (*Endpoint) UnmarshalJSON

func (msg *Endpoint) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*Endpoint) Validate

func (m *Endpoint) Validate() error

Validate checks the field values on Endpoint with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Endpoint) XXX_DiscardUnknown

func (m *Endpoint) XXX_DiscardUnknown()

func (*Endpoint) XXX_Marshal

func (m *Endpoint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Endpoint) XXX_Merge

func (m *Endpoint) XXX_Merge(src proto.Message)

func (*Endpoint) XXX_Size

func (m *Endpoint) XXX_Size() int

func (*Endpoint) XXX_Unmarshal

func (m *Endpoint) XXX_Unmarshal(b []byte) error

type EndpointValidationError

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

EndpointValidationError is the validation error returned by Endpoint.Validate if the designated constraints aren't met.

func (EndpointValidationError) Cause

func (e EndpointValidationError) Cause() error

Cause function returns cause value.

func (EndpointValidationError) Error

func (e EndpointValidationError) Error() string

Error satisfies the builtin error interface

func (EndpointValidationError) ErrorName

func (e EndpointValidationError) ErrorName() string

ErrorName returns error name.

func (EndpointValidationError) Field

func (e EndpointValidationError) Field() string

Field function returns field value.

func (EndpointValidationError) Key

func (e EndpointValidationError) Key() bool

Key function returns key value.

func (EndpointValidationError) Reason

func (e EndpointValidationError) Reason() string

Reason function returns reason value.

type Ethernet

type Ethernet struct {
	Source               string   `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	Destination          string   `protobuf:"bytes,2,opt,name=destination,proto3" json:"destination,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Ethernet) Descriptor

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

func (*Ethernet) GetDestination

func (m *Ethernet) GetDestination() string

func (*Ethernet) GetSource

func (m *Ethernet) GetSource() string

func (*Ethernet) MarshalJSON

func (msg *Ethernet) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*Ethernet) ProtoMessage

func (*Ethernet) ProtoMessage()

func (*Ethernet) Reset

func (m *Ethernet) Reset()

func (*Ethernet) String

func (m *Ethernet) String() string

func (*Ethernet) UnmarshalJSON

func (msg *Ethernet) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*Ethernet) Validate

func (m *Ethernet) Validate() error

Validate checks the field values on Ethernet with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Ethernet) XXX_DiscardUnknown

func (m *Ethernet) XXX_DiscardUnknown()

func (*Ethernet) XXX_Marshal

func (m *Ethernet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Ethernet) XXX_Merge

func (m *Ethernet) XXX_Merge(src proto.Message)

func (*Ethernet) XXX_Size

func (m *Ethernet) XXX_Size() int

func (*Ethernet) XXX_Unmarshal

func (m *Ethernet) XXX_Unmarshal(b []byte) error

type EthernetValidationError

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

EthernetValidationError is the validation error returned by Ethernet.Validate if the designated constraints aren't met.

func (EthernetValidationError) Cause

func (e EthernetValidationError) Cause() error

Cause function returns cause value.

func (EthernetValidationError) Error

func (e EthernetValidationError) Error() string

Error satisfies the builtin error interface

func (EthernetValidationError) ErrorName

func (e EthernetValidationError) ErrorName() string

ErrorName returns error name.

func (EthernetValidationError) Field

func (e EthernetValidationError) Field() string

Field function returns field value.

func (EthernetValidationError) Key

func (e EthernetValidationError) Key() bool

Key function returns key value.

func (EthernetValidationError) Reason

func (e EthernetValidationError) Reason() string

Reason function returns reason value.

type EventType

type EventType int32

EventType are constants are based on the ones from <linux/perf_event.h>.

const (
	EventType_UNKNOWN EventType = 0
	// EventSample is equivalent to PERF_RECORD_SAMPLE.
	EventType_EventSample EventType = 9
	// RecordLost is equivalent to PERF_RECORD_LOST.
	EventType_RecordLost EventType = 2
)

func (EventType) EnumDescriptor

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

func (EventType) String

func (x EventType) String() string

type EventTypeFilter

type EventTypeFilter struct {
	// type is the primary flow type as defined by:
	// github.com/cilium/cilium/pkg/monitor/api.MessageType*
	Type int32 `protobuf:"varint,1,opt,name=type,proto3" json:"type,omitempty"`
	// match_sub_type is set to true when matching on the sub_type should
	// be done. This flag is required as 0 is a valid sub_type.
	MatchSubType bool `protobuf:"varint,2,opt,name=match_sub_type,json=matchSubType,proto3" json:"match_sub_type,omitempty"`
	// sub_type is the secondary type, e.g.
	// - github.com/cilium/cilium/pkg/monitor/api.Trace*
	SubType              int32    `protobuf:"varint,3,opt,name=sub_type,json=subType,proto3" json:"sub_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

EventTypeFilter is a filter describing a particular event type

func (*EventTypeFilter) Descriptor

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

func (*EventTypeFilter) GetMatchSubType

func (m *EventTypeFilter) GetMatchSubType() bool

func (*EventTypeFilter) GetSubType

func (m *EventTypeFilter) GetSubType() int32

func (*EventTypeFilter) GetType

func (m *EventTypeFilter) GetType() int32

func (*EventTypeFilter) MarshalJSON

func (msg *EventTypeFilter) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*EventTypeFilter) ProtoMessage

func (*EventTypeFilter) ProtoMessage()

func (*EventTypeFilter) Reset

func (m *EventTypeFilter) Reset()

func (*EventTypeFilter) String

func (m *EventTypeFilter) String() string

func (*EventTypeFilter) UnmarshalJSON

func (msg *EventTypeFilter) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*EventTypeFilter) Validate

func (m *EventTypeFilter) Validate() error

Validate checks the field values on EventTypeFilter with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*EventTypeFilter) XXX_DiscardUnknown

func (m *EventTypeFilter) XXX_DiscardUnknown()

func (*EventTypeFilter) XXX_Marshal

func (m *EventTypeFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventTypeFilter) XXX_Merge

func (m *EventTypeFilter) XXX_Merge(src proto.Message)

func (*EventTypeFilter) XXX_Size

func (m *EventTypeFilter) XXX_Size() int

func (*EventTypeFilter) XXX_Unmarshal

func (m *EventTypeFilter) XXX_Unmarshal(b []byte) error

type EventTypeFilterValidationError

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

EventTypeFilterValidationError is the validation error returned by EventTypeFilter.Validate if the designated constraints aren't met.

func (EventTypeFilterValidationError) Cause

Cause function returns cause value.

func (EventTypeFilterValidationError) Error

Error satisfies the builtin error interface

func (EventTypeFilterValidationError) ErrorName

func (e EventTypeFilterValidationError) ErrorName() string

ErrorName returns error name.

func (EventTypeFilterValidationError) Field

Field function returns field value.

func (EventTypeFilterValidationError) Key

Key function returns key value.

func (EventTypeFilterValidationError) Reason

Reason function returns reason value.

type Flow

type Flow struct {
	Time    *types.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	Verdict Verdict          `protobuf:"varint,2,opt,name=verdict,proto3,enum=flow.Verdict" json:"verdict,omitempty"`
	// only applicable to Verdict = DROPPED.
	DropReason uint32 `protobuf:"varint,3,opt,name=drop_reason,json=dropReason,proto3" json:"drop_reason,omitempty"`
	// l2
	Ethernet *Ethernet `protobuf:"bytes,4,opt,name=ethernet,proto3" json:"ethernet,omitempty"`
	// l3
	IP *IP `protobuf:"bytes,5,opt,name=IP,proto3" json:"IP,omitempty"`
	// l4
	L4          *Layer4   `protobuf:"bytes,6,opt,name=l4,proto3" json:"l4,omitempty"`
	Source      *Endpoint `protobuf:"bytes,8,opt,name=source,proto3" json:"source,omitempty"`
	Destination *Endpoint `protobuf:"bytes,9,opt,name=destination,proto3" json:"destination,omitempty"`
	Type        FlowType  `protobuf:"varint,10,opt,name=Type,proto3,enum=flow.FlowType" json:"Type,omitempty"`
	// NodeName is the name of the node from which this Flow was captured.
	NodeName string `protobuf:"bytes,11,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	// all names the source IP can have.
	SourceNames []string `protobuf:"bytes,13,rep,name=source_names,json=sourceNames,proto3" json:"source_names,omitempty"`
	// all names the destination IP can have.
	DestinationNames []string `protobuf:"bytes,14,rep,name=destination_names,json=destinationNames,proto3" json:"destination_names,omitempty"`
	// L7 information. This field is set if and only if FlowType is L7.
	L7    *Layer7 `protobuf:"bytes,15,opt,name=l7,proto3" json:"l7,omitempty"`
	Reply bool    `protobuf:"varint,16,opt,name=reply,proto3" json:"reply,omitempty"`
	// EventType of the originating Cilium event
	EventType *CiliumEventType `protobuf:"bytes,19,opt,name=event_type,json=eventType,proto3" json:"event_type,omitempty"`
	// source_service contains the service name of the source
	SourceService *Service `protobuf:"bytes,20,opt,name=source_service,json=sourceService,proto3" json:"source_service,omitempty"`
	// destination_service contains the service name of the destination
	DestinationService *Service `protobuf:"bytes,21,opt,name=destination_service,json=destinationService,proto3" json:"destination_service,omitempty"`
	// This is a temporary workaround to support summary field for pb.Flow without
	// duplicating logic from the old parser. This field will be removed once we
	// fully migrate to the new parser.
	Summary              string   `protobuf:"bytes,100000,opt,name=Summary,proto3" json:"Summary,omitempty"` // Deprecated: Do not use.
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Flow) Descriptor

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

func (*Flow) GetDestination

func (m *Flow) GetDestination() *Endpoint

func (*Flow) GetDestinationNames

func (m *Flow) GetDestinationNames() []string

func (*Flow) GetDestinationService

func (m *Flow) GetDestinationService() *Service

func (*Flow) GetDropReason

func (m *Flow) GetDropReason() uint32

func (*Flow) GetEthernet

func (m *Flow) GetEthernet() *Ethernet

func (*Flow) GetEventType

func (m *Flow) GetEventType() *CiliumEventType

func (*Flow) GetIP

func (m *Flow) GetIP() *IP

func (*Flow) GetL4

func (m *Flow) GetL4() *Layer4

func (*Flow) GetL7

func (m *Flow) GetL7() *Layer7

func (*Flow) GetNodeName

func (m *Flow) GetNodeName() string

func (*Flow) GetReply

func (m *Flow) GetReply() bool

func (*Flow) GetSource

func (m *Flow) GetSource() *Endpoint

func (*Flow) GetSourceNames

func (m *Flow) GetSourceNames() []string

func (*Flow) GetSourceService

func (m *Flow) GetSourceService() *Service

func (*Flow) GetSummary deprecated

func (m *Flow) GetSummary() string

Deprecated: Do not use.

func (*Flow) GetTime

func (m *Flow) GetTime() *types.Timestamp

func (*Flow) GetType

func (m *Flow) GetType() FlowType

func (*Flow) GetVerdict

func (m *Flow) GetVerdict() Verdict

func (*Flow) MarshalJSON

func (msg *Flow) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*Flow) ProtoMessage

func (*Flow) ProtoMessage()

func (*Flow) Reset

func (m *Flow) Reset()

func (*Flow) String

func (m *Flow) String() string

func (*Flow) UnmarshalJSON

func (msg *Flow) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*Flow) Validate

func (m *Flow) Validate() error

Validate checks the field values on Flow with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Flow) XXX_DiscardUnknown

func (m *Flow) XXX_DiscardUnknown()

func (*Flow) XXX_Marshal

func (m *Flow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Flow) XXX_Merge

func (m *Flow) XXX_Merge(src proto.Message)

func (*Flow) XXX_Size

func (m *Flow) XXX_Size() int

func (*Flow) XXX_Unmarshal

func (m *Flow) XXX_Unmarshal(b []byte) error

type FlowFilter

type FlowFilter struct {
	// source_ip filters by a list of source ips
	SourceIp []string `protobuf:"bytes,1,rep,name=source_ip,json=sourceIp,proto3" json:"source_ip,omitempty"`
	// source_pod filters by a list of source pod name prefixes, optionally
	// within a given namespace (e.g. "xwing", "kube-system/coredns-").
	// The pod name can be emitted to only filter by namespace
	// (e.g. "kube-system/")
	SourcePod []string `protobuf:"bytes,2,rep,name=source_pod,json=sourcePod,proto3" json:"source_pod,omitempty"`
	// source_fqdn filters by a list of source fully qualified domain names
	SourceFqdn []string `protobuf:"bytes,7,rep,name=source_fqdn,json=sourceFqdn,proto3" json:"source_fqdn,omitempty"`
	// source_labels filters on a list of source label selectors. Selectors
	// support the full Kubernetes label selector syntax.
	SourceLabel []string `protobuf:"bytes,10,rep,name=source_label,json=sourceLabel,proto3" json:"source_label,omitempty"`
	// source_service filters on a list of source service names. This field
	// supports the same syntax as the source_pod field.
	SourceService []string `protobuf:"bytes,16,rep,name=source_service,json=sourceService,proto3" json:"source_service,omitempty"`
	// destination_ip filters by a list of destination ips
	DestinationIp []string `protobuf:"bytes,3,rep,name=destination_ip,json=destinationIp,proto3" json:"destination_ip,omitempty"`
	// destination_pod filters by a list of destination pod names
	DestinationPod []string `protobuf:"bytes,4,rep,name=destination_pod,json=destinationPod,proto3" json:"destination_pod,omitempty"`
	// destination_fqdn filters by a list of destination fully qualified domain names
	DestinationFqdn []string `protobuf:"bytes,8,rep,name=destination_fqdn,json=destinationFqdn,proto3" json:"destination_fqdn,omitempty"`
	// destination_label filters on a list of destination label selectors
	DestinationLabel []string `protobuf:"bytes,11,rep,name=destination_label,json=destinationLabel,proto3" json:"destination_label,omitempty"`
	// destination_service filters on a list of destination service names
	DestinationService []string `protobuf:"bytes,17,rep,name=destination_service,json=destinationService,proto3" json:"destination_service,omitempty"`
	// only return Flows that were classified with a particular verdict.
	Verdict []Verdict `protobuf:"varint,5,rep,packed,name=verdict,proto3,enum=flow.Verdict" json:"verdict,omitempty"`
	// event_type is the list of event types to filter on
	EventType []*EventTypeFilter `protobuf:"bytes,6,rep,name=event_type,json=eventType,proto3" json:"event_type,omitempty"`
	// http_status_code is a list of string prefixes (e.g. "4+", "404", "5+")
	// to filter on the HTTP status code
	HttpStatusCode []string `protobuf:"bytes,9,rep,name=http_status_code,json=httpStatusCode,proto3" json:"http_status_code,omitempty"`
	// protocol filters flows by L4 or L7 protocol, e.g. (e.g. "tcp", "http")
	Protocol []string `protobuf:"bytes,12,rep,name=protocol,proto3" json:"protocol,omitempty"`
	// source_port filters flows by L4 source port
	SourcePort []string `protobuf:"bytes,13,rep,name=source_port,json=sourcePort,proto3" json:"source_port,omitempty"`
	// destination_port filters flows by L4 destination port
	DestinationPort []string `protobuf:"bytes,14,rep,name=destination_port,json=destinationPort,proto3" json:"destination_port,omitempty"`
	// reply filters flows based on the direction of the flow.
	Reply []bool `protobuf:"varint,15,rep,packed,name=reply,proto3" json:"reply,omitempty"`
	// dns_query filters L7 DNS flows by query patterns (RE2 regex), e.g. 'kube.*local'.
	DnsQuery []string `protobuf:"bytes,18,rep,name=dns_query,json=dnsQuery,proto3" json:"dns_query,omitempty"`
	// source_identity filters by the security identity of the source endpoint.
	SourceIdentity []uint64 `protobuf:"varint,19,rep,packed,name=source_identity,json=sourceIdentity,proto3" json:"source_identity,omitempty"`
	// destination_identity filters by the security identity of the destination endpoint.
	DestinationIdentity  []uint64 `` /* 127-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

FlowFilter represent an individual flow filter. All fields are optional. If multiple fields are set, then all fields must match for the filter to match.

func (*FlowFilter) Descriptor

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

func (*FlowFilter) GetDestinationFqdn

func (m *FlowFilter) GetDestinationFqdn() []string

func (*FlowFilter) GetDestinationIdentity

func (m *FlowFilter) GetDestinationIdentity() []uint64

func (*FlowFilter) GetDestinationIp

func (m *FlowFilter) GetDestinationIp() []string

func (*FlowFilter) GetDestinationLabel

func (m *FlowFilter) GetDestinationLabel() []string

func (*FlowFilter) GetDestinationPod

func (m *FlowFilter) GetDestinationPod() []string

func (*FlowFilter) GetDestinationPort

func (m *FlowFilter) GetDestinationPort() []string

func (*FlowFilter) GetDestinationService

func (m *FlowFilter) GetDestinationService() []string

func (*FlowFilter) GetDnsQuery

func (m *FlowFilter) GetDnsQuery() []string

func (*FlowFilter) GetEventType

func (m *FlowFilter) GetEventType() []*EventTypeFilter

func (*FlowFilter) GetHttpStatusCode

func (m *FlowFilter) GetHttpStatusCode() []string

func (*FlowFilter) GetProtocol

func (m *FlowFilter) GetProtocol() []string

func (*FlowFilter) GetReply

func (m *FlowFilter) GetReply() []bool

func (*FlowFilter) GetSourceFqdn

func (m *FlowFilter) GetSourceFqdn() []string

func (*FlowFilter) GetSourceIdentity

func (m *FlowFilter) GetSourceIdentity() []uint64

func (*FlowFilter) GetSourceIp

func (m *FlowFilter) GetSourceIp() []string

func (*FlowFilter) GetSourceLabel

func (m *FlowFilter) GetSourceLabel() []string

func (*FlowFilter) GetSourcePod

func (m *FlowFilter) GetSourcePod() []string

func (*FlowFilter) GetSourcePort

func (m *FlowFilter) GetSourcePort() []string

func (*FlowFilter) GetSourceService

func (m *FlowFilter) GetSourceService() []string

func (*FlowFilter) GetVerdict

func (m *FlowFilter) GetVerdict() []Verdict

func (*FlowFilter) MarshalJSON

func (msg *FlowFilter) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*FlowFilter) ProtoMessage

func (*FlowFilter) ProtoMessage()

func (*FlowFilter) Reset

func (m *FlowFilter) Reset()

func (*FlowFilter) String

func (m *FlowFilter) String() string

func (*FlowFilter) UnmarshalJSON

func (msg *FlowFilter) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*FlowFilter) Validate

func (m *FlowFilter) Validate() error

Validate checks the field values on FlowFilter with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*FlowFilter) XXX_DiscardUnknown

func (m *FlowFilter) XXX_DiscardUnknown()

func (*FlowFilter) XXX_Marshal

func (m *FlowFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FlowFilter) XXX_Merge

func (m *FlowFilter) XXX_Merge(src proto.Message)

func (*FlowFilter) XXX_Size

func (m *FlowFilter) XXX_Size() int

func (*FlowFilter) XXX_Unmarshal

func (m *FlowFilter) XXX_Unmarshal(b []byte) error

type FlowFilterValidationError

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

FlowFilterValidationError is the validation error returned by FlowFilter.Validate if the designated constraints aren't met.

func (FlowFilterValidationError) Cause

func (e FlowFilterValidationError) Cause() error

Cause function returns cause value.

func (FlowFilterValidationError) Error

Error satisfies the builtin error interface

func (FlowFilterValidationError) ErrorName

func (e FlowFilterValidationError) ErrorName() string

ErrorName returns error name.

func (FlowFilterValidationError) Field

Field function returns field value.

func (FlowFilterValidationError) Key

Key function returns key value.

func (FlowFilterValidationError) Reason

func (e FlowFilterValidationError) Reason() string

Reason function returns reason value.

type FlowType

type FlowType int32
const (
	FlowType_UNKNOWN_TYPE FlowType = 0
	FlowType_L3_L4        FlowType = 1
	FlowType_L7           FlowType = 2
)

func (FlowType) EnumDescriptor

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

func (FlowType) String

func (x FlowType) String() string

type FlowValidationError

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

FlowValidationError is the validation error returned by Flow.Validate if the designated constraints aren't met.

func (FlowValidationError) Cause

func (e FlowValidationError) Cause() error

Cause function returns cause value.

func (FlowValidationError) Error

func (e FlowValidationError) Error() string

Error satisfies the builtin error interface

func (FlowValidationError) ErrorName

func (e FlowValidationError) ErrorName() string

ErrorName returns error name.

func (FlowValidationError) Field

func (e FlowValidationError) Field() string

Field function returns field value.

func (FlowValidationError) Key

func (e FlowValidationError) Key() bool

Key function returns key value.

func (FlowValidationError) Reason

func (e FlowValidationError) Reason() string

Reason function returns reason value.

type HTTP

type HTTP struct {
	Code                 uint32        `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Method               string        `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	Url                  string        `protobuf:"bytes,3,opt,name=url,proto3" json:"url,omitempty"`
	Protocol             string        `protobuf:"bytes,4,opt,name=protocol,proto3" json:"protocol,omitempty"`
	Headers              []*HTTPHeader `protobuf:"bytes,5,rep,name=headers,proto3" json:"headers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

L7 information for HTTP flows. It corresponds to Cilium's accesslog.LogRecordHTTP type.

https://github.com/cilium/cilium/blob/728c79e427438ab6f8d9375b62fccd6fed4ace3a/pkg/proxy/accesslog/record.go#L206

func (*HTTP) Descriptor

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

func (*HTTP) GetCode

func (m *HTTP) GetCode() uint32

func (*HTTP) GetHeaders

func (m *HTTP) GetHeaders() []*HTTPHeader

func (*HTTP) GetMethod

func (m *HTTP) GetMethod() string

func (*HTTP) GetProtocol

func (m *HTTP) GetProtocol() string

func (*HTTP) GetUrl

func (m *HTTP) GetUrl() string

func (*HTTP) MarshalJSON

func (msg *HTTP) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*HTTP) ProtoMessage

func (*HTTP) ProtoMessage()

func (*HTTP) Reset

func (m *HTTP) Reset()

func (*HTTP) String

func (m *HTTP) String() string

func (*HTTP) UnmarshalJSON

func (msg *HTTP) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*HTTP) Validate

func (m *HTTP) Validate() error

Validate checks the field values on HTTP with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*HTTP) XXX_DiscardUnknown

func (m *HTTP) XXX_DiscardUnknown()

func (*HTTP) XXX_Marshal

func (m *HTTP) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HTTP) XXX_Merge

func (m *HTTP) XXX_Merge(src proto.Message)

func (*HTTP) XXX_Size

func (m *HTTP) XXX_Size() int

func (*HTTP) XXX_Unmarshal

func (m *HTTP) XXX_Unmarshal(b []byte) error

type HTTPHeader

type HTTPHeader struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HTTPHeader) Descriptor

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

func (*HTTPHeader) GetKey

func (m *HTTPHeader) GetKey() string

func (*HTTPHeader) GetValue

func (m *HTTPHeader) GetValue() string

func (*HTTPHeader) MarshalJSON

func (msg *HTTPHeader) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*HTTPHeader) ProtoMessage

func (*HTTPHeader) ProtoMessage()

func (*HTTPHeader) Reset

func (m *HTTPHeader) Reset()

func (*HTTPHeader) String

func (m *HTTPHeader) String() string

func (*HTTPHeader) UnmarshalJSON

func (msg *HTTPHeader) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*HTTPHeader) Validate

func (m *HTTPHeader) Validate() error

Validate checks the field values on HTTPHeader with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*HTTPHeader) XXX_DiscardUnknown

func (m *HTTPHeader) XXX_DiscardUnknown()

func (*HTTPHeader) XXX_Marshal

func (m *HTTPHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HTTPHeader) XXX_Merge

func (m *HTTPHeader) XXX_Merge(src proto.Message)

func (*HTTPHeader) XXX_Size

func (m *HTTPHeader) XXX_Size() int

func (*HTTPHeader) XXX_Unmarshal

func (m *HTTPHeader) XXX_Unmarshal(b []byte) error

type HTTPHeaderValidationError

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

HTTPHeaderValidationError is the validation error returned by HTTPHeader.Validate if the designated constraints aren't met.

func (HTTPHeaderValidationError) Cause

func (e HTTPHeaderValidationError) Cause() error

Cause function returns cause value.

func (HTTPHeaderValidationError) Error

Error satisfies the builtin error interface

func (HTTPHeaderValidationError) ErrorName

func (e HTTPHeaderValidationError) ErrorName() string

ErrorName returns error name.

func (HTTPHeaderValidationError) Field

Field function returns field value.

func (HTTPHeaderValidationError) Key

Key function returns key value.

func (HTTPHeaderValidationError) Reason

func (e HTTPHeaderValidationError) Reason() string

Reason function returns reason value.

type HTTPValidationError

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

HTTPValidationError is the validation error returned by HTTP.Validate if the designated constraints aren't met.

func (HTTPValidationError) Cause

func (e HTTPValidationError) Cause() error

Cause function returns cause value.

func (HTTPValidationError) Error

func (e HTTPValidationError) Error() string

Error satisfies the builtin error interface

func (HTTPValidationError) ErrorName

func (e HTTPValidationError) ErrorName() string

ErrorName returns error name.

func (HTTPValidationError) Field

func (e HTTPValidationError) Field() string

Field function returns field value.

func (HTTPValidationError) Key

func (e HTTPValidationError) Key() bool

Key function returns key value.

func (HTTPValidationError) Reason

func (e HTTPValidationError) Reason() string

Reason function returns reason value.

type ICMPv4

type ICMPv4 struct {
	Type                 uint32   `protobuf:"varint,1,opt,name=type,proto3" json:"type,omitempty"`
	Code                 uint32   `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ICMPv4) Descriptor

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

func (*ICMPv4) GetCode

func (m *ICMPv4) GetCode() uint32

func (*ICMPv4) GetType

func (m *ICMPv4) GetType() uint32

func (*ICMPv4) MarshalJSON

func (msg *ICMPv4) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*ICMPv4) ProtoMessage

func (*ICMPv4) ProtoMessage()

func (*ICMPv4) Reset

func (m *ICMPv4) Reset()

func (*ICMPv4) String

func (m *ICMPv4) String() string

func (*ICMPv4) UnmarshalJSON

func (msg *ICMPv4) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*ICMPv4) Validate

func (m *ICMPv4) Validate() error

Validate checks the field values on ICMPv4 with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ICMPv4) XXX_DiscardUnknown

func (m *ICMPv4) XXX_DiscardUnknown()

func (*ICMPv4) XXX_Marshal

func (m *ICMPv4) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ICMPv4) XXX_Merge

func (m *ICMPv4) XXX_Merge(src proto.Message)

func (*ICMPv4) XXX_Size

func (m *ICMPv4) XXX_Size() int

func (*ICMPv4) XXX_Unmarshal

func (m *ICMPv4) XXX_Unmarshal(b []byte) error

type ICMPv4ValidationError

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

ICMPv4ValidationError is the validation error returned by ICMPv4.Validate if the designated constraints aren't met.

func (ICMPv4ValidationError) Cause

func (e ICMPv4ValidationError) Cause() error

Cause function returns cause value.

func (ICMPv4ValidationError) Error

func (e ICMPv4ValidationError) Error() string

Error satisfies the builtin error interface

func (ICMPv4ValidationError) ErrorName

func (e ICMPv4ValidationError) ErrorName() string

ErrorName returns error name.

func (ICMPv4ValidationError) Field

func (e ICMPv4ValidationError) Field() string

Field function returns field value.

func (ICMPv4ValidationError) Key

func (e ICMPv4ValidationError) Key() bool

Key function returns key value.

func (ICMPv4ValidationError) Reason

func (e ICMPv4ValidationError) Reason() string

Reason function returns reason value.

type ICMPv6

type ICMPv6 struct {
	Type                 uint32   `protobuf:"varint,1,opt,name=type,proto3" json:"type,omitempty"`
	Code                 uint32   `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ICMPv6) Descriptor

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

func (*ICMPv6) GetCode

func (m *ICMPv6) GetCode() uint32

func (*ICMPv6) GetType

func (m *ICMPv6) GetType() uint32

func (*ICMPv6) MarshalJSON

func (msg *ICMPv6) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*ICMPv6) ProtoMessage

func (*ICMPv6) ProtoMessage()

func (*ICMPv6) Reset

func (m *ICMPv6) Reset()

func (*ICMPv6) String

func (m *ICMPv6) String() string

func (*ICMPv6) UnmarshalJSON

func (msg *ICMPv6) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*ICMPv6) Validate

func (m *ICMPv6) Validate() error

Validate checks the field values on ICMPv6 with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ICMPv6) XXX_DiscardUnknown

func (m *ICMPv6) XXX_DiscardUnknown()

func (*ICMPv6) XXX_Marshal

func (m *ICMPv6) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ICMPv6) XXX_Merge

func (m *ICMPv6) XXX_Merge(src proto.Message)

func (*ICMPv6) XXX_Size

func (m *ICMPv6) XXX_Size() int

func (*ICMPv6) XXX_Unmarshal

func (m *ICMPv6) XXX_Unmarshal(b []byte) error

type ICMPv6ValidationError

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

ICMPv6ValidationError is the validation error returned by ICMPv6.Validate if the designated constraints aren't met.

func (ICMPv6ValidationError) Cause

func (e ICMPv6ValidationError) Cause() error

Cause function returns cause value.

func (ICMPv6ValidationError) Error

func (e ICMPv6ValidationError) Error() string

Error satisfies the builtin error interface

func (ICMPv6ValidationError) ErrorName

func (e ICMPv6ValidationError) ErrorName() string

ErrorName returns error name.

func (ICMPv6ValidationError) Field

func (e ICMPv6ValidationError) Field() string

Field function returns field value.

func (ICMPv6ValidationError) Key

func (e ICMPv6ValidationError) Key() bool

Key function returns key value.

func (ICMPv6ValidationError) Reason

func (e ICMPv6ValidationError) Reason() string

Reason function returns reason value.

type IP

type IP struct {
	Source      string    `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	Destination string    `protobuf:"bytes,2,opt,name=destination,proto3" json:"destination,omitempty"`
	IpVersion   IPVersion `protobuf:"varint,3,opt,name=ipVersion,proto3,enum=flow.IPVersion" json:"ipVersion,omitempty"`
	// This field indicates whether the TraceReasonEncryptMask is set or not.
	// https://github.com/cilium/cilium/blob/ba0ed147bd5bb342f67b1794c2ad13c6e99d5236/pkg/monitor/datapath_trace.go#L27
	Encrypted            bool     `protobuf:"varint,4,opt,name=encrypted,proto3" json:"encrypted,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IP) Descriptor

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

func (*IP) GetDestination

func (m *IP) GetDestination() string

func (*IP) GetEncrypted

func (m *IP) GetEncrypted() bool

func (*IP) GetIpVersion

func (m *IP) GetIpVersion() IPVersion

func (*IP) GetSource

func (m *IP) GetSource() string

func (*IP) MarshalJSON

func (msg *IP) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*IP) ProtoMessage

func (*IP) ProtoMessage()

func (*IP) Reset

func (m *IP) Reset()

func (*IP) String

func (m *IP) String() string

func (*IP) UnmarshalJSON

func (msg *IP) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*IP) Validate

func (m *IP) Validate() error

Validate checks the field values on IP with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*IP) XXX_DiscardUnknown

func (m *IP) XXX_DiscardUnknown()

func (*IP) XXX_Marshal

func (m *IP) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IP) XXX_Merge

func (m *IP) XXX_Merge(src proto.Message)

func (*IP) XXX_Size

func (m *IP) XXX_Size() int

func (*IP) XXX_Unmarshal

func (m *IP) XXX_Unmarshal(b []byte) error

type IPValidationError

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

IPValidationError is the validation error returned by IP.Validate if the designated constraints aren't met.

func (IPValidationError) Cause

func (e IPValidationError) Cause() error

Cause function returns cause value.

func (IPValidationError) Error

func (e IPValidationError) Error() string

Error satisfies the builtin error interface

func (IPValidationError) ErrorName

func (e IPValidationError) ErrorName() string

ErrorName returns error name.

func (IPValidationError) Field

func (e IPValidationError) Field() string

Field function returns field value.

func (IPValidationError) Key

func (e IPValidationError) Key() bool

Key function returns key value.

func (IPValidationError) Reason

func (e IPValidationError) Reason() string

Reason function returns reason value.

type IPVersion

type IPVersion int32
const (
	IPVersion_IP_NOT_USED IPVersion = 0
	IPVersion_IPv4        IPVersion = 1
	IPVersion_IPv6        IPVersion = 2
)

func (IPVersion) EnumDescriptor

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

func (IPVersion) String

func (x IPVersion) String() string

type Kafka

type Kafka struct {
	ErrorCode            int32    `protobuf:"varint,1,opt,name=error_code,json=errorCode,proto3" json:"error_code,omitempty"`
	ApiVersion           int32    `protobuf:"varint,2,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"`
	ApiKey               string   `protobuf:"bytes,3,opt,name=api_key,json=apiKey,proto3" json:"api_key,omitempty"`
	CorrelationId        int32    `protobuf:"varint,4,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	Topic                string   `protobuf:"bytes,5,opt,name=topic,proto3" json:"topic,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

L7 information for Kafka flows. It corresponds to Cilium's accesslog.LogRecordKafka type.

https://github.com/cilium/cilium/blob/728c79e427438ab6f8d9375b62fccd6fed4ace3a/pkg/proxy/accesslog/record.go#L229

func (*Kafka) Descriptor

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

func (*Kafka) GetApiKey

func (m *Kafka) GetApiKey() string

func (*Kafka) GetApiVersion

func (m *Kafka) GetApiVersion() int32

func (*Kafka) GetCorrelationId

func (m *Kafka) GetCorrelationId() int32

func (*Kafka) GetErrorCode

func (m *Kafka) GetErrorCode() int32

func (*Kafka) GetTopic

func (m *Kafka) GetTopic() string

func (*Kafka) MarshalJSON

func (msg *Kafka) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*Kafka) ProtoMessage

func (*Kafka) ProtoMessage()

func (*Kafka) Reset

func (m *Kafka) Reset()

func (*Kafka) String

func (m *Kafka) String() string

func (*Kafka) UnmarshalJSON

func (msg *Kafka) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*Kafka) Validate

func (m *Kafka) Validate() error

Validate checks the field values on Kafka with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Kafka) XXX_DiscardUnknown

func (m *Kafka) XXX_DiscardUnknown()

func (*Kafka) XXX_Marshal

func (m *Kafka) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Kafka) XXX_Merge

func (m *Kafka) XXX_Merge(src proto.Message)

func (*Kafka) XXX_Size

func (m *Kafka) XXX_Size() int

func (*Kafka) XXX_Unmarshal

func (m *Kafka) XXX_Unmarshal(b []byte) error

type KafkaValidationError

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

KafkaValidationError is the validation error returned by Kafka.Validate if the designated constraints aren't met.

func (KafkaValidationError) Cause

func (e KafkaValidationError) Cause() error

Cause function returns cause value.

func (KafkaValidationError) Error

func (e KafkaValidationError) Error() string

Error satisfies the builtin error interface

func (KafkaValidationError) ErrorName

func (e KafkaValidationError) ErrorName() string

ErrorName returns error name.

func (KafkaValidationError) Field

func (e KafkaValidationError) Field() string

Field function returns field value.

func (KafkaValidationError) Key

func (e KafkaValidationError) Key() bool

Key function returns key value.

func (KafkaValidationError) Reason

func (e KafkaValidationError) Reason() string

Reason function returns reason value.

type L7FlowType

type L7FlowType int32

This enum corresponds to Cilium's L7 accesslog FlowType:

https://github.com/cilium/cilium/blob/728c79e427438ab6f8d9375b62fccd6fed4ace3a/pkg/proxy/accesslog/record.go#L26
const (
	L7FlowType_UNKNOWN_L7_TYPE L7FlowType = 0
	L7FlowType_REQUEST         L7FlowType = 1
	L7FlowType_RESPONSE        L7FlowType = 2
	L7FlowType_SAMPLE          L7FlowType = 3
)

func (L7FlowType) EnumDescriptor

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

func (L7FlowType) String

func (x L7FlowType) String() string

type Layer4

type Layer4 struct {
	// Types that are valid to be assigned to Protocol:
	//	*Layer4_TCP
	//	*Layer4_UDP
	//	*Layer4_ICMPv4
	//	*Layer4_ICMPv6
	Protocol             isLayer4_Protocol `protobuf_oneof:"protocol"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Layer4) Descriptor

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

func (*Layer4) GetICMPv4

func (m *Layer4) GetICMPv4() *ICMPv4

func (*Layer4) GetICMPv6

func (m *Layer4) GetICMPv6() *ICMPv6

func (*Layer4) GetProtocol

func (m *Layer4) GetProtocol() isLayer4_Protocol

func (*Layer4) GetTCP

func (m *Layer4) GetTCP() *TCP

func (*Layer4) GetUDP

func (m *Layer4) GetUDP() *UDP

func (*Layer4) MarshalJSON

func (msg *Layer4) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*Layer4) ProtoMessage

func (*Layer4) ProtoMessage()

func (*Layer4) Reset

func (m *Layer4) Reset()

func (*Layer4) String

func (m *Layer4) String() string

func (*Layer4) UnmarshalJSON

func (msg *Layer4) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*Layer4) Validate

func (m *Layer4) Validate() error

Validate checks the field values on Layer4 with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Layer4) XXX_DiscardUnknown

func (m *Layer4) XXX_DiscardUnknown()

func (*Layer4) XXX_Marshal

func (m *Layer4) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Layer4) XXX_Merge

func (m *Layer4) XXX_Merge(src proto.Message)

func (*Layer4) XXX_OneofWrappers

func (*Layer4) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Layer4) XXX_Size

func (m *Layer4) XXX_Size() int

func (*Layer4) XXX_Unmarshal

func (m *Layer4) XXX_Unmarshal(b []byte) error

type Layer4ValidationError

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

Layer4ValidationError is the validation error returned by Layer4.Validate if the designated constraints aren't met.

func (Layer4ValidationError) Cause

func (e Layer4ValidationError) Cause() error

Cause function returns cause value.

func (Layer4ValidationError) Error

func (e Layer4ValidationError) Error() string

Error satisfies the builtin error interface

func (Layer4ValidationError) ErrorName

func (e Layer4ValidationError) ErrorName() string

ErrorName returns error name.

func (Layer4ValidationError) Field

func (e Layer4ValidationError) Field() string

Field function returns field value.

func (Layer4ValidationError) Key

func (e Layer4ValidationError) Key() bool

Key function returns key value.

func (Layer4ValidationError) Reason

func (e Layer4ValidationError) Reason() string

Reason function returns reason value.

type Layer4_ICMPv4

type Layer4_ICMPv4 struct {
	ICMPv4 *ICMPv4 `protobuf:"bytes,3,opt,name=ICMPv4,proto3,oneof"`
}

type Layer4_ICMPv6

type Layer4_ICMPv6 struct {
	ICMPv6 *ICMPv6 `protobuf:"bytes,4,opt,name=ICMPv6,proto3,oneof"`
}

type Layer4_TCP

type Layer4_TCP struct {
	TCP *TCP `protobuf:"bytes,1,opt,name=TCP,proto3,oneof"`
}

type Layer4_UDP

type Layer4_UDP struct {
	UDP *UDP `protobuf:"bytes,2,opt,name=UDP,proto3,oneof"`
}

type Layer7

type Layer7 struct {
	Type L7FlowType `protobuf:"varint,1,opt,name=type,proto3,enum=flow.L7FlowType" json:"type,omitempty"`
	// Latency of the response
	LatencyNs uint64 `protobuf:"varint,2,opt,name=latency_ns,json=latencyNs,proto3" json:"latency_ns,omitempty"`
	// L7 field. This field is set if and only if FlowType is L7.
	//
	// Types that are valid to be assigned to Record:
	//	*Layer7_Dns
	//	*Layer7_Http
	//	*Layer7_Kafka
	Record               isLayer7_Record `protobuf_oneof:"record"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

Message for L7 flow, which roughly corresponds to Cilium's accesslog LogRecord:

https://github.com/cilium/cilium/blob/728c79e427438ab6f8d9375b62fccd6fed4ace3a/pkg/proxy/accesslog/record.go#L141

func (*Layer7) Descriptor

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

func (*Layer7) GetDns

func (m *Layer7) GetDns() *DNS

func (*Layer7) GetHttp

func (m *Layer7) GetHttp() *HTTP

func (*Layer7) GetKafka

func (m *Layer7) GetKafka() *Kafka

func (*Layer7) GetLatencyNs

func (m *Layer7) GetLatencyNs() uint64

func (*Layer7) GetRecord

func (m *Layer7) GetRecord() isLayer7_Record

func (*Layer7) GetType

func (m *Layer7) GetType() L7FlowType

func (*Layer7) MarshalJSON

func (msg *Layer7) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*Layer7) ProtoMessage

func (*Layer7) ProtoMessage()

func (*Layer7) Reset

func (m *Layer7) Reset()

func (*Layer7) String

func (m *Layer7) String() string

func (*Layer7) UnmarshalJSON

func (msg *Layer7) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*Layer7) Validate

func (m *Layer7) Validate() error

Validate checks the field values on Layer7 with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Layer7) XXX_DiscardUnknown

func (m *Layer7) XXX_DiscardUnknown()

func (*Layer7) XXX_Marshal

func (m *Layer7) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Layer7) XXX_Merge

func (m *Layer7) XXX_Merge(src proto.Message)

func (*Layer7) XXX_OneofWrappers

func (*Layer7) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Layer7) XXX_Size

func (m *Layer7) XXX_Size() int

func (*Layer7) XXX_Unmarshal

func (m *Layer7) XXX_Unmarshal(b []byte) error

type Layer7ValidationError

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

Layer7ValidationError is the validation error returned by Layer7.Validate if the designated constraints aren't met.

func (Layer7ValidationError) Cause

func (e Layer7ValidationError) Cause() error

Cause function returns cause value.

func (Layer7ValidationError) Error

func (e Layer7ValidationError) Error() string

Error satisfies the builtin error interface

func (Layer7ValidationError) ErrorName

func (e Layer7ValidationError) ErrorName() string

ErrorName returns error name.

func (Layer7ValidationError) Field

func (e Layer7ValidationError) Field() string

Field function returns field value.

func (Layer7ValidationError) Key

func (e Layer7ValidationError) Key() bool

Key function returns key value.

func (Layer7ValidationError) Reason

func (e Layer7ValidationError) Reason() string

Reason function returns reason value.

type Layer7_Dns

type Layer7_Dns struct {
	Dns *DNS `protobuf:"bytes,100,opt,name=dns,proto3,oneof"`
}

type Layer7_Http

type Layer7_Http struct {
	Http *HTTP `protobuf:"bytes,101,opt,name=http,proto3,oneof"`
}

type Layer7_Kafka

type Layer7_Kafka struct {
	Kafka *Kafka `protobuf:"bytes,102,opt,name=kafka,proto3,oneof"`
}

type Payload

type Payload struct {
	// type is the event type perf returns.
	Type EventType `protobuf:"varint,1,opt,name=type,proto3,enum=flow.EventType" json:"type,omitempty"`
	// CPU is the CPU id for this event.
	CPU int32 `protobuf:"varint,2,opt,name=CPU,proto3" json:"CPU,omitempty"`
	// lost is the number of events lost for a given CPU.
	Lost uint64 `protobuf:"varint,3,opt,name=lost,proto3" json:"lost,omitempty"`
	// data is the sample data returned by perf.
	Data []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	// time when the event was observed
	Time *types.Timestamp `protobuf:"bytes,5,opt,name=time,proto3" json:"time,omitempty"`
	// the host name from which the payload was captured.
	HostName             string   `protobuf:"bytes,6,opt,name=host_name,json=hostName,proto3" json:"host_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Payload is the payload, i.e. the data the monitor returns.

func (*Payload) Descriptor

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

func (*Payload) GetCPU

func (m *Payload) GetCPU() int32

func (*Payload) GetData

func (m *Payload) GetData() []byte

func (*Payload) GetHostName

func (m *Payload) GetHostName() string

func (*Payload) GetLost

func (m *Payload) GetLost() uint64

func (*Payload) GetTime

func (m *Payload) GetTime() *types.Timestamp

func (*Payload) GetType

func (m *Payload) GetType() EventType

func (*Payload) MarshalJSON

func (msg *Payload) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*Payload) ProtoMessage

func (*Payload) ProtoMessage()

func (*Payload) Reset

func (m *Payload) Reset()

func (*Payload) String

func (m *Payload) String() string

func (*Payload) UnmarshalJSON

func (msg *Payload) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*Payload) Validate

func (m *Payload) Validate() error

Validate checks the field values on Payload with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Payload) XXX_DiscardUnknown

func (m *Payload) XXX_DiscardUnknown()

func (*Payload) XXX_Marshal

func (m *Payload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Payload) XXX_Merge

func (m *Payload) XXX_Merge(src proto.Message)

func (*Payload) XXX_Size

func (m *Payload) XXX_Size() int

func (*Payload) XXX_Unmarshal

func (m *Payload) XXX_Unmarshal(b []byte) error

type PayloadValidationError

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

PayloadValidationError is the validation error returned by Payload.Validate if the designated constraints aren't met.

func (PayloadValidationError) Cause

func (e PayloadValidationError) Cause() error

Cause function returns cause value.

func (PayloadValidationError) Error

func (e PayloadValidationError) Error() string

Error satisfies the builtin error interface

func (PayloadValidationError) ErrorName

func (e PayloadValidationError) ErrorName() string

ErrorName returns error name.

func (PayloadValidationError) Field

func (e PayloadValidationError) Field() string

Field function returns field value.

func (PayloadValidationError) Key

func (e PayloadValidationError) Key() bool

Key function returns key value.

func (PayloadValidationError) Reason

func (e PayloadValidationError) Reason() string

Reason function returns reason value.

type Service

type Service struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace            string   `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Service) Descriptor

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

func (*Service) GetName

func (m *Service) GetName() string

func (*Service) GetNamespace

func (m *Service) GetNamespace() string

func (*Service) MarshalJSON

func (msg *Service) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*Service) ProtoMessage

func (*Service) ProtoMessage()

func (*Service) Reset

func (m *Service) Reset()

func (*Service) String

func (m *Service) String() string

func (*Service) UnmarshalJSON

func (msg *Service) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*Service) Validate

func (m *Service) Validate() error

Validate checks the field values on Service with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Service) XXX_DiscardUnknown

func (m *Service) XXX_DiscardUnknown()

func (*Service) XXX_Marshal

func (m *Service) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Service) XXX_Merge

func (m *Service) XXX_Merge(src proto.Message)

func (*Service) XXX_Size

func (m *Service) XXX_Size() int

func (*Service) XXX_Unmarshal

func (m *Service) XXX_Unmarshal(b []byte) error

type ServiceValidationError

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

ServiceValidationError is the validation error returned by Service.Validate if the designated constraints aren't met.

func (ServiceValidationError) Cause

func (e ServiceValidationError) Cause() error

Cause function returns cause value.

func (ServiceValidationError) Error

func (e ServiceValidationError) Error() string

Error satisfies the builtin error interface

func (ServiceValidationError) ErrorName

func (e ServiceValidationError) ErrorName() string

ErrorName returns error name.

func (ServiceValidationError) Field

func (e ServiceValidationError) Field() string

Field function returns field value.

func (ServiceValidationError) Key

func (e ServiceValidationError) Key() bool

Key function returns key value.

func (ServiceValidationError) Reason

func (e ServiceValidationError) Reason() string

Reason function returns reason value.

type TCP

type TCP struct {
	SourcePort           uint32    `protobuf:"varint,1,opt,name=source_port,json=sourcePort,proto3" json:"source_port,omitempty"`
	DestinationPort      uint32    `protobuf:"varint,2,opt,name=destination_port,json=destinationPort,proto3" json:"destination_port,omitempty"`
	Flags                *TCPFlags `protobuf:"bytes,3,opt,name=flags,proto3" json:"flags,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*TCP) Descriptor

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

func (*TCP) GetDestinationPort

func (m *TCP) GetDestinationPort() uint32

func (*TCP) GetFlags

func (m *TCP) GetFlags() *TCPFlags

func (*TCP) GetSourcePort

func (m *TCP) GetSourcePort() uint32

func (*TCP) MarshalJSON

func (msg *TCP) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*TCP) ProtoMessage

func (*TCP) ProtoMessage()

func (*TCP) Reset

func (m *TCP) Reset()

func (*TCP) String

func (m *TCP) String() string

func (*TCP) UnmarshalJSON

func (msg *TCP) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*TCP) Validate

func (m *TCP) Validate() error

Validate checks the field values on TCP with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TCP) XXX_DiscardUnknown

func (m *TCP) XXX_DiscardUnknown()

func (*TCP) XXX_Marshal

func (m *TCP) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TCP) XXX_Merge

func (m *TCP) XXX_Merge(src proto.Message)

func (*TCP) XXX_Size

func (m *TCP) XXX_Size() int

func (*TCP) XXX_Unmarshal

func (m *TCP) XXX_Unmarshal(b []byte) error

type TCPFlags

type TCPFlags struct {
	FIN                  bool     `protobuf:"varint,1,opt,name=FIN,proto3" json:"FIN,omitempty"`
	SYN                  bool     `protobuf:"varint,2,opt,name=SYN,proto3" json:"SYN,omitempty"`
	RST                  bool     `protobuf:"varint,3,opt,name=RST,proto3" json:"RST,omitempty"`
	PSH                  bool     `protobuf:"varint,4,opt,name=PSH,proto3" json:"PSH,omitempty"`
	ACK                  bool     `protobuf:"varint,5,opt,name=ACK,proto3" json:"ACK,omitempty"`
	URG                  bool     `protobuf:"varint,6,opt,name=URG,proto3" json:"URG,omitempty"`
	ECE                  bool     `protobuf:"varint,7,opt,name=ECE,proto3" json:"ECE,omitempty"`
	CWR                  bool     `protobuf:"varint,8,opt,name=CWR,proto3" json:"CWR,omitempty"`
	NS                   bool     `protobuf:"varint,9,opt,name=NS,proto3" json:"NS,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TCPFlags) Descriptor

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

func (*TCPFlags) GetACK

func (m *TCPFlags) GetACK() bool

func (*TCPFlags) GetCWR

func (m *TCPFlags) GetCWR() bool

func (*TCPFlags) GetECE

func (m *TCPFlags) GetECE() bool

func (*TCPFlags) GetFIN

func (m *TCPFlags) GetFIN() bool

func (*TCPFlags) GetNS

func (m *TCPFlags) GetNS() bool

func (*TCPFlags) GetPSH

func (m *TCPFlags) GetPSH() bool

func (*TCPFlags) GetRST

func (m *TCPFlags) GetRST() bool

func (*TCPFlags) GetSYN

func (m *TCPFlags) GetSYN() bool

func (*TCPFlags) GetURG

func (m *TCPFlags) GetURG() bool

func (*TCPFlags) MarshalJSON

func (msg *TCPFlags) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*TCPFlags) ProtoMessage

func (*TCPFlags) ProtoMessage()

func (*TCPFlags) Reset

func (m *TCPFlags) Reset()

func (*TCPFlags) String

func (m *TCPFlags) String() string

func (*TCPFlags) UnmarshalJSON

func (msg *TCPFlags) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*TCPFlags) Validate

func (m *TCPFlags) Validate() error

Validate checks the field values on TCPFlags with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TCPFlags) XXX_DiscardUnknown

func (m *TCPFlags) XXX_DiscardUnknown()

func (*TCPFlags) XXX_Marshal

func (m *TCPFlags) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TCPFlags) XXX_Merge

func (m *TCPFlags) XXX_Merge(src proto.Message)

func (*TCPFlags) XXX_Size

func (m *TCPFlags) XXX_Size() int

func (*TCPFlags) XXX_Unmarshal

func (m *TCPFlags) XXX_Unmarshal(b []byte) error

type TCPFlagsValidationError

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

TCPFlagsValidationError is the validation error returned by TCPFlags.Validate if the designated constraints aren't met.

func (TCPFlagsValidationError) Cause

func (e TCPFlagsValidationError) Cause() error

Cause function returns cause value.

func (TCPFlagsValidationError) Error

func (e TCPFlagsValidationError) Error() string

Error satisfies the builtin error interface

func (TCPFlagsValidationError) ErrorName

func (e TCPFlagsValidationError) ErrorName() string

ErrorName returns error name.

func (TCPFlagsValidationError) Field

func (e TCPFlagsValidationError) Field() string

Field function returns field value.

func (TCPFlagsValidationError) Key

func (e TCPFlagsValidationError) Key() bool

Key function returns key value.

func (TCPFlagsValidationError) Reason

func (e TCPFlagsValidationError) Reason() string

Reason function returns reason value.

type TCPValidationError

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

TCPValidationError is the validation error returned by TCP.Validate if the designated constraints aren't met.

func (TCPValidationError) Cause

func (e TCPValidationError) Cause() error

Cause function returns cause value.

func (TCPValidationError) Error

func (e TCPValidationError) Error() string

Error satisfies the builtin error interface

func (TCPValidationError) ErrorName

func (e TCPValidationError) ErrorName() string

ErrorName returns error name.

func (TCPValidationError) Field

func (e TCPValidationError) Field() string

Field function returns field value.

func (TCPValidationError) Key

func (e TCPValidationError) Key() bool

Key function returns key value.

func (TCPValidationError) Reason

func (e TCPValidationError) Reason() string

Reason function returns reason value.

type UDP

type UDP struct {
	SourcePort           uint32   `protobuf:"varint,1,opt,name=source_port,json=sourcePort,proto3" json:"source_port,omitempty"`
	DestinationPort      uint32   `protobuf:"varint,2,opt,name=destination_port,json=destinationPort,proto3" json:"destination_port,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UDP) Descriptor

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

func (*UDP) GetDestinationPort

func (m *UDP) GetDestinationPort() uint32

func (*UDP) GetSourcePort

func (m *UDP) GetSourcePort() uint32

func (*UDP) MarshalJSON

func (msg *UDP) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*UDP) ProtoMessage

func (*UDP) ProtoMessage()

func (*UDP) Reset

func (m *UDP) Reset()

func (*UDP) String

func (m *UDP) String() string

func (*UDP) UnmarshalJSON

func (msg *UDP) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*UDP) Validate

func (m *UDP) Validate() error

Validate checks the field values on UDP with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*UDP) XXX_DiscardUnknown

func (m *UDP) XXX_DiscardUnknown()

func (*UDP) XXX_Marshal

func (m *UDP) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UDP) XXX_Merge

func (m *UDP) XXX_Merge(src proto.Message)

func (*UDP) XXX_Size

func (m *UDP) XXX_Size() int

func (*UDP) XXX_Unmarshal

func (m *UDP) XXX_Unmarshal(b []byte) error

type UDPValidationError

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

UDPValidationError is the validation error returned by UDP.Validate if the designated constraints aren't met.

func (UDPValidationError) Cause

func (e UDPValidationError) Cause() error

Cause function returns cause value.

func (UDPValidationError) Error

func (e UDPValidationError) Error() string

Error satisfies the builtin error interface

func (UDPValidationError) ErrorName

func (e UDPValidationError) ErrorName() string

ErrorName returns error name.

func (UDPValidationError) Field

func (e UDPValidationError) Field() string

Field function returns field value.

func (UDPValidationError) Key

func (e UDPValidationError) Key() bool

Key function returns key value.

func (UDPValidationError) Reason

func (e UDPValidationError) Reason() string

Reason function returns reason value.

type Verdict

type Verdict int32
const (
	Verdict_VERDICT_UNKNOWN Verdict = 0
	Verdict_FORWARDED       Verdict = 1
	Verdict_DROPPED         Verdict = 2
	Verdict_ERROR           Verdict = 3
)

func (Verdict) EnumDescriptor

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

func (Verdict) String

func (x Verdict) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL