echo

Documentation

Index

• Variables
• func NewInvoker(handler pbapi.Echo, opts ...server.Option) server.Invoker
• func NewServer(handler pbapi.Echo, opts ...server.Option) server.Server
• type BidirectionalEchoArgs
  • func (p *BidirectionalEchoArgs) GetReq() *pbapi.Request
  • func (p *BidirectionalEchoArgs) IsSetReq() bool
  • func (p *BidirectionalEchoArgs) Marshal(out []byte) ([]byte, error)
  • func (p *BidirectionalEchoArgs) Unmarshal(in []byte) error
• type BidirectionalEchoResult
  • func (p *BidirectionalEchoResult) GetSuccess() *pbapi.Response
  • func (p *BidirectionalEchoResult) IsSetSuccess() bool
  • func (p *BidirectionalEchoResult) Marshal(out []byte) ([]byte, error)
  • func (p *BidirectionalEchoResult) SetSuccess(x interface{})
  • func (p *BidirectionalEchoResult) Unmarshal(in []byte) error
• type Client
  • func MustNewClient(psm string, opts ...client.Option) Client
  • func NewClient(psm string, opts ...client.Option) (Client, error)
• type Echo_BidirectionalEchoClient
• type Echo_StreamRequestEchoClient
• type Echo_StreamResponseEchoClient
• type StreamRequestEchoArgs
  • func (p *StreamRequestEchoArgs) GetReq() *pbapi.Request
  • func (p *StreamRequestEchoArgs) IsSetReq() bool
  • func (p *StreamRequestEchoArgs) Marshal(out []byte) ([]byte, error)
  • func (p *StreamRequestEchoArgs) Unmarshal(in []byte) error
• type StreamRequestEchoResult
  • func (p *StreamRequestEchoResult) GetSuccess() *pbapi.Response
  • func (p *StreamRequestEchoResult) IsSetSuccess() bool
  • func (p *StreamRequestEchoResult) Marshal(out []byte) ([]byte, error)
  • func (p *StreamRequestEchoResult) SetSuccess(x interface{})
  • func (p *StreamRequestEchoResult) Unmarshal(in []byte) error
• type StreamResponseEchoArgs
  • func (p *StreamResponseEchoArgs) GetReq() *pbapi.Request
  • func (p *StreamResponseEchoArgs) IsSetReq() bool
  • func (p *StreamResponseEchoArgs) Marshal(out []byte) ([]byte, error)
  • func (p *StreamResponseEchoArgs) Unmarshal(in []byte) error
• type StreamResponseEchoResult
  • func (p *StreamResponseEchoResult) GetSuccess() *pbapi.Response
  • func (p *StreamResponseEchoResult) IsSetSuccess() bool
  • func (p *StreamResponseEchoResult) Marshal(out []byte) ([]byte, error)
  • func (p *StreamResponseEchoResult) SetSuccess(x interface{})
  • func (p *StreamResponseEchoResult) Unmarshal(in []byte) error

Variables

var BidirectionalEchoArgs_Req_DEFAULT *pbapi.Request

var BidirectionalEchoResult_Success_DEFAULT *pbapi.Response

var StreamRequestEchoArgs_Req_DEFAULT *pbapi.Request

var StreamRequestEchoResult_Success_DEFAULT *pbapi.Response

var StreamResponseEchoArgs_Req_DEFAULT *pbapi.Request

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