Versions in this module Expand all Collapse all v0 v0.8.20 Mar 14, 2023 Changes in this version + var EventType_name = map[int32]string + var EventType_value = map[string]int32 + var FlowType_name = map[int32]string + var FlowType_value = map[string]int32 + var IPVersion_name = map[int32]string + var IPVersion_value = map[string]int32 + var L7FlowType_name = map[int32]string + var L7FlowType_value = map[string]int32 + var Verdict_name = map[int32]string + var Verdict_value = map[string]int32 + type CiliumEventType struct + SubType int32 + Type int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CiliumEventType) Descriptor() ([]byte, []int) + func (*CiliumEventType) ProtoMessage() + func (m *CiliumEventType) GetSubType() int32 + func (m *CiliumEventType) GetType() int32 + func (m *CiliumEventType) Reset() + func (m *CiliumEventType) String() string + func (m *CiliumEventType) Validate() error + func (m *CiliumEventType) XXX_DiscardUnknown() + func (m *CiliumEventType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CiliumEventType) XXX_Merge(src proto.Message) + func (m *CiliumEventType) XXX_Size() int + func (m *CiliumEventType) XXX_Unmarshal(b []byte) error + func (msg *CiliumEventType) MarshalJSON() ([]byte, error) + func (msg *CiliumEventType) UnmarshalJSON(b []byte) error + type CiliumEventTypeValidationError struct + func (e CiliumEventTypeValidationError) Cause() error + func (e CiliumEventTypeValidationError) Error() string + func (e CiliumEventTypeValidationError) ErrorName() string + func (e CiliumEventTypeValidationError) Field() string + func (e CiliumEventTypeValidationError) Key() bool + func (e CiliumEventTypeValidationError) Reason() string + type DNS struct + Cnames []string + Ips []string + ObservationSource string + Qtypes []string + Query string + Rcode uint32 + Rrtypes []string + Ttl uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DNS) Descriptor() ([]byte, []int) + func (*DNS) ProtoMessage() + func (m *DNS) GetCnames() []string + func (m *DNS) GetIps() []string + func (m *DNS) GetObservationSource() string + func (m *DNS) GetQtypes() []string + func (m *DNS) GetQuery() string + func (m *DNS) GetRcode() uint32 + func (m *DNS) GetRrtypes() []string + func (m *DNS) GetTtl() uint32 + func (m *DNS) Reset() + func (m *DNS) String() string + func (m *DNS) Validate() error + func (m *DNS) XXX_DiscardUnknown() + func (m *DNS) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DNS) XXX_Merge(src proto.Message) + func (m *DNS) XXX_Size() int + func (m *DNS) XXX_Unmarshal(b []byte) error + func (msg *DNS) MarshalJSON() ([]byte, error) + func (msg *DNS) UnmarshalJSON(b []byte) error + type DNSValidationError struct + func (e DNSValidationError) Cause() error + func (e DNSValidationError) Error() string + func (e DNSValidationError) ErrorName() string + func (e DNSValidationError) Field() string + func (e DNSValidationError) Key() bool + func (e DNSValidationError) Reason() string + type Endpoint struct + ID uint64 + Identity uint64 + Labels []string + Namespace string + PodName string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Endpoint) Descriptor() ([]byte, []int) + func (*Endpoint) ProtoMessage() + func (m *Endpoint) GetID() uint64 + func (m *Endpoint) GetIdentity() uint64 + func (m *Endpoint) GetLabels() []string + func (m *Endpoint) GetNamespace() string + func (m *Endpoint) GetPodName() string + func (m *Endpoint) Reset() + func (m *Endpoint) String() string + func (m *Endpoint) Validate() error + func (m *Endpoint) XXX_DiscardUnknown() + func (m *Endpoint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Endpoint) XXX_Merge(src proto.Message) + func (m *Endpoint) XXX_Size() int + func (m *Endpoint) XXX_Unmarshal(b []byte) error + func (msg *Endpoint) MarshalJSON() ([]byte, error) + func (msg *Endpoint) UnmarshalJSON(b []byte) error + type EndpointValidationError struct + func (e EndpointValidationError) Cause() error + func (e EndpointValidationError) Error() string + func (e EndpointValidationError) ErrorName() string + func (e EndpointValidationError) Field() string + func (e EndpointValidationError) Key() bool + func (e EndpointValidationError) Reason() string + type Ethernet struct + Destination string + Source string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Ethernet) Descriptor() ([]byte, []int) + func (*Ethernet) ProtoMessage() + func (m *Ethernet) GetDestination() string + func (m *Ethernet) GetSource() string + func (m *Ethernet) Reset() + func (m *Ethernet) String() string + func (m *Ethernet) Validate() error + func (m *Ethernet) XXX_DiscardUnknown() + func (m *Ethernet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Ethernet) XXX_Merge(src proto.Message) + func (m *Ethernet) XXX_Size() int + func (m *Ethernet) XXX_Unmarshal(b []byte) error + func (msg *Ethernet) MarshalJSON() ([]byte, error) + func (msg *Ethernet) UnmarshalJSON(b []byte) error + type EthernetValidationError struct + func (e EthernetValidationError) Cause() error + func (e EthernetValidationError) Error() string + func (e EthernetValidationError) ErrorName() string + func (e EthernetValidationError) Field() string + func (e EthernetValidationError) Key() bool + func (e EthernetValidationError) Reason() string + type EventType int32 + const EventType_EventSample + const EventType_RecordLost + const EventType_UNKNOWN + func (EventType) EnumDescriptor() ([]byte, []int) + func (x EventType) String() string + type EventTypeFilter struct + MatchSubType bool + SubType int32 + Type int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*EventTypeFilter) Descriptor() ([]byte, []int) + func (*EventTypeFilter) ProtoMessage() + func (m *EventTypeFilter) GetMatchSubType() bool + func (m *EventTypeFilter) GetSubType() int32 + func (m *EventTypeFilter) GetType() int32 + func (m *EventTypeFilter) Reset() + func (m *EventTypeFilter) String() string + func (m *EventTypeFilter) Validate() error + func (m *EventTypeFilter) XXX_DiscardUnknown() + func (m *EventTypeFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EventTypeFilter) XXX_Merge(src proto.Message) + func (m *EventTypeFilter) XXX_Size() int + func (m *EventTypeFilter) XXX_Unmarshal(b []byte) error + func (msg *EventTypeFilter) MarshalJSON() ([]byte, error) + func (msg *EventTypeFilter) UnmarshalJSON(b []byte) error + type EventTypeFilterValidationError struct + func (e EventTypeFilterValidationError) Cause() error + func (e EventTypeFilterValidationError) Error() string + func (e EventTypeFilterValidationError) ErrorName() string + func (e EventTypeFilterValidationError) Field() string + func (e EventTypeFilterValidationError) Key() bool + func (e EventTypeFilterValidationError) Reason() string + type Flow struct + Destination *Endpoint + DestinationNames []string + DestinationService *Service + DropReason uint32 + Ethernet *Ethernet + EventType *CiliumEventType + IP *IP + L4 *Layer4 + L7 *Layer7 + NodeName string + Reply bool + Source *Endpoint + SourceNames []string + SourceService *Service + Summary string + Time *types.Timestamp + Type FlowType + Verdict Verdict + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Flow) Descriptor() ([]byte, []int) + func (*Flow) ProtoMessage() + func (m *Flow) GetDestination() *Endpoint + func (m *Flow) GetDestinationNames() []string + func (m *Flow) GetDestinationService() *Service + func (m *Flow) GetDropReason() uint32 + func (m *Flow) GetEthernet() *Ethernet + func (m *Flow) GetEventType() *CiliumEventType + func (m *Flow) GetIP() *IP + func (m *Flow) GetL4() *Layer4 + func (m *Flow) GetL7() *Layer7 + func (m *Flow) GetNodeName() string + func (m *Flow) GetReply() bool + func (m *Flow) GetSource() *Endpoint + func (m *Flow) GetSourceNames() []string + func (m *Flow) GetSourceService() *Service + func (m *Flow) GetSummary() string + func (m *Flow) GetTime() *types.Timestamp + func (m *Flow) GetType() FlowType + func (m *Flow) GetVerdict() Verdict + func (m *Flow) Reset() + func (m *Flow) String() string + func (m *Flow) Validate() error + func (m *Flow) XXX_DiscardUnknown() + func (m *Flow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Flow) XXX_Merge(src proto.Message) + func (m *Flow) XXX_Size() int + func (m *Flow) XXX_Unmarshal(b []byte) error + func (msg *Flow) MarshalJSON() ([]byte, error) + func (msg *Flow) UnmarshalJSON(b []byte) error + type FlowFilter struct + DestinationFqdn []string + DestinationIdentity []uint64 + DestinationIp []string + DestinationLabel []string + DestinationPod []string + DestinationPort []string + DestinationService []string + DnsQuery []string + EventType []*EventTypeFilter + HttpStatusCode []string + Protocol []string + Reply []bool + SourceFqdn []string + SourceIdentity []uint64 + SourceIp []string + SourceLabel []string + SourcePod []string + SourcePort []string + SourceService []string + Verdict []Verdict + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FlowFilter) Descriptor() ([]byte, []int) + func (*FlowFilter) ProtoMessage() + func (m *FlowFilter) GetDestinationFqdn() []string + func (m *FlowFilter) GetDestinationIdentity() []uint64 + func (m *FlowFilter) GetDestinationIp() []string + func (m *FlowFilter) GetDestinationLabel() []string + func (m *FlowFilter) GetDestinationPod() []string + func (m *FlowFilter) GetDestinationPort() []string + func (m *FlowFilter) GetDestinationService() []string + func (m *FlowFilter) GetDnsQuery() []string + func (m *FlowFilter) GetEventType() []*EventTypeFilter + func (m *FlowFilter) GetHttpStatusCode() []string + func (m *FlowFilter) GetProtocol() []string + func (m *FlowFilter) GetReply() []bool + func (m *FlowFilter) GetSourceFqdn() []string + func (m *FlowFilter) GetSourceIdentity() []uint64 + func (m *FlowFilter) GetSourceIp() []string + func (m *FlowFilter) GetSourceLabel() []string + func (m *FlowFilter) GetSourcePod() []string + func (m *FlowFilter) GetSourcePort() []string + func (m *FlowFilter) GetSourceService() []string + func (m *FlowFilter) GetVerdict() []Verdict + func (m *FlowFilter) Reset() + func (m *FlowFilter) String() string + func (m *FlowFilter) Validate() error + func (m *FlowFilter) XXX_DiscardUnknown() + func (m *FlowFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FlowFilter) XXX_Merge(src proto.Message) + func (m *FlowFilter) XXX_Size() int + func (m *FlowFilter) XXX_Unmarshal(b []byte) error + func (msg *FlowFilter) MarshalJSON() ([]byte, error) + func (msg *FlowFilter) UnmarshalJSON(b []byte) error + type FlowFilterValidationError struct + func (e FlowFilterValidationError) Cause() error + func (e FlowFilterValidationError) Error() string + func (e FlowFilterValidationError) ErrorName() string + func (e FlowFilterValidationError) Field() string + func (e FlowFilterValidationError) Key() bool + func (e FlowFilterValidationError) Reason() string + type FlowType int32 + const FlowType_L3_L4 + const FlowType_L7 + const FlowType_UNKNOWN_TYPE + func (FlowType) EnumDescriptor() ([]byte, []int) + func (x FlowType) String() string + type FlowValidationError struct + func (e FlowValidationError) Cause() error + func (e FlowValidationError) Error() string + func (e FlowValidationError) ErrorName() string + func (e FlowValidationError) Field() string + func (e FlowValidationError) Key() bool + func (e FlowValidationError) Reason() string + type HTTP struct + Code uint32 + Headers []*HTTPHeader + Method string + Protocol string + Url string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*HTTP) Descriptor() ([]byte, []int) + func (*HTTP) ProtoMessage() + func (m *HTTP) GetCode() uint32 + func (m *HTTP) GetHeaders() []*HTTPHeader + func (m *HTTP) GetMethod() string + func (m *HTTP) GetProtocol() string + func (m *HTTP) GetUrl() string + func (m *HTTP) Reset() + func (m *HTTP) String() string + func (m *HTTP) Validate() error + func (m *HTTP) XXX_DiscardUnknown() + func (m *HTTP) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *HTTP) XXX_Merge(src proto.Message) + func (m *HTTP) XXX_Size() int + func (m *HTTP) XXX_Unmarshal(b []byte) error + func (msg *HTTP) MarshalJSON() ([]byte, error) + func (msg *HTTP) UnmarshalJSON(b []byte) error + type HTTPHeader struct + Key string + Value string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*HTTPHeader) Descriptor() ([]byte, []int) + func (*HTTPHeader) ProtoMessage() + func (m *HTTPHeader) GetKey() string + func (m *HTTPHeader) GetValue() string + func (m *HTTPHeader) Reset() + func (m *HTTPHeader) String() string + func (m *HTTPHeader) Validate() error + func (m *HTTPHeader) XXX_DiscardUnknown() + func (m *HTTPHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *HTTPHeader) XXX_Merge(src proto.Message) + func (m *HTTPHeader) XXX_Size() int + func (m *HTTPHeader) XXX_Unmarshal(b []byte) error + func (msg *HTTPHeader) MarshalJSON() ([]byte, error) + func (msg *HTTPHeader) UnmarshalJSON(b []byte) error + type HTTPHeaderValidationError struct + func (e HTTPHeaderValidationError) Cause() error + func (e HTTPHeaderValidationError) Error() string + func (e HTTPHeaderValidationError) ErrorName() string + func (e HTTPHeaderValidationError) Field() string + func (e HTTPHeaderValidationError) Key() bool + func (e HTTPHeaderValidationError) Reason() string + type HTTPValidationError struct + func (e HTTPValidationError) Cause() error + func (e HTTPValidationError) Error() string + func (e HTTPValidationError) ErrorName() string + func (e HTTPValidationError) Field() string + func (e HTTPValidationError) Key() bool + func (e HTTPValidationError) Reason() string + type ICMPv4 struct + Code uint32 + Type uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ICMPv4) Descriptor() ([]byte, []int) + func (*ICMPv4) ProtoMessage() + func (m *ICMPv4) GetCode() uint32 + func (m *ICMPv4) GetType() uint32 + func (m *ICMPv4) Reset() + func (m *ICMPv4) String() string + func (m *ICMPv4) Validate() error + func (m *ICMPv4) XXX_DiscardUnknown() + func (m *ICMPv4) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ICMPv4) XXX_Merge(src proto.Message) + func (m *ICMPv4) XXX_Size() int + func (m *ICMPv4) XXX_Unmarshal(b []byte) error + func (msg *ICMPv4) MarshalJSON() ([]byte, error) + func (msg *ICMPv4) UnmarshalJSON(b []byte) error + type ICMPv4ValidationError struct + func (e ICMPv4ValidationError) Cause() error + func (e ICMPv4ValidationError) Error() string + func (e ICMPv4ValidationError) ErrorName() string + func (e ICMPv4ValidationError) Field() string + func (e ICMPv4ValidationError) Key() bool + func (e ICMPv4ValidationError) Reason() string + type ICMPv6 struct + Code uint32 + Type uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ICMPv6) Descriptor() ([]byte, []int) + func (*ICMPv6) ProtoMessage() + func (m *ICMPv6) GetCode() uint32 + func (m *ICMPv6) GetType() uint32 + func (m *ICMPv6) Reset() + func (m *ICMPv6) String() string + func (m *ICMPv6) Validate() error + func (m *ICMPv6) XXX_DiscardUnknown() + func (m *ICMPv6) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ICMPv6) XXX_Merge(src proto.Message) + func (m *ICMPv6) XXX_Size() int + func (m *ICMPv6) XXX_Unmarshal(b []byte) error + func (msg *ICMPv6) MarshalJSON() ([]byte, error) + func (msg *ICMPv6) UnmarshalJSON(b []byte) error + type ICMPv6ValidationError struct + func (e ICMPv6ValidationError) Cause() error + func (e ICMPv6ValidationError) Error() string + func (e ICMPv6ValidationError) ErrorName() string + func (e ICMPv6ValidationError) Field() string + func (e ICMPv6ValidationError) Key() bool + func (e ICMPv6ValidationError) Reason() string + type IP struct + Destination string + Encrypted bool + IpVersion IPVersion + Source string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*IP) Descriptor() ([]byte, []int) + func (*IP) ProtoMessage() + func (m *IP) GetDestination() string + func (m *IP) GetEncrypted() bool + func (m *IP) GetIpVersion() IPVersion + func (m *IP) GetSource() string + func (m *IP) Reset() + func (m *IP) String() string + func (m *IP) Validate() error + func (m *IP) XXX_DiscardUnknown() + func (m *IP) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IP) XXX_Merge(src proto.Message) + func (m *IP) XXX_Size() int + func (m *IP) XXX_Unmarshal(b []byte) error + func (msg *IP) MarshalJSON() ([]byte, error) + func (msg *IP) UnmarshalJSON(b []byte) error + type IPValidationError struct + func (e IPValidationError) Cause() error + func (e IPValidationError) Error() string + func (e IPValidationError) ErrorName() string + func (e IPValidationError) Field() string + func (e IPValidationError) Key() bool + func (e IPValidationError) Reason() string + type IPVersion int32 + const IPVersion_IP_NOT_USED + const IPVersion_IPv4 + const IPVersion_IPv6 + func (IPVersion) EnumDescriptor() ([]byte, []int) + func (x IPVersion) String() string + type Kafka struct + ApiKey string + ApiVersion int32 + CorrelationId int32 + ErrorCode int32 + Topic string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Kafka) Descriptor() ([]byte, []int) + func (*Kafka) ProtoMessage() + func (m *Kafka) GetApiKey() string + func (m *Kafka) GetApiVersion() int32 + func (m *Kafka) GetCorrelationId() int32 + func (m *Kafka) GetErrorCode() int32 + func (m *Kafka) GetTopic() string + func (m *Kafka) Reset() + func (m *Kafka) String() string + func (m *Kafka) Validate() error + func (m *Kafka) XXX_DiscardUnknown() + func (m *Kafka) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Kafka) XXX_Merge(src proto.Message) + func (m *Kafka) XXX_Size() int + func (m *Kafka) XXX_Unmarshal(b []byte) error + func (msg *Kafka) MarshalJSON() ([]byte, error) + func (msg *Kafka) UnmarshalJSON(b []byte) error + type KafkaValidationError struct + func (e KafkaValidationError) Cause() error + func (e KafkaValidationError) Error() string + func (e KafkaValidationError) ErrorName() string + func (e KafkaValidationError) Field() string + func (e KafkaValidationError) Key() bool + func (e KafkaValidationError) Reason() string + type L7FlowType int32 + const L7FlowType_REQUEST + const L7FlowType_RESPONSE + const L7FlowType_SAMPLE + const L7FlowType_UNKNOWN_L7_TYPE + func (L7FlowType) EnumDescriptor() ([]byte, []int) + func (x L7FlowType) String() string + type Layer4 struct + Protocol isLayer4_Protocol + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Layer4) Descriptor() ([]byte, []int) + func (*Layer4) ProtoMessage() + func (*Layer4) XXX_OneofWrappers() []interface{} + func (m *Layer4) GetICMPv4() *ICMPv4 + func (m *Layer4) GetICMPv6() *ICMPv6 + func (m *Layer4) GetProtocol() isLayer4_Protocol + func (m *Layer4) GetTCP() *TCP + func (m *Layer4) GetUDP() *UDP + func (m *Layer4) Reset() + func (m *Layer4) String() string + func (m *Layer4) Validate() error + func (m *Layer4) XXX_DiscardUnknown() + func (m *Layer4) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Layer4) XXX_Merge(src proto.Message) + func (m *Layer4) XXX_Size() int + func (m *Layer4) XXX_Unmarshal(b []byte) error + func (msg *Layer4) MarshalJSON() ([]byte, error) + func (msg *Layer4) UnmarshalJSON(b []byte) error + type Layer4ValidationError struct + func (e Layer4ValidationError) Cause() error + func (e Layer4ValidationError) Error() string + func (e Layer4ValidationError) ErrorName() string + func (e Layer4ValidationError) Field() string + func (e Layer4ValidationError) Key() bool + func (e Layer4ValidationError) Reason() string + type Layer4_ICMPv4 struct + ICMPv4 *ICMPv4 + type Layer4_ICMPv6 struct + ICMPv6 *ICMPv6 + type Layer4_TCP struct + TCP *TCP + type Layer4_UDP struct + UDP *UDP + type Layer7 struct + LatencyNs uint64 + Record isLayer7_Record + Type L7FlowType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Layer7) Descriptor() ([]byte, []int) + func (*Layer7) ProtoMessage() + func (*Layer7) XXX_OneofWrappers() []interface{} + func (m *Layer7) GetDns() *DNS + func (m *Layer7) GetHttp() *HTTP + func (m *Layer7) GetKafka() *Kafka + func (m *Layer7) GetLatencyNs() uint64 + func (m *Layer7) GetRecord() isLayer7_Record + func (m *Layer7) GetType() L7FlowType + func (m *Layer7) Reset() + func (m *Layer7) String() string + func (m *Layer7) Validate() error + func (m *Layer7) XXX_DiscardUnknown() + func (m *Layer7) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Layer7) XXX_Merge(src proto.Message) + func (m *Layer7) XXX_Size() int + func (m *Layer7) XXX_Unmarshal(b []byte) error + func (msg *Layer7) MarshalJSON() ([]byte, error) + func (msg *Layer7) UnmarshalJSON(b []byte) error + type Layer7ValidationError struct + func (e Layer7ValidationError) Cause() error + func (e Layer7ValidationError) Error() string + func (e Layer7ValidationError) ErrorName() string + func (e Layer7ValidationError) Field() string + func (e Layer7ValidationError) Key() bool + func (e Layer7ValidationError) Reason() string + type Layer7_Dns struct + Dns *DNS + type Layer7_Http struct + Http *HTTP + type Layer7_Kafka struct + Kafka *Kafka + type Payload struct + CPU int32 + Data []byte + HostName string + Lost uint64 + Time *types.Timestamp + Type EventType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Payload) Descriptor() ([]byte, []int) + func (*Payload) ProtoMessage() + func (m *Payload) GetCPU() int32 + func (m *Payload) GetData() []byte + func (m *Payload) GetHostName() string + func (m *Payload) GetLost() uint64 + func (m *Payload) GetTime() *types.Timestamp + func (m *Payload) GetType() EventType + func (m *Payload) Reset() + func (m *Payload) String() string + func (m *Payload) Validate() error + func (m *Payload) XXX_DiscardUnknown() + func (m *Payload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Payload) XXX_Merge(src proto.Message) + func (m *Payload) XXX_Size() int + func (m *Payload) XXX_Unmarshal(b []byte) error + func (msg *Payload) MarshalJSON() ([]byte, error) + func (msg *Payload) UnmarshalJSON(b []byte) error + type PayloadValidationError struct + func (e PayloadValidationError) Cause() error + func (e PayloadValidationError) Error() string + func (e PayloadValidationError) ErrorName() string + func (e PayloadValidationError) Field() string + func (e PayloadValidationError) Key() bool + func (e PayloadValidationError) Reason() string + type Service struct + Name string + Namespace string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Service) Descriptor() ([]byte, []int) + func (*Service) ProtoMessage() + func (m *Service) GetName() string + func (m *Service) GetNamespace() string + func (m *Service) Reset() + func (m *Service) String() string + func (m *Service) Validate() error + func (m *Service) XXX_DiscardUnknown() + func (m *Service) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Service) XXX_Merge(src proto.Message) + func (m *Service) XXX_Size() int + func (m *Service) XXX_Unmarshal(b []byte) error + func (msg *Service) MarshalJSON() ([]byte, error) + func (msg *Service) UnmarshalJSON(b []byte) error + type ServiceValidationError struct + func (e ServiceValidationError) Cause() error + func (e ServiceValidationError) Error() string + func (e ServiceValidationError) ErrorName() string + func (e ServiceValidationError) Field() string + func (e ServiceValidationError) Key() bool + func (e ServiceValidationError) Reason() string + type TCP struct + DestinationPort uint32 + Flags *TCPFlags + SourcePort uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TCP) Descriptor() ([]byte, []int) + func (*TCP) ProtoMessage() + func (m *TCP) GetDestinationPort() uint32 + func (m *TCP) GetFlags() *TCPFlags + func (m *TCP) GetSourcePort() uint32 + func (m *TCP) Reset() + func (m *TCP) String() string + func (m *TCP) Validate() error + func (m *TCP) XXX_DiscardUnknown() + func (m *TCP) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TCP) XXX_Merge(src proto.Message) + func (m *TCP) XXX_Size() int + func (m *TCP) XXX_Unmarshal(b []byte) error + func (msg *TCP) MarshalJSON() ([]byte, error) + func (msg *TCP) UnmarshalJSON(b []byte) error + type TCPFlags struct + ACK bool + CWR bool + ECE bool + FIN bool + NS bool + PSH bool + RST bool + SYN bool + URG bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TCPFlags) Descriptor() ([]byte, []int) + func (*TCPFlags) ProtoMessage() + func (m *TCPFlags) GetACK() bool + func (m *TCPFlags) GetCWR() bool + func (m *TCPFlags) GetECE() bool + func (m *TCPFlags) GetFIN() bool + func (m *TCPFlags) GetNS() bool + func (m *TCPFlags) GetPSH() bool + func (m *TCPFlags) GetRST() bool + func (m *TCPFlags) GetSYN() bool + func (m *TCPFlags) GetURG() bool + func (m *TCPFlags) Reset() + func (m *TCPFlags) String() string + func (m *TCPFlags) Validate() error + func (m *TCPFlags) XXX_DiscardUnknown() + func (m *TCPFlags) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TCPFlags) XXX_Merge(src proto.Message) + func (m *TCPFlags) XXX_Size() int + func (m *TCPFlags) XXX_Unmarshal(b []byte) error + func (msg *TCPFlags) MarshalJSON() ([]byte, error) + func (msg *TCPFlags) UnmarshalJSON(b []byte) error + type TCPFlagsValidationError struct + func (e TCPFlagsValidationError) Cause() error + func (e TCPFlagsValidationError) Error() string + func (e TCPFlagsValidationError) ErrorName() string + func (e TCPFlagsValidationError) Field() string + func (e TCPFlagsValidationError) Key() bool + func (e TCPFlagsValidationError) Reason() string + type TCPValidationError struct + func (e TCPValidationError) Cause() error + func (e TCPValidationError) Error() string + func (e TCPValidationError) ErrorName() string + func (e TCPValidationError) Field() string + func (e TCPValidationError) Key() bool + func (e TCPValidationError) Reason() string + type UDP struct + DestinationPort uint32 + SourcePort uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UDP) Descriptor() ([]byte, []int) + func (*UDP) ProtoMessage() + func (m *UDP) GetDestinationPort() uint32 + func (m *UDP) GetSourcePort() uint32 + func (m *UDP) Reset() + func (m *UDP) String() string + func (m *UDP) Validate() error + func (m *UDP) XXX_DiscardUnknown() + func (m *UDP) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UDP) XXX_Merge(src proto.Message) + func (m *UDP) XXX_Size() int + func (m *UDP) XXX_Unmarshal(b []byte) error + func (msg *UDP) MarshalJSON() ([]byte, error) + func (msg *UDP) UnmarshalJSON(b []byte) error + type UDPValidationError struct + func (e UDPValidationError) Cause() error + func (e UDPValidationError) Error() string + func (e UDPValidationError) ErrorName() string + func (e UDPValidationError) Field() string + func (e UDPValidationError) Key() bool + func (e UDPValidationError) Reason() string + type Verdict int32 + const Verdict_DROPPED + const Verdict_ERROR + const Verdict_FORWARDED + const Verdict_VERDICT_UNKNOWN + func (Verdict) EnumDescriptor() ([]byte, []int) + func (x Verdict) String() string
Go to main page