grpc

type FlowHandlerClient interface {
	// Submit is a streaming RPC that accepts a stream of Observations from
	// conntrack and returns a summary with the number of processed
	// observations.
	Submit(ctx context.Context, opts ...grpc.CallOption) (FlowHandler_SubmitClient, error)
}

type FlowHandlerServer interface {
	// Submit is a streaming RPC that accepts a stream of Observations from
	// conntrack and returns a summary with the number of processed
	// observations.
	Submit(FlowHandler_SubmitServer) error
	// contains filtered or unexported methods
}

type FlowHandler_SubmitClient interface {
	Send(*Observation) error
	CloseAndRecv() (*ObservationSummary, error)
	grpc.ClientStream
}

type FlowHandler_SubmitServer interface {
	SendAndClose(*ObservationSummary) error
	Recv() (*Observation, error)
	grpc.ServerStream
}

type Observation struct {

	// The flow observed.
	Flow *Observation_Flow `protobuf:"bytes,1,opt,name=flow,proto3" json:"flow,omitempty"`
	// The node on which the flow was observed.
	NodeName string `protobuf:"bytes,2,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	// The timestamp, in Unix seconds, when the flow was observed.
	Timestamp uint64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

type ObservationSummary struct {

	// The number of observations processed during the stream.
	ObservationCount uint32 `protobuf:"varint,1,opt,name=observation_count,json=observationCount,proto3" json:"observation_count,omitempty"`
	// contains filtered or unexported fields
}

type Observation_Flow struct {
	Proto uint32 `protobuf:"varint,1,opt,name=proto,proto3" json:"proto,omitempty"`
	// The original tuple when opening the connection.
	Original *Observation_Flow_FlowTuple `protobuf:"bytes,2,opt,name=original,proto3" json:"original,omitempty"`
	// The reply tuple. In the simple case, this is a mirror image of the
	// original tuple (with the exception for the packet and byte counters),
	// but sometimes it is different, e.g. due to NAT.
	Reply *Observation_Flow_FlowTuple `protobuf:"bytes,3,opt,name=reply,proto3" json:"reply,omitempty"`
	// contains filtered or unexported fields
}

type Observation_Flow_FlowTuple struct {

	// Source tuple.
	Source *Observation_Flow_FlowTuple_L4Endpoint `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	// Destination tuple.
	Destination *Observation_Flow_FlowTuple_L4Endpoint `protobuf:"bytes,2,opt,name=destination,proto3" json:"destination,omitempty"`
	// Number of packets seen from source to destination.
	Packets uint64 `protobuf:"varint,3,opt,name=packets,proto3" json:"packets,omitempty"`
	// Number of bytes seen from source to destination.
	Bytes uint64 `protobuf:"varint,4,opt,name=bytes,proto3" json:"bytes,omitempty"`
	// contains filtered or unexported fields
}

type Observation_Flow_FlowTuple_L4Endpoint struct {

	// IP.
	//
	// Types that are assignable to IpAddr:
	//
	//	*Observation_Flow_FlowTuple_L4Endpoint_V4
	//	*Observation_Flow_FlowTuple_L4Endpoint_V6
	IpAddr isObservation_Flow_FlowTuple_L4Endpoint_IpAddr `protobuf_oneof:"ip_addr"`
	// Port (uint16 doesn't exist in protobuf).
	Port uint32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

type Observation_Flow_FlowTuple_L4Endpoint_V4 struct {
	// IPv4.
	V4 uint32 `protobuf:"fixed32,1,opt,name=v4,proto3,oneof"`
}

type Observation_Flow_FlowTuple_L4Endpoint_V6 struct {
	// IPv6.
	V6 []byte `protobuf:"bytes,2,opt,name=v6,proto3,oneof"`
}

type UnimplementedFlowHandlerServer struct {
}

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