gpusher_srv_gateway

package
v0.0.0-...-02b4230 Latest Latest
Warning

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

 Go to latest Published: Sep 10, 2020 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterGatewayServer 

func RegisterGatewayServer(s *grpc.Server, srv GatewayServer)

Types

type CloseRequest 

type CloseRequest struct {
	AppId                int32    `protobuf:"varint,1,opt,name=AppId,proto3" json:"AppId,omitempty"`
	UUid                 string   `protobuf:"bytes,2,opt,name=UUid,proto3" json:"UUid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CloseRequest) Descriptor 

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

func (*CloseRequest) GetAppId 

func (m *CloseRequest) GetAppId() int32

func (*CloseRequest) GetUUid 

func (m *CloseRequest) GetUUid() string

func (*CloseRequest) ProtoMessage 

func (*CloseRequest) ProtoMessage()

func (*CloseRequest) Reset 

func (m *CloseRequest) Reset()

func (*CloseRequest) String 

func (m *CloseRequest) String() string

func (*CloseRequest) XXX_DiscardUnknown 

func (m *CloseRequest) XXX_DiscardUnknown()

func (*CloseRequest) XXX_Marshal 

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

func (*CloseRequest) XXX_Merge 

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

func (*CloseRequest) XXX_Size 

func (m *CloseRequest) XXX_Size() int

func (*CloseRequest) XXX_Unmarshal 

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

type GatewayClient 

type GatewayClient interface {
	New(ctx context.Context, in *NewRequest, opts ...grpc.CallOption) (*Respond, error)
	Close(ctx context.Context, in *CloseRequest, opts ...grpc.CallOption) (*Respond, error)
	PushOne(ctx context.Context, in *PushOneRequest, opts ...grpc.CallOption) (*Respond, error)
	PushApp(ctx context.Context, in *PushAppRequest, opts ...grpc.CallOption) (*Respond, error)
	PushAll(ctx context.Context, in *PushAllRequest, opts ...grpc.CallOption) (*Respond, error)
}

GatewayClient is the client API for Gateway service.

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

func NewGatewayClient 

func NewGatewayClient(cc *grpc.ClientConn) GatewayClient

type GatewayServer 

type GatewayServer interface {
	New(context.Context, *NewRequest) (*Respond, error)
	Close(context.Context, *CloseRequest) (*Respond, error)
	PushOne(context.Context, *PushOneRequest) (*Respond, error)
	PushApp(context.Context, *PushAppRequest) (*Respond, error)
	PushAll(context.Context, *PushAllRequest) (*Respond, error)
}

GatewayServer is the server API for Gateway service.

type NewRequest 

type NewRequest struct {
	AppId                int32    `protobuf:"varint,1,opt,name=AppId,proto3" json:"AppId,omitempty"`
	UUid                 string   `protobuf:"bytes,2,opt,name=UUid,proto3" json:"UUid,omitempty"`
	Key                  int32    `protobuf:"varint,3,opt,name=Key,proto3" json:"Key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NewRequest) Descriptor 

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

func (*NewRequest) GetAppId 

func (m *NewRequest) GetAppId() int32

func (*NewRequest) GetKey 

func (m *NewRequest) GetKey() int32

func (*NewRequest) GetUUid 

func (m *NewRequest) GetUUid() string

func (*NewRequest) ProtoMessage 

func (*NewRequest) ProtoMessage()

func (*NewRequest) Reset 

func (m *NewRequest) Reset()

func (*NewRequest) String 

func (m *NewRequest) String() string

func (*NewRequest) XXX_DiscardUnknown 

func (m *NewRequest) XXX_DiscardUnknown()

func (*NewRequest) XXX_Marshal 

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

func (*NewRequest) XXX_Merge 

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

func (*NewRequest) XXX_Size 

func (m *NewRequest) XXX_Size() int

func (*NewRequest) XXX_Unmarshal 

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

type PushAllRequest 

type PushAllRequest struct {
	MsgId                string   `protobuf:"bytes,1,opt,name=MsgId,proto3" json:"MsgId,omitempty"`
	Timestamp            string   `protobuf:"bytes,2,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	Content              string   `protobuf:"bytes,3,opt,name=Content,proto3" json:"Content,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PushAllRequest) Descriptor 

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

func (*PushAllRequest) GetContent 

func (m *PushAllRequest) GetContent() string

func (*PushAllRequest) GetMsgId 

func (m *PushAllRequest) GetMsgId() string

func (*PushAllRequest) GetTimestamp 

func (m *PushAllRequest) GetTimestamp() string

func (*PushAllRequest) ProtoMessage 

func (*PushAllRequest) ProtoMessage()

func (*PushAllRequest) Reset 

func (m *PushAllRequest) Reset()

func (*PushAllRequest) String 

func (m *PushAllRequest) String() string

func (*PushAllRequest) XXX_DiscardUnknown 

func (m *PushAllRequest) XXX_DiscardUnknown()

func (*PushAllRequest) XXX_Marshal 

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

func (*PushAllRequest) XXX_Merge 

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

func (*PushAllRequest) XXX_Size 

func (m *PushAllRequest) XXX_Size() int

func (*PushAllRequest) XXX_Unmarshal 

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

type PushAppRequest 

type PushAppRequest struct {
	AppId                int32    `protobuf:"varint,1,opt,name=AppId,proto3" json:"AppId,omitempty"`
	MsgId                string   `protobuf:"bytes,2,opt,name=MsgId,proto3" json:"MsgId,omitempty"`
	Timestamp            string   `protobuf:"bytes,3,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	Content              string   `protobuf:"bytes,4,opt,name=Content,proto3" json:"Content,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PushAppRequest) Descriptor 

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

func (*PushAppRequest) GetAppId 

func (m *PushAppRequest) GetAppId() int32

func (*PushAppRequest) GetContent 

func (m *PushAppRequest) GetContent() string

func (*PushAppRequest) GetMsgId 

func (m *PushAppRequest) GetMsgId() string

func (*PushAppRequest) GetTimestamp 

func (m *PushAppRequest) GetTimestamp() string

func (*PushAppRequest) ProtoMessage 

func (*PushAppRequest) ProtoMessage()

func (*PushAppRequest) Reset 

func (m *PushAppRequest) Reset()

func (*PushAppRequest) String 

func (m *PushAppRequest) String() string

func (*PushAppRequest) XXX_DiscardUnknown 

func (m *PushAppRequest) XXX_DiscardUnknown()

func (*PushAppRequest) XXX_Marshal 

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

func (*PushAppRequest) XXX_Merge 

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

func (*PushAppRequest) XXX_Size 

func (m *PushAppRequest) XXX_Size() int

func (*PushAppRequest) XXX_Unmarshal 

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

type PushOneRequest 

type PushOneRequest struct {
	AppId                int32    `protobuf:"varint,1,opt,name=AppId,proto3" json:"AppId,omitempty"`
	UUid                 string   `protobuf:"bytes,2,opt,name=UUid,proto3" json:"UUid,omitempty"`
	MsgId                string   `protobuf:"bytes,3,opt,name=MsgId,proto3" json:"MsgId,omitempty"`
	Timestamp            string   `protobuf:"bytes,4,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	Content              string   `protobuf:"bytes,5,opt,name=Content,proto3" json:"Content,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PushOneRequest) Descriptor 

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

func (*PushOneRequest) GetAppId 

func (m *PushOneRequest) GetAppId() int32

func (*PushOneRequest) GetContent 

func (m *PushOneRequest) GetContent() string

func (*PushOneRequest) GetMsgId 

func (m *PushOneRequest) GetMsgId() string

func (*PushOneRequest) GetTimestamp 

func (m *PushOneRequest) GetTimestamp() string

func (*PushOneRequest) GetUUid 

func (m *PushOneRequest) GetUUid() string

func (*PushOneRequest) ProtoMessage 

func (*PushOneRequest) ProtoMessage()

func (*PushOneRequest) Reset 

func (m *PushOneRequest) Reset()

func (*PushOneRequest) String 

func (m *PushOneRequest) String() string

func (*PushOneRequest) XXX_DiscardUnknown 

func (m *PushOneRequest) XXX_DiscardUnknown()

func (*PushOneRequest) XXX_Marshal 

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

func (*PushOneRequest) XXX_Merge 

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

func (*PushOneRequest) XXX_Size 

func (m *PushOneRequest) XXX_Size() int

func (*PushOneRequest) XXX_Unmarshal 

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

type Respond 

type Respond 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Respond) Descriptor 

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

func (*Respond) GetCode 

func (m *Respond) GetCode() int32

func (*Respond) GetMsg 

func (m *Respond) GetMsg() string

func (*Respond) ProtoMessage 

func (*Respond) ProtoMessage()

func (*Respond) Reset 

func (m *Respond) Reset()

func (*Respond) String 

func (m *Respond) String() string

func (*Respond) XXX_DiscardUnknown 

func (m *Respond) XXX_DiscardUnknown()

func (*Respond) XXX_Marshal 

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

func (*Respond) XXX_Merge 

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

func (*Respond) XXX_Size 

func (m *Respond) XXX_Size() int

func (*Respond) XXX_Unmarshal 

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

type UnimplementedGatewayServer 

type UnimplementedGatewayServer struct {
}

UnimplementedGatewayServer can be embedded to have forward compatible implementations.

func (*UnimplementedGatewayServer) Close 

func (*UnimplementedGatewayServer) Close(ctx context.Context, req *CloseRequest) (*Respond, error)

func (*UnimplementedGatewayServer) New 

func (*UnimplementedGatewayServer) New(ctx context.Context, req *NewRequest) (*Respond, error)

func (*UnimplementedGatewayServer) PushAll 

func (*UnimplementedGatewayServer) PushAll(ctx context.Context, req *PushAllRequest) (*Respond, error)

func (*UnimplementedGatewayServer) PushApp 

func (*UnimplementedGatewayServer) PushApp(ctx context.Context, req *PushAppRequest) (*Respond, error)

func (*UnimplementedGatewayServer) PushOne 

func (*UnimplementedGatewayServer) PushOne(ctx context.Context, req *PushOneRequest) (*Respond, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.