echo

Documentation

Overview

Package echo shows a simple RPC service that can be served with rpcz.

Index

• Variables
• type Echo
  • func New() *Echo
  • func (s *Echo) Echo(ctx context.Context, req *EchoRequest, resp *EchoResponse) error
• type EchoRequest
  • func (*EchoRequest) Descriptor() ([]byte, []int)
  • func (x *EchoRequest) GetDelay() int64
  • func (x *EchoRequest) GetMsg() string
  • func (*EchoRequest) ProtoMessage()
  • func (x *EchoRequest) ProtoReflect() protoreflect.Message
  • func (x *EchoRequest) Reset()
  • func (x *EchoRequest) String() string
• type EchoResponse
  • func (*EchoResponse) Descriptor() ([]byte, []int)
  • func (x *EchoResponse) GetMsg() string
  • func (*EchoResponse) ProtoMessage()
  • func (x *EchoResponse) ProtoReflect() protoreflect.Message
  • func (x *EchoResponse) Reset()
  • func (x *EchoResponse) String() string
• type ExtendedEcho
  • func NewExtendedEcho(timeout time.Duration) *ExtendedEcho
  • func (s *ExtendedEcho) Echo(ctx context.Context, req *EchoRequest, resp *EchoResponse) error

Variables

var File_echo_proto protoreflect.FileDescriptor

Types

type Echo

type Echo struct{}

Echo service replies back with the message it receives.

func New

func New() *Echo

New returns an instance of Echo.

func (*Echo) Echo

func (s *Echo) Echo(ctx context.Context, req *EchoRequest, resp *EchoResponse) error

Echo handles req and fills in resp.

type EchoRequest

type EchoRequest struct {
	Msg   string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	Delay int64  `protobuf:"varint,2,opt,name=delay,proto3" json:"delay,omitempty"`
	// contains filtered or unexported fields
}

func (*EchoRequest) Descriptor

func (*EchoRequest) Descriptor() ([]byte, []int)

Deprecated: Use EchoRequest.ProtoReflect.Descriptor instead.

func (*EchoRequest) GetDelay

func (x *EchoRequest) GetDelay() int64

func (*EchoRequest) GetMsg

func (x *EchoRequest) GetMsg() string

func (*EchoRequest) ProtoMessage

func (*EchoRequest) ProtoMessage()

func (*EchoRequest) ProtoReflect

func (x *EchoRequest) ProtoReflect() protoreflect.Message

func (*EchoRequest) Reset

func (x *EchoRequest) Reset()

func (*EchoRequest) String

func (x *EchoRequest) String() string

type EchoResponse

type EchoResponse struct {
	Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*EchoResponse) Descriptor

func (*EchoResponse) Descriptor() ([]byte, []int)

Deprecated: Use EchoResponse.ProtoReflect.Descriptor instead.

func (*EchoResponse) GetMsg

func (x *EchoResponse) GetMsg() string

func (*EchoResponse) ProtoMessage

func (*EchoResponse) ProtoMessage()

func (*EchoResponse) ProtoReflect

func (x *EchoResponse) ProtoReflect() protoreflect.Message

func (*EchoResponse) Reset

func (x *EchoResponse) Reset()

func (*EchoResponse) String

func (x *EchoResponse) String() string

type ExtendedEcho

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

ExtendedEcho service replies back with the message it receives.

It shows an example of service-side and caller-defined timeouts.

func NewExtendedEcho

func NewExtendedEcho(timeout time.Duration) *ExtendedEcho

NewExtendedEcho returns a new ExtendedEcho with the specified timeout.

func (*ExtendedEcho) Echo

func (s *ExtendedEcho) Echo(ctx context.Context, req *EchoRequest, resp *EchoResponse) error

Echo handles req and fills in resp.

The service may wait for req.Delay, if specified, but no longer than s.timeout.