proto

type Direction int32

type FlowEvent struct {

	// Unique client event identifier
	EventId []byte `protobuf:"bytes,1,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	// When the event occurred
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Public key of the sending peer
	PublicKey   []byte      `protobuf:"bytes,3,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	FlowFields  *FlowFields `protobuf:"bytes,4,opt,name=flow_fields,json=flowFields,proto3" json:"flow_fields,omitempty"`
	IsInitiator bool        `protobuf:"varint,5,opt,name=isInitiator,proto3" json:"isInitiator,omitempty"`
	// contains filtered or unexported fields
}

type FlowEventAck struct {

	// Unique client event identifier that has been ack'ed
	EventId     []byte `protobuf:"bytes,1,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	IsInitiator bool   `protobuf:"varint,2,opt,name=isInitiator,proto3" json:"isInitiator,omitempty"`
	// contains filtered or unexported fields
}

type FlowFields struct {

	// Unique client flow session identifier
	FlowId []byte `protobuf:"bytes,1,opt,name=flow_id,json=flowId,proto3" json:"flow_id,omitempty"`
	// Flow type
	Type Type `protobuf:"varint,2,opt,name=type,proto3,enum=flow.Type" json:"type,omitempty"`
	// RuleId identifies the rule that allowed or denied the connection
	RuleId []byte `protobuf:"bytes,3,opt,name=rule_id,json=ruleId,proto3" json:"rule_id,omitempty"`
	// Initiating traffic direction
	Direction Direction `protobuf:"varint,4,opt,name=direction,proto3,enum=flow.Direction" json:"direction,omitempty"`
	// IP protocol number
	Protocol uint32 `protobuf:"varint,5,opt,name=protocol,proto3" json:"protocol,omitempty"`
	// Source IP address
	SourceIp []byte `protobuf:"bytes,6,opt,name=source_ip,json=sourceIp,proto3" json:"source_ip,omitempty"`
	// Destination IP address
	DestIp []byte `protobuf:"bytes,7,opt,name=dest_ip,json=destIp,proto3" json:"dest_ip,omitempty"`
	// Layer 4 -specific information
	//
	// Types that are assignable to ConnectionInfo:
	//
	//	*FlowFields_PortInfo
	//	*FlowFields_IcmpInfo
	ConnectionInfo isFlowFields_ConnectionInfo `protobuf_oneof:"connection_info"`
	// Number of packets
	RxPackets uint64 `protobuf:"varint,10,opt,name=rx_packets,json=rxPackets,proto3" json:"rx_packets,omitempty"`
	TxPackets uint64 `protobuf:"varint,11,opt,name=tx_packets,json=txPackets,proto3" json:"tx_packets,omitempty"`
	// Number of bytes
	RxBytes uint64 `protobuf:"varint,12,opt,name=rx_bytes,json=rxBytes,proto3" json:"rx_bytes,omitempty"`
	TxBytes uint64 `protobuf:"varint,13,opt,name=tx_bytes,json=txBytes,proto3" json:"tx_bytes,omitempty"`
	// Resource ID
	SourceResourceId []byte `protobuf:"bytes,14,opt,name=source_resource_id,json=sourceResourceId,proto3" json:"source_resource_id,omitempty"`
	DestResourceId   []byte `protobuf:"bytes,15,opt,name=dest_resource_id,json=destResourceId,proto3" json:"dest_resource_id,omitempty"`
	// contains filtered or unexported fields
}

type FlowFields_IcmpInfo struct {
	// ICMP type and code
	IcmpInfo *ICMPInfo `protobuf:"bytes,9,opt,name=icmp_info,json=icmpInfo,proto3,oneof"`
}

type FlowFields_PortInfo struct {
	// TCP/UDP port information
	PortInfo *PortInfo `protobuf:"bytes,8,opt,name=port_info,json=portInfo,proto3,oneof"`
}

type FlowServiceClient interface {
	// Client to receiver streams of events and acknowledgements
	Events(ctx context.Context, opts ...grpc.CallOption) (FlowService_EventsClient, error)
}

type FlowServiceServer interface {
	// Client to receiver streams of events and acknowledgements
	Events(FlowService_EventsServer) error
	// contains filtered or unexported methods
}

type FlowService_EventsClient interface {
	Send(*FlowEvent) error
	Recv() (*FlowEventAck, error)
	grpc.ClientStream
}

type FlowService_EventsServer interface {
	Send(*FlowEventAck) error
	Recv() (*FlowEvent, error)
	grpc.ServerStream
}

type ICMPInfo struct {
	IcmpType uint32 `protobuf:"varint,1,opt,name=icmp_type,json=icmpType,proto3" json:"icmp_type,omitempty"`
	IcmpCode uint32 `protobuf:"varint,2,opt,name=icmp_code,json=icmpCode,proto3" json:"icmp_code,omitempty"`
	// contains filtered or unexported fields
}

type PortInfo struct {
	SourcePort uint32 `protobuf:"varint,1,opt,name=source_port,json=sourcePort,proto3" json:"source_port,omitempty"`
	DestPort   uint32 `protobuf:"varint,2,opt,name=dest_port,json=destPort,proto3" json:"dest_port,omitempty"`
	// contains filtered or unexported fields
}

type Type int32

type UnimplementedFlowServiceServer struct {
}

type UnsafeFlowServiceServer interface {
	// contains filtered or unexported methods
}