pcap

type API struct {
	UnimplementedAPIServer
	// contains filtered or unexported fields
}

type APIClient interface {
	Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
	// Capture starts capturing packets on either BOSH or CF VMs. The capture can be
	// stopped by closing the client-side send channel, or explicitly sending a Stop command.
	// The Api MUST listen for that close and the stop command and MUST stop sending packets
	// as soon as possible but SHOULD send packets that it still receives from the agents.
	Capture(ctx context.Context, opts ...grpc.CallOption) (API_CaptureClient, error)
}

type APIServer interface {
	Status(context.Context, *StatusRequest) (*StatusResponse, error)
	// Capture starts capturing packets on either BOSH or CF VMs. The capture can be
	// stopped by closing the client-side send channel, or explicitly sending a Stop command.
	// The Api MUST listen for that close and the stop command and MUST stop sending packets
	// as soon as possible but SHOULD send packets that it still receives from the agents.
	Capture(API_CaptureServer) error
	// contains filtered or unexported methods
}

type API_CaptureClient interface {
	Send(*CaptureRequest) error
	Recv() (*CaptureResponse, error)
	grpc.ClientStream
}

type API_CaptureServer interface {
	Send(*CaptureResponse) error
	Recv() (*CaptureRequest, error)
	grpc.ServerStream
}

type Agent struct {
	UnimplementedAgentServer
	// contains filtered or unexported fields
}

type AgentClient interface {
	// Status returns the current status of the agent. It indicates whether the agent is ready to
	// accept new capture requests or is currently unavailable.
	Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
	// Capture is the main handler for the pcap agent. It contains the logic to open an interface
	// and start a packet capture. The resulting packets will be streamed back to the caller together
	// with messages informing the caller of any abnormal conditions that occur. The first message
	// sent must contain a payload of type StartAgentCapture, this will trigger the start of the capture.
	// The only messages that can be sent next is a StopAgentCapture which stops the capture gracefully
	// still sending any packets that are remaining and closing the stream afterwards.
	Capture(ctx context.Context, opts ...grpc.CallOption) (Agent_CaptureClient, error)
}

type AgentEndpoint struct {
	IP         string
	Port       int
	Identifier string
}

