echo

package
v0.3.3 Latest Latest
Warning

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

Go to latest
Published: Jun 4, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var KitexUnusedProtection = struct{}{}

KitexUnusedProtection is used to prevent 'imported and not used' error.

Functions

This section is empty.

Types

type Request

type Request struct {
	Message string `thrift:"message,1,required" frugal:"1,required,string" json:"message"`
}
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

func NewRequest() *Request

func (*Request) BLength

func (p *Request) BLength() int

func (*Request) DeepEqual

func (p *Request) DeepEqual(ano *Request) bool

func (*Request) FastRead

func (p *Request) FastRead(buf []byte) (int, error)

func (*Request) FastReadField1

func (p *Request) FastReadField1(buf []byte) (int, error)

func (*Request) FastWrite

func (p *Request) FastWrite(buf []byte) int

for compatibility

func (*Request) FastWriteNocopy

func (p *Request) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*Request) Field1DeepEqual

func (p *Request) Field1DeepEqual(src string) bool

func (*Request) GetMessage

func (p *Request) GetMessage() (v string)

func (*Request) InitDefault

func (p *Request) InitDefault()

func (*Request) Read

func (p *Request) Read(iprot thrift.TProtocol) (err error)

func (*Request) ReadField1

func (p *Request) ReadField1(iprot thrift.TProtocol) error

func (*Request) SetMessage

func (p *Request) SetMessage(val string)

func (*Request) String

func (p *Request) String() string

func (*Request) Write

func (p *Request) Write(oprot thrift.TProtocol) (err error)

type Response

type Response struct {
	Message string `thrift:"message,1,required" frugal:"1,required,string" json:"message"`
}
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

func NewResponse() *Response

func (*Response) BLength

func (p *Response) BLength() int

func (*Response) DeepEqual

func (p *Response) DeepEqual(ano *Response) bool

func (*Response) FastRead

func (p *Response) FastRead(buf []byte) (int, error)

func (*Response) FastReadField1

func (p *Response) FastReadField1(buf []byte) (int, error)

func (*Response) FastWrite

func (p *Response) FastWrite(buf []byte) int

for compatibility

func (*Response) FastWriteNocopy

func (p *Response) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*Response) Field1DeepEqual

func (p *Response) Field1DeepEqual(src string) bool

func (*Response) GetMessage

func (p *Response) GetMessage() (v string)

func (*Response) InitDefault

func (p *Response) InitDefault()

func (*Response) Read

func (p *Response) Read(iprot thrift.TProtocol) (err error)

func (*Response) ReadField1

func (p *Response) ReadField1(iprot thrift.TProtocol) error

func (*Response) SetMessage

func (p *Response) SetMessage(val string)

func (*Response) String

func (p *Response) String() string

func (*Response) Write

func (p *Response) Write(oprot thrift.TProtocol) (err error)

type TestService

type TestService interface {
	Echo(stream TestService_EchoServer) (err error)

	EchoClient(stream TestService_EchoClientServer) (err error)

	EchoServer(req *Request, stream TestService_EchoServerServer) (err error)

	EchoUnary(ctx context.Context, req *Request) (r *Response, err error)

	EchoPingPong(ctx context.Context, req *Request) (r *Response, err error)
}

type TestServiceClient

type TestServiceClient struct {
	// contains filtered or unexported fields
}

func NewTestServiceClient

func NewTestServiceClient(c thrift.TClient) *TestServiceClient

func NewTestServiceClientProtocol

func NewTestServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *TestServiceClient

func (*TestServiceClient) Client_

func (p *TestServiceClient) Client_() thrift.TClient

func (*TestServiceClient) Echo

func (p *TestServiceClient) Echo(stream TestService_EchoServer) (err error)

func (*TestServiceClient) EchoClient

func (p *TestServiceClient) EchoClient(stream TestService_EchoClientServer) (err error)

func (*TestServiceClient) EchoPingPong

func (p *TestServiceClient) EchoPingPong(ctx context.Context, req *Request) (r *Response, err error)

func (*TestServiceClient) EchoServer

func (p *TestServiceClient) EchoServer(req *Request, stream TestService_EchoServerServer) (err error)

func (*TestServiceClient) EchoUnary

