stream_pb

Documentation

Index

• func RegisterStringServiceServer(s *grpc.Server, srv StringServiceServer)
• type StringRequest
  • func (*StringRequest) Descriptor() ([]byte, []int)
  • func (m *StringRequest) GetA() string
  • func (m *StringRequest) GetB() string
  • func (*StringRequest) ProtoMessage()
  • func (m *StringRequest) Reset()
  • func (m *StringRequest) String() string
  • func (m *StringRequest) XXX_DiscardUnknown()
  • func (m *StringRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *StringRequest) XXX_Merge(src proto.Message)
  • func (m *StringRequest) XXX_Size() int
  • func (m *StringRequest) XXX_Unmarshal(b []byte) error
• type StringResponse
  • func (*StringResponse) Descriptor() ([]byte, []int)
  • func (m *StringResponse) GetErr() string
  • func (m *StringResponse) GetRet() string
  • func (*StringResponse) ProtoMessage()
  • func (m *StringResponse) Reset()
  • func (m *StringResponse) String() string
  • func (m *StringResponse) XXX_DiscardUnknown()
  • func (m *StringResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *StringResponse) XXX_Merge(src proto.Message)
  • func (m *StringResponse) XXX_Size() int
  • func (m *StringResponse) XXX_Unmarshal(b []byte) error
• type StringServiceClient
  • func NewStringServiceClient(cc *grpc.ClientConn) StringServiceClient
• type StringServiceServer
• type StringService_LotsOfClientStreamClient
• type StringService_LotsOfClientStreamServer
• type StringService_LotsOfServerAndClientStreamClient
• type StringService_LotsOfServerAndClientStreamServer
• type StringService_LotsOfServerStreamClient
• type StringService_LotsOfServerStreamServer
• type UnimplementedStringServiceServer
  • func (*UnimplementedStringServiceServer) Concat(ctx context.Context, req *StringRequest) (*StringResponse, error)
  • func (*UnimplementedStringServiceServer) LotsOfClientStream(srv StringService_LotsOfClientStreamServer) error
  • func (*UnimplementedStringServiceServer) LotsOfServerAndClientStream(srv StringService_LotsOfServerAndClientStreamServer) error
  • func (*UnimplementedStringServiceServer) LotsOfServerStream(req *StringRequest, srv StringService_LotsOfServerStreamServer) error

Functions

func RegisterStringServiceServer

func RegisterStringServiceServer(s *grpc.Server, srv StringServiceServer)

Types

type StringRequest

