Versions in this module Expand all Collapse all v0 v0.2.3 May 14, 2021 v0.2.2 May 14, 2021 Changes in this version + var File_v1_ping_proto protoreflect.FileDescriptor + var PingResponse_ResultType_name = map[int32]string + var PingResponse_ResultType_value = map[string]int32 + var Service_ServiceDesc = grpc.ServiceDesc + func RegisterServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error + func RegisterServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ServiceClient) error + func RegisterServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error) + func RegisterServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ServiceServer) error + func RegisterServiceServer(s grpc.ServiceRegistrar, srv ServiceServer) + type Content struct + Data []byte + Id string + Metadata map[string]string + func (*Content) Descriptor() ([]byte, []int) + func (*Content) ProtoMessage() + func (x *Content) GetData() []byte + func (x *Content) GetId() string + func (x *Content) GetMetadata() map[string]string + func (x *Content) ProtoReflect() protoreflect.Message + func (x *Content) Reset() + func (x *Content) String() string + type PingRequest struct + Content *Content + Sent int64 + func (*PingRequest) Descriptor() ([]byte, []int) + func (*PingRequest) ProtoMessage() + func (x *PingRequest) GetContent() *Content + func (x *PingRequest) GetSent() int64 + func (x *PingRequest) ProtoReflect() protoreflect.Message + func (x *PingRequest) Reset() + func (x *PingRequest) String() string + type PingResponse struct + Detail string + MessageCount int64 + MessageID string + Processed int64 + func (*PingResponse) Descriptor() ([]byte, []int) + func (*PingResponse) ProtoMessage() + func (x *PingResponse) GetDetail() string + func (x *PingResponse) GetMessageCount() int64 + func (x *PingResponse) GetMessageID() string + func (x *PingResponse) GetProcessed() int64 + func (x *PingResponse) ProtoReflect() protoreflect.Message + func (x *PingResponse) Reset() + func (x *PingResponse) String() string + type PingResponse_ResultType int32 + const PingResponse_Eror + const PingResponse_Success + const PingResponse_UNKNOWN + func (PingResponse_ResultType) Descriptor() protoreflect.EnumDescriptor + func (PingResponse_ResultType) EnumDescriptor() ([]byte, []int) + func (PingResponse_ResultType) Type() protoreflect.EnumType + func (x PingResponse_ResultType) Enum() *PingResponse_ResultType + func (x PingResponse_ResultType) Number() protoreflect.EnumNumber + func (x PingResponse_ResultType) String() string + type ServiceClient interface + Ping func(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error) + Stream func(ctx context.Context, opts ...grpc.CallOption) (Service_StreamClient, error) + func NewServiceClient(cc grpc.ClientConnInterface) ServiceClient + type ServiceServer interface + Ping func(context.Context, *PingRequest) (*PingResponse, error) + Stream func(Service_StreamServer) error + type Service_StreamClient interface + Recv func() (*PingResponse, error) + Send func(*PingRequest) error + type Service_StreamServer interface + Recv func() (*PingRequest, error) + Send func(*PingResponse) error + type UnimplementedServiceServer struct + func (UnimplementedServiceServer) Ping(context.Context, *PingRequest) (*PingResponse, error) + func (UnimplementedServiceServer) Stream(Service_StreamServer) error + type UnsafeServiceServer interface