pbpacket

Documentation

Index

• Constants
• Variables
• func RegisterCollectorServer(s grpc.ServiceRegistrar, srv CollectorServer)
• type CollectorClient
  • func NewCollectorClient(cc grpc.ClientConnInterface) CollectorClient
• type CollectorReply
  • func (*CollectorReply) Descriptor() ([]byte, []int)
  • func (*CollectorReply) ProtoMessage()
  • func (x *CollectorReply) ProtoReflect() protoreflect.Message
  • func (x *CollectorReply) Reset()
  • func (x *CollectorReply) String() string
• type CollectorServer
• type Packet
  • func (*Packet) Descriptor() ([]byte, []int)
  • func (x *Packet) GetPcap() *anypb.Any
  • func (*Packet) ProtoMessage()
  • func (x *Packet) ProtoReflect() protoreflect.Message
  • func (x *Packet) Reset()
  • func (x *Packet) String() string
• type UnimplementedCollectorServer
  • func (UnimplementedCollectorServer) Send(context.Context, *Packet) (*CollectorReply, error)
• type UnsafeCollectorServer

Constants

const (
	Collector_Send_FullMethodName = "/pbpacket.Collector/Send"
)

Variables

var Collector_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pbpacket.Collector",
	HandlerType: (*CollectorServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Send",
			Handler:    _Collector_Send_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/packet.proto",
}

Collector_ServiceDesc is the grpc.ServiceDesc for Collector service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

var File_proto_packet_proto protoreflect.FileDescriptor

Functions

func RegisterCollectorServer

func RegisterCollectorServer(s grpc.ServiceRegistrar, srv CollectorServer)

Types

type CollectorClient

type CollectorClient interface {
	Send(ctx context.Context, in *Packet, opts ...grpc.CallOption) (*CollectorReply, error)
}

CollectorClient is the client API for Collector service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewCollectorClient

func NewCollectorClient(cc grpc.ClientConnInterface) CollectorClient

type CollectorReply

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

intentionally empty

func (*CollectorReply) Descriptor

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

Deprecated: Use CollectorReply.ProtoReflect.Descriptor instead.

func (*CollectorReply) ProtoMessage

func (*CollectorReply) ProtoMessage()

func (*CollectorReply) ProtoReflect

func (x *CollectorReply) ProtoReflect() protoreflect.Message

func (*CollectorReply) Reset

func (x *CollectorReply) Reset()

func (*CollectorReply) String

func (x *CollectorReply) String() string

type CollectorServer

type CollectorServer interface {
	Send(context.Context, *Packet) (*CollectorReply, error)
	// contains filtered or unexported methods
}

CollectorServer is the server API for Collector service. All implementations must embed UnimplementedCollectorServer for forward compatibility

type Packet

type Packet struct {
	Pcap *anypb.Any `protobuf:"bytes,1,opt,name=pcap,proto3" json:"pcap,omitempty"`
	// contains filtered or unexported fields
}

The request message containing the Packet

func (*Packet) Descriptor

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

Deprecated: Use Packet.ProtoReflect.Descriptor instead.

func (*Packet) GetPcap

func (x *Packet) GetPcap() *anypb.Any

func (*Packet) ProtoMessage

func (*Packet) ProtoMessage()

func (*Packet) ProtoReflect

func (x *Packet) ProtoReflect() protoreflect.Message

func (*Packet) Reset

func (x *Packet) Reset()

func (*Packet) String

func (x *Packet) String() string

type UnimplementedCollectorServer

type UnimplementedCollectorServer struct {
}

UnimplementedCollectorServer must be embedded to have forward compatible implementations.

func (UnimplementedCollectorServer) Send

func (UnimplementedCollectorServer) Send(context.Context, *Packet) (*CollectorReply, error)

type UnsafeCollectorServer

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

UnsafeCollectorServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CollectorServer will result in compilation errors.