echo

package
v0.0.0-...-ce3419d Latest Latest
Warning

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

 Go to latest Published: Dec 28, 2022 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Overview

Code generated by Kitex v0.0.6. DO NOT EDIT.

Index

Constants

This section is empty.

Variables

View Source 
var BidirectionalEchoArgs_Req_DEFAULT *pbapi.Request
View Source 
var BidirectionalEchoResult_Success_DEFAULT *pbapi.Response
View Source 
var StreamRequestEchoArgs_Req_DEFAULT *pbapi.Request
View Source 
var StreamRequestEchoResult_Success_DEFAULT *pbapi.Response
View Source 
var StreamResponseEchoArgs_Req_DEFAULT *pbapi.Request
View Source 
var StreamResponseEchoResult_Success_DEFAULT *pbapi.Response

Functions

func NewInvoker 

func NewInvoker(handler pbapi.Echo, opts ...server.Option) server.Invoker

NewInvoker creates a server.Invoker with the given handler and options.

func NewServer 

func NewServer(handler pbapi.Echo, opts ...server.Option) server.Server

NewServer creates a server.Server with the given handler and options.

Types

type BidirectionalEchoArgs 

type BidirectionalEchoArgs struct {
	Req *pbapi.Request
}

func (*BidirectionalEchoArgs) GetReq 

func (p *BidirectionalEchoArgs) GetReq() *pbapi.Request

func (*BidirectionalEchoArgs) IsSetReq 

func (p *BidirectionalEchoArgs) IsSetReq() bool

func (*BidirectionalEchoArgs) Marshal 

func (p *BidirectionalEchoArgs) Marshal(out []byte) ([]byte, error)

func (*BidirectionalEchoArgs) Unmarshal 

func (p *BidirectionalEchoArgs) Unmarshal(in []byte) error

type BidirectionalEchoResult 

type BidirectionalEchoResult struct {
	Success *pbapi.Response
}

func (*BidirectionalEchoResult) GetSuccess 

func (p *BidirectionalEchoResult) GetSuccess() *pbapi.Response

func (*BidirectionalEchoResult) IsSetSuccess 

func (p *BidirectionalEchoResult) IsSetSuccess() bool

func (*BidirectionalEchoResult) Marshal 

func (p *BidirectionalEchoResult) Marshal(out []byte) ([]byte, error)

func (*BidirectionalEchoResult) SetSuccess 

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

func (*BidirectionalEchoResult) Unmarshal 

func (p *BidirectionalEchoResult) Unmarshal(in []byte) error

type Client 

type Client interface {
	StreamRequestEcho(ctx context.Context, callOptions ...callopt.Option) (stream Echo_StreamRequestEchoClient, err error)
	StreamResponseEcho(ctx context.Context, Req *pbapi.Request, callOptions ...callopt.Option) (stream Echo_StreamResponseEchoClient, err error)
	BidirectionalEcho(ctx context.Context, callOptions ...callopt.Option) (stream Echo_BidirectionalEchoClient, err error)
}

Client is designed to provide IDL-compatible methods with call-option parameter for kitex framework.

func MustNewClient 

func MustNewClient(destService string, opts ...client.Option) Client

MustNewClient creates a client for the service defined in IDL. It panics if any error occurs.

func NewClient 

func NewClient(destService string, opts ...client.Option) (Client, error)

NewClient creates a client for the service defined in IDL.

type Echo_BidirectionalEchoClient 

type Echo_BidirectionalEchoClient interface {
	streaming.Stream
	Send(*pbapi.Request) error
	Recv() (*pbapi.Response, error)
}

type Echo_StreamRequestEchoClient 

type Echo_StreamRequestEchoClient interface {
	streaming.Stream
	Send(*pbapi.Request) error
	CloseAndRecv() (*pbapi.Response, error)
}

type Echo_StreamResponseEchoClient 

type Echo_StreamResponseEchoClient interface {
	streaming.Stream
	Recv() (*pbapi.Response, error)
}

type StreamRequestEchoArgs 

type StreamRequestEchoArgs struct {
	Req *pbapi.Request
}

func (*StreamRequestEchoArgs) GetReq 

func (p *StreamRequestEchoArgs) GetReq() *pbapi.Request

func (*StreamRequestEchoArgs) IsSetReq 

func (p *StreamRequestEchoArgs) IsSetReq() bool

func (*StreamRequestEchoArgs) Marshal 

func (p *StreamRequestEchoArgs) Marshal(out []byte) ([]byte, error)

func (*StreamRequestEchoArgs) Unmarshal 

func (p *StreamRequestEchoArgs) Unmarshal(in []byte) error

type StreamRequestEchoResult 

type StreamRequestEchoResult struct {
	Success *pbapi.Response
}

func (*StreamRequestEchoResult) GetSuccess 

func (p *StreamRequestEchoResult) GetSuccess() *pbapi.Response

func (*StreamRequestEchoResult) IsSetSuccess 

func (p *StreamRequestEchoResult) IsSetSuccess() bool

func (*StreamRequestEchoResult) Marshal 

func (p *StreamRequestEchoResult) Marshal(out []byte) ([]byte, error)

func (*StreamRequestEchoResult) SetSuccess 

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

func (*StreamRequestEchoResult) Unmarshal 

func (p *StreamRequestEchoResult) Unmarshal(in []byte) error

type StreamResponseEchoArgs 

type StreamResponseEchoArgs struct {
	Req *pbapi.Request
}

func (*StreamResponseEchoArgs) GetReq 

func (p *StreamResponseEchoArgs) GetReq() *pbapi.Request

func (*StreamResponseEchoArgs) IsSetReq 

func (p *StreamResponseEchoArgs) IsSetReq() bool

func (*StreamResponseEchoArgs) Marshal 

func (p *StreamResponseEchoArgs) Marshal(out []byte) ([]byte, error)

func (*StreamResponseEchoArgs) Unmarshal 

func (p *StreamResponseEchoArgs) Unmarshal(in []byte) error

type StreamResponseEchoResult 

type StreamResponseEchoResult struct {
	Success *pbapi.Response
}

func (*StreamResponseEchoResult) GetSuccess 

func (p *StreamResponseEchoResult) GetSuccess() *pbapi.Response

func (*StreamResponseEchoResult) IsSetSuccess 

func (p *StreamResponseEchoResult) IsSetSuccess() bool

func (*StreamResponseEchoResult) Marshal 

func (p *StreamResponseEchoResult) Marshal(out []byte) ([]byte, error)

func (*StreamResponseEchoResult) SetSuccess 

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

func (*StreamResponseEchoResult) Unmarshal 

func (p *StreamResponseEchoResult) Unmarshal(in []byte) error

Source Files

View all Source files

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.