proto

Documentation

Index

• Constants
• Variables
• func RegisterExchangeServer(s grpc.ServiceRegistrar, srv ExchangeServer)
• type ExchangeClient
  • func NewExchangeClient(cc grpc.ClientConnInterface) ExchangeClient
• type ExchangeServer
• type Exchange_NextClient
• type Exchange_NextServer
• type NextReq
  • func (*NextReq) Descriptor() ([]byte, []int)
  • func (x *NextReq) GetName() string
  • func (*NextReq) ProtoMessage()
  • func (x *NextReq) ProtoReflect() protoreflect.Message
  • func (x *NextReq) Reset()
  • func (x *NextReq) String() string
• type NextRes
  • func (*NextRes) Descriptor() ([]byte, []int)
  • func (x *NextRes) GetMsgbody() string
  • func (*NextRes) ProtoMessage()
  • func (x *NextRes) ProtoReflect() protoreflect.Message
  • func (x *NextRes) Reset()
  • func (x *NextRes) String() string
• type SendReq
  • func (*SendReq) Descriptor() ([]byte, []int)
  • func (x *SendReq) GetMsgbody() string
  • func (x *SendReq) GetName() string
  • func (*SendReq) ProtoMessage()
  • func (x *SendReq) ProtoReflect() protoreflect.Message
  • func (x *SendReq) Reset()
  • func (x *SendReq) String() string
• type SendRes
  • func (*SendRes) Descriptor() ([]byte, []int)
  • func (*SendRes) ProtoMessage()
  • func (x *SendRes) ProtoReflect() protoreflect.Message
  • func (x *SendRes) Reset()
  • func (x *SendRes) String() string
• type UnimplementedExchangeServer
  • func (UnimplementedExchangeServer) Next(*NextReq, Exchange_NextServer) error
  • func (UnimplementedExchangeServer) Send(context.Context, *SendReq) (*SendRes, error)
• type UnsafeExchangeServer

Constants

const (
	Exchange_Send_FullMethodName = "/exchange.Exchange/Send"
	Exchange_Next_FullMethodName = "/exchange.Exchange/Next"
)

Variables

var Exchange_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "exchange.Exchange",
	HandlerType: (*ExchangeServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Send",
			Handler:    _Exchange_Send_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Next",
			Handler:       _Exchange_Next_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "exchange.proto",
}

Exchange_ServiceDesc is the grpc.ServiceDesc for Exchange service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

var File_exchange_proto protoreflect.FileDescriptor

Functions

func RegisterExchangeServer

func RegisterExchangeServer(s grpc.ServiceRegistrar, srv ExchangeServer)

Types

type ExchangeClient

type ExchangeClient interface {
	Send(ctx context.Context, in *SendReq, opts ...grpc.CallOption) (*SendRes, error)
	Next(ctx context.Context, in *NextReq, opts ...grpc.CallOption) (Exchange_NextClient, error)
}

ExchangeClient is the client API for Exchange service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewExchangeClient

func NewExchangeClient(cc grpc.ClientConnInterface) ExchangeClient

type ExchangeServer

type ExchangeServer interface {
	Send(context.Context, *SendReq) (*SendRes, error)
	Next(*NextReq, Exchange_NextServer) error
	// contains filtered or unexported methods
}

ExchangeServer is the server API for Exchange service. All implementations must embed UnimplementedExchangeServer for forward compatibility

type Exchange_NextClient

type Exchange_NextClient interface {
	Recv() (*NextRes, error)
	grpc.ClientStream
}

type Exchange_NextServer

type Exchange_NextServer interface {
	Send(*NextRes) error
	grpc.ServerStream
}

type NextReq

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

func (*NextReq) Descriptor

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

Deprecated: Use NextReq.ProtoReflect.Descriptor instead.

func (*NextReq) GetName

func (x *NextReq) GetName() string

func (*NextReq) ProtoMessage

func (*NextReq) ProtoMessage()

func (*NextReq) ProtoReflect

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

func (*NextReq) Reset

func (x *NextReq) Reset()

func (*NextReq) String

func (x *NextReq) String() string

type NextRes

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

func (*NextRes) Descriptor

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

Deprecated: Use NextRes.ProtoReflect.Descriptor instead.

func (*NextRes) GetMsgbody

func (x *NextRes) GetMsgbody() string

func (*NextRes) ProtoMessage

func (*NextRes) ProtoMessage()

func (*NextRes) ProtoReflect

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

func (*NextRes) Reset

func (x *NextRes) Reset()

func (*NextRes) String

func (x *NextRes) String() string

type SendReq

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

func (*SendReq) Descriptor

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

Deprecated: Use SendReq.ProtoReflect.Descriptor instead.

func (*SendReq) GetMsgbody

func (x *SendReq) GetMsgbody() string

func (*SendReq) GetName

func (x *SendReq) GetName() string

func (*SendReq) ProtoMessage

func (*SendReq) ProtoMessage()

func (*SendReq) ProtoReflect

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

func (*SendReq) Reset

func (x *SendReq) Reset()

func (*SendReq) String

func (x *SendReq) String() string

type SendRes

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

func (*SendRes) Descriptor

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

Deprecated: Use SendRes.ProtoReflect.Descriptor instead.

func (*SendRes) ProtoMessage

func (*SendRes) ProtoMessage()

func (*SendRes) ProtoReflect

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

func (*SendRes) Reset

func (x *SendRes) Reset()

func (*SendRes) String

func (x *SendRes) String() string

type UnimplementedExchangeServer

type UnimplementedExchangeServer struct {
}

UnimplementedExchangeServer must be embedded to have forward compatible implementations.

func (UnimplementedExchangeServer) Next

func (UnimplementedExchangeServer) Next(*NextReq, Exchange_NextServer) error

func (UnimplementedExchangeServer) Send

func (UnimplementedExchangeServer) Send(context.Context, *SendReq) (*SendRes, error)

type UnsafeExchangeServer

type UnsafeExchangeServer interface {
	// contains filtered or unexported methods
}

UnsafeExchangeServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ExchangeServer will result in compilation errors.