func (p *TestServiceClient) EchoUnary(ctx context.Context, req *Request) (r *Response, err error)

type TestServiceEchoArgs

type TestServiceEchoArgs struct {
	Req *Request `thrift:"req,1" frugal:"1,default,Request" json:"req"`
}

func NewTestServiceEchoArgs

func NewTestServiceEchoArgs() *TestServiceEchoArgs

func (*TestServiceEchoArgs) BLength

func (p *TestServiceEchoArgs) BLength() int

func (*TestServiceEchoArgs) DeepEqual

func (p *TestServiceEchoArgs) DeepEqual(ano *TestServiceEchoArgs) bool

func (*TestServiceEchoArgs) FastRead

func (p *TestServiceEchoArgs) FastRead(buf []byte) (int, error)

func (*TestServiceEchoArgs) FastReadField1

func (p *TestServiceEchoArgs) FastReadField1(buf []byte) (int, error)

func (*TestServiceEchoArgs) FastWrite

func (p *TestServiceEchoArgs) FastWrite(buf []byte) int

for compatibility

func (*TestServiceEchoArgs) FastWriteNocopy

func (p *TestServiceEchoArgs) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*TestServiceEchoArgs) Field1DeepEqual

func (p *TestServiceEchoArgs) Field1DeepEqual(src *Request) bool

func (*TestServiceEchoArgs) GetFirstArgument

func (p *TestServiceEchoArgs) GetFirstArgument() interface{}

func (*TestServiceEchoArgs) GetReq

func (p *TestServiceEchoArgs) GetReq() (v *Request)

func (*TestServiceEchoArgs) InitDefault

func (p *TestServiceEchoArgs) InitDefault()

func (*TestServiceEchoArgs) IsSetReq

func (p *TestServiceEchoArgs) IsSetReq() bool

func (*TestServiceEchoArgs) Read

func (p *TestServiceEchoArgs) Read(iprot thrift.TProtocol) (err error)

func (*TestServiceEchoArgs) ReadField1

func (p *TestServiceEchoArgs) ReadField1(iprot thrift.TProtocol) error

func (*TestServiceEchoArgs) SetReq

func (p *TestServiceEchoArgs) SetReq(val *Request)

func (*TestServiceEchoArgs) String

func (p *TestServiceEchoArgs) String() string

func (*TestServiceEchoArgs) Write

func (p *TestServiceEchoArgs) Write(oprot thrift.TProtocol) (err error)

type TestServiceEchoClientArgs

type TestServiceEchoClientArgs struct {
	Req *Request `thrift:"req,1" frugal:"1,default,Request" json:"req"`
}

func NewTestServiceEchoClientArgs

func NewTestServiceEchoClientArgs() *TestServiceEchoClientArgs

func (*TestServiceEchoClientArgs) BLength

func (p *TestServiceEchoClientArgs) BLength() int

func (*TestServiceEchoClientArgs) DeepEqual

func (*TestServiceEchoClientArgs) FastRead

func (p *TestServiceEchoClientArgs) FastRead(buf []byte) (int, error)

func (*TestServiceEchoClientArgs) FastReadField1

func (p *TestServiceEchoClientArgs) FastReadField1(buf []byte) (int, error)

func (*TestServiceEchoClientArgs) FastWrite

func (p *TestServiceEchoClientArgs) FastWrite(buf []byte) int

for compatibility

func (*TestServiceEchoClientArgs) FastWriteNocopy

func (p *TestServiceEchoClientArgs) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*TestServiceEchoClientArgs) Field1DeepEqual

func (p *TestServiceEchoClientArgs) Field1DeepEqual(src *Request) bool

func (*TestServiceEchoClientArgs) GetFirstArgument

func (p *TestServiceEchoClientArgs) GetFirstArgument() interface{}

func (*TestServiceEchoClientArgs) GetReq

func (p *TestServiceEchoClientArgs) GetReq() (v *Request)

func (*TestServiceEchoClientArgs) InitDefault

func (p *TestServiceEchoClientArgs) InitDefault()

func (*TestServiceEchoClientArgs) IsSetReq

func (p *TestServiceEchoClientArgs) IsSetReq() bool

func (*TestServiceEchoClientArgs) Read