type StringRequest struct {
	A                    string   `protobuf:"bytes,1,opt,name=A,proto3" json:"A,omitempty"`
	B                    string   `protobuf:"bytes,2,opt,name=B,proto3" json:"B,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StringRequest) Descriptor

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

func (*StringRequest) GetA

func (m *StringRequest) GetA() string

func (*StringRequest) GetB

func (m *StringRequest) GetB() string

func (*StringRequest) ProtoMessage

func (*StringRequest) ProtoMessage()

func (*StringRequest) Reset

func (m *StringRequest) Reset()

func (*StringRequest) String

func (m *StringRequest) String() string

func (*StringRequest) XXX_DiscardUnknown

func (m *StringRequest) XXX_DiscardUnknown()

func (*StringRequest) XXX_Marshal

func (m *StringRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StringRequest) XXX_Merge

func (m *StringRequest) XXX_Merge(src proto.Message)

func (*StringRequest) XXX_Size

func (m *StringRequest) XXX_Size() int

func (*StringRequest) XXX_Unmarshal

func (m *StringRequest) XXX_Unmarshal(b []byte) error

type StringResponse

type StringResponse struct {
	Ret                  string   `protobuf:"bytes,1,opt,name=Ret,proto3" json:"Ret,omitempty"`
	Err                  string   `protobuf:"bytes,2,opt,name=err,proto3" json:"err,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StringResponse) Descriptor

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

func (*StringResponse) GetErr

func (m *StringResponse) GetErr() string

func (*StringResponse) GetRet

func (m *StringResponse) GetRet() string

func (*StringResponse) ProtoMessage

func (*StringResponse) ProtoMessage()

func (*StringResponse) Reset

func (m *StringResponse) Reset()

func (*StringResponse) String

func (m *StringResponse) String() string

func (*StringResponse) XXX_DiscardUnknown

func (m *StringResponse) XXX_DiscardUnknown()

func (*StringResponse) XXX_Marshal

func (m *StringResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StringResponse) XXX_Merge

func (m *StringResponse) XXX_Merge(src proto.Message)

func (*StringResponse) XXX_Size

func (m *StringResponse) XXX_Size() int

func (*StringResponse) XXX_Unmarshal

func (m *StringResponse) XXX_Unmarshal(b []byte) error

type StringServiceClient

type StringServiceClient interface {
	Concat(ctx context.Context, in *StringRequest, opts ...grpc.CallOption) (*StringResponse, error)
	LotsOfServerStream(ctx context.Context, in *StringRequest, opts ...grpc.CallOption) (StringService_LotsOfServerStreamClient, error)
	LotsOfClientStream(ctx context.Context, opts ...grpc.CallOption) (StringService_LotsOfClientStreamClient, error)
	LotsOfServerAndClientStream(ctx context.Context, opts ...grpc.CallOption) (StringService_LotsOfServerAndClientStreamClient, error)
}

StringServiceClient is the client API for StringService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewStringServiceClient

func NewStringServiceClient(cc *grpc.ClientConn) StringServiceClient

type StringServiceServer

type StringServiceServer interface {
	Concat(context.Context, *StringRequest) (*StringResponse, error)
	LotsOfServerStream(*StringRequest, StringService_LotsOfServerStreamServer) error
	LotsOfClientStream(StringService_LotsOfClientStreamServer) error
	LotsOfServerAndClientStream(StringService_LotsOfServerAndClientStreamServer) error
}

StringServiceServer is the server API for StringService service.

type StringService_LotsOfClientStreamClient

type StringService_LotsOfClientStreamClient interface {
	Send(*StringRequest) error
	CloseAndRecv() (*StringResponse, error)
	grpc.ClientStream
}

type StringService_LotsOfClientStreamServer

type StringService_LotsOfClientStreamServer interface {
	SendAndClose(*StringResponse) error
	Recv() (*StringRequest, error)
	grpc.ServerStream
}

type StringService_LotsOfServerAndClientStreamClient

type StringService_LotsOfServerAndClientStreamClient interface {
	Send(*StringRequest) error
	Recv() (*StringResponse, error)
	grpc.ClientStream
}

type StringService_LotsOfServerAndClientStreamServer

type StringService_LotsOfServerAndClientStreamServer interface {
	Send(*StringResponse) error
	Recv() (*StringRequest, error)
	grpc.ServerStream
}

type StringService_LotsOfServerStreamClient

type StringService_LotsOfServerStreamClient interface {
	Recv() (*StringResponse, error)
	grpc.ClientStream
}

type StringService_LotsOfServerStreamServer

type StringService_LotsOfServerStreamServer interface {
	Send(*StringResponse) error
	grpc.ServerStream
}

type UnimplementedStringServiceServer

type UnimplementedStringServiceServer struct {
}

UnimplementedStringServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedStringServiceServer) Concat

func (*UnimplementedStringServiceServer) Concat(ctx context.Context, req *StringRequest) (*StringResponse, error)

func (*UnimplementedStringServiceServer) LotsOfClientStream

func (*UnimplementedStringServiceServer) LotsOfClientStream(srv StringService_LotsOfClientStreamServer) error

func (*UnimplementedStringServiceServer) LotsOfServerAndClientStream

func (*UnimplementedStringServiceServer) LotsOfServerAndClientStream(srv StringService_LotsOfServerAndClientStreamServer) error

func (*UnimplementedStringServiceServer) LotsOfServerStream

func (*UnimplementedStringServiceServer) LotsOfServerStream(req *StringRequest, srv StringService_LotsOfServerStreamServer) error