rpc

Documentation

Index

• func RegisterGrpcServiceServer(s *grpc.Server, srv GrpcServiceServer)
• type GRPCReply
  • func (*GRPCReply) Descriptor() ([]byte, []int)
  • func (m *GRPCReply) GetCode() int32
  • func (m *GRPCReply) GetData() string
  • func (m *GRPCReply) GetMessage() string
  • func (*GRPCReply) ProtoMessage()
  • func (m *GRPCReply) Reset()
  • func (m *GRPCReply) String() string
  • func (m *GRPCReply) XXX_DiscardUnknown()
  • func (m *GRPCReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *GRPCReply) XXX_Merge(src proto.Message)
  • func (m *GRPCReply) XXX_Size() int
  • func (m *GRPCReply) XXX_Unmarshal(b []byte) error
• type GRPCRequest
  • func (*GRPCRequest) Descriptor() ([]byte, []int)
  • func (m *GRPCRequest) GetName() string
  • func (*GRPCRequest) ProtoMessage()
  • func (m *GRPCRequest) Reset()
  • func (m *GRPCRequest) String() string
  • func (m *GRPCRequest) XXX_DiscardUnknown()
  • func (m *GRPCRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *GRPCRequest) XXX_Merge(src proto.Message)
  • func (m *GRPCRequest) XXX_Size() int
  • func (m *GRPCRequest) XXX_Unmarshal(b []byte) error
• type GrpcServiceClient
  • func NewGrpcServiceClient(cc *grpc.ClientConn) GrpcServiceClient
• type GrpcServiceServer

Functions

func RegisterGrpcServiceServer

func RegisterGrpcServiceServer(s *grpc.Server, srv GrpcServiceServer)

Types

type GRPCReply

type GRPCReply struct {
	Code                 int32    `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Data                 string   `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GRPCReply) Descriptor

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

func (*GRPCReply) GetCode

func (m *GRPCReply) GetCode() int32

func (*GRPCReply) GetData

func (m *GRPCReply) GetData() string

func (*GRPCReply) GetMessage

func (m *GRPCReply) GetMessage() string

func (*GRPCReply) ProtoMessage

func (*GRPCReply) ProtoMessage()

func (*GRPCReply) Reset

func (m *GRPCReply) Reset()

func (*GRPCReply) String

func (m *GRPCReply) String() string

func (*GRPCReply) XXX_DiscardUnknown

func (m *GRPCReply) XXX_DiscardUnknown()

func (*GRPCReply) XXX_Marshal

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

func (*GRPCReply) XXX_Merge

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

func (*GRPCReply) XXX_Size

func (m *GRPCReply) XXX_Size() int

func (*GRPCReply) XXX_Unmarshal

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

type GRPCRequest

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

func (*GRPCRequest) Descriptor

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

func (*GRPCRequest) GetName

func (m *GRPCRequest) GetName() string

func (*GRPCRequest) ProtoMessage

func (*GRPCRequest) ProtoMessage()

func (*GRPCRequest) Reset

func (m *GRPCRequest) Reset()

func (*GRPCRequest) String

func (m *GRPCRequest) String() string

func (*GRPCRequest) XXX_DiscardUnknown

func (m *GRPCRequest) XXX_DiscardUnknown()

func (*GRPCRequest) XXX_Marshal

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

func (*GRPCRequest) XXX_Merge

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

func (*GRPCRequest) XXX_Size

func (m *GRPCRequest) XXX_Size() int

func (*GRPCRequest) XXX_Unmarshal

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

type GrpcServiceClient

type GrpcServiceClient interface {
	GRPCResponse(ctx context.Context, in *GRPCRequest, opts ...grpc.CallOption) (*GRPCReply, error)
}

GrpcServiceClient is the client API for GrpcService service.

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

func NewGrpcServiceClient

func NewGrpcServiceClient(cc *grpc.ClientConn) GrpcServiceClient

type GrpcServiceServer

type GrpcServiceServer interface {
	GRPCResponse(context.Context, *GRPCRequest) (*GRPCReply, error)
}

GrpcServiceServer is the server API for GrpcService service.