func (p *TestServiceEchoClientArgs) Read(iprot thrift.TProtocol) (err error)

func (*TestServiceEchoClientArgs) ReadField1

func (p *TestServiceEchoClientArgs) ReadField1(iprot thrift.TProtocol) error

func (*TestServiceEchoClientArgs) SetReq

func (p *TestServiceEchoClientArgs) SetReq(val *Request)

func (*TestServiceEchoClientArgs) String

func (p *TestServiceEchoClientArgs) String() string

func (*TestServiceEchoClientArgs) Write

func (p *TestServiceEchoClientArgs) Write(oprot thrift.TProtocol) (err error)

type TestServiceEchoClientResult

type TestServiceEchoClientResult struct {
	Success *Response `thrift:"success,0,optional" frugal:"0,optional,Response" json:"success,omitempty"`
}

func NewTestServiceEchoClientResult

func NewTestServiceEchoClientResult() *TestServiceEchoClientResult

func (*TestServiceEchoClientResult) BLength

func (p *TestServiceEchoClientResult) BLength() int

func (*TestServiceEchoClientResult) DeepEqual

func (*TestServiceEchoClientResult) FastRead

func (p *TestServiceEchoClientResult) FastRead(buf []byte) (int, error)

func (*TestServiceEchoClientResult) FastReadField0

func (p *TestServiceEchoClientResult) FastReadField0(buf []byte) (int, error)

func (*TestServiceEchoClientResult) FastWrite

func (p *TestServiceEchoClientResult) FastWrite(buf []byte) int

for compatibility

func (*TestServiceEchoClientResult) FastWriteNocopy

func (p *TestServiceEchoClientResult) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*TestServiceEchoClientResult) Field0DeepEqual

func (p *TestServiceEchoClientResult) Field0DeepEqual(src *Response) bool

func (*TestServiceEchoClientResult) GetResult

func (p *TestServiceEchoClientResult) GetResult() interface{}

func (*TestServiceEchoClientResult) GetSuccess

func (p *TestServiceEchoClientResult) GetSuccess() (v *Response)

func (*TestServiceEchoClientResult) InitDefault

func (p *TestServiceEchoClientResult) InitDefault()

func (*TestServiceEchoClientResult) IsSetSuccess

func (p *TestServiceEchoClientResult) IsSetSuccess() bool

func (*TestServiceEchoClientResult) Read

func (p *TestServiceEchoClientResult) Read(iprot thrift.TProtocol) (err error)

func (*TestServiceEchoClientResult) ReadField0

func (p *TestServiceEchoClientResult) ReadField0(iprot thrift.TProtocol) error

func (*TestServiceEchoClientResult) SetSuccess

func (p *TestServiceEchoClientResult) SetSuccess(x interface{})

func (*TestServiceEchoClientResult) String

func (p *TestServiceEchoClientResult) String() string

func (*TestServiceEchoClientResult) Write

func (p *TestServiceEchoClientResult) Write(oprot thrift.TProtocol) (err error)

type TestServiceEchoPingPongArgs

type TestServiceEchoPingPongArgs struct {
	Req *Request `thrift:"req,1" frugal:"1,default,Request" json:"req"`
}

func NewTestServiceEchoPingPongArgs

func NewTestServiceEchoPingPongArgs() *TestServiceEchoPingPongArgs

func (*TestServiceEchoPingPongArgs) BLength

func (p *TestServiceEchoPingPongArgs) BLength() int

func (*TestServiceEchoPingPongArgs) DeepEqual

func (*TestServiceEchoPingPongArgs) FastRead

func (p *TestServiceEchoPingPongArgs) FastRead(buf []byte) (int, error)

func (*TestServiceEchoPingPongArgs) FastReadField1

func (p *TestServiceEchoPingPongArgs) FastReadField1(buf []byte) (int, error)

func (*TestServiceEchoPingPongArgs) FastWrite

func (p *TestServiceEchoPingPongArgs) FastWrite(buf []byte) int

for compatibility

func (*TestServiceEchoPingPongArgs) FastWriteNocopy

func (p *TestServiceEchoPingPongArgs) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*TestServiceEchoPingPongArgs) Field1DeepEqual

func (p *TestServiceEchoPingPongArgs) Field1DeepEqual(src *Request) bool

func (*TestServiceEchoPingPongArgs) GetFirstArgument

func (p *TestServiceEchoPingPongArgs) GetFirstArgument() interface{}

func (*TestServiceEchoPingPongArgs) GetReq

func (p *TestServiceEchoPingPongArgs) GetReq() (v *Request)

func (*TestServiceEchoPingPongArgs) InitDefault

func (p *TestServiceEchoPingPongArgs) InitDefault()

func (*TestServiceEchoPingPongArgs) IsSetReq

func (p *TestServiceEchoPingPongArgs) IsSetReq() bool

func (*TestServiceEchoPingPongArgs) Read

func (p *TestServiceEchoPingPongArgs) Read(iprot thrift.TProtocol) (err error)

func (*TestServiceEchoPingPongArgs) ReadField1

func (p *TestServiceEchoPingPongArgs) ReadField1(iprot thrift.TProtocol) error

func (*TestServiceEchoPingPongArgs) SetReq

func (p *TestServiceEchoPingPongArgs) SetReq(val *Request)

func (*TestServiceEchoPingPongArgs) String

func (p *TestServiceEchoPingPongArgs) String() string

func (*TestServiceEchoPingPongArgs) Write

func (p *TestServiceEchoPingPongArgs) Write(oprot thrift.TProtocol) (err error)

type TestServiceEchoPingPongResult

type TestServiceEchoPingPongResult struct {
	Success *Response `thrift:"success,0,optional" frugal:"0,optional,Response" json:"success,omitempty"`
}

func NewTestServiceEchoPingPongResult

func NewTestServiceEchoPingPongResult() *TestServiceEchoPingPongResult

func (*TestServiceEchoPingPongResult) BLength

func (p *TestServiceEchoPingPongResult) BLength() int

func (*TestServiceEchoPingPongResult) DeepEqual

func (*TestServiceEchoPingPongResult) FastRead

func (p *TestServiceEchoPingPongResult) FastRead(buf []byte) (int, error)

func (*TestServiceEchoPingPongResult) FastReadField0

func (p *TestServiceEchoPingPongResult) FastReadField0(buf []byte) (int, error)

func (*TestServiceEchoPingPongResult) FastWrite

func (p *TestServiceEchoPingPongResult) FastWrite(buf []byte) int

for compatibility

func (*TestServiceEchoPingPongResult) FastWriteNocopy

func (p *TestServiceEchoPingPongResult) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*TestServiceEchoPingPongResult) Field0DeepEqual

func (p *TestServiceEchoPingPongResult) Field0DeepEqual(src *Response) bool

func (*TestServiceEchoPingPongResult) GetResult

func (p *TestServiceEchoPingPongResult) GetResult() interface{}

func (*TestServiceEchoPingPongResult) GetSuccess

func (p *TestServiceEchoPingPongResult) GetSuccess() (v *Response)

func (*TestServiceEchoPingPongResult) InitDefault

func (p *TestServiceEchoPingPongResult) InitDefault()

func (*TestServiceEchoPingPongResult) IsSetSuccess

func (p *TestServiceEchoPingPongResult) IsSetSuccess() bool

func (*TestServiceEchoPingPongResult) Read

func (p *TestServiceEchoPingPongResult) Read(iprot thrift.TProtocol) (err error)

func (*TestServiceEchoPingPongResult) ReadField0

func (p *TestServiceEchoPingPongResult) ReadField0(iprot thrift.TProtocol) error

func (*TestServiceEchoPingPongResult) SetSuccess

func (p *TestServiceEchoPingPongResult) SetSuccess(x interface{})

func (*TestServiceEchoPingPongResult) String

func (*TestServiceEchoPingPongResult) Write

func (p *TestServiceEchoPingPongResult) Write(oprot thrift.TProtocol) (err error)

type TestServiceEchoResult

type TestServiceEchoResult struct {
	Success *Response `thrift:"success,0,optional" frugal:"0,optional,Response" json:"success,omitempty"`
}

func NewTestServiceEchoResult

func NewTestServiceEchoResult() *TestServiceEchoResult

func (*TestServiceEchoResult) BLength

func (p *TestServiceEchoResult) BLength() int

func (*TestServiceEchoResult) DeepEqual

