topo

package
v0.8.12 Latest Latest
Warning

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

 Go to latest Published: Jan 10, 2022 License: Apache-2.0 Imports: 9 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthPerf        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPerf          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPerf = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterPerfServiceServer 

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

Types

type Data 

type Data struct {
	Length uint32 `protobuf:"varint,1,opt,name=length,proto3" json:"length,omitempty"`
	Data   []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
}

func (*Data) Descriptor 

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

func (*Data) GetData 

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

func (*Data) GetLength 

func (m *Data) GetLength() uint32

func (*Data) Marshal 

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

func (*Data) MarshalTo 

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

func (*Data) MarshalToSizedBuffer 

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

func (*Data) ProtoMessage 

func (*Data) ProtoMessage()

func (*Data) Reset 

func (m *Data) Reset()

func (*Data) Size 

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

func (*Data) String 

func (m *Data) String() string

func (*Data) Unmarshal 

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

func (*Data) XXX_DiscardUnknown 

func (m *Data) XXX_DiscardUnknown()

func (*Data) XXX_Marshal 

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

func (*Data) XXX_Merge 

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

func (*Data) XXX_Size 

func (m *Data) XXX_Size() int

func (*Data) XXX_Unmarshal 

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

type PerfServiceClient 

type PerfServiceClient interface {
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
	PingStream(ctx context.Context, opts ...grpc.CallOption) (PerfService_PingStreamClient, error)
}

PerfServiceClient is the client API for PerfService service.

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

func NewPerfServiceClient 

func NewPerfServiceClient(cc *grpc.ClientConn) PerfServiceClient

type PerfServiceServer 

type PerfServiceServer interface {
	Ping(context.Context, *PingRequest) (*PingResponse, error)
	PingStream(PerfService_PingStreamServer) error
}

PerfServiceServer is the server API for PerfService service.

type PerfService_PingStreamClient 

type PerfService_PingStreamClient interface {
	Send(*PingRequest) error
	Recv() (*PingResponse, error)
	grpc.ClientStream
}

type PerfService_PingStreamServer 

type PerfService_PingStreamServer interface {
	Send(*PingResponse) error
	Recv() (*PingRequest, error)
	grpc.ServerStream
}

type PingRequest 

type PingRequest struct {
	Payload     *Data  `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	Timestamp   uint64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	RepeatCount uint32 `protobuf:"varint,3,opt,name=repeatCount,proto3" json:"repeatCount,omitempty"`
}

func (*PingRequest) Descriptor 

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

func (*PingRequest) GetPayload 

func (m *PingRequest) GetPayload() *Data

func (*PingRequest) GetRepeatCount 

func (m *PingRequest) GetRepeatCount() uint32

func (*PingRequest) GetTimestamp 

func (m *PingRequest) GetTimestamp() uint64

func (*PingRequest) Marshal 

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

func (*PingRequest) MarshalTo 

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

func (*PingRequest) MarshalToSizedBuffer 

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

func (*PingRequest) ProtoMessage 

func (*PingRequest) ProtoMessage()

func (*PingRequest) Reset 

func (m *PingRequest) Reset()

func (*PingRequest) Size 

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

func (*PingRequest) String 

func (m *PingRequest) String() string

func (*PingRequest) Unmarshal 

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

func (*PingRequest) XXX_DiscardUnknown 

func (m *PingRequest) XXX_DiscardUnknown()

func (*PingRequest) XXX_Marshal 

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

func (*PingRequest) XXX_Merge 

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

func (*PingRequest) XXX_Size 

func (m *PingRequest) XXX_Size() int

func (*PingRequest) XXX_Unmarshal 

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

type PingResponse 

type PingResponse struct {
	Payload   *Data  `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	Timestamp uint64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
}

func (*PingResponse) Descriptor 

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

func (*PingResponse) GetPayload 

func (m *PingResponse) GetPayload() *Data

func (*PingResponse) GetTimestamp 

func (m *PingResponse) GetTimestamp() uint64

func (*PingResponse) Marshal 

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

func (*PingResponse) MarshalTo 

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

func (*PingResponse) MarshalToSizedBuffer 

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

func (*PingResponse) ProtoMessage 

func (*PingResponse) ProtoMessage()

func (*PingResponse) Reset 

func (m *PingResponse) Reset()

func (*PingResponse) Size 

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

func (*PingResponse) String 

func (m *PingResponse) String() string

func (*PingResponse) Unmarshal 

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

func (*PingResponse) XXX_DiscardUnknown 

func (m *PingResponse) XXX_DiscardUnknown()

func (*PingResponse) XXX_Marshal 

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

func (*PingResponse) XXX_Merge 

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

func (*PingResponse) XXX_Size 

func (m *PingResponse) XXX_Size() int

func (*PingResponse) XXX_Unmarshal 

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

type UnimplementedPerfServiceServer 

type UnimplementedPerfServiceServer struct {
}

UnimplementedPerfServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedPerfServiceServer) Ping 

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

func (*UnimplementedPerfServiceServer) PingStream 

func (*UnimplementedPerfServiceServer) PingStream(srv PerfService_PingStreamServer) 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.