topo

Sep 1, 2021

Changes in this version

+ var ErrIntOverflowPerf = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthPerf = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupPerf = fmt.Errorf("proto: unexpected end of group")

+ func RegisterPerfServiceServer(s *grpc.Server, srv PerfServiceServer)

+ type Data struct

+ Data []byte

+ Length uint32

+ func (*Data) Descriptor() ([]byte, []int)

+ func (*Data) ProtoMessage()

+ func (m *Data) GetData() []byte

+ func (m *Data) GetLength() uint32

+ func (m *Data) Marshal() (dAtA []byte, err error)

+ func (m *Data) MarshalTo(dAtA []byte) (int, error)

+ func (m *Data) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Data) Reset()

+ func (m *Data) Size() (n int)

+ func (m *Data) String() string

+ func (m *Data) Unmarshal(dAtA []byte) error

+ func (m *Data) XXX_DiscardUnknown()

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

+ func (m *Data) XXX_Merge(src proto.Message)

+ func (m *Data) XXX_Size() int

+ func (m *Data) XXX_Unmarshal(b []byte) error

+ type PerfServiceClient interface

+ Ping func(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)

+ PingStream func(ctx context.Context, opts ...grpc.CallOption) (PerfService_PingStreamClient, error)

+ func NewPerfServiceClient(cc *grpc.ClientConn) PerfServiceClient

+ type PerfServiceServer interface

+ Ping func(context.Context, *PingRequest) (*PingResponse, error)

+ PingStream func(PerfService_PingStreamServer) error

+ type PerfService_PingStreamClient interface

+ Recv func() (*PingResponse, error)

+ Send func(*PingRequest) error

+ type PerfService_PingStreamServer interface

+ Recv func() (*PingRequest, error)

+ Send func(*PingResponse) error

+ type PingRequest struct

+ Payload *Data

+ RepeatCount uint32

+ Timestamp uint64

+ func (*PingRequest) Descriptor() ([]byte, []int)

+ func (*PingRequest) ProtoMessage()

+ func (m *PingRequest) GetPayload() *Data

+ func (m *PingRequest) GetRepeatCount() uint32

+ func (m *PingRequest) GetTimestamp() uint64

+ func (m *PingRequest) Marshal() (dAtA []byte, err error)

+ func (m *PingRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *PingRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PingRequest) Reset()

+ func (m *PingRequest) Size() (n int)

+ func (m *PingRequest) String() string

+ func (m *PingRequest) Unmarshal(dAtA []byte) error

+ func (m *PingRequest) XXX_DiscardUnknown()

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

+ func (m *PingRequest) XXX_Merge(src proto.Message)

+ func (m *PingRequest) XXX_Size() int

+ func (m *PingRequest) XXX_Unmarshal(b []byte) error

+ type PingResponse struct

+ Payload *Data

+ Timestamp uint64

+ func (*PingResponse) Descriptor() ([]byte, []int)

+ func (*PingResponse) ProtoMessage()

+ func (m *PingResponse) GetPayload() *Data

+ func (m *PingResponse) GetTimestamp() uint64

+ func (m *PingResponse) Marshal() (dAtA []byte, err error)

+ func (m *PingResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *PingResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PingResponse) Reset()

+ func (m *PingResponse) Size() (n int)

+ func (m *PingResponse) String() string

+ func (m *PingResponse) Unmarshal(dAtA []byte) error

+ func (m *PingResponse) XXX_DiscardUnknown()

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

+ func (m *PingResponse) XXX_Merge(src proto.Message)

+ func (m *PingResponse) XXX_Size() int

+ func (m *PingResponse) XXX_Unmarshal(b []byte) error

+ type UnimplementedPerfServiceServer struct

+ func (*UnimplementedPerfServiceServer) Ping(ctx context.Context, req *PingRequest) (*PingResponse, error)

+ func (*UnimplementedPerfServiceServer) PingStream(srv PerfService_PingStreamServer) error