func (*TestServiceEchoResult) FastRead

func (p *TestServiceEchoResult) FastRead(buf []byte) (int, error)

func (*TestServiceEchoResult) FastReadField0

func (p *TestServiceEchoResult) FastReadField0(buf []byte) (int, error)

func (*TestServiceEchoResult) FastWrite

func (p *TestServiceEchoResult) FastWrite(buf []byte) int

for compatibility

func (*TestServiceEchoResult) FastWriteNocopy

func (p *TestServiceEchoResult) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*TestServiceEchoResult) Field0DeepEqual

func (p *TestServiceEchoResult) Field0DeepEqual(src *Response) bool

func (*TestServiceEchoResult) GetResult

func (p *TestServiceEchoResult) GetResult() interface{}

func (*TestServiceEchoResult) GetSuccess

func (p *TestServiceEchoResult) GetSuccess() (v *Response)

func (*TestServiceEchoResult) InitDefault

func (p *TestServiceEchoResult) InitDefault()

func (*TestServiceEchoResult) IsSetSuccess

func (p *TestServiceEchoResult) IsSetSuccess() bool

func (*TestServiceEchoResult) Read

func (p *TestServiceEchoResult) Read(iprot thrift.TProtocol) (err error)

func (*TestServiceEchoResult) ReadField0

func (p *TestServiceEchoResult) ReadField0(iprot thrift.TProtocol) error

func (*TestServiceEchoResult) SetSuccess

func (p *TestServiceEchoResult) SetSuccess(x interface{})

func (*TestServiceEchoResult) String

func (p *TestServiceEchoResult) String() string

func (*TestServiceEchoResult) Write

func (p *TestServiceEchoResult) Write(oprot thrift.TProtocol) (err error)

type TestServiceEchoServerArgs

type TestServiceEchoServerArgs struct {
	Req *Request `thrift:"req,1" frugal:"1,default,Request" json:"req"`
}

func NewTestServiceEchoServerArgs

func NewTestServiceEchoServerArgs() *TestServiceEchoServerArgs

func (*TestServiceEchoServerArgs) BLength

func (p *TestServiceEchoServerArgs) BLength() int

func (*TestServiceEchoServerArgs) DeepEqual

func (*TestServiceEchoServerArgs) FastRead

func (p *TestServiceEchoServerArgs) FastRead(buf []byte) (int, error)

func (*TestServiceEchoServerArgs) FastReadField1

func (p *TestServiceEchoServerArgs) FastReadField1(buf []byte) (int, error)

func (*TestServiceEchoServerArgs) FastWrite

func (p *TestServiceEchoServerArgs) FastWrite(buf []byte) int

for compatibility

func (*TestServiceEchoServerArgs) FastWriteNocopy

func (p *TestServiceEchoServerArgs) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*TestServiceEchoServerArgs) Field1DeepEqual

func (p *TestServiceEchoServerArgs) Field1DeepEqual(src *Request) bool

func (*TestServiceEchoServerArgs) GetFirstArgument

func (p *TestServiceEchoServerArgs) GetFirstArgument() interface{}

func (*TestServiceEchoServerArgs) GetReq

func (p *TestServiceEchoServerArgs) GetReq() (v *Request)

func (*TestServiceEchoServerArgs) InitDefault

func (p *TestServiceEchoServerArgs) InitDefault()

func (*TestServiceEchoServerArgs) IsSetReq

func (p *TestServiceEchoServerArgs) IsSetReq() bool

func (*TestServiceEchoServerArgs) Read

func (p *TestServiceEchoServerArgs) Read(iprot thrift.TProtocol) (err error)

func (*TestServiceEchoServerArgs) ReadField1

func (p *TestServiceEchoServerArgs) ReadField1(iprot thrift.TProtocol) error

func (*TestServiceEchoServerArgs) SetReq

func (p *TestServiceEchoServerArgs) SetReq(val *Request)

func (*TestServiceEchoServerArgs) String

func (p *TestServiceEchoServerArgs) String() string

func (*TestServiceEchoServerArgs) Write

func (p *TestServiceEchoServerArgs) Write(oprot thrift.TProtocol) (err error)

type TestServiceEchoServerResult

