kitexreflectidl

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Jan 20, 2023 License: MIT Imports: 9 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

func MarshalReflectServiceReqPayload 

func MarshalReflectServiceReqPayload(payload *ReflectServiceReqPayload) ([]byte, error)

MarshalReflectServiceReqPayload encodes a ReflectServiceReqPayload with binary protocol.

func MarshalReflectServiceRespPayload 

func MarshalReflectServiceRespPayload(payload *ReflectServiceRespPayload) ([]byte, error)

MarshalReflectServiceRespPayload encodes a ReflectServiceRespPayload with binary protocol.

Types

type PluginImpl added in v0.4.0 

type PluginImpl struct {
	Version          string
	IsCombineService bool

	GetIDLBytes func() []byte
	// contains filtered or unexported fields
}

func (*PluginImpl) NewMethodInfo added in v0.4.0 

func (p *PluginImpl) NewMethodInfo(method string) serviceinfo.MethodInfo

func (*PluginImpl) NewReflectServiceRespPayload added in v0.5.0 

func (p *PluginImpl) NewReflectServiceRespPayload() *ReflectServiceRespPayload

func (*PluginImpl) ServeReflectServiceRequest added in v0.5.0 

func (p *PluginImpl) ServeReflectServiceRequest(ctx context.Context, req *ReflectServiceRequest, resp *ReflectServiceResponse) error

func (*PluginImpl) SetReflectServiceMiddleware added in v0.5.0 

func (p *PluginImpl) SetReflectServiceMiddleware(mw func(next ReflectServiceHandler) ReflectServiceHandler)

type ReflectServiceHandler added in v0.5.0 

type ReflectServiceHandler func(ctx context.Context, req *ReflectServiceRequest, resp *ReflectServiceResponse) error

type ReflectServiceReqPayload 

type ReflectServiceReqPayload struct {
	ExistingIDLVersion string `thrift:"ExistingIDLVersion,1" frugal:"1,default,string" json:"ExistingIDLVersion"`
}

func NewReflectServiceReqPayload 

func NewReflectServiceReqPayload() *ReflectServiceReqPayload

func UnmarshalReflectServiceReqPayload 

func UnmarshalReflectServiceReqPayload(bs []byte) (*ReflectServiceReqPayload, error)

UnmarshalReflectServiceReqPayload decodes a ReflectServiceReqPayload with binary protocol.

func (*ReflectServiceReqPayload) BLength 

func (p *ReflectServiceReqPayload) BLength() int

func (*ReflectServiceReqPayload) DeepEqual 

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

func (*ReflectServiceReqPayload) FastRead 

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

func (*ReflectServiceReqPayload) FastReadField1 added in v0.3.0 

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

func (*ReflectServiceReqPayload) FastWrite 

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

for compatibility

func (*ReflectServiceReqPayload) FastWriteNocopy 

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

func (*ReflectServiceReqPayload) Field1DeepEqual added in v0.3.0 

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

func (*ReflectServiceReqPayload) GetExistingIDLVersion added in v0.3.1 

func (p *ReflectServiceReqPayload) GetExistingIDLVersion() (v string)

func (*ReflectServiceReqPayload) InitDefault 

func (p *ReflectServiceReqPayload) InitDefault()

func (*ReflectServiceReqPayload) Read 

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

func (*ReflectServiceReqPayload) ReadField1 added in v0.3.0 

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

func (*ReflectServiceReqPayload) SetExistingIDLVersion added in v0.3.1 

func (p *ReflectServiceReqPayload) SetExistingIDLVersion(val string)

func (*ReflectServiceReqPayload) String 

func (p *ReflectServiceReqPayload) String() string

func (*ReflectServiceReqPayload) Write 

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

type ReflectServiceRequest 

type ReflectServiceRequest struct {
	Payload []byte `thrift:"Payload,1" frugal:"1,default,binary" json:"Payload"`
}
var ReflectionServiceReflectServiceArgs_Request_DEFAULT *ReflectServiceRequest

