packets

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 2, 2021 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterPacketCollectionServer 

func RegisterPacketCollectionServer(s *grpc.Server, srv PacketCollectionServer)

Types

type PacketCollectionClient 

type PacketCollectionClient interface {
	// packetsummary ingest stream
	Ingest(ctx context.Context, opts ...grpc.CallOption) (PacketCollection_IngestClient, error)
	// Register a CapturePoint
	CapturePoint(ctx context.Context, in *RegisterCapturePoint, opts ...grpc.CallOption) (*RegisterResponse, error)
}

PacketCollectionClient is the client API for PacketCollection service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPacketCollectionClient 

func NewPacketCollectionClient(cc *grpc.ClientConn) PacketCollectionClient

type PacketCollectionServer 

type PacketCollectionServer interface {
	// packetsummary ingest stream
	Ingest(PacketCollection_IngestServer) error
	// Register a CapturePoint
	CapturePoint(context.Context, *RegisterCapturePoint) (*RegisterResponse, error)
}

PacketCollectionServer is the server API for PacketCollection service.

type PacketCollection_IngestClient 

type PacketCollection_IngestClient interface {
	Send(*PacketSummaryMessage) error
	CloseAndRecv() (*empty.Empty, error)
	grpc.ClientStream
}

type PacketCollection_IngestServer 

type PacketCollection_IngestServer interface {
	SendAndClose(*empty.Empty) error
	Recv() (*PacketSummaryMessage, error)
	grpc.ServerStream
}

type PacketSummary 

type PacketSummary struct {
	SrcIP  net.IP
	SrcMac net.HardwareAddr
	DstIP  net.IP
	DstMac net.HardwareAddr
	TTL    uint8
	CapID  uint32 //capturepoint this packetsummary was taken from
}

func UnmarshallSummary 

func UnmarshallSummary(data []byte) (summary PacketSummary, err error)

func (PacketSummary) Marshall 

func (s PacketSummary) Marshall() ([]byte, error)

type PacketSummaryMessage 