type TestServiceEchoServerResult struct {
	Success *Response `thrift:"success,0,optional" frugal:"0,optional,Response" json:"success,omitempty"`
}

func NewTestServiceEchoServerResult

func NewTestServiceEchoServerResult() *TestServiceEchoServerResult

func (*TestServiceEchoServerResult) BLength

func (p *TestServiceEchoServerResult) BLength() int

func (*TestServiceEchoServerResult) DeepEqual

func (*TestServiceEchoServerResult) FastRead

func (p *TestServiceEchoServerResult) FastRead(buf []byte) (int, error)

func (*TestServiceEchoServerResult) FastReadField0

func (p *TestServiceEchoServerResult) FastReadField0(buf []byte) (int, error)

func (*TestServiceEchoServerResult) FastWrite

func (p *TestServiceEchoServerResult) FastWrite(buf []byte) int

for compatibility

func (*TestServiceEchoServerResult) FastWriteNocopy

func (p *TestServiceEchoServerResult) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*TestServiceEchoServerResult) Field0DeepEqual

func (p *TestServiceEchoServerResult) Field0DeepEqual(src *Response) bool

func (*TestServiceEchoServerResult) GetResult

func (p *TestServiceEchoServerResult) GetResult() interface{}

func (*TestServiceEchoServerResult) GetSuccess

func (p *TestServiceEchoServerResult) GetSuccess() (v *Response)

func (*TestServiceEchoServerResult) InitDefault

func (p *TestServiceEchoServerResult) InitDefault()

func (*TestServiceEchoServerResult) IsSetSuccess

func (p *TestServiceEchoServerResult) IsSetSuccess() bool

func (*TestServiceEchoServerResult) Read

func (p *TestServiceEchoServerResult) Read(iprot thrift.TProtocol) (err error)

func (*TestServiceEchoServerResult) ReadField0

func (p *TestServiceEchoServerResult) ReadField0(iprot thrift.TProtocol) error

func (*TestServiceEchoServerResult) SetSuccess

func (p *TestServiceEchoServerResult) SetSuccess(x interface{})

func (*TestServiceEchoServerResult) String

func (p *TestServiceEchoServerResult) String() string

func (*TestServiceEchoServerResult) Write

func (p *TestServiceEchoServerResult) Write(oprot thrift.TProtocol) (err error)

type TestServiceEchoUnaryArgs

type TestServiceEchoUnaryArgs struct {
	Req *Request `thrift:"req,1" frugal:"1,default,Request" json:"req"`
}

func NewTestServiceEchoUnaryArgs

func NewTestServiceEchoUnaryArgs() *TestServiceEchoUnaryArgs

func (*TestServiceEchoUnaryArgs) BLength

func (p *TestServiceEchoUnaryArgs) BLength() int

func (*TestServiceEchoUnaryArgs) DeepEqual

func (*TestServiceEchoUnaryArgs) FastRead

func (p *TestServiceEchoUnaryArgs) FastRead(buf []byte) (int, error)

func (*TestServiceEchoUnaryArgs) FastReadField1

func (p *TestServiceEchoUnaryArgs) FastReadField1(buf []byte) (int, error)

func (*TestServiceEchoUnaryArgs) FastWrite

func (p *TestServiceEchoUnaryArgs) FastWrite(buf []byte) int

for compatibility

func (*TestServiceEchoUnaryArgs) FastWriteNocopy

func (p *TestServiceEchoUnaryArgs) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*TestServiceEchoUnaryArgs) Field1DeepEqual

func (p *TestServiceEchoUnaryArgs) Field1DeepEqual(src *Request) bool

func (*TestServiceEchoUnaryArgs) GetFirstArgument

func (p *TestServiceEchoUnaryArgs) GetFirstArgument() interface{}

func (*TestServiceEchoUnaryArgs) GetReq

func (p *TestServiceEchoUnaryArgs) GetReq() (v *Request)

func (*TestServiceEchoUnaryArgs) InitDefault

func (p *TestServiceEchoUnaryArgs) InitDefault()

func (*TestServiceEchoUnaryArgs) IsSetReq

func (p *TestServiceEchoUnaryArgs) IsSetReq() bool

func (*TestServiceEchoUnaryArgs) Read

func (p *TestServiceEchoUnaryArgs) Read(iprot thrift.TProtocol) (err error)

