bumpb

Documentation

Index

• Variables
• func RegisterBumSniffServiceServer(s grpc.ServiceRegistrar, srv BumSniffServiceServer)
• type BumSniffServiceClient
  • func NewBumSniffServiceClient(cc grpc.ClientConnInterface) BumSniffServiceClient
• type BumSniffServiceServer
• type BumSniffService_SniffClient
• type BumSniffService_SniffServer
• type Packet
  • func (*Packet) Descriptor() ([]byte, []int)
  • func (x *Packet) GetData() []byte
  • func (x *Packet) GetDomain() string
  • func (x *Packet) GetLabel() uint32
  • func (x *Packet) GetPeerid() string
  • func (x *Packet) GetRemote() string
  • func (x *Packet) GetTimestamp() *timestamppb.Timestamp
  • func (*Packet) ProtoMessage()
  • func (x *Packet) ProtoReflect() protoreflect.Message
  • func (x *Packet) Reset()
  • func (x *Packet) String() string
• type Request
  • func (*Request) Descriptor() ([]byte, []int)
  • func (x *Request) GetDomain() string
  • func (x *Request) GetFilter() string
  • func (x *Request) GetRemote() string
  • func (*Request) ProtoMessage()
  • func (x *Request) ProtoReflect() protoreflect.Message
  • func (x *Request) Reset()
  • func (x *Request) String() string
• type UnimplementedBumSniffServiceServer
  • func (UnimplementedBumSniffServiceServer) Sniff(*Request, BumSniffService_SniffServer) error
• type UnsafeBumSniffServiceServer

Variables

var BumSniffService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "protobuf.BumSniffService",
	HandlerType: (*BumSniffServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Sniff",
			Handler:       _BumSniffService_Sniff_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "bumstream.proto",
}

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

var File_bumstream_proto protoreflect.FileDescriptor

Functions

func RegisterBumSniffServiceServer

func RegisterBumSniffServiceServer(s grpc.ServiceRegistrar, srv BumSniffServiceServer)

Types

type BumSniffServiceClient

type BumSniffServiceClient interface {
	Sniff(ctx context.Context, in *Request, opts ...grpc.CallOption) (BumSniffService_SniffClient, error)
}

BumSniffServiceClient is the client API for BumSniffService 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 NewBumSniffServiceClient

func NewBumSniffServiceClient(cc grpc.ClientConnInterface) BumSniffServiceClient

type BumSniffServiceServer

type BumSniffServiceServer interface {
	Sniff(*Request, BumSniffService_SniffServer) error
}

BumSniffServiceServer is the server API for BumSniffService service. All implementations should embed UnimplementedBumSniffServiceServer for forward compatibility

type BumSniffService_SniffClient

type BumSniffService_SniffClient interface {
	Recv() (*Packet, error)
	grpc.ClientStream
}

type BumSniffService_SniffServer

type BumSniffService_SniffServer interface {
	Send(*Packet) error
	grpc.ServerStream
}

type Packet

type Packet struct {
	Data      []byte                 `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Label     uint32                 `protobuf:"varint,2,opt,name=label,proto3" json:"label,omitempty"`
	Remote    string                 `protobuf:"bytes,3,opt,name=remote,proto3" json:"remote,omitempty"`
	Domain    string                 `protobuf:"bytes,4,opt,name=domain,proto3" json:"domain,omitempty"`
	Peerid    string                 `protobuf:"bytes,5,opt,name=peerid,proto3" json:"peerid,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*Packet) Descriptor

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

Deprecated: Use Packet.ProtoReflect.Descriptor instead.

func (*Packet) GetData

func (x *Packet) GetData() []byte

func (*Packet) GetDomain

func (x *Packet) GetDomain() string

func (*Packet) GetLabel

func (x *Packet) GetLabel() uint32

func (*Packet) GetPeerid

func (x *Packet) GetPeerid() string

func (*Packet) GetRemote

func (x *Packet) GetRemote() string

func (*Packet) GetTimestamp

func (x *Packet) GetTimestamp() *timestamppb.Timestamp

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 Request

type Request struct {
	Filter string `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	Remote string `protobuf:"bytes,2,opt,name=remote,proto3" json:"remote,omitempty"`
	Domain string `protobuf:"bytes,3,opt,name=domain,proto3" json:"domain,omitempty"`
	// contains filtered or unexported fields
}

func (*Request) Descriptor

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

Deprecated: Use Request.ProtoReflect.Descriptor instead.

func (*Request) GetDomain

func (x *Request) GetDomain() string

func (*Request) GetFilter

func (x *Request) GetFilter() string

func (*Request) GetRemote

func (x *Request) GetRemote() string

func (*Request) ProtoMessage

func (*Request) ProtoMessage()

func (*Request) ProtoReflect

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

func (*Request) Reset

func (x *Request) Reset()

func (*Request) String

func (x *Request) String() string

type UnimplementedBumSniffServiceServer

type UnimplementedBumSniffServiceServer struct {
}

UnimplementedBumSniffServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedBumSniffServiceServer) Sniff

func (UnimplementedBumSniffServiceServer) Sniff(*Request, BumSniffService_SniffServer) error

type UnsafeBumSniffServiceServer

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

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