Documentation ¶
Overview ¶
Code generated by Kitex v0.3.4. DO NOT EDIT.
Index ¶
- Variables
- func NewInvoker(handler v3.AggregatedDiscoveryService, opts ...server.Option) server.Invoker
- func NewServer(handler v3.AggregatedDiscoveryService, opts ...server.Option) server.Server
- func NewServiceInfo() *kitex.ServiceInfo
- type AggregatedDiscoveryService_DeltaAggregatedResourcesClient
- type AggregatedDiscoveryService_StreamAggregatedResourcesClient
- type Client
- type DeltaAggregatedResourcesArgs
- type DeltaAggregatedResourcesResult
- func (p *DeltaAggregatedResourcesResult) GetSuccess() *v3discovery.DeltaDiscoveryResponse
- func (p *DeltaAggregatedResourcesResult) IsSetSuccess() bool
- func (p *DeltaAggregatedResourcesResult) Marshal(out []byte) ([]byte, error)
- func (p *DeltaAggregatedResourcesResult) SetSuccess(x interface{})
- func (p *DeltaAggregatedResourcesResult) Unmarshal(in []byte) error
- type StreamAggregatedResourcesArgs
- type StreamAggregatedResourcesResult
- func (p *StreamAggregatedResourcesResult) GetSuccess() *v3discovery.DiscoveryResponse
- func (p *StreamAggregatedResourcesResult) IsSetSuccess() bool
- func (p *StreamAggregatedResourcesResult) Marshal(out []byte) ([]byte, error)
- func (p *StreamAggregatedResourcesResult) SetSuccess(x interface{})
- func (p *StreamAggregatedResourcesResult) Unmarshal(in []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var DeltaAggregatedResourcesArgs_Req_DEFAULT *v3discovery.DeltaDiscoveryRequest
View Source
var DeltaAggregatedResourcesResult_Success_DEFAULT *v3discovery.DeltaDiscoveryResponse
View Source
var StreamAggregatedResourcesArgs_Req_DEFAULT *v3discovery.DiscoveryRequest
View Source
var StreamAggregatedResourcesResult_Success_DEFAULT *v3discovery.DiscoveryResponse
Functions ¶
func NewInvoker ¶
NewInvoker creates a server.Invoker with the given handler and options.
func NewServiceInfo ¶
func NewServiceInfo() *kitex.ServiceInfo
Types ¶
type AggregatedDiscoveryService_DeltaAggregatedResourcesClient ¶
type AggregatedDiscoveryService_DeltaAggregatedResourcesClient interface { streaming.Stream Send(*v3discovery.DeltaDiscoveryRequest) error Recv() (*v3discovery.DeltaDiscoveryResponse, error) }
type AggregatedDiscoveryService_StreamAggregatedResourcesClient ¶
type AggregatedDiscoveryService_StreamAggregatedResourcesClient interface { streaming.Stream Send(*v3discovery.DiscoveryRequest) error Recv() (*v3discovery.DiscoveryResponse, error) }
type Client ¶
type Client interface { StreamAggregatedResources(ctx context.Context, callOptions ...callopt.Option) (stream AggregatedDiscoveryService_StreamAggregatedResourcesClient, err error) DeltaAggregatedResources(ctx context.Context, callOptions ...callopt.Option) (stream AggregatedDiscoveryService_DeltaAggregatedResourcesClient, err error) }
Client is designed to provide IDL-compatible methods with call-option parameter for kitex framework.
func MustNewClient ¶
MustNewClient creates a client for the service defined in IDL. It panics if any error occurs.
type DeltaAggregatedResourcesArgs ¶
type DeltaAggregatedResourcesArgs struct {
Req *v3discovery.DeltaDiscoveryRequest
}
func (*DeltaAggregatedResourcesArgs) GetReq ¶
func (p *DeltaAggregatedResourcesArgs) GetReq() *v3discovery.DeltaDiscoveryRequest
func (*DeltaAggregatedResourcesArgs) IsSetReq ¶
func (p *DeltaAggregatedResourcesArgs) IsSetReq() bool
func (*DeltaAggregatedResourcesArgs) Marshal ¶
func (p *DeltaAggregatedResourcesArgs) Marshal(out []byte) ([]byte, error)
func (*DeltaAggregatedResourcesArgs) Unmarshal ¶
func (p *DeltaAggregatedResourcesArgs) Unmarshal(in []byte) error
type DeltaAggregatedResourcesResult ¶
type DeltaAggregatedResourcesResult struct {
Success *v3discovery.DeltaDiscoveryResponse
}
func (*DeltaAggregatedResourcesResult) GetSuccess ¶
func (p *DeltaAggregatedResourcesResult) GetSuccess() *v3discovery.DeltaDiscoveryResponse
func (*DeltaAggregatedResourcesResult) IsSetSuccess ¶
func (p *DeltaAggregatedResourcesResult) IsSetSuccess() bool
func (*DeltaAggregatedResourcesResult) Marshal ¶
func (p *DeltaAggregatedResourcesResult) Marshal(out []byte) ([]byte, error)
func (*DeltaAggregatedResourcesResult) SetSuccess ¶
func (p *DeltaAggregatedResourcesResult) SetSuccess(x interface{})
func (*DeltaAggregatedResourcesResult) Unmarshal ¶
func (p *DeltaAggregatedResourcesResult) Unmarshal(in []byte) error
type StreamAggregatedResourcesArgs ¶
type StreamAggregatedResourcesArgs struct {
Req *v3discovery.DiscoveryRequest
}
func (*StreamAggregatedResourcesArgs) GetReq ¶
func (p *StreamAggregatedResourcesArgs) GetReq() *v3discovery.DiscoveryRequest
func (*StreamAggregatedResourcesArgs) IsSetReq ¶
func (p *StreamAggregatedResourcesArgs) IsSetReq() bool
func (*StreamAggregatedResourcesArgs) Marshal ¶
func (p *StreamAggregatedResourcesArgs) Marshal(out []byte) ([]byte, error)
func (*StreamAggregatedResourcesArgs) Unmarshal ¶
func (p *StreamAggregatedResourcesArgs) Unmarshal(in []byte) error
type StreamAggregatedResourcesResult ¶
type StreamAggregatedResourcesResult struct {
Success *v3discovery.DiscoveryResponse
}
func (*StreamAggregatedResourcesResult) GetSuccess ¶
func (p *StreamAggregatedResourcesResult) GetSuccess() *v3discovery.DiscoveryResponse
func (*StreamAggregatedResourcesResult) IsSetSuccess ¶
func (p *StreamAggregatedResourcesResult) IsSetSuccess() bool
func (*StreamAggregatedResourcesResult) Marshal ¶
func (p *StreamAggregatedResourcesResult) Marshal(out []byte) ([]byte, error)
func (*StreamAggregatedResourcesResult) SetSuccess ¶
func (p *StreamAggregatedResourcesResult) SetSuccess(x interface{})
func (*StreamAggregatedResourcesResult) Unmarshal ¶
func (p *StreamAggregatedResourcesResult) Unmarshal(in []byte) error
Click to show internal directories.
Click to hide internal directories.