func (*TestServiceEchoUnaryArgs) ReadField1

func (p *TestServiceEchoUnaryArgs) ReadField1(iprot thrift.TProtocol) error

func (*TestServiceEchoUnaryArgs) SetReq

func (p *TestServiceEchoUnaryArgs) SetReq(val *Request)

func (*TestServiceEchoUnaryArgs) String

func (p *TestServiceEchoUnaryArgs) String() string

func (*TestServiceEchoUnaryArgs) Write

func (p *TestServiceEchoUnaryArgs) Write(oprot thrift.TProtocol) (err error)

type TestServiceEchoUnaryResult

type TestServiceEchoUnaryResult struct {
	Success *Response `thrift:"success,0,optional" frugal:"0,optional,Response" json:"success,omitempty"`
}

func NewTestServiceEchoUnaryResult

func NewTestServiceEchoUnaryResult() *TestServiceEchoUnaryResult

func (*TestServiceEchoUnaryResult) BLength

func (p *TestServiceEchoUnaryResult) BLength() int

func (*TestServiceEchoUnaryResult) DeepEqual

func (*TestServiceEchoUnaryResult) FastRead

func (p *TestServiceEchoUnaryResult) FastRead(buf []byte) (int, error)

func (*TestServiceEchoUnaryResult) FastReadField0

func (p *TestServiceEchoUnaryResult) FastReadField0(buf []byte) (int, error)

func (*TestServiceEchoUnaryResult) FastWrite

func (p *TestServiceEchoUnaryResult) FastWrite(buf []byte) int

for compatibility

func (*TestServiceEchoUnaryResult) FastWriteNocopy

func (p *TestServiceEchoUnaryResult) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*TestServiceEchoUnaryResult) Field0DeepEqual

func (p *TestServiceEchoUnaryResult) Field0DeepEqual(src *Response) bool

func (*TestServiceEchoUnaryResult) GetResult

func (p *TestServiceEchoUnaryResult) GetResult() interface{}

func (*TestServiceEchoUnaryResult) GetSuccess

func (p *TestServiceEchoUnaryResult) GetSuccess() (v *Response)

func (*TestServiceEchoUnaryResult) InitDefault

func (p *TestServiceEchoUnaryResult) InitDefault()

func (*TestServiceEchoUnaryResult) IsSetSuccess

func (p *TestServiceEchoUnaryResult) IsSetSuccess() bool

func (*TestServiceEchoUnaryResult) Read

func (p *TestServiceEchoUnaryResult) Read(iprot thrift.TProtocol) (err error)

func (*TestServiceEchoUnaryResult) ReadField0

func (p *TestServiceEchoUnaryResult) ReadField0(iprot thrift.TProtocol) error

func (*TestServiceEchoUnaryResult) SetSuccess

func (p *TestServiceEchoUnaryResult) SetSuccess(x interface{})

func (*TestServiceEchoUnaryResult) String

func (p *TestServiceEchoUnaryResult) String() string

func (*TestServiceEchoUnaryResult) Write

func (p *TestServiceEchoUnaryResult) Write(oprot thrift.TProtocol) (err error)

type TestServiceProcessor

type TestServiceProcessor struct {
	// contains filtered or unexported fields
}

func NewTestServiceProcessor

func NewTestServiceProcessor(handler TestService) *TestServiceProcessor

func (*TestServiceProcessor) AddToProcessorMap

func (p *TestServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)

func (*TestServiceProcessor) GetProcessorFunction

func (p *TestServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)

func (*TestServiceProcessor) Process

func (p *TestServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*TestServiceProcessor) ProcessorMap

func (p *TestServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction

type TestService_EchoClientServer

type TestService_EchoClientServer interface {
	streaming.Stream

	Recv() (*Request, error)

	SendAndClose(*Response) error
}

type TestService_EchoServer

type TestService_EchoServer interface {
	streaming.Stream

	Recv() (*Request, error)

	Send(*Response) error
}

type TestService_EchoServerServer

type TestService_EchoServerServer interface {
	streaming.Stream

	Send(*Response) error
}

Directories

Path Synopsis
Code generated by Kitex v0.9.0.
Code generated by Kitex v0.9.0.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL