echo

package
v0.0.0-...-92745da Latest Latest
Warning

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

Go to latest
Published: Jul 14, 2021 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

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(psm 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(psm 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

Jump to

Keyboard shortcuts

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