PandaX-Go资源

//------------------------------------------------------------------------------ // Copyright (c) 2020-2022 EMQ Technologies Co., Ltd. All Rights Reserved. // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. // You may obtain a copy of the License at // // http://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, software // distributed under the License is distributed on an "AS IS" BASIS, // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. //------------------------------------------------------------------------------ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: // protoc-gen-go v1.28.1 // protoc v3.18.1 // source: protobuf/exhook.proto // The exhook proto version should be fixed as `v2` in EMQX v5.x // to make sure the exhook proto version is compatible package exhook import ( protoreflect "google.golang.org/protobuf/reflect/protoreflect" protoimpl "google.golang.org/protobuf/runtime/protoimpl" reflect "reflect" sync "sync" ) const ( // Verify that this generated code is sufficiently up-to-date. _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) // Verify that runtime/protoimpl is sufficiently up-to-date. _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) ) type ClientAuthorizeRequest_AuthorizeReqType int32 const ( ClientAuthorizeRequest_PUBLISH ClientAuthorizeRequest_AuthorizeReqType = 0 ClientAuthorizeRequest_SUBSCRIBE ClientAuthorizeRequest_AuthorizeReqType = 1 ) // Enum value maps for ClientAuthorizeRequest_AuthorizeReqType. var ( ClientAuthorizeRequest_AuthorizeReqType_name = map[int32]string{ 0: "PUBLISH", 1: "SUBSCRIBE", } ClientAuthorizeRequest_AuthorizeReqType_value = map[string]int32{ "PUBLISH": 0, "SUBSCRIBE": 1, } ) func (x ClientAuthorizeRequest_AuthorizeReqType) Enum() *ClientAuthorizeRequest_AuthorizeReqType { p := new(ClientAuthorizeRequest_AuthorizeReqType) *p = x return p } func (x ClientAuthorizeRequest_AuthorizeReqType) String() string { return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) } func (ClientAuthorizeRequest_AuthorizeReqType) Descriptor() protoreflect.EnumDescriptor { return file_protobuf_exhook_proto_enumTypes[0].Descriptor() } func (ClientAuthorizeRequest_AuthorizeReqType) Type() protoreflect.EnumType { return &file_protobuf_exhook_proto_enumTypes[0] } func (x ClientAuthorizeRequest_AuthorizeReqType) Number() protoreflect.EnumNumber { return protoreflect.EnumNumber(x) } // Deprecated: Use ClientAuthorizeRequest_AuthorizeReqType.Descriptor instead. func (ClientAuthorizeRequest_AuthorizeReqType) EnumDescriptor() ([]byte, []int) { return file_protobuf_exhook_proto_rawDescGZIP(), []int{7, 0} } // The responded value type // - contiune: Use the responded value and execute the next hook // - ignore: Ignore the responded value // - stop_and_return: Use the responded value and stop the chain executing type ValuedResponse_ResponsedType int32 const ( ValuedResponse_CONTINUE ValuedResponse_ResponsedType = 0 ValuedResponse_IGNORE ValuedResponse_ResponsedType = 1 ValuedResponse_STOP_AND_RETURN ValuedResponse_ResponsedType = 2 ) // Enum value maps for ValuedResponse_ResponsedType. var ( ValuedResponse_ResponsedType_name = map[int32]string{ 0: "CONTINUE", 1: "IGNORE", 2: "STOP_AND_RETURN", } ValuedResponse_ResponsedType_value = map[string]int32{ "CONTINUE": 0, "IGNORE": 1, "STOP_AND_RETURN": 2, } ) func (x ValuedResponse_ResponsedType) Enum() *ValuedResponse_ResponsedType { p := new(ValuedResponse_ResponsedType) *p = x return p } func (x ValuedResponse_ResponsedType) String() string { return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) } func (ValuedResponse_ResponsedType) Descriptor() protoreflect.EnumDescriptor { return file_protobuf_exhook_proto_enumTypes[1].Descriptor() } func (ValuedResponse_ResponsedType) Type() protoreflect.EnumType { return &file_protobuf_exhook_proto_enumTypes[1] } func (x ValuedResponse_ResponsedType) Number() protoreflect.EnumNumber { return protoreflect.EnumNumber(x) } // Deprecated: Use ValuedResponse_ResponsedType.Descriptor instead. func (ValuedResponse_ResponsedType) EnumDescriptor() ([]byte, []int) { return file_protobuf_exhook_proto_rawDescGZIP(), []int{22, 0} } type ProviderLoadedRequest struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields Broker *BrokerInfo `protobuf:"bytes,1,opt,name=broker,proto3" json:"broker,omitempty"` Meta *RequestMeta `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"` } func (x *ProviderLoadedRequest) Reset() { *x = ProviderLoadedRequest{} if protoimpl.UnsafeEnabled { mi := &file_protobuf_exhook_proto_msgTypes[0] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *ProviderLoadedRequest) String() string { return protoimpl.X.MessageStringOf(x) } func (*ProviderLoadedRequest) ProtoMessage() {} func (x *ProviderLoadedRequest) ProtoReflect() protoreflect.Message { mi := &file_protobuf_exhook_proto_msgTypes[0] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use ProviderLoadedRequest.ProtoReflect.Descriptor instead. func (*ProviderLoadedRequest) Descriptor() ([]byte, []int) { return file_protobuf_exhook_proto_rawDescGZIP(), []int{0} } func (x *ProviderLoadedRequest) GetBroker() *BrokerInfo { if x != nil { return x.Broker } return nil } func (x *ProviderLoadedRequest) GetMeta() *RequestMeta { if x != nil { return x.Meta } return nil } type ProviderUnloadedRequest struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields Meta *RequestMeta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"` } func (x *ProviderUnloadedRequest) Reset() { *x = ProviderUnloadedRequest{} if protoimpl.UnsafeEnabled { mi := &file_protobuf_exhook_proto_msgTypes[1] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } } func (x *ProviderUnloadedRequest) String() string { return protoimpl.X.MessageStringOf(x) } func (*ProviderUnloadedRequest) ProtoMessage() {} func (x *ProviderUnloadedRequest) ProtoReflect() protoreflect.Message { mi := &file_protobuf_exhook_proto_msgTypes[1] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { ms.StoreMessageInfo(mi) } return ms } return mi.MessageOf(x) } // Deprecated: Use ProviderUnloadedRequest.ProtoReflect.Descriptor instead. func (*ProviderUnloadedRequest) Descriptor() ([]byte, []int) { return file_protobuf_exhook_proto_rawDescGZIP(), []int{1} } func (x *ProviderUnloadedRequest) GetMeta() *RequestMeta { if x != nil { return x.Meta } return nil } type ClientConnectRequest struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields Conninfo *ConnInfo `protobuf:"bytes,1,opt,name=conninfo,proto3" json:"conninfo,omitempty"` // MQTT CONNECT packet's properties (MQTT v5.0) // // It should be empty on MQTT v3.1.1/v3.1 or others protocol Props []*Property `protobuf:"bytes,2,rep,name=props,proto3" json:"props,omitempty"` Meta *RequestMeta `protobuf:"bytes,3,opt,name=meta,proto3" json:"meta,omitempty"` } func (x *ClientConnectRequest) Reset() { *x = ClientConnectRequest{} if protoimpl.UnsafeEnabled { mi := &file_protobuf_exhook_proto_msgTypes[2] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x