ping

Documentation

Index

• Variables
• func RegisterPingServiceServer(s *grpc.Server, srv PingServiceServer)
• type PingReply
  • func (*PingReply) Descriptor() ([]byte, []int)
  • func (this *PingReply) Equal(that interface{}) bool
  • func (m *PingReply) GetReply() string
  • func (this *PingReply) GoString() string
  • func (m *PingReply) Marshal() (dAtA []byte, err error)
  • func (m *PingReply) MarshalTo(dAtA []byte) (int, error)
  • func (m *PingReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*PingReply) ProtoMessage()
  • func (m *PingReply) Reset()
  • func (m *PingReply) Size() (n int)
  • func (this *PingReply) String() string
  • func (m *PingReply) Unmarshal(dAtA []byte) error
  • func (m *PingReply) XXX_DiscardUnknown()
  • func (m *PingReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *PingReply) XXX_Merge(src proto.Message)
  • func (m *PingReply) XXX_Size() int
  • func (m *PingReply) XXX_Unmarshal(b []byte) error
• type PingRequest
  • func (*PingRequest) Descriptor() ([]byte, []int)
  • func (this *PingRequest) Equal(that interface{}) bool
  • func (m *PingRequest) GetReq() string
  • func (this *PingRequest) GoString() string
  • 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 (*PingRequest) ProtoMessage()
  • func (m *PingRequest) Reset()
  • func (m *PingRequest) Size() (n int)
  • func (this *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 PingServiceClient
  • func NewPingServiceClient(cc *grpc.ClientConn) PingServiceClient
• type PingServiceServer
• type PingService_PingClientStreamClient
• type PingService_PingClientStreamServer
• type PingService_PingServerStreamClient
• type PingService_PingServerStreamServer
• type UnimplementedPingServiceServer
  • func (*UnimplementedPingServiceServer) Ping(ctx context.Context, req *PingRequest) (*PingReply, error)
  • func (*UnimplementedPingServiceServer) PingClientStream(srv PingService_PingClientStreamServer) error
  • func (*UnimplementedPingServiceServer) PingServerStream(req *PingRequest, srv PingService_PingServerStreamServer) error

Variables

var (
	ErrInvalidLengthPing        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPing          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPing = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterPingServiceServer

func RegisterPingServiceServer(s *grpc.Server, srv PingServiceServer)

Types

type PingReply

type PingReply struct {
	Reply string `protobuf:"bytes,1,opt,name=reply,proto3" json:"reply,omitempty"`
}

func (*PingReply) Descriptor

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

func (*PingReply) Equal

func (this *PingReply) Equal(that interface{}) bool

func (*PingReply) GetReply

func (m *PingReply) GetReply() string

func (*PingReply) GoString

func (this *PingReply) GoString() string

func (*PingReply) Marshal

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

func (*PingReply) MarshalTo

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

func (*PingReply) MarshalToSizedBuffer

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

func (*PingReply) ProtoMessage

func (*PingReply) ProtoMessage()

func (*PingReply) Reset

func (m *PingReply) Reset()

func (*PingReply) Size

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

func (*PingReply) String

func (this *PingReply) String() string

func (*PingReply) Unmarshal

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

func (*PingReply) XXX_DiscardUnknown

func (m *PingReply) XXX_DiscardUnknown()

func (*PingReply) XXX_Marshal

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

func (*PingReply) XXX_Merge

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

func (*PingReply) XXX_Size

func (m *PingReply) XXX_Size() int

func (*PingReply) XXX_Unmarshal

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

type PingRequest

type PingRequest struct {
	Req string `protobuf:"bytes,1,opt,name=req,proto3" json:"req,omitempty"`
}

func (*PingRequest) Descriptor

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

func (*PingRequest) Equal

func (this *PingRequest) Equal(that interface{}) bool

func (*PingRequest) GetReq

func (m *PingRequest) GetReq() string

func (*PingRequest) GoString

func (this *PingRequest) GoString() string

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 (this *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 PingServiceClient

type PingServiceClient interface {
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingReply, error)
	PingClientStream(ctx context.Context, opts ...grpc.CallOption) (PingService_PingClientStreamClient, error)
	PingServerStream(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (PingService_PingServerStreamClient, error)
}

PingServiceClient is the client API for PingService service.

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

func NewPingServiceClient

func NewPingServiceClient(cc *grpc.ClientConn) PingServiceClient

type PingServiceServer

type PingServiceServer interface {
	Ping(context.Context, *PingRequest) (*PingReply, error)
	PingClientStream(PingService_PingClientStreamServer) error
	PingServerStream(*PingRequest, PingService_PingServerStreamServer) error
}

PingServiceServer is the server API for PingService service.

type PingService_PingClientStreamClient

type PingService_PingClientStreamClient interface {
	Send(*PingRequest) error
	CloseAndRecv() (*PingReply, error)
	grpc.ClientStream
}

type PingService_PingClientStreamServer

type PingService_PingClientStreamServer interface {
	SendAndClose(*PingReply) error
	Recv() (*PingRequest, error)
	grpc.ServerStream
}

type PingService_PingServerStreamClient

type PingService_PingServerStreamClient interface {
	Recv() (*PingReply, error)
	grpc.ClientStream
}

type PingService_PingServerStreamServer

type PingService_PingServerStreamServer interface {
	Send(*PingReply) error
	grpc.ServerStream
}

type UnimplementedPingServiceServer

type UnimplementedPingServiceServer struct {
}

UnimplementedPingServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedPingServiceServer) Ping

func (*UnimplementedPingServiceServer) Ping(ctx context.Context, req *PingRequest) (*PingReply, error)

func (*UnimplementedPingServiceServer) PingClientStream

func (*UnimplementedPingServiceServer) PingClientStream(srv PingService_PingClientStreamServer) error

func (*UnimplementedPingServiceServer) PingServerStream

func (*UnimplementedPingServiceServer) PingServerStream(req *PingRequest, srv PingService_PingServerStreamServer) error