proto

Documentation

Overview

Package proto ...

Index

• Constants
• Variables
• func RegisterStreamsHandler(handler StreamsHandler) server.RegistrationFunc
• type CallRequest
  • func (*CallRequest) Descriptor() ([]byte, []int)
  • func (x *CallRequest) GetName() string
  • func (*CallRequest) ProtoMessage()
  • func (x *CallRequest) ProtoReflect() protoreflect.Message
  • func (x *CallRequest) Reset()
  • func (x *CallRequest) String() string
• type CallResponse
  • func (*CallResponse) Descriptor() ([]byte, []int)
  • func (x *CallResponse) GetMsg() string
  • func (x *CallResponse) GetPayload() []byte
  • func (*CallResponse) ProtoMessage()
  • func (x *CallResponse) ProtoReflect() protoreflect.Message
  • func (x *CallResponse) Reset()
  • func (x *CallResponse) String() string
• type StreamsClient
  • func NewStreamsClient(client client.Client) *StreamsClient
  • func (c *StreamsClient) Call(ctx context.Context, service string, req *CallRequest, ...) (*CallResponse, error)
• type StreamsHandler

Constants

const HandlerStreams = "echo.Streams"

HandlerStreams is the name of a service, it's here to static type/reference.

Variables

var File_echo_proto protoreflect.FileDescriptor

Functions

func RegisterStreamsHandler

func RegisterStreamsHandler(handler StreamsHandler) server.RegistrationFunc

RegisterStreamsHandler will return a registration function that can be provided to entrypoints as a handler registration.

Types

type CallRequest

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

func (*CallRequest) Descriptor

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

Deprecated: Use CallRequest.ProtoReflect.Descriptor instead.

func (*CallRequest) GetName

func (x *CallRequest) GetName() string

func (*CallRequest) ProtoMessage

func (*CallRequest) ProtoMessage()

func (*CallRequest) ProtoReflect

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

func (*CallRequest) Reset

func (x *CallRequest) Reset()

func (*CallRequest) String

func (x *CallRequest) String() string

type CallResponse

type CallResponse struct {
	Msg     string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*CallResponse) Descriptor

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

Deprecated: Use CallResponse.ProtoReflect.Descriptor instead.

func (*CallResponse) GetMsg

func (x *CallResponse) GetMsg() string

func (*CallResponse) GetPayload

func (x *CallResponse) GetPayload() []byte

func (*CallResponse) ProtoMessage

func (*CallResponse) ProtoMessage()

func (*CallResponse) ProtoReflect

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

func (*CallResponse) Reset

func (x *CallResponse) Reset()

func (*CallResponse) String

func (x *CallResponse) String() string

type StreamsClient

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

StreamsClient is the client for echo.Streams

func NewStreamsClient

func NewStreamsClient(client client.Client) *StreamsClient

NewStreamsClient creates a new client for echo.Streams

func (*StreamsClient) Call

func (c *StreamsClient) Call(ctx context.Context, service string, req *CallRequest, opts ...client.CallOption) (*CallResponse, error)

Call calls Call.

type StreamsHandler

type StreamsHandler interface {
	Call(ctx context.Context, req *CallRequest) (*CallResponse, error)
}

StreamsHandler is the Handler for echo.Streams