type PacketSummaryMessage struct {
	CapID                uint32   `protobuf:"varint,1,opt,name=CapID,proto3" json:"CapID,omitempty"`
	SrcIP                uint32   `protobuf:"varint,2,opt,name=SrcIP,proto3" json:"SrcIP,omitempty"`
	SrcMac               uint32   `protobuf:"varint,3,opt,name=SrcMac,proto3" json:"SrcMac,omitempty"`
	DstIP                uint32   `protobuf:"varint,4,opt,name=DstIP,proto3" json:"DstIP,omitempty"`
	DstMac               uint32   `protobuf:"varint,5,opt,name=DstMac,proto3" json:"DstMac,omitempty"`
	TTL                  uint32   `protobuf:"varint,6,opt,name=TTL,proto3" json:"TTL,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Main PacketSummary protobuf

func (*PacketSummaryMessage) Descriptor 

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

func (*PacketSummaryMessage) GetCapID 

func (m *PacketSummaryMessage) GetCapID() uint32

func (*PacketSummaryMessage) GetDstIP 

func (m *PacketSummaryMessage) GetDstIP() uint32

func (*PacketSummaryMessage) GetDstMac 

func (m *PacketSummaryMessage) GetDstMac() uint32

func (*PacketSummaryMessage) GetSrcIP 

func (m *PacketSummaryMessage) GetSrcIP() uint32

func (*PacketSummaryMessage) GetSrcMac 

func (m *PacketSummaryMessage) GetSrcMac() uint32

func (*PacketSummaryMessage) GetTTL 

func (m *PacketSummaryMessage) GetTTL() uint32

func (*PacketSummaryMessage) ProtoMessage 

func (*PacketSummaryMessage) ProtoMessage()

func (*PacketSummaryMessage) Reset 

func (m *PacketSummaryMessage) Reset()

func (*PacketSummaryMessage) String 

func (m *PacketSummaryMessage) String() string

func (*PacketSummaryMessage) XXX_DiscardUnknown 

func (m *PacketSummaryMessage) XXX_DiscardUnknown()

func (*PacketSummaryMessage) XXX_Marshal 

func (m *PacketSummaryMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PacketSummaryMessage) XXX_Merge 

func (m *PacketSummaryMessage) XXX_Merge(src proto.Message)

func (*PacketSummaryMessage) XXX_Size 

func (m *PacketSummaryMessage) XXX_Size() int

func (*PacketSummaryMessage) XXX_Unmarshal 

func (m *PacketSummaryMessage) XXX_Unmarshal(b []byte) error

type RegisterCapturePoint 

type RegisterCapturePoint struct {
	CollectorID          string   `protobuf:"bytes,1,opt,name=CollectorID,proto3" json:"CollectorID,omitempty"`
	Netaddr              uint32   `protobuf:"varint,2,opt,name=Netaddr,proto3" json:"Netaddr,omitempty"`
	Netmask              uint32   `protobuf:"varint,3,opt,name=Netmask,proto3" json:"Netmask,omitempty"`
	NicName              string   `protobuf:"bytes,4,opt,name=NicName,proto3" json:"NicName,omitempty"`
	DefaultGateway       uint32   `protobuf:"varint,5,opt,name=DefaultGateway,proto3" json:"DefaultGateway,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request to Register a New Capturepoint

func (*RegisterCapturePoint) Descriptor 

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

func (*RegisterCapturePoint) GetCollectorID 

func (m *RegisterCapturePoint) GetCollectorID() string

func (*RegisterCapturePoint) GetDefaultGateway 

func (m *RegisterCapturePoint) GetDefaultGateway() uint32

func (*RegisterCapturePoint) GetNetaddr 

func (m *RegisterCapturePoint) GetNetaddr() uint32

func (*RegisterCapturePoint) GetNetmask 

func (m *RegisterCapturePoint) GetNetmask() uint32

func (*RegisterCapturePoint) GetNicName 

func (m *RegisterCapturePoint) GetNicName() string

func (*RegisterCapturePoint) ProtoMessage 

func (*RegisterCapturePoint) ProtoMessage()

func (*RegisterCapturePoint) Reset 

func (m *RegisterCapturePoint) Reset()

func (*RegisterCapturePoint) String 

func (m *RegisterCapturePoint) String() string

func (*RegisterCapturePoint) XXX_DiscardUnknown 

func (m *RegisterCapturePoint) XXX_DiscardUnknown()

func (*RegisterCapturePoint) XXX_Marshal 

func (m *RegisterCapturePoint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegisterCapturePoint) XXX_Merge 

func (m *RegisterCapturePoint) XXX_Merge(src proto.Message)

func (*RegisterCapturePoint) XXX_Size 

func (m *RegisterCapturePoint) XXX_Size() int

func (*RegisterCapturePoint) XXX_Unmarshal 

func (m *RegisterCapturePoint) XXX_Unmarshal(b []byte) error

type RegisterResponse 

type RegisterResponse struct {
	CaptureID            uint32   `protobuf:"varint,1,opt,name=CaptureID,proto3" json:"CaptureID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RegisterResponse) Descriptor 

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

func (*RegisterResponse) GetCaptureID 

func (m *RegisterResponse) GetCaptureID() uint32

func (*RegisterResponse) ProtoMessage 

func (*RegisterResponse) ProtoMessage()

func (*RegisterResponse) Reset 

func (m *RegisterResponse) Reset()

func (*RegisterResponse) String 

func (m *RegisterResponse) String() string

func (*RegisterResponse) XXX_DiscardUnknown 

func (m *RegisterResponse) XXX_DiscardUnknown()

func (*RegisterResponse) XXX_Marshal 

func (m *RegisterResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegisterResponse) XXX_Merge 

func (m *RegisterResponse) XXX_Merge(src proto.Message)

func (*RegisterResponse) XXX_Size 

func (m *RegisterResponse) XXX_Size() int

func (*RegisterResponse) XXX_Unmarshal 

func (m *RegisterResponse) XXX_Unmarshal(b []byte) error

type UnimplementedPacketCollectionServer 

type UnimplementedPacketCollectionServer struct {
}

UnimplementedPacketCollectionServer can be embedded to have forward compatible implementations.

func (*UnimplementedPacketCollectionServer) CapturePoint 

func (*UnimplementedPacketCollectionServer) CapturePoint(ctx context.Context, req *RegisterCapturePoint) (*RegisterResponse, error)

func (*UnimplementedPacketCollectionServer) Ingest 

func (*UnimplementedPacketCollectionServer) Ingest(srv PacketCollection_IngestServer) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.