func NewReflectServiceRequest 

func NewReflectServiceRequest() *ReflectServiceRequest

func (*ReflectServiceRequest) BLength 

func (p *ReflectServiceRequest) BLength() int

func (*ReflectServiceRequest) DeepEqual 

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

func (*ReflectServiceRequest) FastRead 

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

func (*ReflectServiceRequest) FastReadField1 

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

func (*ReflectServiceRequest) FastWrite 

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

for compatibility

func (*ReflectServiceRequest) FastWriteNocopy 

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

func (*ReflectServiceRequest) Field1DeepEqual 

func (p *ReflectServiceRequest) Field1DeepEqual(src []byte) bool

func (*ReflectServiceRequest) GetPayload 

func (p *ReflectServiceRequest) GetPayload() (v []byte)

func (*ReflectServiceRequest) InitDefault 

func (p *ReflectServiceRequest) InitDefault()

func (*ReflectServiceRequest) Read 

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

func (*ReflectServiceRequest) ReadField1 

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

func (*ReflectServiceRequest) SetPayload 

func (p *ReflectServiceRequest) SetPayload(val []byte)

func (*ReflectServiceRequest) String 

func (p *ReflectServiceRequest) String() string

func (*ReflectServiceRequest) Write 

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

type ReflectServiceRespPayload 

type ReflectServiceRespPayload struct {
	Version          string `thrift:"Version,1" frugal:"1,default,string" json:"Version"`
	IsCombineService bool   `thrift:"IsCombineService,2" frugal:"2,default,bool" json:"IsCombineService"`
	IDL              []byte `thrift:"IDL,15" frugal:"15,default,binary" json:"IDL"`
}

func NewReflectServiceRespPayload 

func NewReflectServiceRespPayload() *ReflectServiceRespPayload

func UnmarshalReflectServiceRespPayload 

func UnmarshalReflectServiceRespPayload(bs []byte) (*ReflectServiceRespPayload, error)

UnmarshalReflectServiceRespPayload decodes a ReflectServiceRespPayload with binary protocol.

func (*ReflectServiceRespPayload) BLength 

func (p *ReflectServiceRespPayload) BLength() int

func (*ReflectServiceRespPayload) DeepEqual 

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

func (*ReflectServiceRespPayload) FastRead 

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

func (*ReflectServiceRespPayload) FastReadField1 

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

func (*ReflectServiceRespPayload) FastReadField15 added in v0.4.0 

func (p *ReflectServiceRespPayload) FastReadField15(buf []byte) (int, error)

func (*ReflectServiceRespPayload) FastReadField2 

func (p *ReflectServiceRespPayload) FastReadField2(buf []byte) (int, error)

func (*ReflectServiceRespPayload) FastWrite 

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

for compatibility

func (*ReflectServiceRespPayload) FastWriteNocopy 

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

func (*ReflectServiceRespPayload) Field15DeepEqual added in v0.4.0 

func (p *ReflectServiceRespPayload) Field15DeepEqual(src []byte) bool

func (*ReflectServiceRespPayload) Field1DeepEqual 

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

func (*ReflectServiceRespPayload) Field2DeepEqual 

func (p *ReflectServiceRespPayload) Field2DeepEqual(src bool) bool

func (*ReflectServiceRespPayload) GetIDL added in v0.3.0 

func (p *ReflectServiceRespPayload) GetIDL() (v []byte)

func (*ReflectServiceRespPayload) GetIsCombineService added in v0.4.0 

func (p *ReflectServiceRespPayload) GetIsCombineService() (v bool)

func (*ReflectServiceRespPayload) GetVersion 

func (p *ReflectServiceRespPayload) GetVersion() (v string)

func (*ReflectServiceRespPayload) InitDefault 

func (p *ReflectServiceRespPayload) InitDefault()

func (*ReflectServiceRespPayload) Read 

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

func (*ReflectServiceRespPayload) ReadField1 

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

func (*ReflectServiceRespPayload) ReadField15 added in v0.4.0 

func (p *ReflectServiceRespPayload) ReadField15(iprot thrift.TProtocol) error

func (*ReflectServiceRespPayload) ReadField2 

func (p *ReflectServiceRespPayload) ReadField2(iprot thrift.TProtocol) error

func (*ReflectServiceRespPayload) SetIDL added in v0.3.0 

func (p *ReflectServiceRespPayload) SetIDL(val []byte)

func (*ReflectServiceRespPayload) SetIsCombineService added in v0.4.0 

func (p *ReflectServiceRespPayload) SetIsCombineService(val bool)

func (*ReflectServiceRespPayload) SetVersion 

func (p *ReflectServiceRespPayload) SetVersion(val string)

func (*ReflectServiceRespPayload) String 

func (p *ReflectServiceRespPayload) String() string

func (*ReflectServiceRespPayload) Write 

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

type ReflectServiceResponse 

type ReflectServiceResponse struct {
	Payload []byte `thrift:"Payload,1" frugal:"1,default,binary" json:"Payload"`
}
var ReflectionServiceReflectServiceResult_Success_DEFAULT *ReflectServiceResponse

func NewReflectServiceResponse 

func NewReflectServiceResponse() *ReflectServiceResponse

func (*ReflectServiceResponse) BLength 

func (p *ReflectServiceResponse) BLength() int

func (*ReflectServiceResponse) DeepEqual 

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

func (*ReflectServiceResponse) FastRead 

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

func (*ReflectServiceResponse) FastReadField1 

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

func (*ReflectServiceResponse) FastWrite 

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

for compatibility

func (*ReflectServiceResponse) FastWriteNocopy 

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

func (*ReflectServiceResponse) Field1DeepEqual 

func (p *ReflectServiceResponse) Field1DeepEqual(src []byte) bool

func (*ReflectServiceResponse) GetPayload 

func (p *ReflectServiceResponse) GetPayload() (v []byte)

func (*ReflectServiceResponse) InitDefault 

func (p *ReflectServiceResponse) InitDefault()

func (*ReflectServiceResponse) Read 

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

func (*ReflectServiceResponse) ReadField1 

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

func (*ReflectServiceResponse) SetPayload 

func (p *ReflectServiceResponse) SetPayload(val []byte)

func (*ReflectServiceResponse) String 

func (p *ReflectServiceResponse) String() string

func (*ReflectServiceResponse) Write 

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

type ReflectionService 

type ReflectionService interface {
	ReflectService(ctx context.Context, request *ReflectServiceRequest) (r *ReflectServiceResponse, err error)
}

type ReflectionServiceClient 

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

func NewReflectionServiceClient 

func NewReflectionServiceClient(c thrift.TClient) *ReflectionServiceClient

func NewReflectionServiceClientFactory 

func NewReflectionServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *ReflectionServiceClient

func NewReflectionServiceClientProtocol 

func NewReflectionServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *ReflectionServiceClient

func (*ReflectionServiceClient) Client_ 

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

func (*ReflectionServiceClient) ReflectService 

func (p *ReflectionServiceClient) ReflectService(ctx context.Context, request *ReflectServiceRequest) (r *ReflectServiceResponse, err error)

type ReflectionServiceProcessor 

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

func NewReflectionServiceProcessor 

func NewReflectionServiceProcessor(handler ReflectionService) *ReflectionServiceProcessor

func (*ReflectionServiceProcessor) AddToProcessorMap 

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

func (*ReflectionServiceProcessor) GetProcessorFunction 

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

func (*ReflectionServiceProcessor) Process 

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

func (*ReflectionServiceProcessor) ProcessorMap 

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

type ReflectionServiceReflectServiceArgs 

type ReflectionServiceReflectServiceArgs struct {
	Request *ReflectServiceRequest `thrift:"request,1" frugal:"1,default,ReflectServiceRequest" json:"request"`
}

func NewReflectionServiceReflectServiceArgs 

