requestservice

Documentation

Index

• Variables
• func RegisterRequestServiceServer(s *grpc.Server, srv RequestServiceServer)
• type GetRequestStatusRequest
  • func (*GetRequestStatusRequest) Descriptor() ([]byte, []int)
  • func (this *GetRequestStatusRequest) Equal(that interface{}) bool
  • func (m *GetRequestStatusRequest) GetRequestId() string
  • func (this *GetRequestStatusRequest) GoString() string
  • func (m *GetRequestStatusRequest) Marshal() (dAtA []byte, err error)
  • func (m *GetRequestStatusRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *GetRequestStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*GetRequestStatusRequest) ProtoMessage()
  • func (m *GetRequestStatusRequest) Reset()
  • func (m *GetRequestStatusRequest) Size() (n int)
  • func (this *GetRequestStatusRequest) String() string
  • func (m *GetRequestStatusRequest) Unmarshal(dAtA []byte) error
  • func (m *GetRequestStatusRequest) XXX_DiscardUnknown()
  • func (m *GetRequestStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *GetRequestStatusRequest) XXX_Merge(src proto.Message)
  • func (m *GetRequestStatusRequest) XXX_Size() int
  • func (m *GetRequestStatusRequest) XXX_Unmarshal(b []byte) error
• type GetRequestStatusResponse
  • func (*GetRequestStatusResponse) Descriptor() ([]byte, []int)
  • func (this *GetRequestStatusResponse) Equal(that interface{}) bool
  • func (m *GetRequestStatusResponse) GetRequestStatus() *v1.RequestStatus
  • func (this *GetRequestStatusResponse) GoString() string
  • func (m *GetRequestStatusResponse) Marshal() (dAtA []byte, err error)
  • func (m *GetRequestStatusResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *GetRequestStatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*GetRequestStatusResponse) ProtoMessage()
  • func (m *GetRequestStatusResponse) Reset()
  • func (m *GetRequestStatusResponse) Size() (n int)
  • func (this *GetRequestStatusResponse) String() string
  • func (m *GetRequestStatusResponse) Unmarshal(dAtA []byte) error
  • func (m *GetRequestStatusResponse) XXX_DiscardUnknown()
  • func (m *GetRequestStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *GetRequestStatusResponse) XXX_Merge(src proto.Message)
  • func (m *GetRequestStatusResponse) XXX_Size() int
  • func (m *GetRequestStatusResponse) XXX_Unmarshal(b []byte) error
• type RequestServiceClient
  • func NewRequestServiceClient(cc *grpc.ClientConn) RequestServiceClient
• type RequestServiceServer
• type UnimplementedRequestServiceServer
  • func (*UnimplementedRequestServiceServer) GetRequestStatus(ctx context.Context, req *GetRequestStatusRequest) (*GetRequestStatusResponse, error)

Variables

var (
	ErrInvalidLengthRequestResponse        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRequestResponse          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRequestResponse = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterRequestServiceServer

func RegisterRequestServiceServer(s *grpc.Server, srv RequestServiceServer)

Types

type GetRequestStatusRequest

type GetRequestStatusRequest struct {
	// the request id
	RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
}

func (*GetRequestStatusRequest) Descriptor

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

func (*GetRequestStatusRequest) Equal

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

func (*GetRequestStatusRequest) GetRequestId

func (m *GetRequestStatusRequest) GetRequestId() string

func (*GetRequestStatusRequest) GoString

func (this *GetRequestStatusRequest) GoString() string

func (*GetRequestStatusRequest) Marshal

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

func (*GetRequestStatusRequest) MarshalTo

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

func (*GetRequestStatusRequest) MarshalToSizedBuffer

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

func (*GetRequestStatusRequest) ProtoMessage

func (*GetRequestStatusRequest) ProtoMessage()

func (*GetRequestStatusRequest) Reset

func (m *GetRequestStatusRequest) Reset()

func (*GetRequestStatusRequest) Size

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

func (*GetRequestStatusRequest) String

func (this *GetRequestStatusRequest) String() string

func (*GetRequestStatusRequest) Unmarshal

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

func (*GetRequestStatusRequest) XXX_DiscardUnknown

func (m *GetRequestStatusRequest) XXX_DiscardUnknown()

func (*GetRequestStatusRequest) XXX_Marshal

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

func (*GetRequestStatusRequest) XXX_Merge

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

func (*GetRequestStatusRequest) XXX_Size

func (m *GetRequestStatusRequest) XXX_Size() int

func (*GetRequestStatusRequest) XXX_Unmarshal

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

type GetRequestStatusResponse

type GetRequestStatusResponse struct {
	// the request status
	RequestStatus *v1.RequestStatus `protobuf:"bytes,1,opt,name=request_status,json=requestStatus,proto3" json:"request_status,omitempty"`
}

func (*GetRequestStatusResponse) Descriptor

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

func (*GetRequestStatusResponse) Equal

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

func (*GetRequestStatusResponse) GetRequestStatus

func (m *GetRequestStatusResponse) GetRequestStatus() *v1.RequestStatus

func (*GetRequestStatusResponse) GoString

func (this *GetRequestStatusResponse) GoString() string

func (*GetRequestStatusResponse) Marshal

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

func (*GetRequestStatusResponse) MarshalTo

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

func (*GetRequestStatusResponse) MarshalToSizedBuffer

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

func (*GetRequestStatusResponse) ProtoMessage

func (*GetRequestStatusResponse) ProtoMessage()

func (*GetRequestStatusResponse) Reset

func (m *GetRequestStatusResponse) Reset()

func (*GetRequestStatusResponse) Size

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

func (*GetRequestStatusResponse) String

func (this *GetRequestStatusResponse) String() string

func (*GetRequestStatusResponse) Unmarshal

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

func (*GetRequestStatusResponse) XXX_DiscardUnknown

func (m *GetRequestStatusResponse) XXX_DiscardUnknown()

func (*GetRequestStatusResponse) XXX_Marshal

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

func (*GetRequestStatusResponse) XXX_Merge

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

func (*GetRequestStatusResponse) XXX_Size

func (m *GetRequestStatusResponse) XXX_Size() int

func (*GetRequestStatusResponse) XXX_Unmarshal

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

type RequestServiceClient

type RequestServiceClient interface {
	// GetRequestStatus get the status of a request.
	GetRequestStatus(ctx context.Context, in *GetRequestStatusRequest, opts ...grpc.CallOption) (*GetRequestStatusResponse, error)
}

RequestServiceClient is the client API for RequestService service.

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

func NewRequestServiceClient

func NewRequestServiceClient(cc *grpc.ClientConn) RequestServiceClient

type RequestServiceServer

type RequestServiceServer interface {
	// GetRequestStatus get the status of a request.
	GetRequestStatus(context.Context, *GetRequestStatusRequest) (*GetRequestStatusResponse, error)
}

RequestServiceServer is the server API for RequestService service.

type UnimplementedRequestServiceServer

type UnimplementedRequestServiceServer struct {
}

UnimplementedRequestServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedRequestServiceServer) GetRequestStatus

func (*UnimplementedRequestServiceServer) GetRequestStatus(ctx context.Context, req *GetRequestStatusRequest) (*GetRequestStatusResponse, error)