Documentation
¶
Index ¶
- Variables
- func RegisterRabbitServiceServer(s *grpc.Server, srv RabbitServiceServer)
- type EmptyResponse
- type Exchange
- type Exchange_KindGroup
- func (Exchange_KindGroup) Descriptor() protoreflect.EnumDescriptor
- func (x Exchange_KindGroup) Enum() *Exchange_KindGroup
- func (Exchange_KindGroup) EnumDescriptor() ([]byte, []int)deprecated
- func (x Exchange_KindGroup) Number() protoreflect.EnumNumber
- func (x Exchange_KindGroup) String() string
- func (Exchange_KindGroup) Type() protoreflect.EnumType
- type PushMessageRequest
- func (*PushMessageRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PushMessageRequest) GetExchange() *Exchange
- func (x *PushMessageRequest) GetKey() string
- func (x *PushMessageRequest) GetMessage() []byte
- func (*PushMessageRequest) ProtoMessage()
- func (x *PushMessageRequest) ProtoReflect() protoreflect.Message
- func (x *PushMessageRequest) Reset()
- func (x *PushMessageRequest) String() string
- type RabbitServiceClient
- type RabbitServiceServer
- type UnimplementedRabbitServiceServer
Constants ¶
This section is empty.
Variables ¶
View Source
var ( Exchange_KindGroup_name = map[int32]string{ 0: "direct", 1: "fanout", } Exchange_KindGroup_value = map[string]int32{ "direct": 0, "fanout": 1, } )
Enum value maps for Exchange_KindGroup.
View Source
var File_rabbit_proto protoreflect.FileDescriptor
Functions ¶
func RegisterRabbitServiceServer ¶
func RegisterRabbitServiceServer(s *grpc.Server, srv RabbitServiceServer)
Types ¶
type EmptyResponse ¶
type EmptyResponse struct {
// contains filtered or unexported fields
}
func (*EmptyResponse) Descriptor
deprecated
func (*EmptyResponse) Descriptor() ([]byte, []int)
Deprecated: Use EmptyResponse.ProtoReflect.Descriptor instead.
func (*EmptyResponse) ProtoMessage ¶
func (*EmptyResponse) ProtoMessage()
func (*EmptyResponse) ProtoReflect ¶
func (x *EmptyResponse) ProtoReflect() protoreflect.Message
func (*EmptyResponse) Reset ¶
func (x *EmptyResponse) Reset()
func (*EmptyResponse) String ¶
func (x *EmptyResponse) String() string
type Exchange ¶
type Exchange struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Kind Exchange_KindGroup `protobuf:"varint,2,opt,name=kind,proto3,enum=rabbit.Exchange_KindGroup" json:"kind,omitempty"` // 类型
// contains filtered or unexported fields
}
func (*Exchange) Descriptor
deprecated
func (*Exchange) GetKind ¶
func (x *Exchange) GetKind() Exchange_KindGroup
func (*Exchange) ProtoMessage ¶
func (*Exchange) ProtoMessage()
func (*Exchange) ProtoReflect ¶
func (x *Exchange) ProtoReflect() protoreflect.Message
type Exchange_KindGroup ¶
type Exchange_KindGroup int32
const ( Exchange_direct Exchange_KindGroup = 0 Exchange_fanout Exchange_KindGroup = 1 )
func (Exchange_KindGroup) Descriptor ¶
func (Exchange_KindGroup) Descriptor() protoreflect.EnumDescriptor
func (Exchange_KindGroup) Enum ¶
func (x Exchange_KindGroup) Enum() *Exchange_KindGroup
func (Exchange_KindGroup) EnumDescriptor
deprecated
func (Exchange_KindGroup) EnumDescriptor() ([]byte, []int)
Deprecated: Use Exchange_KindGroup.Descriptor instead.
func (Exchange_KindGroup) Number ¶
func (x Exchange_KindGroup) Number() protoreflect.EnumNumber
func (Exchange_KindGroup) String ¶
func (x Exchange_KindGroup) String() string
func (Exchange_KindGroup) Type ¶
func (Exchange_KindGroup) Type() protoreflect.EnumType
type PushMessageRequest ¶
type PushMessageRequest struct {
Exchange *Exchange `protobuf:"bytes,1,opt,name=exchange,proto3" json:"exchange,omitempty"`
Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
Message []byte `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
// contains filtered or unexported fields
}
func (*PushMessageRequest) Descriptor
deprecated
func (*PushMessageRequest) Descriptor() ([]byte, []int)
Deprecated: Use PushMessageRequest.ProtoReflect.Descriptor instead.
func (*PushMessageRequest) GetExchange ¶
func (x *PushMessageRequest) GetExchange() *Exchange
func (*PushMessageRequest) GetKey ¶
func (x *PushMessageRequest) GetKey() string
func (*PushMessageRequest) GetMessage ¶
func (x *PushMessageRequest) GetMessage() []byte
func (*PushMessageRequest) ProtoMessage ¶
func (*PushMessageRequest) ProtoMessage()
func (*PushMessageRequest) ProtoReflect ¶
func (x *PushMessageRequest) ProtoReflect() protoreflect.Message
func (*PushMessageRequest) Reset ¶
func (x *PushMessageRequest) Reset()
func (*PushMessageRequest) String ¶
func (x *PushMessageRequest) String() string
type RabbitServiceClient ¶
type RabbitServiceClient interface {
Push(ctx context.Context, in *PushMessageRequest, opts ...grpc.CallOption) (*EmptyResponse, error)
}
RabbitServiceClient is the client API for RabbitService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewClient ¶
func NewClient(target string) RabbitServiceClient
func NewRabbitServiceClient ¶
func NewRabbitServiceClient(cc grpc.ClientConnInterface) RabbitServiceClient
type RabbitServiceServer ¶
type RabbitServiceServer interface {
Push(context.Context, *PushMessageRequest) (*EmptyResponse, error)
}
RabbitServiceServer is the server API for RabbitService service.
type UnimplementedRabbitServiceServer ¶
type UnimplementedRabbitServiceServer struct {
}
UnimplementedRabbitServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedRabbitServiceServer) Push ¶
func (*UnimplementedRabbitServiceServer) Push(context.Context, *PushMessageRequest) (*EmptyResponse, error)
Source Files
Click to show internal directories.
Click to hide internal directories.