func NewReflectionServiceReflectServiceArgs() *ReflectionServiceReflectServiceArgs

func (*ReflectionServiceReflectServiceArgs) BLength 

func (p *ReflectionServiceReflectServiceArgs) BLength() int

func (*ReflectionServiceReflectServiceArgs) DeepEqual 

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

func (*ReflectionServiceReflectServiceArgs) FastRead 

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

func (*ReflectionServiceReflectServiceArgs) FastReadField1 

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

func (*ReflectionServiceReflectServiceArgs) FastWrite 

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

for compatibility

func (*ReflectionServiceReflectServiceArgs) FastWriteNocopy 

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

func (*ReflectionServiceReflectServiceArgs) Field1DeepEqual 

func (p *ReflectionServiceReflectServiceArgs) Field1DeepEqual(src *ReflectServiceRequest) bool

func (*ReflectionServiceReflectServiceArgs) GetFirstArgument 

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

func (*ReflectionServiceReflectServiceArgs) GetRequest added in v0.3.0 

func (p *ReflectionServiceReflectServiceArgs) GetRequest() (v *ReflectServiceRequest)

func (*ReflectionServiceReflectServiceArgs) InitDefault 

func (p *ReflectionServiceReflectServiceArgs) InitDefault()

func (*ReflectionServiceReflectServiceArgs) IsSetRequest added in v0.3.0 

func (p *ReflectionServiceReflectServiceArgs) IsSetRequest() bool

func (*ReflectionServiceReflectServiceArgs) Read 

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

func (*ReflectionServiceReflectServiceArgs) ReadField1 

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

func (*ReflectionServiceReflectServiceArgs) SetRequest added in v0.3.0 

func (p *ReflectionServiceReflectServiceArgs) SetRequest(val *ReflectServiceRequest)

func (*ReflectionServiceReflectServiceArgs) String 

func (p *ReflectionServiceReflectServiceArgs) String() string

func (*ReflectionServiceReflectServiceArgs) Write 

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

type ReflectionServiceReflectServiceResult 

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

func NewReflectionServiceReflectServiceResult 

func NewReflectionServiceReflectServiceResult() *ReflectionServiceReflectServiceResult

func (*ReflectionServiceReflectServiceResult) BLength 

func (p *ReflectionServiceReflectServiceResult) BLength() int

func (*ReflectionServiceReflectServiceResult) DeepEqual 

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

func (*ReflectionServiceReflectServiceResult) FastRead 

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

func (*ReflectionServiceReflectServiceResult) FastReadField0 

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

func (*ReflectionServiceReflectServiceResult) FastWrite 

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

for compatibility

func (*ReflectionServiceReflectServiceResult) FastWriteNocopy 

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

func (*ReflectionServiceReflectServiceResult) Field0DeepEqual 

func (p *ReflectionServiceReflectServiceResult) Field0DeepEqual(src *ReflectServiceResponse) bool

func (*ReflectionServiceReflectServiceResult) GetResult 

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

func (*ReflectionServiceReflectServiceResult) GetSuccess 

func (p *ReflectionServiceReflectServiceResult) GetSuccess() (v *ReflectServiceResponse)

func (*ReflectionServiceReflectServiceResult) InitDefault 

func (p *ReflectionServiceReflectServiceResult) InitDefault()

func (*ReflectionServiceReflectServiceResult) IsSetSuccess 

func (p *ReflectionServiceReflectServiceResult) IsSetSuccess() bool

func (*ReflectionServiceReflectServiceResult) Read 

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

func (*ReflectionServiceReflectServiceResult) ReadField0 

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

func (*ReflectionServiceReflectServiceResult) SetSuccess 

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

func (*ReflectionServiceReflectServiceResult) String 

func (p *ReflectionServiceReflectServiceResult) String() string

func (*ReflectionServiceReflectServiceResult) Write 

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

Source Files

View all Source files

Directories

Path Synopsis
Code generated by thrift-gen-kitex-reflect.
 Code generated by thrift-gen-kitex-reflect.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.