Documentation
¶
Index ¶
- func RegisterTestApiGateway(srv string, g fiber.Router, opts ...grpc.DialOption) error
- func RegisterTestApiServer(s *grpc.Server, srv TestApiServer)
- func RegisterTestApiV2Gateway(srv string, g fiber.Router, opts ...grpc.DialOption) error
- func RegisterTestApiV2Server(s *grpc.Server, srv TestApiV2Server)
- func RegisterTransportGateway(srv string, g fiber.Router, opts ...grpc.DialOption) error
- func RegisterTransportServer(s *grpc.Server, srv TransportServer)
- type Message
- func (*Message) Descriptor() ([]byte, []int)
- func (m *Message) GetBody() []byte
- func (m *Message) GetHeader() map[string]string
- func (*Message) ProtoMessage()
- func (m *Message) Reset()
- func (m *Message) String() string
- func (m *Message) XXX_DiscardUnknown()
- func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Message) XXX_Merge(src proto.Message)
- func (m *Message) XXX_Size() int
- func (m *Message) XXX_Unmarshal(b []byte) error
- type TestApiClient
- type TestApiData
- func (*TestApiData) Descriptor() ([]byte, []int)
- func (m *TestApiData) GetSrvVersion() string
- func (m *TestApiData) GetVersion() string
- func (*TestApiData) ProtoMessage()
- func (m *TestApiData) Reset()
- func (m *TestApiData) String() string
- func (m *TestApiData) XXX_DiscardUnknown()
- func (m *TestApiData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TestApiData) XXX_Merge(src proto.Message)
- func (m *TestApiData) XXX_Size() int
- func (m *TestApiData) XXX_Unmarshal(b []byte) error
- type TestApiOutput
- func (*TestApiOutput) Descriptor() ([]byte, []int)
- func (m *TestApiOutput) GetCode() int32
- func (m *TestApiOutput) GetData() *TestApiData
- func (m *TestApiOutput) GetMsg() string
- func (m *TestApiOutput) GetNowTime() int64
- func (*TestApiOutput) ProtoMessage()
- func (m *TestApiOutput) Reset()
- func (m *TestApiOutput) String() string
- func (m *TestApiOutput) XXX_DiscardUnknown()
- func (m *TestApiOutput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TestApiOutput) XXX_Merge(src proto.Message)
- func (m *TestApiOutput) XXX_Size() int
- func (m *TestApiOutput) XXX_Unmarshal(b []byte) error
- type TestApiServer
- type TestApiV2Client
- type TestApiV2Server
- type TestReq
- func (*TestReq) Descriptor() ([]byte, []int)
- func (m *TestReq) GetInput() string
- func (*TestReq) ProtoMessage()
- func (m *TestReq) Reset()
- func (m *TestReq) String() string
- func (m *TestReq) XXX_DiscardUnknown()
- func (m *TestReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TestReq) XXX_Merge(src proto.Message)
- func (m *TestReq) XXX_Size() int
- func (m *TestReq) XXX_Unmarshal(b []byte) error
- type TransportClient
- type TransportServer
- type Transport_TestStream1Client
- type Transport_TestStream1Server
- type Transport_TestStream2Client
- type Transport_TestStream2Server
- type Transport_TestStreamClient
- type Transport_TestStreamServer
- type UnimplementedTestApiServer
- type UnimplementedTestApiV2Server
- type UnimplementedTransportServer
- func (*UnimplementedTransportServer) TestStream(srv Transport_TestStreamServer) error
- func (*UnimplementedTransportServer) TestStream1(srv Transport_TestStream1Server) error
- func (*UnimplementedTransportServer) TestStream2(req *Message, srv Transport_TestStream2Server) error
- func (*UnimplementedTransportServer) TestStream3(ctx context.Context, req *Message) (*Message, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterTestApiGateway ¶ added in v0.0.2
func RegisterTestApiServer ¶
func RegisterTestApiServer(s *grpc.Server, srv TestApiServer)
func RegisterTestApiV2Gateway ¶ added in v0.0.2
func RegisterTestApiV2Server ¶
func RegisterTestApiV2Server(s *grpc.Server, srv TestApiV2Server)
func RegisterTransportGateway ¶ added in v0.0.2
func RegisterTransportServer ¶
func RegisterTransportServer(s *grpc.Server, srv TransportServer)
Types ¶
type Message ¶
type Message struct {
Header map[string]string `` /* 153-byte string literal not displayed */
Body []byte `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*Message) Descriptor ¶
func (*Message) ProtoMessage ¶
func (*Message) ProtoMessage()
func (*Message) XXX_DiscardUnknown ¶ added in v0.0.2
func (m *Message) XXX_DiscardUnknown()
func (*Message) XXX_Marshal ¶ added in v0.0.2
func (*Message) XXX_Unmarshal ¶ added in v0.0.2
type TestApiClient ¶
type TestApiClient interface {
Version(ctx context.Context, in *TestReq, opts ...grpc.CallOption) (*TestApiOutput, error)
VersionTest(ctx context.Context, in *TestReq, opts ...grpc.CallOption) (*TestApiOutput, error)
}
TestApiClient is the client API for TestApi service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func GetTestApiClient ¶
func GetTestApiClient(srv string, opts ...grpc.DialOption) (TestApiClient, error)
func NewTestApiClient ¶
func NewTestApiClient(cc *grpc.ClientConn) TestApiClient
type TestApiData ¶
type TestApiData struct {
Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
SrvVersion string `protobuf:"bytes,2,opt,name=srvVersion,proto3" json:"srvVersion,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*TestApiData) Descriptor ¶
func (*TestApiData) Descriptor() ([]byte, []int)
func (*TestApiData) GetSrvVersion ¶
func (m *TestApiData) GetSrvVersion() string
func (*TestApiData) GetVersion ¶
func (m *TestApiData) GetVersion() string
func (*TestApiData) ProtoMessage ¶
func (*TestApiData) ProtoMessage()
func (*TestApiData) Reset ¶
func (m *TestApiData) Reset()
func (*TestApiData) String ¶
func (m *TestApiData) String() string
func (*TestApiData) XXX_DiscardUnknown ¶ added in v0.0.2
func (m *TestApiData) XXX_DiscardUnknown()
func (*TestApiData) XXX_Marshal ¶ added in v0.0.2
func (m *TestApiData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TestApiData) XXX_Merge ¶ added in v0.0.2
func (m *TestApiData) XXX_Merge(src proto.Message)
func (*TestApiData) XXX_Size ¶ added in v0.0.2
func (m *TestApiData) XXX_Size() int
func (*TestApiData) XXX_Unmarshal ¶ added in v0.0.2
func (m *TestApiData) XXX_Unmarshal(b []byte) error
type TestApiOutput ¶
type TestApiOutput struct {
Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
NowTime int64 `protobuf:"varint,3,opt,name=nowTime,proto3" json:"nowTime,omitempty"`
Data *TestApiData `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*TestApiOutput) Descriptor ¶
func (*TestApiOutput) Descriptor() ([]byte, []int)
func (*TestApiOutput) GetCode ¶
func (m *TestApiOutput) GetCode() int32
func (*TestApiOutput) GetData ¶
func (m *TestApiOutput) GetData() *TestApiData
func (*TestApiOutput) GetMsg ¶
func (m *TestApiOutput) GetMsg() string
func (*TestApiOutput) GetNowTime ¶
func (m *TestApiOutput) GetNowTime() int64
func (*TestApiOutput) ProtoMessage ¶
func (*TestApiOutput) ProtoMessage()
func (*TestApiOutput) Reset ¶
func (m *TestApiOutput) Reset()
func (*TestApiOutput) String ¶
func (m *TestApiOutput) String() string
func (*TestApiOutput) XXX_DiscardUnknown ¶ added in v0.0.2
func (m *TestApiOutput) XXX_DiscardUnknown()
func (*TestApiOutput) XXX_Marshal ¶ added in v0.0.2
func (m *TestApiOutput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TestApiOutput) XXX_Merge ¶ added in v0.0.2
func (m *TestApiOutput) XXX_Merge(src proto.Message)
func (*TestApiOutput) XXX_Size ¶ added in v0.0.2
func (m *TestApiOutput) XXX_Size() int
func (*TestApiOutput) XXX_Unmarshal ¶ added in v0.0.2
func (m *TestApiOutput) XXX_Unmarshal(b []byte) error
type TestApiServer ¶
type TestApiServer interface {
Version(context.Context, *TestReq) (*TestApiOutput, error)
VersionTest(context.Context, *TestReq) (*TestApiOutput, error)
}
TestApiServer is the server API for TestApi service.
type TestApiV2Client ¶
type TestApiV2Client interface {
Version1(ctx context.Context, in *TestReq, opts ...grpc.CallOption) (*TestApiOutput, error)
VersionTest1(ctx context.Context, in *TestReq, opts ...grpc.CallOption) (*TestApiOutput, error)
}
TestApiV2Client is the client API for TestApiV2 service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func GetTestApiV2Client ¶
func GetTestApiV2Client(srv string, opts ...grpc.DialOption) (TestApiV2Client, error)
func NewTestApiV2Client ¶
func NewTestApiV2Client(cc *grpc.ClientConn) TestApiV2Client
type TestApiV2Server ¶
type TestApiV2Server interface {
Version1(context.Context, *TestReq) (*TestApiOutput, error)
VersionTest1(context.Context, *TestReq) (*TestApiOutput, error)
}
TestApiV2Server is the server API for TestApiV2 service.
type TestReq ¶
type TestReq struct {
Input string `protobuf:"bytes,1,opt,name=input,proto3" json:"input,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*TestReq) Descriptor ¶
func (*TestReq) ProtoMessage ¶
func (*TestReq) ProtoMessage()
func (*TestReq) XXX_DiscardUnknown ¶ added in v0.0.2
func (m *TestReq) XXX_DiscardUnknown()
func (*TestReq) XXX_Marshal ¶ added in v0.0.2
func (*TestReq) XXX_Unmarshal ¶ added in v0.0.2
type TransportClient ¶
type TransportClient interface {
TestStream(ctx context.Context, opts ...grpc.CallOption) (Transport_TestStreamClient, error)
TestStream1(ctx context.Context, opts ...grpc.CallOption) (Transport_TestStream1Client, error)
TestStream2(ctx context.Context, in *Message, opts ...grpc.CallOption) (Transport_TestStream2Client, error)
TestStream3(ctx context.Context, in *Message, opts ...grpc.CallOption) (*Message, error)
}
TransportClient is the client API for Transport service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func GetTransportClient ¶
func GetTransportClient(srv string, opts ...grpc.DialOption) (TransportClient, error)
func NewTransportClient ¶
func NewTransportClient(cc *grpc.ClientConn) TransportClient
type TransportServer ¶
type TransportServer interface {
TestStream(Transport_TestStreamServer) error
TestStream1(Transport_TestStream1Server) error
TestStream2(*Message, Transport_TestStream2Server) error
TestStream3(context.Context, *Message) (*Message, error)
}
TransportServer is the server API for Transport service.
type Transport_TestStream2Client ¶
type Transport_TestStream2Client interface {
Recv() (*Message, error)
grpc.ClientStream
}
type Transport_TestStream2Server ¶
type Transport_TestStream2Server interface {
Send(*Message) error
grpc.ServerStream
}
type UnimplementedTestApiServer ¶
type UnimplementedTestApiServer struct {
}
UnimplementedTestApiServer can be embedded to have forward compatible implementations.
func (*UnimplementedTestApiServer) Version ¶
func (*UnimplementedTestApiServer) Version(ctx context.Context, req *TestReq) (*TestApiOutput, error)
func (*UnimplementedTestApiServer) VersionTest ¶
func (*UnimplementedTestApiServer) VersionTest(ctx context.Context, req *TestReq) (*TestApiOutput, error)
type UnimplementedTestApiV2Server ¶
type UnimplementedTestApiV2Server struct {
}
UnimplementedTestApiV2Server can be embedded to have forward compatible implementations.
func (*UnimplementedTestApiV2Server) Version1 ¶
func (*UnimplementedTestApiV2Server) Version1(ctx context.Context, req *TestReq) (*TestApiOutput, error)
func (*UnimplementedTestApiV2Server) VersionTest1 ¶
func (*UnimplementedTestApiV2Server) VersionTest1(ctx context.Context, req *TestReq) (*TestApiOutput, error)
type UnimplementedTransportServer ¶
type UnimplementedTransportServer struct {
}
UnimplementedTransportServer can be embedded to have forward compatible implementations.
func (*UnimplementedTransportServer) TestStream ¶
func (*UnimplementedTransportServer) TestStream(srv Transport_TestStreamServer) error
func (*UnimplementedTransportServer) TestStream1 ¶
func (*UnimplementedTransportServer) TestStream1(srv Transport_TestStream1Server) error
func (*UnimplementedTransportServer) TestStream2 ¶
func (*UnimplementedTransportServer) TestStream2(req *Message, srv Transport_TestStream2Server) error