hello

package
v0.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 11, 2021 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterTestApiGateway added in v0.0.2

func RegisterTestApiGateway(srv string, g fiber.Router, opts ...grpc.DialOption) error

func RegisterTestApiServer

func RegisterTestApiServer(s *grpc.Server, srv TestApiServer)

func RegisterTestApiV2Gateway added in v0.0.2

func RegisterTestApiV2Gateway(srv string, g fiber.Router, opts ...grpc.DialOption) error

func RegisterTestApiV2Server

func RegisterTestApiV2Server(s *grpc.Server, srv TestApiV2Server)

func RegisterTransportGateway added in v0.0.2

func RegisterTransportGateway(srv string, g fiber.Router, opts ...grpc.DialOption) error

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) Descriptor() ([]byte, []int)

func (*Message) GetBody

func (m *Message) GetBody() []byte

func (*Message) GetHeader

func (m *Message) GetHeader() map[string]string

func (*Message) ProtoMessage

func (*Message) ProtoMessage()

func (*Message) Reset

func (m *Message) Reset()

func (*Message) String

func (m *Message) String() string

func (*Message) XXX_DiscardUnknown added in v0.0.2

func (m *Message) XXX_DiscardUnknown()

func (*Message) XXX_Marshal added in v0.0.2

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

func (*Message) XXX_Merge added in v0.0.2

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

func (*Message) XXX_Size added in v0.0.2

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal added in v0.0.2

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

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) Descriptor() ([]byte, []int)

func (*TestReq) GetInput

func (m *TestReq) GetInput() string

func (*TestReq) ProtoMessage

func (*TestReq) ProtoMessage()

func (*TestReq) Reset

func (m *TestReq) Reset()

func (*TestReq) String

func (m *TestReq) String() string

func (*TestReq) XXX_DiscardUnknown added in v0.0.2

func (m *TestReq) XXX_DiscardUnknown()

func (*TestReq) XXX_Marshal added in v0.0.2

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

func (*TestReq) XXX_Merge added in v0.0.2

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

func (*TestReq) XXX_Size added in v0.0.2

func (m *TestReq) XXX_Size() int

func (*TestReq) XXX_Unmarshal added in v0.0.2

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

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_TestStream1Client

type Transport_TestStream1Client interface {
	Send(*Message) error
	CloseAndRecv() (*Message, error)
	grpc.ClientStream
}

type Transport_TestStream1Server

type Transport_TestStream1Server interface {
	SendAndClose(*Message) error
	Recv() (*Message, error)
	grpc.ServerStream
}

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 Transport_TestStreamClient

type Transport_TestStreamClient interface {
	Send(*Message) error
	Recv() (*Message, error)
	grpc.ClientStream
}

type Transport_TestStreamServer

type Transport_TestStreamServer interface {
	Send(*Message) error
	Recv() (*Message, error)
	grpc.ServerStream
}

type UnimplementedTestApiServer

type UnimplementedTestApiServer struct {
}

UnimplementedTestApiServer can be embedded to have forward compatible implementations.

func (*UnimplementedTestApiServer) Version

func (*UnimplementedTestApiServer) VersionTest

type UnimplementedTestApiV2Server

type UnimplementedTestApiV2Server struct {
}

UnimplementedTestApiV2Server can be embedded to have forward compatible implementations.

func (*UnimplementedTestApiV2Server) Version1

func (*UnimplementedTestApiV2Server) VersionTest1

type UnimplementedTransportServer

type UnimplementedTransportServer struct {
}

UnimplementedTransportServer can be embedded to have forward compatible implementations.

func (*UnimplementedTransportServer) TestStream

func (*UnimplementedTransportServer) TestStream1

func (*UnimplementedTransportServer) TestStream2

func (*UnimplementedTransportServer) TestStream3

func (*UnimplementedTransportServer) TestStream3(ctx context.Context, req *Message) (*Message, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL