Versions in this module Expand all Collapse all v0 v0.3.3 Jun 4, 2024 v0.3.1 Mar 5, 2024 Changes in this version + var KitexUnusedProtection = struct{} + type Request struct + Message string + var TestServiceEchoArgs_Req_DEFAULT *Request + var TestServiceEchoClientArgs_Req_DEFAULT *Request + var TestServiceEchoPingPongArgs_Req_DEFAULT *Request + var TestServiceEchoServerArgs_Req_DEFAULT *Request + var TestServiceEchoUnaryArgs_Req_DEFAULT *Request + func NewRequest() *Request + func (p *Request) BLength() int + func (p *Request) DeepEqual(ano *Request) bool + func (p *Request) FastRead(buf []byte) (int, error) + func (p *Request) FastReadField1(buf []byte) (int, error) + func (p *Request) FastWrite(buf []byte) int + func (p *Request) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int + func (p *Request) Field1DeepEqual(src string) bool + func (p *Request) GetMessage() (v string) + func (p *Request) InitDefault() + func (p *Request) Read(iprot thrift.TProtocol) (err error) + func (p *Request) ReadField1(iprot thrift.TProtocol) error + func (p *Request) SetMessage(val string) + func (p *Request) String() string + func (p *Request) Write(oprot thrift.TProtocol) (err error) + type Response struct + Message string + var TestServiceEchoClientResult_Success_DEFAULT *Response + var TestServiceEchoPingPongResult_Success_DEFAULT *Response + var TestServiceEchoResult_Success_DEFAULT *Response + var TestServiceEchoServerResult_Success_DEFAULT *Response + var TestServiceEchoUnaryResult_Success_DEFAULT *Response + func NewResponse() *Response + func (p *Response) BLength() int + func (p *Response) DeepEqual(ano *Response) bool + func (p *Response) FastRead(buf []byte) (int, error) + func (p *Response) FastReadField1(buf []byte) (int, error) + func (p *Response) FastWrite(buf []byte) int + func (p *Response) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int + func (p *Response) Field1DeepEqual(src string) bool + func (p *Response) GetMessage() (v string) + func (p *Response) InitDefault() + func (p *Response) Read(iprot thrift.TProtocol) (err error) + func (p *Response) ReadField1(iprot thrift.TProtocol) error + func (p *Response) SetMessage(val string) + func (p *Response) String() string + func (p *Response) Write(oprot thrift.TProtocol) (err error) + type TestService interface + Echo func(stream TestService_EchoServer) (err error) + EchoClient func(stream TestService_EchoClientServer) (err error) + EchoPingPong func(ctx context.Context, req *Request) (r *Response, err error) + EchoServer func(req *Request, stream TestService_EchoServerServer) (err error) + EchoUnary func(ctx context.Context, req *Request) (r *Response, err error) + type TestServiceClient struct + func NewTestServiceClient(c thrift.TClient) *TestServiceClient + func NewTestServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *TestServiceClient + func NewTestServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *TestServiceClient + func (p *TestServiceClient) Client_() thrift.TClient + func (p *TestServiceClient) Echo(stream TestService_EchoServer) (err error) + func (p *TestServiceClient) EchoClient(stream TestService_EchoClientServer) (err error) + func (p *TestServiceClient) EchoPingPong(ctx context.Context, req *Request) (r *Response, err error) + func (p *TestServiceClient) EchoServer(req *Request, stream TestService_EchoServerServer) (err error) + func (p *TestServiceClient) EchoUnary(ctx context.Context, req *Request) (r *Response, err error) + type TestServiceEchoArgs struct + Req *Request + func NewTestServiceEchoArgs() *TestServiceEchoArgs + func (p *TestServiceEchoArgs) BLength() int + func (p *TestServiceEchoArgs) DeepEqual(ano *TestServiceEchoArgs) bool + func (p *TestServiceEchoArgs) FastRead(buf []byte) (int, error) + func (p *TestServiceEchoArgs) FastReadField1(buf []byte) (int, error) + func (p *TestServiceEchoArgs) FastWrite(buf []byte) int + func (p *TestServiceEchoArgs) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int + func (p *TestServiceEchoArgs) Field1DeepEqual(src *Request) bool + func (p *TestServiceEchoArgs) GetFirstArgument() interface{} + func (p *TestServiceEchoArgs) GetReq() (v *Request) + func (p *TestServiceEchoArgs) InitDefault() + func (p *TestServiceEchoArgs) IsSetReq() bool + func (p *TestServiceEchoArgs) Read(iprot thrift.TProtocol) (err error) + func (p *TestServiceEchoArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TestServiceEchoArgs) SetReq(val *Request) + func (p *TestServiceEchoArgs) String() string + func (p *TestServiceEchoArgs) Write(oprot thrift.TProtocol) (err error) + type TestServiceEchoClientArgs struct + Req *Request + func NewTestServiceEchoClientArgs() *TestServiceEchoClientArgs + func (p *TestServiceEchoClientArgs) BLength() int + func (p *TestServiceEchoClientArgs) DeepEqual(ano *TestServiceEchoClientArgs) bool + func (p *TestServiceEchoClientArgs) FastRead(buf []byte) (int, error) + func (p *TestServiceEchoClientArgs) FastReadField1(buf []byte) (int, error) + func (p *TestServiceEchoClientArgs) FastWrite(buf []byte) int + func (p *TestServiceEchoClientArgs) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int + func (p *TestServiceEchoClientArgs) Field1DeepEqual(src *Request) bool + func (p *TestServiceEchoClientArgs) GetFirstArgument() interface{} + func (p *TestServiceEchoClientArgs) GetReq() (v *Request) + func (p *TestServiceEchoClientArgs) InitDefault() + func (p *TestServiceEchoClientArgs) IsSetReq() bool + func (p *TestServiceEchoClientArgs) Read(iprot thrift.TProtocol) (err error) + func (p *TestServiceEchoClientArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TestServiceEchoClientArgs) SetReq(val *Request) + func (p *TestServiceEchoClientArgs) String() string + func (p *TestServiceEchoClientArgs) Write(oprot thrift.TProtocol) (err error) + type TestServiceEchoClientResult struct + Success *Response + func NewTestServiceEchoClientResult() *TestServiceEchoClientResult + func (p *TestServiceEchoClientResult) BLength() int + func (p *TestServiceEchoClientResult) DeepEqual(ano *TestServiceEchoClientResult) bool + func (p *TestServiceEchoClientResult) FastRead(buf []byte) (int, error) + func (p *TestServiceEchoClientResult) FastReadField0(buf []byte) (int, error) + func (p *TestServiceEchoClientResult) FastWrite(buf []byte) int + func (p *TestServiceEchoClientResult) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int + func (p *TestServiceEchoClientResult) Field0DeepEqual(src *Response) bool + func (p *TestServiceEchoClientResult) GetResult() interface{} + func (p *TestServiceEchoClientResult) GetSuccess() (v *Response) + func (p *TestServiceEchoClientResult) InitDefault() + func (p *TestServiceEchoClientResult) IsSetSuccess() bool + func (p *TestServiceEchoClientResult) Read(iprot thrift.TProtocol) (err error) + func (p *TestServiceEchoClientResult) ReadField0(iprot thrift.TProtocol) error + func (p *TestServiceEchoClientResult) SetSuccess(x interface{}) + func (p *TestServiceEchoClientResult) String() string + func (p *TestServiceEchoClientResult) Write(oprot thrift.TProtocol) (err error) + type TestServiceEchoPingPongArgs struct + Req *Request + func NewTestServiceEchoPingPongArgs() *TestServiceEchoPingPongArgs + func (p *TestServiceEchoPingPongArgs) BLength() int + func (p *TestServiceEchoPingPongArgs) DeepEqual(ano *TestServiceEchoPingPongArgs) bool + func (p *TestServiceEchoPingPongArgs) FastRead(buf []byte) (int, error) + func (p *TestServiceEchoPingPongArgs) FastReadField1(buf []byte) (int, error) + func (p *TestServiceEchoPingPongArgs) FastWrite(buf []byte) int + func (p *TestServiceEchoPingPongArgs) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int + func (p *TestServiceEchoPingPongArgs) Field1DeepEqual(src *Request) bool + func (p *TestServiceEchoPingPongArgs) GetFirstArgument() interface{} + func (p *TestServiceEchoPingPongArgs) GetReq() (v *Request) + func (p *TestServiceEchoPingPongArgs) InitDefault() + func (p *TestServiceEchoPingPongArgs) IsSetReq() bool + func (p *TestServiceEchoPingPongArgs) Read(iprot thrift.TProtocol) (err error) + func (p *TestServiceEchoPingPongArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TestServiceEchoPingPongArgs) SetReq(val *Request) + func (p *TestServiceEchoPingPongArgs) String() string + func (p *TestServiceEchoPingPongArgs) Write(oprot thrift.TProtocol) (err error) + type TestServiceEchoPingPongResult struct + Success *Response + func NewTestServiceEchoPingPongResult() *TestServiceEchoPingPongResult + func (p *TestServiceEchoPingPongResult) BLength() int + func (p *TestServiceEchoPingPongResult) DeepEqual(ano *TestServiceEchoPingPongResult) bool + func (p *TestServiceEchoPingPongResult) FastRead(buf []byte) (int, error) + func (p *TestServiceEchoPingPongResult) FastReadField0(buf []byte) (int, error) + func (p *TestServiceEchoPingPongResult) FastWrite(buf []byte) int + func (p *TestServiceEchoPingPongResult) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int + func (p *TestServiceEchoPingPongResult) Field0DeepEqual(src *Response) bool + func (p *TestServiceEchoPingPongResult) GetResult() interface{} + func (p *TestServiceEchoPingPongResult) GetSuccess() (v *Response) + func (p *TestServiceEchoPingPongResult) InitDefault() + func (p *TestServiceEchoPingPongResult) IsSetSuccess() bool + func (p *TestServiceEchoPingPongResult) Read(iprot thrift.TProtocol) (err error) + func (p *TestServiceEchoPingPongResult) ReadField0(iprot thrift.TProtocol) error + func (p *TestServiceEchoPingPongResult) SetSuccess(x interface{}) + func (p *TestServiceEchoPingPongResult) String() string + func (p *TestServiceEchoPingPongResult) Write(oprot thrift.TProtocol) (err error) + type TestServiceEchoResult struct + Success *Response + func NewTestServiceEchoResult() *TestServiceEchoResult + func (p *TestServiceEchoResult) BLength() int + func (p *TestServiceEchoResult) DeepEqual(ano *TestServiceEchoResult) bool + func (p *TestServiceEchoResult) FastRead(buf []byte) (int, error) + func (p *TestServiceEchoResult) FastReadField0(buf []byte) (int, error) + func (p *TestServiceEchoResult) FastWrite(buf []byte) int + func (p *TestServiceEchoResult) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int + func (p *TestServiceEchoResult) Field0DeepEqual(src *Response) bool + func (p *TestServiceEchoResult) GetResult() interface{} + func (p *TestServiceEchoResult) GetSuccess() (v *Response) + func (p *TestServiceEchoResult) InitDefault() + func (p *TestServiceEchoResult) IsSetSuccess() bool + func (p *TestServiceEchoResult) Read(iprot thrift.TProtocol) (err error) + func (p *TestServiceEchoResult) ReadField0(iprot thrift.TProtocol) error + func (p *TestServiceEchoResult) SetSuccess(x interface{}) + func (p *TestServiceEchoResult) String() string + func (p *TestServiceEchoResult) Write(oprot thrift.TProtocol) (err error) + type TestServiceEchoServerArgs struct + Req *Request + func NewTestServiceEchoServerArgs() *TestServiceEchoServerArgs + func (p *TestServiceEchoServerArgs) BLength() int + func (p *TestServiceEchoServerArgs) DeepEqual(ano *TestServiceEchoServerArgs) bool + func (p *TestServiceEchoServerArgs) FastRead(buf []byte) (int, error) + func (p *TestServiceEchoServerArgs) FastReadField1(buf []byte) (int, error) + func (p *TestServiceEchoServerArgs) FastWrite(buf []byte) int + func (p *TestServiceEchoServerArgs) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int + func (p *TestServiceEchoServerArgs) Field1DeepEqual(src *Request) bool + func (p *TestServiceEchoServerArgs) GetFirstArgument() interface{} + func (p *TestServiceEchoServerArgs) GetReq() (v *Request) + func (p *TestServiceEchoServerArgs) InitDefault() + func (p *TestServiceEchoServerArgs) IsSetReq() bool + func (p *TestServiceEchoServerArgs) Read(iprot thrift.TProtocol) (err error) + func (p *TestServiceEchoServerArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TestServiceEchoServerArgs) SetReq(val *Request) + func (p *TestServiceEchoServerArgs) String() string + func (p *TestServiceEchoServerArgs) Write(oprot thrift.TProtocol) (err error) + type TestServiceEchoServerResult struct + Success *Response + func NewTestServiceEchoServerResult() *TestServiceEchoServerResult + func (p *TestServiceEchoServerResult) BLength() int + func (p *TestServiceEchoServerResult) DeepEqual(ano *TestServiceEchoServerResult) bool + func (p *TestServiceEchoServerResult) FastRead(buf []byte) (int, error) + func (p *TestServiceEchoServerResult) FastReadField0(buf []byte) (int, error) + func (p *TestServiceEchoServerResult) FastWrite(buf []byte) int + func (p *TestServiceEchoServerResult) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int + func (p *TestServiceEchoServerResult) Field0DeepEqual(src *Response) bool + func (p *TestServiceEchoServerResult) GetResult() interface{} + func (p *TestServiceEchoServerResult) GetSuccess() (v *Response) + func (p *TestServiceEchoServerResult) InitDefault() + func (p *TestServiceEchoServerResult) IsSetSuccess() bool + func (p *TestServiceEchoServerResult) Read(iprot thrift.TProtocol) (err error) + func (p *TestServiceEchoServerResult) ReadField0(iprot thrift.TProtocol) error + func (p *TestServiceEchoServerResult) SetSuccess(x interface{}) + func (p *TestServiceEchoServerResult) String() string + func (p *TestServiceEchoServerResult) Write(oprot thrift.TProtocol) (err error) + type TestServiceEchoUnaryArgs struct + Req *Request + func NewTestServiceEchoUnaryArgs() *TestServiceEchoUnaryArgs + func (p *TestServiceEchoUnaryArgs) BLength() int + func (p *TestServiceEchoUnaryArgs) DeepEqual(ano *TestServiceEchoUnaryArgs) bool + func (p *TestServiceEchoUnaryArgs) FastRead(buf []byte) (int, error) + func (p *TestServiceEchoUnaryArgs) FastReadField1(buf []byte) (int, error) + func (p *TestServiceEchoUnaryArgs) FastWrite(buf []byte) int + func (p *TestServiceEchoUnaryArgs) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int + func (p *TestServiceEchoUnaryArgs) Field1DeepEqual(src *Request) bool + func (p *TestServiceEchoUnaryArgs) GetFirstArgument() interface{} + func (p *TestServiceEchoUnaryArgs) GetReq() (v *Request) + func (p *TestServiceEchoUnaryArgs) InitDefault() + func (p *TestServiceEchoUnaryArgs) IsSetReq() bool + func (p *TestServiceEchoUnaryArgs) Read(iprot thrift.TProtocol) (err error) + func (p *TestServiceEchoUnaryArgs) ReadField1(iprot thrift.TProtocol) error + func (p *TestServiceEchoUnaryArgs) SetReq(val *Request) + func (p *TestServiceEchoUnaryArgs) String() string + func (p *TestServiceEchoUnaryArgs) Write(oprot thrift.TProtocol) (err error) + type TestServiceEchoUnaryResult struct + Success *Response + func NewTestServiceEchoUnaryResult() *TestServiceEchoUnaryResult + func (p *TestServiceEchoUnaryResult) BLength() int + func (p *TestServiceEchoUnaryResult) DeepEqual(ano *TestServiceEchoUnaryResult) bool + func (p *TestServiceEchoUnaryResult) FastRead(buf []byte) (int, error) + func (p *TestServiceEchoUnaryResult) FastReadField0(buf []byte) (int, error) + func (p *TestServiceEchoUnaryResult) FastWrite(buf []byte) int + func (p *TestServiceEchoUnaryResult) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int + func (p *TestServiceEchoUnaryResult) Field0DeepEqual(src *Response) bool + func (p *TestServiceEchoUnaryResult) GetResult() interface{} + func (p *TestServiceEchoUnaryResult) GetSuccess() (v *Response) + func (p *TestServiceEchoUnaryResult) InitDefault() + func (p *TestServiceEchoUnaryResult) IsSetSuccess() bool + func (p *TestServiceEchoUnaryResult) Read(iprot thrift.TProtocol) (err error) + func (p *TestServiceEchoUnaryResult) ReadField0(iprot thrift.TProtocol) error + func (p *TestServiceEchoUnaryResult) SetSuccess(x interface{}) + func (p *TestServiceEchoUnaryResult) String() string + func (p *TestServiceEchoUnaryResult) Write(oprot thrift.TProtocol) (err error) + type TestServiceProcessor struct + func NewTestServiceProcessor(handler TestService) *TestServiceProcessor + func (p *TestServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction) + func (p *TestServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool) + func (p *TestServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) + func (p *TestServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction + type TestService_EchoClientServer interface + Recv func() (*Request, error) + SendAndClose func(*Response) error + type TestService_EchoServer interface + Recv func() (*Request, error) + Send func(*Response) error + type TestService_EchoServerServer interface + Send func(*Response) error