type AgentRequest struct {

	// payload wraps the start and stop requests.
	//
	// Types that are assignable to Payload:
	//
	//	*AgentRequest_Start
	//	*AgentRequest_Stop
	Payload isAgentRequest_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

type AgentRequest_Start struct {
	Start *StartAgentCapture `protobuf:"bytes,1,opt,name=start,proto3,oneof"`
}

type AgentRequest_Stop struct {
	Stop *StopAgentCapture `protobuf:"bytes,2,opt,name=stop,proto3,oneof"`
}

type AgentResolver interface {
	// Name provides the name of the handler for outputs and internal mapping.
	Name() string
	// CanResolve determines if this handler is responsible for handling the Capture
	CanResolve(*EndpointRequest) bool
	// Resolve either resolves and returns the agents targeted by Capture or provides an error
	Resolve(*EndpointRequest, *zap.Logger) ([]AgentEndpoint, error)
	// Healthy determines, whether this handler is healthy or not
	Healthy() bool
}

type AgentServer interface {
	// Status returns the current status of the agent. It indicates whether the agent is ready to
	// accept new capture requests or is currently unavailable.
	Status(context.Context, *StatusRequest) (*StatusResponse, error)
	// Capture is the main handler for the pcap agent. It contains the logic to open an interface
	// and start a packet capture. The resulting packets will be streamed back to the caller together
	// with messages informing the caller of any abnormal conditions that occur. The first message
	// sent must contain a payload of type StartAgentCapture, this will trigger the start of the capture.
	// The only messages that can be sent next is a StopAgentCapture which stops the capture gracefully
	// still sending any packets that are remaining and closing the stream afterwards.
	Capture(Agent_CaptureServer) error
	// contains filtered or unexported methods
}

type Agent_CaptureClient interface {
	Send(*AgentRequest) error
	Recv() (*CaptureResponse, error)
	grpc.ClientStream
}

type Agent_CaptureServer interface {
	Send(*CaptureResponse) error
	Recv() (*AgentRequest, error)
	grpc.ServerStream
}

type BoshInfo struct {
	Name            string `json:"name"`
	UUID            string `json:"uuid"`
	Version         string `json:"version"`
	Cpi             string `json:"cpi"`
	StemcellOS      string `json:"stemcell_os"`
	StemcellVersion string `json:"stemcell_version"`

	UserAuthentication struct {
		Type    string `json:"type"`
		Options struct {
			URL  string   `json:"url"`
			URLs []string `json:"urls"`
		} `json:"options"`
	} `json:"user_authentication"`
}

type BoshInstance struct {
	AgentID     string    `json:"agent_id"`
	Cid         string    `json:"cid"`
	Job         string    `json:"job"`
	Index       int       `json:"index"`
	ID          string    `json:"id"`
	Az          string    `json:"az"`
	Ips         []string  `json:"ips"`
	VMCreatedAt time.Time `json:"vm_created_at"`
	ExpectsVM   bool      `json:"expects_vm"`
}

type BoshRequest struct {
	Token      string   `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	Deployment string   `protobuf:"bytes,2,opt,name=deployment,proto3" json:"deployment,omitempty"`
	Groups     []string `protobuf:"bytes,3,rep,name=groups,proto3" json:"groups,omitempty"`
	Instances  []string `protobuf:"bytes,4,rep,name=instances,proto3" json:"instances,omitempty"`
	// contains filtered or unexported fields
}

type BoshResolver struct {
	UaaURLs     []string
	Config      BoshResolverConfig
	DirectorURL *url.URL
	// contains filtered or unexported fields
}

type BoshResolverConfig struct {
	RawDirectorURL string     `yaml:"director_url" validate:"required,url"`
	AgentPort      int        `yaml:"agent_port" validate:"required,gt=0,lte=65535"`
	TokenScope     string     `yaml:"token_scope" validate:"required"`
	TLS            *ClientTLS `yaml:"tls" validate:"omitempty"`
}

type BufferConf struct {
	// Size is the number of responses that can be buffered per stream.
	Size int `yaml:"size" validate:"gte=0"`
	// UpperLimit tells the manager of the buffer to start discarding messages
	// once the limit is exceeded. The condition looks like this:
	//   len(buf) >= UpperLimit
	UpperLimit int `yaml:"upper_limit" validate:"gte=0,ltefield=Size"`
	// LowerLimit tells the manager of the buffer to stop discarding messages
	// once the limit is reached/undercut. The condition looks like this:
	//   len(buf) <= LowerLimit
	LowerLimit int `yaml:"lower_limit" validate:"gte=0,ltefield=UpperLimit"`
}

type CaptureOptions struct {
	Device  string `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	Filter  string `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"`
	SnapLen uint32 `protobuf:"varint,3,opt,name=snapLen,proto3" json:"snapLen,omitempty"`
	// contains filtered or unexported fields
}

type CaptureRequest struct {

	// Types that are assignable to Operation:
	//
	//	*CaptureRequest_Start
	//	*CaptureRequest_Stop
	Operation isCaptureRequest_Operation `protobuf_oneof:"operation"`
	// contains filtered or unexported fields
}

type CaptureRequest_Start struct {
	Start *StartCapture `protobuf:"bytes,1,opt,name=start,proto3,oneof"`
}

type CaptureRequest_Stop struct {
	Stop *StopCapture `protobuf:"bytes,2,opt,name=stop,proto3,oneof"`
}

type CaptureResponse struct {

	// Types that are assignable to Payload:
	//
	//	*CaptureResponse_Packet
	//	*CaptureResponse_Message
	Payload isCaptureResponse_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

type CaptureResponse_Message struct {
	Message *Message `protobuf:"bytes,2,opt,name=message,proto3,oneof"`
}

type CaptureResponse_Packet struct {
	Packet *Packet `protobuf:"bytes,1,opt,name=packet,proto3,oneof"`
}

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

type ClientTLS struct {
	// Certificate holds the path to the PEM encoded certificate (chain) that
	// is presented by the client / server to its peer.
	Certificate string `yaml:"certificate" validate:"omitempty,file"`
	// PrivateKey is the private key matching the certificate.
	PrivateKey string `yaml:"private_key" validate:"omitempty,file"`
	// RootCas holds the path to the PEM encoded CA bundle which
	// is used to validate the certificate presented by the server if acting as
	// the client.
	RootCas string `yaml:"ca" validate:"omitempty,file"`
	// SkipVerify can be set to disable verification of the peer certificate if
	// acting as the client.
	SkipVerify bool `yaml:"skip_verify"`
	// ServerName that the certificate presented by the server must be signed
	// for.
	ServerName string `yaml:"server_name"`
}

type CloudfoundryRequest struct {
	Token   string  `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	AppId   string  `protobuf:"bytes,2,opt,name=appId,proto3" json:"appId,omitempty"`
	AppType *string `protobuf:"bytes,3,opt,name=appType,proto3,oneof" json:"appType,omitempty"`
	Indices []int32 `protobuf:"varint,4,rep,packed,name=indices,proto3" json:"indices,omitempty"`
	// contains filtered or unexported fields
}

type CloudfoundryResolver struct {
}

type EndpointRequest struct {

	// Types that are assignable to Request:
	//
	//	*EndpointRequest_Bosh
	//	*EndpointRequest_Cf
	Request isEndpointRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

type EndpointRequest_Bosh struct {
	Bosh *BoshRequest `protobuf:"bytes,1,opt,name=bosh,proto3,oneof"`
}

type EndpointRequest_Cf struct {
	Cf *CloudfoundryRequest `protobuf:"bytes,2,opt,name=cf,proto3,oneof"`
}

type Listen struct {
	Port int        `yaml:"port" validate:"gt=0,lte=65535"`
	TLS  *ServerTLS `yaml:"tls,omitempty"`
}

type LogMessageWriter struct {
	Log *zap.Logger
}

type Message struct {
	Type    MessageType `protobuf:"varint,1,opt,name=type,proto3,enum=pcap.MessageType" json:"type,omitempty"`
	Message string      `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Origin  string      `protobuf:"bytes,3,opt,name=origin,proto3" json:"origin,omitempty"`
	// contains filtered or unexported fields
}

type MessageType int32

type MessageWriter interface {
	WriteMessage(message *Message)
}

type NodeConfig struct {
	Listen   Listen     `yaml:"listen"`
	Buffer   BufferConf `yaml:"buffer"`
	LogLevel string     `yaml:"log_level"`
	ID       string     `yaml:"id" validate:"required"`
}

type Packet struct {
	Data      []byte                 `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Length    int32                  `protobuf:"varint,3,opt,name=length,proto3" json:"length,omitempty"`
	// contains filtered or unexported fields
}

type ServerTLS struct {
	// Certificate holds the path to the PEM encoded certificate (chain) that
	// is presented by the client / server to its peer.
	Certificate string `yaml:"certificate" validate:"omitempty,file"`
	// PrivateKey is the private key matching the certificate.
	PrivateKey string `yaml:"private_key" validate:"omitempty,file"`
	ClientCas  string `yaml:"client_cas"`
	// Verify controls how the peer certificate is verified:
	//
	// 0: tls.NoClientCert
	//
	// 1: tls.RequestClientCert
	//
	// 2: tls.RequireAnyClientCert
	//
	// 3: tls.VerifyClientCertIfGiven
	//
	// 4: tls.RequireAndVerifyClientCert
	Verify tls.ClientAuthType `yaml:"verify"`
}

type StartAgentCapture struct {
	Capture *CaptureOptions `protobuf:"bytes,1,opt,name=capture,proto3" json:"capture,omitempty"`
	// contains filtered or unexported fields
}

type StartCapture struct {
	Request *EndpointRequest `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	Options *CaptureOptions  `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

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

type StatusResponse struct {
	Healthy            bool     `protobuf:"varint,1,opt,name=healthy,proto3" json:"healthy,omitempty"`
	CompatibilityLevel int64    `protobuf:"varint,2,opt,name=compatibilityLevel,proto3" json:"compatibilityLevel,omitempty"`
	Message            string   `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	Resolvers          []string `protobuf:"bytes,4,rep,name=resolvers,proto3" json:"resolvers,omitempty"`
	// contains filtered or unexported fields
}

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

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

type Stoppable interface {
	Stop()
}

type UaaKeyInfo struct {
	Kty   string `json:"kty"`
	E     string `json:"e"`
	Use   string `json:"use"`
	Kid   string `json:"kid"`
	Alg   string `json:"alg"`
	Value string `json:"value"`
	N     string `json:"n"`
}

type UnimplementedAPIServer struct {
}

type UnimplementedAgentServer struct {
}

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

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

type WaitingStoppable interface {
	Stoppable

	Wait()
}