v1

package
v0.0.0-...-cba6ad5 Latest Latest
Warning

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

 Go to latest Published: Jul 28, 2022 License: MIT Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Error_name = map[int32]string{
		0:  "ERR_UNKNOWN",
		1:  "ERR_OK_STATUS",
		2:  "ERR_NOT_FOUND",
		3:  "ERR_INVALID_ARGUMENT",
		4:  "ERR_INTERNAL_STORE",
		5:  "ERR_INTERNAL_ERROR",
		6:  "ERR_RULE_NOT_FOUND",
		7:  "ERR_FORBIDDEN",
		8:  "ERR_UNAUTHORIZED",
		9:  "ERR_FAILED_KAFKA_CONNECTION",
		10: "ERR_OK_KAFKA_CONNECTION",
		11: "ERR_DUPLICATE_CREATE",
		12: "ERR_CANT_DELETE_RUNNING_RULE",
		13: "ERR_FAILED_MYSQL_CONNECTION",
		14: "ERR_FAILED_CLICKHOUSE_CONNECTION",
		15: "ERR_FAILED_SINK_INFO",
		16: "ERR_FAILED_MAP_INFO",
		17: "ERR_FAILED_TABLE_INFO",
		18: "ERR_DUPLICATE_NAME",
		19: "ERR_DUPLICATE_DEVICE",
		20: "ERR_INVALID_RULE",
		21: "ERR_FAILED_INFLUXDB_CONNECTION",
	}
	Error_value = map[string]int32{
		"ERR_UNKNOWN":                      0,
		"ERR_OK_STATUS":                    1,
		"ERR_NOT_FOUND":                    2,
		"ERR_INVALID_ARGUMENT":             3,
		"ERR_INTERNAL_STORE":               4,
		"ERR_INTERNAL_ERROR":               5,
		"ERR_RULE_NOT_FOUND":               6,
		"ERR_FORBIDDEN":                    7,
		"ERR_UNAUTHORIZED":                 8,
		"ERR_FAILED_KAFKA_CONNECTION":      9,
		"ERR_OK_KAFKA_CONNECTION":          10,
		"ERR_DUPLICATE_CREATE":             11,
		"ERR_CANT_DELETE_RUNNING_RULE":     12,
		"ERR_FAILED_MYSQL_CONNECTION":      13,
		"ERR_FAILED_CLICKHOUSE_CONNECTION": 14,
		"ERR_FAILED_SINK_INFO":             15,
		"ERR_FAILED_MAP_INFO":              16,
		"ERR_FAILED_TABLE_INFO":            17,
		"ERR_DUPLICATE_NAME":               18,
		"ERR_DUPLICATE_DEVICE":             19,
		"ERR_INVALID_RULE":                 20,
		"ERR_FAILED_INFLUXDB_CONNECTION":   21,
	}
)

Enum value maps for Error.

View Source 
var File_api_rule_v1_dto_rule_proto protoreflect.FileDescriptor
View Source 
var File_api_rule_v1_error_proto protoreflect.FileDescriptor
View Source 
var File_api_rule_v1_wrappers_proto protoreflect.FileDescriptor
View Source 
var Rules_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.rule.Rules",
	HandlerType: (*RulesServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RuleCreate",
			Handler:    _Rules_RuleCreate_Handler,
		},
		{
			MethodName: "RuleUpdate",
			Handler:    _Rules_RuleUpdate_Handler,
		},
		{
			MethodName: "RuleDelete",
			Handler:    _Rules_RuleDelete_Handler,
		},
		{
			MethodName: "RuleGet",
			Handler:    _Rules_RuleGet_Handler,
		},
		{
			MethodName: "RuleQuery",
			Handler:    _Rules_RuleQuery_Handler,
		},
		{
			MethodName: "RuleStatusSwitch",
			Handler:    _Rules_RuleStatusSwitch_Handler,
		},
		{
			MethodName: "GetRuleDevicesID",
			Handler:    _Rules_GetRuleDevicesID_Handler,
		},
		{
			MethodName: "AddDevicesToRule",
			Handler:    _Rules_AddDevicesToRule_Handler,
		},
		{
			MethodName: "RemoveDevicesFromRule",
			Handler:    _Rules_RemoveDevicesFromRule_Handler,
		},
		{
			MethodName: "RemoveDeviceFromAllRule",
			Handler:    _Rules_RemoveDeviceFromAllRule_Handler,
		},
		{
			MethodName: "GetRuleDevices",
			Handler:    _Rules_GetRuleDevices_Handler,
		},
		{
			MethodName: "CreateRuleTarget",
			Handler:    _Rules_CreateRuleTarget_Handler,
		},
		{
			MethodName: "UpdateRuleTarget",
			Handler:    _Rules_UpdateRuleTarget_Handler,
		},
		{
			MethodName: "TestConnectToKafka",
			Handler:    _Rules_TestConnectToKafka_Handler,
		},
		{
			MethodName: "ActionVerify",
			Handler:    _Rules_ActionVerify_Handler,
		},
		{
			MethodName: "TableList",
			Handler:    _Rules_TableList_Handler,
		},
		{
			MethodName: "GetTableDetails",
			Handler:    _Rules_GetTableDetails_Handler,
		},
		{
			MethodName: "GetTableMap",
			Handler:    _Rules_GetTableMap_Handler,
		},
		{
			MethodName: "UpdateTableMap",
			Handler:    _Rules_UpdateTableMap_Handler,
		},
		{
			MethodName: "ListRuleTarget",
			Handler:    _Rules_ListRuleTarget_Handler,
		},
		{
			MethodName: "DeleteRuleTarget",
			Handler:    _Rules_DeleteRuleTarget_Handler,
		},
		{
			MethodName: "ErrSubscribe",
			Handler:    _Rules_ErrSubscribe_Handler,
		},
		{
			MethodName: "ChangeErrSubscribe",
			Handler:    _Rules_ChangeErrSubscribe_Handler,
		},
		{
			MethodName: "ErrUnsubscribe",
			Handler:    _Rules_ErrUnsubscribe_Handler,
		},
		{
			MethodName: "RuleSQLUpdate",
			Handler:    _Rules_RuleSQLUpdate_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/rule/v1/dto_rule.proto",
}

Rules_ServiceDesc is the grpc.ServiceDesc for Rules service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func ErrCantDeleteRunningRule 

func ErrCantDeleteRunningRule() errors.Error

func ErrDuplicateCreate 

func ErrDuplicateCreate() errors.Error

func ErrDuplicateDevice 

func ErrDuplicateDevice() errors.Error

func ErrDuplicateName 

func ErrDuplicateName() errors.Error

func ErrFailedClickhouseConnection 

func ErrFailedClickhouseConnection() errors.Error

func ErrFailedInfluxdbConnection 

func ErrFailedInfluxdbConnection() errors.Error

func ErrFailedKafkaConnection 

func ErrFailedKafkaConnection() errors.Error

func ErrFailedMapInfo 

func ErrFailedMapInfo() errors.Error

func ErrFailedMysqlConnection 

func ErrFailedMysqlConnection() errors.Error

func ErrFailedSinkInfo 

func ErrFailedSinkInfo() errors.Error

func ErrFailedTableInfo 

func ErrFailedTableInfo() errors.Error

func ErrForbidden 

func ErrForbidden() errors.Error

func ErrInternalError 

func ErrInternalError() errors.Error

func ErrInternalStore 

func ErrInternalStore() errors.Error

func ErrInvalidArgument 

func ErrInvalidArgument() errors.Error

func ErrInvalidRule 

func ErrInvalidRule() errors.Error

func ErrNotFound 

func ErrNotFound() errors.Error

func ErrOkKafkaConnection 

func ErrOkKafkaConnection() errors.Error

func ErrOkStatus 

func ErrOkStatus() errors.Error

func ErrRuleNotFound 

func ErrRuleNotFound() errors.Error

func ErrUnauthorized 

func ErrUnauthorized() errors.Error

func ErrUnknown 

func ErrUnknown() errors.Error

func RegisterRulesHTTPServer 

func RegisterRulesHTTPServer(container *go_restful.Container, srv RulesHTTPServer)

func RegisterRulesServer 

func RegisterRulesServer(s grpc.ServiceRegistrar, srv RulesServer)

Types

type ASGetTableDetailsReq 

type ASGetTableDetailsReq struct {
	Id        string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	TableName string `protobuf:"bytes,3,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	// contains filtered or unexported fields
}

get table details.

func (*ASGetTableDetailsReq) Descriptor deprecated 

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

Deprecated: Use ASGetTableDetailsReq.ProtoReflect.Descriptor instead.

func (*ASGetTableDetailsReq) GetId 

func (x *ASGetTableDetailsReq) GetId() string

func (*ASGetTableDetailsReq) GetTableName 

func (x *ASGetTableDetailsReq) GetTableName() string

func (*ASGetTableDetailsReq) ProtoMessage 

func (*ASGetTableDetailsReq) ProtoMessage()

func (*ASGetTableDetailsReq) ProtoReflect 

func (x *ASGetTableDetailsReq) ProtoReflect() protoreflect.Message

func (*ASGetTableDetailsReq) Reset 

func (x *ASGetTableDetailsReq) Reset()

func (*ASGetTableDetailsReq) String 

func (x *ASGetTableDetailsReq) String() string

type ASGetTableDetailsResp 

type ASGetTableDetailsResp struct {
	Table *Table `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	// contains filtered or unexported fields
}

func (*ASGetTableDetailsResp) Descriptor deprecated 

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

Deprecated: Use ASGetTableDetailsResp.ProtoReflect.Descriptor instead.

func (*ASGetTableDetailsResp) GetTable 

func (x *ASGetTableDetailsResp) GetTable() *Table

func (*ASGetTableDetailsResp) ProtoMessage 

func (*ASGetTableDetailsResp) ProtoMessage()

func (*ASGetTableDetailsResp) ProtoReflect 

func (x *ASGetTableDetailsResp) ProtoReflect() protoreflect.Message

func (*ASGetTableDetailsResp) Reset 

func (x *ASGetTableDetailsResp) Reset()

func (*ASGetTableDetailsResp) String 

func (x *ASGetTableDetailsResp) String() string

type ASGetTableMapReq 

type ASGetTableMapReq struct {
	Id        string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	TableName string `protobuf:"bytes,3,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	// contains filtered or unexported fields
}

get table map

func (*ASGetTableMapReq) Descriptor deprecated 

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

Deprecated: Use ASGetTableMapReq.ProtoReflect.Descriptor instead.

func (*ASGetTableMapReq) GetId 

func (x *ASGetTableMapReq) GetId() string

func (*ASGetTableMapReq) GetTableName 

func (x *ASGetTableMapReq) GetTableName() string

func (*ASGetTableMapReq) ProtoMessage 

func (*ASGetTableMapReq) ProtoMessage()

func (*ASGetTableMapReq) ProtoReflect 

func (x *ASGetTableMapReq) ProtoReflect() protoreflect.Message

func (*ASGetTableMapReq) Reset 

func (x *ASGetTableMapReq) Reset()

func (*ASGetTableMapReq) String 

func (x *ASGetTableMapReq) String() string

type ASGetTableMapResp 

type ASGetTableMapResp struct {
	Id          string      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	TableName   string      `protobuf:"bytes,2,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	TableFields []*Field    `protobuf:"bytes,3,rep,name=table_fields,json=tableFields,proto3" json:"table_fields,omitempty"`
	MapFields   []*MapField `protobuf:"bytes,4,rep,name=map_fields,json=mapFields,proto3" json:"map_fields,omitempty"`
	// contains filtered or unexported fields
}

func (*ASGetTableMapResp) Descriptor deprecated 

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

Deprecated: Use ASGetTableMapResp.ProtoReflect.Descriptor instead.

func (*ASGetTableMapResp) GetId 

func (x *ASGetTableMapResp) GetId() string

func (*ASGetTableMapResp) GetMapFields 

func (x *ASGetTableMapResp) GetMapFields() []*MapField

func (*ASGetTableMapResp) GetTableFields 

func (x *ASGetTableMapResp) GetTableFields() []*Field

func (*ASGetTableMapResp) GetTableName 

func (x *ASGetTableMapResp) GetTableName() string

func (*ASGetTableMapResp) ProtoMessage 

func (*ASGetTableMapResp) ProtoMessage()

func (*ASGetTableMapResp) ProtoReflect 

func (x *ASGetTableMapResp) ProtoReflect() protoreflect.Message

func (*ASGetTableMapResp) Reset 

func (x *ASGetTableMapResp) Reset()

func (*ASGetTableMapResp) String 

func (x *ASGetTableMapResp) String() string

type ASTableListReq 

type ASTableListReq struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

table list

func (*ASTableListReq) Descriptor deprecated 

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

Deprecated: Use ASTableListReq.ProtoReflect.Descriptor instead.

func (*ASTableListReq) GetId 

func (x *ASTableListReq) GetId() string

func (*ASTableListReq) ProtoMessage 

func (*ASTableListReq) ProtoMessage()

func (*ASTableListReq) ProtoReflect 

func (x *ASTableListReq) ProtoReflect() protoreflect.Message

func (*ASTableListReq) Reset 

func (x *ASTableListReq) Reset()

func (*ASTableListReq) String 

func (x *ASTableListReq) String() string

type ASTableListResp 

type ASTableListResp struct {
	Tables []*Table `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"`
	// contains filtered or unexported fields
}

func (*ASTableListResp) Descriptor deprecated 

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

Deprecated: Use ASTableListResp.ProtoReflect.Descriptor instead.

func (*ASTableListResp) GetTables 

func (x *ASTableListResp) GetTables() []*Table

func (*ASTableListResp) ProtoMessage 

func (*ASTableListResp) ProtoMessage()

func (*ASTableListResp) ProtoReflect 

func (x *ASTableListResp) ProtoReflect() protoreflect.Message

func (*ASTableListResp) Reset 

func (x *ASTableListResp) Reset()

func (*ASTableListResp) String 

func (x *ASTableListResp) String() string

type ASUpdateTableMapReq 

type ASUpdateTableMapReq struct {
	Id        string      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	TargetId  string      `protobuf:"bytes,2,opt,name=target_id,json=targetId,proto3" json:"target_id,omitempty"`
	TableName string      `protobuf:"bytes,3,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	Fields    []*MapField `protobuf:"bytes,5,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

update table map.

func (*ASUpdateTableMapReq) Descriptor deprecated 

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

Deprecated: Use ASUpdateTableMapReq.ProtoReflect.Descriptor instead.

func (*ASUpdateTableMapReq) GetFields 

func (x *ASUpdateTableMapReq) GetFields() []*MapField

func (*ASUpdateTableMapReq) GetId 

func (x *ASUpdateTableMapReq) GetId() string

func (*ASUpdateTableMapReq) GetTableName 

func (x *ASUpdateTableMapReq) GetTableName() string

func (*ASUpdateTableMapReq) GetTargetId 

func (x *ASUpdateTableMapReq) GetTargetId() string

func (*ASUpdateTableMapReq) ProtoMessage 

func (*ASUpdateTableMapReq) ProtoMessage()

func (*ASUpdateTableMapReq) ProtoReflect 

func (x *ASUpdateTableMapReq) ProtoReflect() protoreflect.Message

func (*ASUpdateTableMapReq) Reset 

func (x *ASUpdateTableMapReq) Reset()

func (*ASUpdateTableMapReq) String 

func (x *ASUpdateTableMapReq) String() string

type ASUpdateTableMapResp 

type ASUpdateTableMapResp struct {
	Id        string      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	TargetId  string      `protobuf:"bytes,2,opt,name=target_id,json=targetId,proto3" json:"target_id,omitempty"`
	TableName string      `protobuf:"bytes,3,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	Fields    []*MapField `protobuf:"bytes,4,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

func (*ASUpdateTableMapResp) Descriptor deprecated 

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

Deprecated: Use ASUpdateTableMapResp.ProtoReflect.Descriptor instead.

func (*ASUpdateTableMapResp) GetFields 

func (x *ASUpdateTableMapResp) GetFields() []*MapField

func (*ASUpdateTableMapResp) GetId 

func (x *ASUpdateTableMapResp) GetId() string

func (*ASUpdateTableMapResp) GetTableName 

func (x *ASUpdateTableMapResp) GetTableName() string

func (*ASUpdateTableMapResp) GetTargetId 

func (x *ASUpdateTableMapResp) GetTargetId() string

func (*ASUpdateTableMapResp) ProtoMessage 

func (*ASUpdateTableMapResp) ProtoMessage()

func (*ASUpdateTableMapResp) ProtoReflect 

func (x *ASUpdateTableMapResp) ProtoReflect() protoreflect.Message

func (*ASUpdateTableMapResp) Reset 

func (x *ASUpdateTableMapResp) Reset()

func (*ASUpdateTableMapResp) String 

func (x *ASUpdateTableMapResp) String() string

type ASVerifyReq 

type ASVerifyReq struct {
	SinkType string            `protobuf:"bytes,1,opt,name=sink_type,json=sinkType,proto3" json:"sink_type,omitempty"`
	Urls     string            `protobuf:"bytes,2,opt,name=urls,proto3" json:"urls,omitempty"`
	Meta     map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

verify.

func (*ASVerifyReq) Descriptor deprecated 

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

Deprecated: Use ASVerifyReq.ProtoReflect.Descriptor instead.

func (*ASVerifyReq) GetMeta 

func (x *ASVerifyReq) GetMeta() map[string]string

func (*ASVerifyReq) GetSinkType 

func (x *ASVerifyReq) GetSinkType() string

func (*ASVerifyReq) GetUrls 

func (x *ASVerifyReq) GetUrls() string

func (*ASVerifyReq) ProtoMessage 

func (*ASVerifyReq) ProtoMessage()

func (*ASVerifyReq) ProtoReflect 

func (x *ASVerifyReq) ProtoReflect() protoreflect.Message

func (*ASVerifyReq) Reset 

func (x *ASVerifyReq) Reset()

func (*ASVerifyReq) String 

func (x *ASVerifyReq) String() string

type ASVerifyResp 

type ASVerifyResp struct {
	Id    string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Types []string `protobuf:"bytes,2,rep,name=types,proto3" json:"types,omitempty"`
	// contains filtered or unexported fields
}

func (*ASVerifyResp) Descriptor deprecated 

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

Deprecated: Use ASVerifyResp.ProtoReflect.Descriptor instead.

func (*ASVerifyResp) GetId 

func (x *ASVerifyResp) GetId() string

func (*ASVerifyResp) GetTypes 

func (x *ASVerifyResp) GetTypes() []string

func (*ASVerifyResp) ProtoMessage 

func (*ASVerifyResp) ProtoMessage()

func (*ASVerifyResp) ProtoReflect 

func (x *ASVerifyResp) ProtoReflect() protoreflect.Message

func (*ASVerifyResp) Reset 

func (x *ASVerifyResp) Reset()

func (*ASVerifyResp) String 

func (x *ASVerifyResp) String() string

type AddDevicesToRuleReq 

type AddDevicesToRuleReq struct {
	Id         uint64   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	DevicesIds []string `protobuf:"bytes,2,rep,name=devices_ids,json=devicesIds,proto3" json:"devices_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*AddDevicesToRuleReq) Descriptor deprecated 

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

Deprecated: Use AddDevicesToRuleReq.ProtoReflect.Descriptor instead.

func (*AddDevicesToRuleReq) GetDevicesIds 

func (x *AddDevicesToRuleReq) GetDevicesIds() []string

func (*AddDevicesToRuleReq) GetId 

func (x *AddDevicesToRuleReq) GetId() uint64

func (*AddDevicesToRuleReq) ProtoMessage 

func (*AddDevicesToRuleReq) ProtoMessage()

func (*AddDevicesToRuleReq) ProtoReflect 

func (x *AddDevicesToRuleReq) ProtoReflect() protoreflect.Message

func (*AddDevicesToRuleReq) Reset 

func (x *AddDevicesToRuleReq) Reset()

func (*AddDevicesToRuleReq) String 

func (x *AddDevicesToRuleReq) String() string

type Bool 

type Bool struct {
	Value bool `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Bool) Descriptor deprecated 

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

Deprecated: Use Bool.ProtoReflect.Descriptor instead.

func (*Bool) GetValue 

func (x *Bool) GetValue() bool

func (*Bool) ProtoMessage 

func (*Bool) ProtoMessage()

func (*Bool) ProtoReflect 

func (x *Bool) ProtoReflect() protoreflect.Message

func (*Bool) Reset 

func (x *Bool) Reset()

func (*Bool) String 

func (x *Bool) String() string

type ChangeErrSubscribeReq 

type ChangeErrSubscribeReq struct {
	Id          uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	SubscribeId string `protobuf:"bytes,2,opt,name=subscribe_id,json=subscribeId,proto3" json:"subscribe_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangeErrSubscribeReq) Descriptor deprecated 

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

Deprecated: Use ChangeErrSubscribeReq.ProtoReflect.Descriptor instead.

func (*ChangeErrSubscribeReq) GetId 

func (x *ChangeErrSubscribeReq) GetId() uint64

func (*ChangeErrSubscribeReq) GetSubscribeId 

func (x *ChangeErrSubscribeReq) GetSubscribeId() string

func (*ChangeErrSubscribeReq) ProtoMessage 

func (*ChangeErrSubscribeReq) ProtoMessage()

func (*ChangeErrSubscribeReq) ProtoReflect 

func (x *ChangeErrSubscribeReq) ProtoReflect() protoreflect.Message

func (*ChangeErrSubscribeReq) Reset 

func (x *ChangeErrSubscribeReq) Reset()

func (*ChangeErrSubscribeReq) String 

func (x *ChangeErrSubscribeReq) String() string

type CreateRuleTargetReq 

type CreateRuleTargetReq struct {
	Id    uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Type  uint32 `protobuf:"varint,2,opt,name=type,proto3" json:"type,omitempty"`
	Host  string `protobuf:"bytes,3,opt,name=host,proto3" json:"host,omitempty"`
	Value string `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	// string ext = 5;
	TableName string            `protobuf:"bytes,5,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	SinkType  string            `protobuf:"bytes,6,opt,name=sink_type,json=sinkType,proto3" json:"sink_type,omitempty"`
	SinkId    string            `protobuf:"bytes,7,opt,name=sink_id,json=sinkId,proto3" json:"sink_id,omitempty"`
	Fields    []*MapField       `protobuf:"bytes,8,rep,name=fields,proto3" json:"fields,omitempty"`
	Tags      map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateRuleTargetReq) Descriptor deprecated 

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

Deprecated: Use CreateRuleTargetReq.ProtoReflect.Descriptor instead.

func (*CreateRuleTargetReq) GetFields 

func (x *CreateRuleTargetReq) GetFields() []*MapField

func (*CreateRuleTargetReq) GetHost 

func (x *CreateRuleTargetReq) GetHost() string

func (*CreateRuleTargetReq) GetId 

func (x *CreateRuleTargetReq) GetId() uint64

func (*CreateRuleTargetReq) GetSinkId 

func (x *CreateRuleTargetReq) GetSinkId() string

func (*CreateRuleTargetReq) GetSinkType 

func (x *CreateRuleTargetReq) GetSinkType() string

func (*CreateRuleTargetReq) GetTableName 

func (x *CreateRuleTargetReq) GetTableName() string

func (*CreateRuleTargetReq) GetTags 

func (x *CreateRuleTargetReq) GetTags() map[string]string

func (*CreateRuleTargetReq) GetType 

func (x *CreateRuleTargetReq) GetType() uint32

func (*CreateRuleTargetReq) GetValue 

func (x *CreateRuleTargetReq) GetValue() string

func (*CreateRuleTargetReq) ProtoMessage 

func (*CreateRuleTargetReq) ProtoMessage()

func (*CreateRuleTargetReq) ProtoReflect 

func (x *CreateRuleTargetReq) ProtoReflect() protoreflect.Message

func (*CreateRuleTargetReq) Reset 

func (x *CreateRuleTargetReq) Reset()

func (*CreateRuleTargetReq) String 

func (x *CreateRuleTargetReq) String() string

type CreateRuleTargetResp 

type CreateRuleTargetResp struct {
	Id    uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Type  uint32 `protobuf:"varint,2,opt,name=type,proto3" json:"type,omitempty"`
	Host  string `protobuf:"bytes,3,opt,name=host,proto3" json:"host,omitempty"`
	Value string `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	// string ext = 5;
	TableName string            `protobuf:"bytes,5,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	SinkType  string            `protobuf:"bytes,6,opt,name=sink_type,json=sinkType,proto3" json:"sink_type,omitempty"`
	SinkId    string            `protobuf:"bytes,7,opt,name=sink_id,json=sinkId,proto3" json:"sink_id,omitempty"`
	Fields    []*MapField       `protobuf:"bytes,8,rep,name=fields,proto3" json:"fields,omitempty"`
	User      string            `protobuf:"bytes,9,opt,name=user,proto3" json:"user,omitempty"`
	Password  string            `protobuf:"bytes,10,opt,name=password,proto3" json:"password,omitempty"`
	Database  string            `protobuf:"bytes,11,opt,name=database,proto3" json:"database,omitempty"`
	Endpoint  string            `protobuf:"bytes,12,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Tags      map[string]string `` /* 150-byte string literal not displayed */
	Org       string            `protobuf:"bytes,14,opt,name=org,proto3" json:"org,omitempty"`
	Bucket    string            `protobuf:"bytes,15,opt,name=bucket,proto3" json:"bucket,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateRuleTargetResp) Descriptor deprecated 

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

Deprecated: Use CreateRuleTargetResp.ProtoReflect.Descriptor instead.

func (*CreateRuleTargetResp) GetBucket 

func (x *CreateRuleTargetResp) GetBucket() string

func (*CreateRuleTargetResp) GetDatabase 

func (x *CreateRuleTargetResp) GetDatabase() string

func (*CreateRuleTargetResp) GetEndpoint 

func (x *CreateRuleTargetResp) GetEndpoint() string

func (*CreateRuleTargetResp) GetFields 

func (x *CreateRuleTargetResp) GetFields() []*MapField

func (*CreateRuleTargetResp) GetHost 

func (x *CreateRuleTargetResp) GetHost() string

func (*CreateRuleTargetResp) GetId 

func (x *CreateRuleTargetResp) GetId() uint64

func (*CreateRuleTargetResp) GetOrg 

func (x *CreateRuleTargetResp) GetOrg() string

func (*CreateRuleTargetResp) GetPassword 

func (x *CreateRuleTargetResp) GetPassword() string

func (*CreateRuleTargetResp) GetSinkId 

func (x *CreateRuleTargetResp) GetSinkId() string

func (*CreateRuleTargetResp) GetSinkType 

func (x *CreateRuleTargetResp) GetSinkType() string

func (*CreateRuleTargetResp) GetTableName 

func (x *CreateRuleTargetResp) GetTableName() string

func (*CreateRuleTargetResp) GetTags 

func (x *CreateRuleTargetResp) GetTags() map[string]string

func (*CreateRuleTargetResp) GetType 

func (x *CreateRuleTargetResp) GetType() uint32

func (*CreateRuleTargetResp) GetUser 

func (x *CreateRuleTargetResp) GetUser() string

func (*CreateRuleTargetResp) GetValue 

func (x *CreateRuleTargetResp) GetValue() string

func (*CreateRuleTargetResp) ProtoMessage 

func (*CreateRuleTargetResp) ProtoMessage()

func (*CreateRuleTargetResp) ProtoReflect 

func (x *CreateRuleTargetResp) ProtoReflect() protoreflect.Message

func (*CreateRuleTargetResp) Reset 

func (x *CreateRuleTargetResp) Reset()

func (*CreateRuleTargetResp) String 

func (x *CreateRuleTargetResp) String() string

type DeleteRuleTargetReq 

type DeleteRuleTargetReq struct {
	Id       uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	TargetId uint64 `protobuf:"varint,2,opt,name=target_id,json=targetId,proto3" json:"target_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRuleTargetReq) Descriptor deprecated 

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

Deprecated: Use DeleteRuleTargetReq.ProtoReflect.Descriptor instead.

func (*DeleteRuleTargetReq) GetId 

func (x *DeleteRuleTargetReq) GetId() uint64

func (*DeleteRuleTargetReq) GetTargetId 

func (x *DeleteRuleTargetReq) GetTargetId() uint64

func (*DeleteRuleTargetReq) ProtoMessage 

func (*DeleteRuleTargetReq) ProtoMessage()

func (*DeleteRuleTargetReq) ProtoReflect 

func (x *DeleteRuleTargetReq) ProtoReflect() protoreflect.Message

func (*DeleteRuleTargetReq) Reset 

func (x *DeleteRuleTargetReq) Reset()

func (*DeleteRuleTargetReq) String 

func (x *DeleteRuleTargetReq) String() string

type Device 

type Device struct {
	Id         string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name       string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Template   string `protobuf:"bytes,3,opt,name=template,proto3" json:"template,omitempty"`
	GroupName  string `protobuf:"bytes,4,opt,name=group_name,json=groupName,proto3" json:"group_name,omitempty"`
	Status     string `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
	TemplateId string `protobuf:"bytes,6,opt,name=template_id,json=templateId,proto3" json:"template_id,omitempty"`
	// contains filtered or unexported fields
}

func (*Device) Descriptor deprecated 

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

Deprecated: Use Device.ProtoReflect.Descriptor instead.

func (*Device) GetGroupName 

func (x *Device) GetGroupName() string

func (*Device) GetId 

func (x *Device) GetId() string

func (*Device) GetName 

func (x *Device) GetName() string

func (*Device) GetStatus 

func (x *Device) GetStatus() string

func (*Device) GetTemplate 

func (x *Device) GetTemplate() string

func (*Device) GetTemplateId 

func (x *Device) GetTemplateId() string

func (*Device) ProtoMessage 

func (*Device) ProtoMessage()

func (*Device) ProtoReflect 

func (x *Device) ProtoReflect() protoreflect.Message

func (*Device) Reset 

func (x *Device) Reset()

func (*Device) String 

func (x *Device) String() string

type ErrSubscribeReq 

type ErrSubscribeReq struct {
	Id          uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	SubscribeId string `protobuf:"bytes,2,opt,name=subscribe_id,json=subscribeId,proto3" json:"subscribe_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ErrSubscribeReq) Descriptor deprecated 

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

Deprecated: Use ErrSubscribeReq.ProtoReflect.Descriptor instead.

func (*ErrSubscribeReq) GetId 

func (x *ErrSubscribeReq) GetId() uint64

func (*ErrSubscribeReq) GetSubscribeId 

func (x *ErrSubscribeReq) GetSubscribeId() string

func (*ErrSubscribeReq) ProtoMessage 

func (*ErrSubscribeReq) ProtoMessage()

func (*ErrSubscribeReq) ProtoReflect 

func (x *ErrSubscribeReq) ProtoReflect() protoreflect.Message

func (*ErrSubscribeReq) Reset 

func (x *ErrSubscribeReq) Reset()

func (*ErrSubscribeReq) String 

func (x *ErrSubscribeReq) String() string

type ErrUnsubscribeReq 

type ErrUnsubscribeReq struct {
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*ErrUnsubscribeReq) Descriptor deprecated 

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

Deprecated: Use ErrUnsubscribeReq.ProtoReflect.Descriptor instead.

func (*ErrUnsubscribeReq) GetId 

func (x *ErrUnsubscribeReq) GetId() uint64

func (*ErrUnsubscribeReq) ProtoMessage 

func (*ErrUnsubscribeReq) ProtoMessage()

func (*ErrUnsubscribeReq) ProtoReflect 

func (x *ErrUnsubscribeReq) ProtoReflect() protoreflect.Message

func (*ErrUnsubscribeReq) Reset 

func (x *ErrUnsubscribeReq) Reset()

func (*ErrUnsubscribeReq) String 

func (x *ErrUnsubscribeReq) String() string

type Error 

type Error int32

@plugins=protoc-gen-go-errors 错误 

const (
	// @msg=未知类型
	// @code=UNKNOWN
	Error_ERR_UNKNOWN Error = 0
	// @msg=成功
	// @code=OK
	Error_ERR_OK_STATUS Error = 1
	// @msg=未找到资源
	// @code=NOT_FOUND
	Error_ERR_NOT_FOUND Error = 2
	// @msg=请求参数无效
	// @code=INVALID_ARGUMENT
	Error_ERR_INVALID_ARGUMENT Error = 3
	// @msg=请求后端存储错误
	// @code=INTERNAL
	Error_ERR_INTERNAL_STORE Error = 4
	// @msg=内部错误
	// @code=INTERNAL
	Error_ERR_INTERNAL_ERROR Error = 5
	// @msg=未找到对应规则
	// @code=NOT_FOUND
	Error_ERR_RULE_NOT_FOUND Error = 6
	// @msg=请确保用户对该资源拥有足够的权限
	// @code=PERMISSION_DENIED
	Error_ERR_FORBIDDEN Error = 7
	// @msg=请确保用户权限
	// @code=PERMISSION_DENIED
	Error_ERR_UNAUTHORIZED Error = 8
	// @msg=建立连接失败
	// @code=OK
	Error_ERR_FAILED_KAFKA_CONNECTION Error = 9
	// @msg=成功
	// @code=OK
	Error_ERR_OK_KAFKA_CONNECTION Error = 10
	// @msg=重复创建
	// @code=INVALID_ARGUMENT
	Error_ERR_DUPLICATE_CREATE Error = 11
	// @msg=不能删除正在运行的规则
	// @code=INVALID_ARGUMENT
	Error_ERR_CANT_DELETE_RUNNING_RULE Error = 12
	// @msg=建立连接失败
	// @code=OK
	Error_ERR_FAILED_MYSQL_CONNECTION Error = 13
	// @msg=建立连接失败
	// @code=OK
	Error_ERR_FAILED_CLICKHOUSE_CONNECTION Error = 14
	// @msg=获取配置信息失败
	// @code=OK
	Error_ERR_FAILED_SINK_INFO Error = 15
	// @msg=获取映射信息失败
	// @code=OK
	Error_ERR_FAILED_MAP_INFO Error = 16
	// @msg=获取数据表信息失败
	// @code=OK
	Error_ERR_FAILED_TABLE_INFO Error = 17
	// @msg=命名重复
	// @code=INVALID_ARGUMENT
	Error_ERR_DUPLICATE_NAME Error = 18
	// @msg=重复添加设备
	// @code=INVALID_ARGUMENT
	Error_ERR_DUPLICATE_DEVICE Error = 19
	// @msg=没有可用的转发
	// @code=INVALID_ARGUMENT
	Error_ERR_INVALID_RULE Error = 20
	// @msg=建立连接失败
	// @code=OK
	Error_ERR_FAILED_INFLUXDB_CONNECTION Error = 21
)

func (Error) Descriptor 

func (Error) Descriptor() protoreflect.EnumDescriptor

func (Error) Enum 

func (x Error) Enum() *Error

func (Error) EnumDescriptor deprecated 

func (Error) EnumDescriptor() ([]byte, []int)

Deprecated: Use Error.Descriptor instead.

func (Error) Number 

func (x Error) Number() protoreflect.EnumNumber

func (Error) String 

func (x Error) String() string

func (Error) Type 

func (Error) Type() protoreflect.EnumType

type Field 

type Field struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	IsPK bool   `protobuf:"varint,3,opt,name=isPK,proto3" json:"isPK,omitempty"`
	// contains filtered or unexported fields
}

func (*Field) Descriptor deprecated 

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

Deprecated: Use Field.ProtoReflect.Descriptor instead.

func (*Field) GetIsPK 

func (x *Field) GetIsPK() bool

func (*Field) GetName 

func (x *Field) GetName() string

func (*Field) GetType 

func (x *Field) GetType() string

func (*Field) ProtoMessage 

func (*Field) ProtoMessage()

func (*Field) ProtoReflect 

func (x *Field) ProtoReflect() protoreflect.Message

func (*Field) Reset 

func (x *Field) Reset()

func (*Field) String 

func (x *Field) String() string

type Float 

type Float struct {
	Value float32 `protobuf:"fixed32,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Float) Descriptor deprecated 

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

Deprecated: Use Float.ProtoReflect.Descriptor instead.

func (*Float) GetValue 

func (x *Float) GetValue() float32

func (*Float) ProtoMessage 

func (*Float) ProtoMessage()

func (*Float) ProtoReflect 

func (x *Float) ProtoReflect() protoreflect.Message

func (*Float) Reset 

func (x *Float) Reset()

func (*Float) String 

func (x *Float) String() string

type Int32 

type Int32 struct {
	Value int32 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Int32) Descriptor deprecated 

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

Deprecated: Use Int32.ProtoReflect.Descriptor instead.

func (*Int32) GetValue 

func (x *Int32) GetValue() int32

func (*Int32) ProtoMessage 

func (*Int32) ProtoMessage()

func (*Int32) ProtoReflect 

func (x *Int32) ProtoReflect() protoreflect.Message

func (*Int32) Reset 

func (x *Int32) Reset()

func (*Int32) String 

func (x *Int32) String() string

type ListRuleTargetReq 

type ListRuleTargetReq struct {
	PageNum      uint32 `protobuf:"varint,1,opt,name=page_num,json=pageNum,proto3" json:"page_num,omitempty"`
	PageSize     uint32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	OrderBy      string `protobuf:"bytes,3,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
	IsDescending bool   `protobuf:"varint,4,opt,name=is_descending,json=isDescending,proto3" json:"is_descending,omitempty"`
	KeyWords     string `protobuf:"bytes,5,opt,name=key_words,json=keyWords,proto3" json:"key_words,omitempty"`
	SearchKey    string `protobuf:"bytes,6,opt,name=search_key,json=searchKey,proto3" json:"search_key,omitempty"`
	Id           uint64 `protobuf:"varint,7,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRuleTargetReq) Descriptor deprecated 

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

Deprecated: Use ListRuleTargetReq.ProtoReflect.Descriptor instead.

func (*ListRuleTargetReq) GetId 

func (x *ListRuleTargetReq) GetId() uint64

func (*ListRuleTargetReq) GetIsDescending 

func (x *ListRuleTargetReq) GetIsDescending() bool

func (*ListRuleTargetReq) GetKeyWords 

func (x *ListRuleTargetReq) GetKeyWords() string

func (*ListRuleTargetReq) GetOrderBy 

func (x *ListRuleTargetReq) GetOrderBy() string

func (*ListRuleTargetReq) GetPageNum 

func (x *ListRuleTargetReq) GetPageNum() uint32

func (*ListRuleTargetReq) GetPageSize 

func (x *ListRuleTargetReq) GetPageSize() uint32

func (*ListRuleTargetReq) GetSearchKey 

func (x *ListRuleTargetReq) GetSearchKey() string

func (*ListRuleTargetReq) ProtoMessage 

func (*ListRuleTargetReq) ProtoMessage()

func (*ListRuleTargetReq) ProtoReflect 

func (x *ListRuleTargetReq) ProtoReflect() protoreflect.Message

func (*ListRuleTargetReq) Reset 

func (x *ListRuleTargetReq) Reset()

func (*ListRuleTargetReq) String 

func (x *ListRuleTargetReq) String() string

type ListRuleTargetResp 

type ListRuleTargetResp struct {
	Total    uint32                  `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	PageNum  uint32                  `protobuf:"varint,2,opt,name=page_num,json=pageNum,proto3" json:"page_num,omitempty"`
	LastPage uint32                  `protobuf:"varint,3,opt,name=last_page,json=lastPage,proto3" json:"last_page,omitempty"`
	PageSize uint32                  `protobuf:"varint,4,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	Data     []*CreateRuleTargetResp `protobuf:"bytes,5,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRuleTargetResp) Descriptor deprecated 

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

Deprecated: Use ListRuleTargetResp.ProtoReflect.Descriptor instead.

func (*ListRuleTargetResp) GetData 

func (x *ListRuleTargetResp) GetData() []*CreateRuleTargetResp

func (*ListRuleTargetResp) GetLastPage 

func (x *ListRuleTargetResp) GetLastPage() uint32

func (*ListRuleTargetResp) GetPageNum 

func (x *ListRuleTargetResp) GetPageNum() uint32

func (*ListRuleTargetResp) GetPageSize 

func (x *ListRuleTargetResp) GetPageSize() uint32

func (*ListRuleTargetResp) GetTotal 

func (x *ListRuleTargetResp) GetTotal() uint32

func (*ListRuleTargetResp) ProtoMessage 

func (*ListRuleTargetResp) ProtoMessage()

func (*ListRuleTargetResp) ProtoReflect 

func (x *ListRuleTargetResp) ProtoReflect() protoreflect.Message

func (*ListRuleTargetResp) Reset 

func (x *ListRuleTargetResp) Reset()

func (*ListRuleTargetResp) String 

func (x *ListRuleTargetResp) String() string

type MapField 

type MapField struct {
	TField *Field `protobuf:"bytes,1,opt,name=t_field,json=tField,proto3" json:"t_field,omitempty"`
	MField *Field `protobuf:"bytes,2,opt,name=m_field,json=mField,proto3" json:"m_field,omitempty"`
	// contains filtered or unexported fields
}

func (*MapField) Descriptor deprecated 

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

Deprecated: Use MapField.ProtoReflect.Descriptor instead.

func (*MapField) GetMField 

func (x *MapField) GetMField() *Field

func (*MapField) GetTField 

func (x *MapField) GetTField() *Field

func (*MapField) ProtoMessage 

func (*MapField) ProtoMessage()

func (*MapField) ProtoReflect 

func (x *MapField) ProtoReflect() protoreflect.Message

func (*MapField) Reset 

func (x *MapField) Reset()

func (*MapField) String 

func (x *MapField) String() string

type Pager 

type Pager struct {
	Limit   *Int32  `protobuf:"bytes,1,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset  *Int32  `protobuf:"bytes,2,opt,name=offset,proto3" json:"offset,omitempty"`
	SortKey *String `protobuf:"bytes,3,opt,name=sort_key,json=sortKey,proto3" json:"sort_key,omitempty"`
	Reverse *Bool   `protobuf:"bytes,4,opt,name=Reverse,proto3" json:"Reverse,omitempty"`
	// contains filtered or unexported fields
}

func (*Pager) Descriptor deprecated 

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

Deprecated: Use Pager.ProtoReflect.Descriptor instead.

func (*Pager) GetLimit 

func (x *Pager) GetLimit() *Int32

func (*Pager) GetOffset 

func (x *Pager) GetOffset() *Int32

func (*Pager) GetReverse 

func (x *Pager) GetReverse() *Bool

func (*Pager) GetSortKey 

func (x *Pager) GetSortKey() *String

func (*Pager) ProtoMessage 

func (*Pager) ProtoMessage()

func (*Pager) ProtoReflect 

func (x *Pager) ProtoReflect() protoreflect.Message

func (*Pager) Reset 

func (x *Pager) Reset()

func (*Pager) String 

func (x *Pager) String() string

type RemoveDeviceFromAllRuleReq 

type RemoveDeviceFromAllRuleReq struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveDeviceFromAllRuleReq) Descriptor deprecated 

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

Deprecated: Use RemoveDeviceFromAllRuleReq.ProtoReflect.Descriptor instead.

func (*RemoveDeviceFromAllRuleReq) GetId 

func (x *RemoveDeviceFromAllRuleReq) GetId() string

func (*RemoveDeviceFromAllRuleReq) ProtoMessage 

func (*RemoveDeviceFromAllRuleReq) ProtoMessage()

func (*RemoveDeviceFromAllRuleReq) ProtoReflect 

func (x *RemoveDeviceFromAllRuleReq) ProtoReflect() protoreflect.Message

func (*RemoveDeviceFromAllRuleReq) Reset 

func (x *RemoveDeviceFromAllRuleReq) Reset()

func (*RemoveDeviceFromAllRuleReq) String 

func (x *RemoveDeviceFromAllRuleReq) String() string

type RemoveDevicesFromRuleReq 

type RemoveDevicesFromRuleReq struct {
	Id         uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	DevicesIds string `protobuf:"bytes,2,opt,name=devices_ids,json=devicesIds,proto3" json:"devices_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveDevicesFromRuleReq) Descriptor deprecated 

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

Deprecated: Use RemoveDevicesFromRuleReq.ProtoReflect.Descriptor instead.

func (*RemoveDevicesFromRuleReq) GetDevicesIds 

func (x *RemoveDevicesFromRuleReq) GetDevicesIds() string

func (*RemoveDevicesFromRuleReq) GetId 

func (x *RemoveDevicesFromRuleReq) GetId() uint64

func (*RemoveDevicesFromRuleReq) ProtoMessage 

func (*RemoveDevicesFromRuleReq) ProtoMessage()

func (*RemoveDevicesFromRuleReq) ProtoReflect 

func (x *RemoveDevicesFromRuleReq) ProtoReflect() protoreflect.Message

func (*RemoveDevicesFromRuleReq) Reset 

func (x *RemoveDevicesFromRuleReq) Reset()

func (*RemoveDevicesFromRuleReq) String 

func (x *RemoveDevicesFromRuleReq) String() string

type Rule 

type Rule struct {
	Id            uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name          string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Desc          string `protobuf:"bytes,3,opt,name=desc,proto3" json:"desc,omitempty"`
	Type          uint32 `protobuf:"varint,4,opt,name=type,proto3" json:"type,omitempty"`
	Status        uint32 `protobuf:"varint,5,opt,name=status,proto3" json:"status,omitempty"`
	CreatedAt     int64  `protobuf:"varint,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt     int64  `protobuf:"varint,7,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	DevicesStatus uint32 `protobuf:"varint,8,opt,name=devices_status,json=devicesStatus,proto3" json:"devices_status,omitempty"`
	TargetsStatus uint32 `protobuf:"varint,9,opt,name=targets_status,json=targetsStatus,proto3" json:"targets_status,omitempty"`
	SubId         uint32 `protobuf:"varint,10,opt,name=sub_id,json=subId,proto3" json:"sub_id,omitempty"`
	ModelId       string `protobuf:"bytes,11,opt,name=model_id,json=modelId,proto3" json:"model_id,omitempty"`
	ModelName     string `protobuf:"bytes,12,opt,name=model_name,json=modelName,proto3" json:"model_name,omitempty"`
	SelectExpr    string `protobuf:"bytes,13,opt,name=select_expr,json=selectExpr,proto3" json:"select_expr,omitempty"`
	WhereExpr     string `protobuf:"bytes,14,opt,name=where_expr,json=whereExpr,proto3" json:"where_expr,omitempty"`
	// contains filtered or unexported fields
}

func (*Rule) Descriptor deprecated 

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

Deprecated: Use Rule.ProtoReflect.Descriptor instead.

func (*Rule) GetCreatedAt 

func (x *Rule) GetCreatedAt() int64

func (*Rule) GetDesc 

func (x *Rule) GetDesc() string

func (*Rule) GetDevicesStatus 

func (x *Rule) GetDevicesStatus() uint32

func (*Rule) GetId 

func (x *Rule) GetId() uint64

func (*Rule) GetModelId 

func (x *Rule) GetModelId() string

func (*Rule) GetModelName 

func (x *Rule) GetModelName() string

func (*Rule) GetName 

func (x *Rule) GetName() string

func (*Rule) GetSelectExpr 

func (x *Rule) GetSelectExpr() string

func (*Rule) GetStatus 

func (x *Rule) GetStatus() uint32

func (*Rule) GetSubId 

func (x *Rule) GetSubId() uint32

func (*Rule) GetTargetsStatus 

func (x *Rule) GetTargetsStatus() uint32

func (*Rule) GetType 

func (x *Rule) GetType() uint32

func (*Rule) GetUpdatedAt 

func (x *Rule) GetUpdatedAt() int64

func (*Rule) GetWhereExpr 

func (x *Rule) GetWhereExpr() string

func (*Rule) ProtoMessage 

func (*Rule) ProtoMessage()

func (*Rule) ProtoReflect 

func (x *Rule) ProtoReflect() protoreflect.Message

func (*Rule) Reset 

func (x *Rule) Reset()

func (*Rule) String 

func (x *Rule) String() string

type RuleCreateReq 

type RuleCreateReq struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Desc      string `protobuf:"bytes,2,opt,name=desc,proto3" json:"desc,omitempty"`
	Type      uint32 `protobuf:"varint,3,opt,name=type,proto3" json:"type,omitempty"`
	ModelId   string `protobuf:"bytes,4,opt,name=model_id,json=modelId,proto3" json:"model_id,omitempty"`
	ModelName string `protobuf:"bytes,5,opt,name=model_name,json=modelName,proto3" json:"model_name,omitempty"`
	// contains filtered or unexported fields
}

Rule create.

func (*RuleCreateReq) Descriptor deprecated 

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

Deprecated: Use RuleCreateReq.ProtoReflect.Descriptor instead.

func (*RuleCreateReq) GetDesc 

func (x *RuleCreateReq) GetDesc() string

func (*RuleCreateReq) GetModelId 

func (x *RuleCreateReq) GetModelId() string

func (*RuleCreateReq) GetModelName 

func (x *RuleCreateReq) GetModelName() string

func (*RuleCreateReq) GetName 

func (x *RuleCreateReq) GetName() string

func (*RuleCreateReq) GetType 

func (x *RuleCreateReq) GetType() uint32

func (*RuleCreateReq) ProtoMessage 

func (*RuleCreateReq) ProtoMessage()

func (*RuleCreateReq) ProtoReflect 

func (x *RuleCreateReq) ProtoReflect() protoreflect.Message

func (*RuleCreateReq) Reset 

func (x *RuleCreateReq) Reset()

func (*RuleCreateReq) String 

func (x *RuleCreateReq) String() string

type RuleCreateResp 

type RuleCreateResp struct {
	Id        uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name      string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Desc      string `protobuf:"bytes,3,opt,name=desc,proto3" json:"desc,omitempty"`
	Type      uint32 `protobuf:"varint,4,opt,name=type,proto3" json:"type,omitempty"`
	Status    uint32 `protobuf:"varint,5,opt,name=status,proto3" json:"status,omitempty"`
	CreatedAt int64  `protobuf:"varint,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt int64  `protobuf:"varint,7,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	ModelId   string `protobuf:"bytes,8,opt,name=model_id,json=modelId,proto3" json:"model_id,omitempty"`
	ModelName string `protobuf:"bytes,9,opt,name=model_name,json=modelName,proto3" json:"model_name,omitempty"`
	// contains filtered or unexported fields
}

func (*RuleCreateResp) Descriptor deprecated 

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

Deprecated: Use RuleCreateResp.ProtoReflect.Descriptor instead.

func (*RuleCreateResp) GetCreatedAt 

func (x *RuleCreateResp) GetCreatedAt() int64

func (*RuleCreateResp) GetDesc 

func (x *RuleCreateResp) GetDesc() string

func (*RuleCreateResp) GetId 

func (x *RuleCreateResp) GetId() uint64

func (*RuleCreateResp) GetModelId 

func (x *RuleCreateResp) GetModelId() string

func (*RuleCreateResp) GetModelName 

func (x *RuleCreateResp) GetModelName() string

func (*RuleCreateResp) GetName 

func (x *RuleCreateResp) GetName() string

func (*RuleCreateResp) GetStatus 

func (x *RuleCreateResp) GetStatus() uint32

func (*RuleCreateResp) GetType 

func (x *RuleCreateResp) GetType() uint32

func (*RuleCreateResp) GetUpdatedAt 

func (x *RuleCreateResp) GetUpdatedAt() int64

func (*RuleCreateResp) ProtoMessage 

func (*RuleCreateResp) ProtoMessage()

func (*RuleCreateResp) ProtoReflect 

func (x *RuleCreateResp) ProtoReflect() protoreflect.Message

func (*RuleCreateResp) Reset 

func (x *RuleCreateResp) Reset()

func (*RuleCreateResp) String 

func (x *RuleCreateResp) String() string

type RuleDeleteReq 

type RuleDeleteReq struct {
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

rule delete.

func (*RuleDeleteReq) Descriptor deprecated 

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

Deprecated: Use RuleDeleteReq.ProtoReflect.Descriptor instead.

func (*RuleDeleteReq) GetId 

func (x *RuleDeleteReq) GetId() uint64

func (*RuleDeleteReq) ProtoMessage 

func (*RuleDeleteReq) ProtoMessage()

func (*RuleDeleteReq) ProtoReflect 

func (x *RuleDeleteReq) ProtoReflect() protoreflect.Message

func (*RuleDeleteReq) Reset 

func (x *RuleDeleteReq) Reset()

func (*RuleDeleteReq) String 

func (x *RuleDeleteReq) String() string

type RuleDevicesIDReq 

type RuleDevicesIDReq struct {
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*RuleDevicesIDReq) Descriptor deprecated 

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

Deprecated: Use RuleDevicesIDReq.ProtoReflect.Descriptor instead.

func (*RuleDevicesIDReq) GetId 

func (x *RuleDevicesIDReq) GetId() uint64

func (*RuleDevicesIDReq) ProtoMessage 

func (*RuleDevicesIDReq) ProtoMessage()

func (*RuleDevicesIDReq) ProtoReflect 

func (x *RuleDevicesIDReq) ProtoReflect() protoreflect.Message

func (*RuleDevicesIDReq) Reset 

func (x *RuleDevicesIDReq) Reset()

func (*RuleDevicesIDReq) String 

func (x *RuleDevicesIDReq) String() string

type RuleDevicesIDResp 

type RuleDevicesIDResp struct {
	DevicesIds []string `protobuf:"bytes,1,rep,name=devices_ids,json=devicesIds,proto3" json:"devices_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*RuleDevicesIDResp) Descriptor deprecated 

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

Deprecated: Use RuleDevicesIDResp.ProtoReflect.Descriptor instead.

func (*RuleDevicesIDResp) GetDevicesIds 

func (x *RuleDevicesIDResp) GetDevicesIds() []string

func (*RuleDevicesIDResp) ProtoMessage 

func (*RuleDevicesIDResp) ProtoMessage()

func (*RuleDevicesIDResp) ProtoReflect 

func (x *RuleDevicesIDResp) ProtoReflect() protoreflect.Message

func (*RuleDevicesIDResp) Reset 

func (x *RuleDevicesIDResp) Reset()

func (*RuleDevicesIDResp) String 

func (x *RuleDevicesIDResp) String() string

type RuleDevicesReq 

type RuleDevicesReq struct {
	PageNum      uint32 `protobuf:"varint,1,opt,name=page_num,json=pageNum,proto3" json:"page_num,omitempty"`
	PageSize     uint32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	OrderBy      string `protobuf:"bytes,3,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
	IsDescending bool   `protobuf:"varint,4,opt,name=is_descending,json=isDescending,proto3" json:"is_descending,omitempty"`
	KeyWords     string `protobuf:"bytes,5,opt,name=key_words,json=keyWords,proto3" json:"key_words,omitempty"`
	SearchKey    string `protobuf:"bytes,6,opt,name=search_key,json=searchKey,proto3" json:"search_key,omitempty"`
	Id           uint64 `protobuf:"varint,7,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*RuleDevicesReq) Descriptor deprecated 

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

Deprecated: Use RuleDevicesReq.ProtoReflect.Descriptor instead.

func (*RuleDevicesReq) GetId 

func (x *RuleDevicesReq) GetId() uint64

func (*RuleDevicesReq) GetIsDescending 

func (x *RuleDevicesReq) GetIsDescending() bool

func (*RuleDevicesReq) GetKeyWords 

func (x *RuleDevicesReq) GetKeyWords() string

func (*RuleDevicesReq) GetOrderBy 

func (x *RuleDevicesReq) GetOrderBy() string

func (*RuleDevicesReq) GetPageNum 

func (x *RuleDevicesReq) GetPageNum() uint32

func (*RuleDevicesReq) GetPageSize 

func (x *RuleDevicesReq) GetPageSize() uint32

func (*RuleDevicesReq) GetSearchKey 

func (x *RuleDevicesReq) GetSearchKey() string

func (*RuleDevicesReq) ProtoMessage 

func (*RuleDevicesReq) ProtoMessage()

func (*RuleDevicesReq) ProtoReflect 

func (x *RuleDevicesReq) ProtoReflect() protoreflect.Message

func (*RuleDevicesReq) Reset 

func (x *RuleDevicesReq) Reset()

func (*RuleDevicesReq) String 

func (x *RuleDevicesReq) String() string

type RuleDevicesResp 

type RuleDevicesResp struct {
	Total    uint32    `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	PageNum  uint32    `protobuf:"varint,2,opt,name=page_num,json=pageNum,proto3" json:"page_num,omitempty"`
	LastPage uint32    `protobuf:"varint,3,opt,name=last_page,json=lastPage,proto3" json:"last_page,omitempty"`
	PageSize uint32    `protobuf:"varint,4,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	Data     []*Device `protobuf:"bytes,5,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*RuleDevicesResp) Descriptor deprecated 

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

Deprecated: Use RuleDevicesResp.ProtoReflect.Descriptor instead.

func (*RuleDevicesResp) GetData 

func (x *RuleDevicesResp) GetData() []*Device

func (*RuleDevicesResp) GetLastPage 

func (x *RuleDevicesResp) GetLastPage() uint32

func (*RuleDevicesResp) GetPageNum 

func (x *RuleDevicesResp) GetPageNum() uint32

func (*RuleDevicesResp) GetPageSize 

func (x *RuleDevicesResp) GetPageSize() uint32

func (*RuleDevicesResp) GetTotal 

func (x *RuleDevicesResp) GetTotal() uint32

func (*RuleDevicesResp) ProtoMessage 

func (*RuleDevicesResp) ProtoMessage()

func (*RuleDevicesResp) ProtoReflect 

func (x *RuleDevicesResp) ProtoReflect() protoreflect.Message

func (*RuleDevicesResp) Reset 

func (x *RuleDevicesResp) Reset()

func (*RuleDevicesResp) String 

func (x *RuleDevicesResp) String() string

type RuleGetReq 

type RuleGetReq struct {
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

rule delete.

func (*RuleGetReq) Descriptor deprecated 

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

Deprecated: Use RuleGetReq.ProtoReflect.Descriptor instead.

func (*RuleGetReq) GetId 

func (x *RuleGetReq) GetId() uint64

func (*RuleGetReq) ProtoMessage 

func (*RuleGetReq) ProtoMessage()

func (*RuleGetReq) ProtoReflect 

func (x *RuleGetReq) ProtoReflect() protoreflect.Message

func (*RuleGetReq) Reset 

func (x *RuleGetReq) Reset()

func (*RuleGetReq) String 

func (x *RuleGetReq) String() string

type RuleQueryReq 

type RuleQueryReq struct {
	PageNum      uint32   `protobuf:"varint,1,opt,name=page_num,json=pageNum,proto3" json:"page_num,omitempty"`
	PageSize     uint32   `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	OrderBy      string   `protobuf:"bytes,3,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
	IsDescending bool     `protobuf:"varint,4,opt,name=is_descending,json=isDescending,proto3" json:"is_descending,omitempty"`
	KeyWords     string   `protobuf:"bytes,5,opt,name=key_words,json=keyWords,proto3" json:"key_words,omitempty"`
	SearchKey    string   `protobuf:"bytes,6,opt,name=search_key,json=searchKey,proto3" json:"search_key,omitempty"`
	Id           *Uint64  `protobuf:"bytes,7,opt,name=id,proto3" json:"id,omitempty"`
	Ids          []string `protobuf:"bytes,8,rep,name=ids,proto3" json:"ids,omitempty"`
	Name         *String  `protobuf:"bytes,9,opt,name=name,proto3" json:"name,omitempty"`
	Type         uint32   `protobuf:"varint,10,opt,name=type,proto3" json:"type,omitempty"`
	Status       *Uint32  `protobuf:"bytes,11,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

rule query

func (*RuleQueryReq) Descriptor deprecated 

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

Deprecated: Use RuleQueryReq.ProtoReflect.Descriptor instead.

func (*RuleQueryReq) GetId 

func (x *RuleQueryReq) GetId() *Uint64

func (*RuleQueryReq) GetIds 

func (x *RuleQueryReq) GetIds() []string

func (*RuleQueryReq) GetIsDescending 

func (x *RuleQueryReq) GetIsDescending() bool

func (*RuleQueryReq) GetKeyWords 

func (x *RuleQueryReq) GetKeyWords() string

func (*RuleQueryReq) GetName 

func (x *RuleQueryReq) GetName() *String

func (*RuleQueryReq) GetOrderBy 

func (x *RuleQueryReq) GetOrderBy() string

func (*RuleQueryReq) GetPageNum 

func (x *RuleQueryReq) GetPageNum() uint32

func (*RuleQueryReq) GetPageSize 

func (x *RuleQueryReq) GetPageSize() uint32

func (*RuleQueryReq) GetSearchKey 

func (x *RuleQueryReq) GetSearchKey() string

func (*RuleQueryReq) GetStatus 

func (x *RuleQueryReq) GetStatus() *Uint32

func (*RuleQueryReq) GetType 

func (x *RuleQueryReq) GetType() uint32

func (*RuleQueryReq) ProtoMessage 

func (*RuleQueryReq) ProtoMessage()

func (*RuleQueryReq) ProtoReflect 

func (x *RuleQueryReq) ProtoReflect() protoreflect.Message

func (*RuleQueryReq) Reset 

func (x *RuleQueryReq) Reset()

func (*RuleQueryReq) String 

func (x *RuleQueryReq) String() string

type RuleQueryResp 

type RuleQueryResp struct {
	Total    uint32  `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	PageNum  uint32  `protobuf:"varint,2,opt,name=page_num,json=pageNum,proto3" json:"page_num,omitempty"`
	LastPage uint32  `protobuf:"varint,3,opt,name=last_page,json=lastPage,proto3" json:"last_page,omitempty"`
	PageSize uint32  `protobuf:"varint,4,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	Data     []*Rule `protobuf:"bytes,5,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*RuleQueryResp) Descriptor deprecated 

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

Deprecated: Use RuleQueryResp.ProtoReflect.Descriptor instead.

func (*RuleQueryResp) GetData 

func (x *RuleQueryResp) GetData() []*Rule

func (*RuleQueryResp) GetLastPage 

func (x *RuleQueryResp) GetLastPage() uint32

func (*RuleQueryResp) GetPageNum 

func (x *RuleQueryResp) GetPageNum() uint32

func (*RuleQueryResp) GetPageSize 

func (x *RuleQueryResp) GetPageSize() uint32

func (*RuleQueryResp) GetTotal 

func (x *RuleQueryResp) GetTotal() uint32

func (*RuleQueryResp) ProtoMessage 

func (*RuleQueryResp) ProtoMessage()

func (*RuleQueryResp) ProtoReflect 

func (x *RuleQueryResp) ProtoReflect() protoreflect.Message

func (*RuleQueryResp) Reset 

func (x *RuleQueryResp) Reset()

func (*RuleQueryResp) String 

func (x *RuleQueryResp) String() string

type RuleSqlUpdateReq 

type RuleSqlUpdateReq struct {
	Id         uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	SelectExpr string `protobuf:"bytes,2,opt,name=select_expr,json=selectExpr,proto3" json:"select_expr,omitempty"`
	WhereExpr  string `protobuf:"bytes,3,opt,name=where_expr,json=whereExpr,proto3" json:"where_expr,omitempty"`
	// contains filtered or unexported fields
}

func (*RuleSqlUpdateReq) Descriptor deprecated 

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

Deprecated: Use RuleSqlUpdateReq.ProtoReflect.Descriptor instead.

func (*RuleSqlUpdateReq) GetId 

func (x *RuleSqlUpdateReq) GetId() uint64

func (*RuleSqlUpdateReq) GetSelectExpr 

func (x *RuleSqlUpdateReq) GetSelectExpr() string

func (*RuleSqlUpdateReq) GetWhereExpr 

func (x *RuleSqlUpdateReq) GetWhereExpr() string

func (*RuleSqlUpdateReq) ProtoMessage 

func (*RuleSqlUpdateReq) ProtoMessage()

func (*RuleSqlUpdateReq) ProtoReflect 

func (x *RuleSqlUpdateReq) ProtoReflect() protoreflect.Message

func (*RuleSqlUpdateReq) Reset 

func (x *RuleSqlUpdateReq) Reset()

func (*RuleSqlUpdateReq) String 

func (x *RuleSqlUpdateReq) String() string

type RuleSqlUpdateResp 

type RuleSqlUpdateResp struct {
	Id         uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	UpdatedAt  int64  `protobuf:"varint,2,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	SelectExpr string `protobuf:"bytes,3,opt,name=select_expr,json=selectExpr,proto3" json:"select_expr,omitempty"`
	WhereExpr  string `protobuf:"bytes,4,opt,name=where_expr,json=whereExpr,proto3" json:"where_expr,omitempty"`
	// contains filtered or unexported fields
}

func (*RuleSqlUpdateResp) Descriptor deprecated 

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

Deprecated: Use RuleSqlUpdateResp.ProtoReflect.Descriptor instead.

func (*RuleSqlUpdateResp) GetId 

func (x *RuleSqlUpdateResp) GetId() uint64

func (*RuleSqlUpdateResp) GetSelectExpr 

func (x *RuleSqlUpdateResp) GetSelectExpr() string

func (*RuleSqlUpdateResp) GetUpdatedAt 

func (x *RuleSqlUpdateResp) GetUpdatedAt() int64

func (*RuleSqlUpdateResp) GetWhereExpr 

func (x *RuleSqlUpdateResp) GetWhereExpr() string

func (*RuleSqlUpdateResp) ProtoMessage 

func (*RuleSqlUpdateResp) ProtoMessage()

func (*RuleSqlUpdateResp) ProtoReflect 

func (x *RuleSqlUpdateResp) ProtoReflect() protoreflect.Message

func (*RuleSqlUpdateResp) Reset 

func (x *RuleSqlUpdateResp) Reset()

func (*RuleSqlUpdateResp) String 

func (x *RuleSqlUpdateResp) String() string

type RuleStatusSwitchReq 

type RuleStatusSwitchReq struct {
	Id     uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Status uint32 `protobuf:"varint,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*RuleStatusSwitchReq) Descriptor deprecated 

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

Deprecated: Use RuleStatusSwitchReq.ProtoReflect.Descriptor instead.

func (*RuleStatusSwitchReq) GetId 

func (x *RuleStatusSwitchReq) GetId() uint64

func (*RuleStatusSwitchReq) GetStatus 

func (x *RuleStatusSwitchReq) GetStatus() uint32

func (*RuleStatusSwitchReq) ProtoMessage 

func (*RuleStatusSwitchReq) ProtoMessage()

func (*RuleStatusSwitchReq) ProtoReflect 

func (x *RuleStatusSwitchReq) ProtoReflect() protoreflect.Message

func (*RuleStatusSwitchReq) Reset 

func (x *RuleStatusSwitchReq) Reset()

func (*RuleStatusSwitchReq) String 

func (x *RuleStatusSwitchReq) String() string

type RuleStatusSwitchResp 

type RuleStatusSwitchResp struct {
	Id     uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Status uint32 `protobuf:"varint,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*RuleStatusSwitchResp) Descriptor deprecated 

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

Deprecated: Use RuleStatusSwitchResp.ProtoReflect.Descriptor instead.

func (*RuleStatusSwitchResp) GetId 

func (x *RuleStatusSwitchResp) GetId() uint64

func (*RuleStatusSwitchResp) GetStatus 

func (x *RuleStatusSwitchResp) GetStatus() uint32

func (*RuleStatusSwitchResp) ProtoMessage 

func (*RuleStatusSwitchResp) ProtoMessage()

func (*RuleStatusSwitchResp) ProtoReflect 

func (x *RuleStatusSwitchResp) ProtoReflect() protoreflect.Message

func (*RuleStatusSwitchResp) Reset 

func (x *RuleStatusSwitchResp) Reset()

func (*RuleStatusSwitchResp) String 

func (x *RuleStatusSwitchResp) String() string

type RuleUpdateReq 

type RuleUpdateReq struct {
	Id   uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Desc string `protobuf:"bytes,3,opt,name=desc,proto3" json:"desc,omitempty"`
	// contains filtered or unexported fields
}

rule update

func (*RuleUpdateReq) Descriptor deprecated 

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

Deprecated: Use RuleUpdateReq.ProtoReflect.Descriptor instead.

func (*RuleUpdateReq) GetDesc 

func (x *RuleUpdateReq) GetDesc() string

func (*RuleUpdateReq) GetId 

func (x *RuleUpdateReq) GetId() uint64

func (*RuleUpdateReq) GetName 

func (x *RuleUpdateReq) GetName() string

func (*RuleUpdateReq) ProtoMessage 

func (*RuleUpdateReq) ProtoMessage()

func (*RuleUpdateReq) ProtoReflect 

func (x *RuleUpdateReq) ProtoReflect() protoreflect.Message

func (*RuleUpdateReq) Reset 

func (x *RuleUpdateReq) Reset()

func (*RuleUpdateReq) String 

func (x *RuleUpdateReq) String() string

type RuleUpdateResp 

type RuleUpdateResp struct {
	Id        uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name      string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Desc      string `protobuf:"bytes,3,opt,name=desc,proto3" json:"desc,omitempty"`
	Type      uint32 `protobuf:"varint,4,opt,name=type,proto3" json:"type,omitempty"`
	Status    uint32 `protobuf:"varint,5,opt,name=status,proto3" json:"status,omitempty"`
	CreatedAt int64  `protobuf:"varint,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt int64  `protobuf:"varint,7,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	ModelId   string `protobuf:"bytes,8,opt,name=model_id,json=modelId,proto3" json:"model_id,omitempty"`
	ModelName string `protobuf:"bytes,9,opt,name=model_name,json=modelName,proto3" json:"model_name,omitempty"`
	// contains filtered or unexported fields
}

func (*RuleUpdateResp) Descriptor deprecated 

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

Deprecated: Use RuleUpdateResp.ProtoReflect.Descriptor instead.

func (*RuleUpdateResp) GetCreatedAt 

func (x *RuleUpdateResp) GetCreatedAt() int64

func (*RuleUpdateResp) GetDesc 

func (x *RuleUpdateResp) GetDesc() string

func (*RuleUpdateResp) GetId 

func (x *RuleUpdateResp) GetId() uint64

func (*RuleUpdateResp) GetModelId 

func (x *RuleUpdateResp) GetModelId() string

func (*RuleUpdateResp) GetModelName 

func (x *RuleUpdateResp) GetModelName() string

func (*RuleUpdateResp) GetName 

func (x *RuleUpdateResp) GetName() string

func (*RuleUpdateResp) GetStatus 

func (x *RuleUpdateResp) GetStatus() uint32

func (*RuleUpdateResp) GetType 

func (x *RuleUpdateResp) GetType() uint32

func (*RuleUpdateResp) GetUpdatedAt 

func (x *RuleUpdateResp) GetUpdatedAt() int64

func (*RuleUpdateResp) ProtoMessage 

func (*RuleUpdateResp) ProtoMessage()

func (*RuleUpdateResp) ProtoReflect 

func (x *RuleUpdateResp) ProtoReflect() protoreflect.Message

func (*RuleUpdateResp) Reset 

func (x *RuleUpdateResp) Reset()

func (*RuleUpdateResp) String 

func (x *RuleUpdateResp) String() string

type RulesClient 

type RulesClient interface {
	RuleCreate(ctx context.Context, in *RuleCreateReq, opts ...grpc.CallOption) (*RuleCreateResp, error)
	RuleUpdate(ctx context.Context, in *RuleUpdateReq, opts ...grpc.CallOption) (*RuleUpdateResp, error)
	RuleDelete(ctx context.Context, in *RuleDeleteReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	RuleGet(ctx context.Context, in *RuleGetReq, opts ...grpc.CallOption) (*Rule, error)
	RuleQuery(ctx context.Context, in *RuleQueryReq, opts ...grpc.CallOption) (*RuleQueryResp, error)
	RuleStatusSwitch(ctx context.Context, in *RuleStatusSwitchReq, opts ...grpc.CallOption) (*RuleStatusSwitchResp, error)
	GetRuleDevicesID(ctx context.Context, in *RuleDevicesIDReq, opts ...grpc.CallOption) (*RuleDevicesIDResp, error)
	AddDevicesToRule(ctx context.Context, in *AddDevicesToRuleReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	RemoveDevicesFromRule(ctx context.Context, in *RemoveDevicesFromRuleReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	RemoveDeviceFromAllRule(ctx context.Context, in *RemoveDeviceFromAllRuleReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetRuleDevices(ctx context.Context, in *RuleDevicesReq, opts ...grpc.CallOption) (*RuleDevicesResp, error)
	CreateRuleTarget(ctx context.Context, in *CreateRuleTargetReq, opts ...grpc.CallOption) (*CreateRuleTargetResp, error)
	UpdateRuleTarget(ctx context.Context, in *UpdateRuleTargetReq, opts ...grpc.CallOption) (*UpdateRuleTargetResp, error)
	TestConnectToKafka(ctx context.Context, in *TestConnectToKafkaReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ActionVerify(ctx context.Context, in *ASVerifyReq, opts ...grpc.CallOption) (*ASVerifyResp, error)
	TableList(ctx context.Context, in *ASTableListReq, opts ...grpc.CallOption) (*ASTableListResp, error)
	GetTableDetails(ctx context.Context, in *ASGetTableDetailsReq, opts ...grpc.CallOption) (*ASGetTableDetailsResp, error)
	GetTableMap(ctx context.Context, in *ASGetTableMapReq, opts ...grpc.CallOption) (*ASGetTableMapResp, error)
	UpdateTableMap(ctx context.Context, in *ASUpdateTableMapReq, opts ...grpc.CallOption) (*ASUpdateTableMapResp, error)
	ListRuleTarget(ctx context.Context, in *ListRuleTargetReq, opts ...grpc.CallOption) (*ListRuleTargetResp, error)
	DeleteRuleTarget(ctx context.Context, in *DeleteRuleTargetReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ErrSubscribe(ctx context.Context, in *ErrSubscribeReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ChangeErrSubscribe(ctx context.Context, in *ChangeErrSubscribeReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ErrUnsubscribe(ctx context.Context, in *ErrUnsubscribeReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	RuleSQLUpdate(ctx context.Context, in *RuleSqlUpdateReq, opts ...grpc.CallOption) (*RuleSqlUpdateResp, error)
}

RulesClient is the client API for Rules service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewRulesClient 

func NewRulesClient(cc grpc.ClientConnInterface) RulesClient

type RulesHTTPHandler 

type RulesHTTPHandler struct {
	// contains filtered or unexported fields
}

func (*RulesHTTPHandler) ActionVerify 

func (h *RulesHTTPHandler) ActionVerify(req *go_restful.Request, resp *go_restful.Response)

func (*RulesHTTPHandler) AddDevicesToRule 

func (h *RulesHTTPHandler) AddDevicesToRule(req *go_restful.Request, resp *go_restful.Response)

func (*RulesHTTPHandler) ChangeErrSubscribe 

func (h *RulesHTTPHandler) ChangeErrSubscribe(req *go_restful.Request, resp *go_restful.Response)

func (*RulesHTTPHandler) CreateRuleTarget 

func (h *RulesHTTPHandler) CreateRuleTarget(req *go_restful.Request, resp *go_restful.Response)

func (*RulesHTTPHandler) DeleteRuleTarget 

func (h *RulesHTTPHandler) DeleteRuleTarget(req *go_restful.Request, resp *go_restful.Response)

func (*RulesHTTPHandler) ErrSubscribe 

func (h *RulesHTTPHandler) ErrSubscribe(req *go_restful.Request, resp *go_restful.Response)

func (*RulesHTTPHandler) ErrUnsubscribe 

func (h *RulesHTTPHandler) ErrUnsubscribe(req *go_restful.Request, resp *go_restful.Response)

func (*RulesHTTPHandler) GetRuleDevices 

func (h *RulesHTTPHandler) GetRuleDevices(req *go_restful.Request, resp *go_restful.Response)

func (*RulesHTTPHandler) GetRuleDevicesID 

func (h *RulesHTTPHandler) GetRuleDevicesID(req *go_restful.Request, resp *go_restful.Response)

func (*RulesHTTPHandler) GetTableDetails 

func (h *RulesHTTPHandler) GetTableDetails(req *go_restful.Request, resp *go_restful.Response)

func (*RulesHTTPHandler) GetTableMap 

func (h *RulesHTTPHandler) GetTableMap(req *go_restful.Request, resp *go_restful.Response)

func (*RulesHTTPHandler) ListRuleTarget 

func (h *RulesHTTPHandler) ListRuleTarget(req *go_restful.Request, resp *go_restful.Response)

func (*RulesHTTPHandler) RemoveDeviceFromAllRule 

func (h *RulesHTTPHandler) RemoveDeviceFromAllRule(req *go_restful.Request, resp *go_restful.Response)

func (*RulesHTTPHandler) RemoveDevicesFromRule 

func (h *RulesHTTPHandler) RemoveDevicesFromRule(req *go_restful.Request, resp *go_restful.Response)

func (*RulesHTTPHandler) RuleCreate 

func (h *RulesHTTPHandler) RuleCreate(req *go_restful.Request, resp *go_restful.Response)

func (*RulesHTTPHandler) RuleDelete 

func (h *RulesHTTPHandler) RuleDelete(req *go_restful.Request, resp *go_restful.Response)

func (*RulesHTTPHandler) RuleGet 

func (h *RulesHTTPHandler) RuleGet(req *go_restful.Request, resp *go_restful.Response)

func (*RulesHTTPHandler) RuleQuery 

func (h *RulesHTTPHandler) RuleQuery(req *go_restful.Request, resp *go_restful.Response)

func (*RulesHTTPHandler) RuleSQLUpdate 

func (h *RulesHTTPHandler) RuleSQLUpdate(req *go_restful.Request, resp *go_restful.Response)

func (*RulesHTTPHandler) RuleStatusSwitch 

func (h *RulesHTTPHandler) RuleStatusSwitch(req *go_restful.Request, resp *go_restful.Response)

func (*RulesHTTPHandler) RuleUpdate 

func (h *RulesHTTPHandler) RuleUpdate(req *go_restful.Request, resp *go_restful.Response)

func (*RulesHTTPHandler) TableList 

func (h *RulesHTTPHandler) TableList(req *go_restful.Request, resp *go_restful.Response)

func (*RulesHTTPHandler) TestConnectToKafka 

func (h *RulesHTTPHandler) TestConnectToKafka(req *go_restful.Request, resp *go_restful.Response)

func (*RulesHTTPHandler) UpdateRuleTarget 

func (h *RulesHTTPHandler) UpdateRuleTarget(req *go_restful.Request, resp *go_restful.Response)

func (*RulesHTTPHandler) UpdateTableMap 

func (h *RulesHTTPHandler) UpdateTableMap(req *go_restful.Request, resp *go_restful.Response)

type RulesHTTPServer 

type RulesHTTPServer interface {
	ActionVerify(context.Context, *ASVerifyReq) (*ASVerifyResp, error)
	AddDevicesToRule(context.Context, *AddDevicesToRuleReq) (*emptypb.Empty, error)
	ChangeErrSubscribe(context.Context, *ChangeErrSubscribeReq) (*emptypb.Empty, error)
	CreateRuleTarget(context.Context, *CreateRuleTargetReq) (*CreateRuleTargetResp, error)
	DeleteRuleTarget(context.Context, *DeleteRuleTargetReq) (*emptypb.Empty, error)
	ErrSubscribe(context.Context, *ErrSubscribeReq) (*emptypb.Empty, error)
	ErrUnsubscribe(context.Context, *ErrUnsubscribeReq) (*emptypb.Empty, error)
	GetRuleDevices(context.Context, *RuleDevicesReq) (*RuleDevicesResp, error)
	GetRuleDevicesID(context.Context, *RuleDevicesIDReq) (*RuleDevicesIDResp, error)
	GetTableDetails(context.Context, *ASGetTableDetailsReq) (*ASGetTableDetailsResp, error)
	GetTableMap(context.Context, *ASGetTableMapReq) (*ASGetTableMapResp, error)
	ListRuleTarget(context.Context, *ListRuleTargetReq) (*ListRuleTargetResp, error)
	RemoveDeviceFromAllRule(context.Context, *RemoveDeviceFromAllRuleReq) (*emptypb.Empty, error)
	RemoveDevicesFromRule(context.Context, *RemoveDevicesFromRuleReq) (*emptypb.Empty, error)
	RuleCreate(context.Context, *RuleCreateReq) (*RuleCreateResp, error)
	RuleDelete(context.Context, *RuleDeleteReq) (*emptypb.Empty, error)
	RuleGet(context.Context, *RuleGetReq) (*Rule, error)
	RuleQuery(context.Context, *RuleQueryReq) (*RuleQueryResp, error)
	RuleSQLUpdate(context.Context, *RuleSqlUpdateReq) (*RuleSqlUpdateResp, error)
	RuleStatusSwitch(context.Context, *RuleStatusSwitchReq) (*RuleStatusSwitchResp, error)
	RuleUpdate(context.Context, *RuleUpdateReq) (*RuleUpdateResp, error)
	TableList(context.Context, *ASTableListReq) (*ASTableListResp, error)
	TestConnectToKafka(context.Context, *TestConnectToKafkaReq) (*emptypb.Empty, error)
	UpdateRuleTarget(context.Context, *UpdateRuleTargetReq) (*UpdateRuleTargetResp, error)
	UpdateTableMap(context.Context, *ASUpdateTableMapReq) (*ASUpdateTableMapResp, error)
}

type RulesServer 

type RulesServer interface {
	RuleCreate(context.Context, *RuleCreateReq) (*RuleCreateResp, error)
	RuleUpdate(context.Context, *RuleUpdateReq) (*RuleUpdateResp, error)
	RuleDelete(context.Context, *RuleDeleteReq) (*emptypb.Empty, error)
	RuleGet(context.Context, *RuleGetReq) (*Rule, error)
	RuleQuery(context.Context, *RuleQueryReq) (*RuleQueryResp, error)
	RuleStatusSwitch(context.Context, *RuleStatusSwitchReq) (*RuleStatusSwitchResp, error)
	GetRuleDevicesID(context.Context, *RuleDevicesIDReq) (*RuleDevicesIDResp, error)
	AddDevicesToRule(context.Context, *AddDevicesToRuleReq) (*emptypb.Empty, error)
	RemoveDevicesFromRule(context.Context, *RemoveDevicesFromRuleReq) (*emptypb.Empty, error)
	RemoveDeviceFromAllRule(context.Context, *RemoveDeviceFromAllRuleReq) (*emptypb.Empty, error)
	GetRuleDevices(context.Context, *RuleDevicesReq) (*RuleDevicesResp, error)
	CreateRuleTarget(context.Context, *CreateRuleTargetReq) (*CreateRuleTargetResp, error)
	UpdateRuleTarget(context.Context, *UpdateRuleTargetReq) (*UpdateRuleTargetResp, error)
	TestConnectToKafka(context.Context, *TestConnectToKafkaReq) (*emptypb.Empty, error)
	ActionVerify(context.Context, *ASVerifyReq) (*ASVerifyResp, error)
	TableList(context.Context, *ASTableListReq) (*ASTableListResp, error)
	GetTableDetails(context.Context, *ASGetTableDetailsReq) (*ASGetTableDetailsResp, error)
	GetTableMap(context.Context, *ASGetTableMapReq) (*ASGetTableMapResp, error)
	UpdateTableMap(context.Context, *ASUpdateTableMapReq) (*ASUpdateTableMapResp, error)
	ListRuleTarget(context.Context, *ListRuleTargetReq) (*ListRuleTargetResp, error)
	DeleteRuleTarget(context.Context, *DeleteRuleTargetReq) (*emptypb.Empty, error)
	ErrSubscribe(context.Context, *ErrSubscribeReq) (*emptypb.Empty, error)
	ChangeErrSubscribe(context.Context, *ChangeErrSubscribeReq) (*emptypb.Empty, error)
	ErrUnsubscribe(context.Context, *ErrUnsubscribeReq) (*emptypb.Empty, error)
	RuleSQLUpdate(context.Context, *RuleSqlUpdateReq) (*RuleSqlUpdateResp, error)
	// contains filtered or unexported methods
}

RulesServer is the server API for Rules service. All implementations must embed UnimplementedRulesServer for forward compatibility

type String 

type String struct {
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*String) Descriptor deprecated 

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

Deprecated: Use String.ProtoReflect.Descriptor instead.

func (*String) GetValue 

func (x *String) GetValue() string

func (*String) ProtoMessage 

func (*String) ProtoMessage()

func (*String) ProtoReflect 

func (x *String) ProtoReflect() protoreflect.Message

func (*String) Reset 

func (x *String) Reset()

func (*String) String 

func (x *String) String() string

type Table 

type Table struct {
	Name   string   `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Fields []*Field `protobuf:"bytes,8,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

func (*Table) Descriptor deprecated 

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

Deprecated: Use Table.ProtoReflect.Descriptor instead.

func (*Table) GetFields 

func (x *Table) GetFields() []*Field

func (*Table) GetName 

func (x *Table) GetName() string

func (*Table) ProtoMessage 

func (*Table) ProtoMessage()

func (*Table) ProtoReflect 

func (x *Table) ProtoReflect() protoreflect.Message

func (*Table) Reset 

func (x *Table) Reset()

func (*Table) String 

func (x *Table) String() string

type TestConnectToKafkaReq 

type TestConnectToKafkaReq struct {
	Host  string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

func (*TestConnectToKafkaReq) Descriptor deprecated 

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

Deprecated: Use TestConnectToKafkaReq.ProtoReflect.Descriptor instead.

func (*TestConnectToKafkaReq) GetHost 

func (x *TestConnectToKafkaReq) GetHost() string

func (*TestConnectToKafkaReq) GetTopic 

func (x *TestConnectToKafkaReq) GetTopic() string

func (*TestConnectToKafkaReq) ProtoMessage 

func (*TestConnectToKafkaReq) ProtoMessage()

func (*TestConnectToKafkaReq) ProtoReflect 

func (x *TestConnectToKafkaReq) ProtoReflect() protoreflect.Message

func (*TestConnectToKafkaReq) Reset 

func (x *TestConnectToKafkaReq) Reset()

func (*TestConnectToKafkaReq) String 

func (x *TestConnectToKafkaReq) String() string

type Uint32 

type Uint32 struct {
	Value uint32 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Uint32) Descriptor deprecated 

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

Deprecated: Use Uint32.ProtoReflect.Descriptor instead.

func (*Uint32) GetValue 

func (x *Uint32) GetValue() uint32

func (*Uint32) ProtoMessage 

func (*Uint32) ProtoMessage()

func (*Uint32) ProtoReflect 

func (x *Uint32) ProtoReflect() protoreflect.Message

func (*Uint32) Reset 

func (x *Uint32) Reset()

func (*Uint32) String 

func (x *Uint32) String() string

type Uint64 

type Uint64 struct {
	Value uint64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Uint64) Descriptor deprecated 

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

Deprecated: Use Uint64.ProtoReflect.Descriptor instead.

func (*Uint64) GetValue 

func (x *Uint64) GetValue() uint64

func (*Uint64) ProtoMessage 

func (*Uint64) ProtoMessage()

func (*Uint64) ProtoReflect 

func (x *Uint64) ProtoReflect() protoreflect.Message

func (*Uint64) Reset 

func (x *Uint64) Reset()

func (*Uint64) String 

func (x *Uint64) String() string

type UnimplementedRulesServer 

type UnimplementedRulesServer struct {
}

UnimplementedRulesServer must be embedded to have forward compatible implementations.

func (UnimplementedRulesServer) ActionVerify 

func (UnimplementedRulesServer) ActionVerify(context.Context, *ASVerifyReq) (*ASVerifyResp, error)

func (UnimplementedRulesServer) AddDevicesToRule 

func (UnimplementedRulesServer) AddDevicesToRule(context.Context, *AddDevicesToRuleReq) (*emptypb.Empty, error)

func (UnimplementedRulesServer) ChangeErrSubscribe 

func (UnimplementedRulesServer) ChangeErrSubscribe(context.Context, *ChangeErrSubscribeReq) (*emptypb.Empty, error)

func (UnimplementedRulesServer) CreateRuleTarget 

func (UnimplementedRulesServer) CreateRuleTarget(context.Context, *CreateRuleTargetReq) (*CreateRuleTargetResp, error)

func (UnimplementedRulesServer) DeleteRuleTarget 

func (UnimplementedRulesServer) DeleteRuleTarget(context.Context, *DeleteRuleTargetReq) (*emptypb.Empty, error)

func (UnimplementedRulesServer) ErrSubscribe 

func (UnimplementedRulesServer) ErrSubscribe(context.Context, *ErrSubscribeReq) (*emptypb.Empty, error)

func (UnimplementedRulesServer) ErrUnsubscribe 

func (UnimplementedRulesServer) ErrUnsubscribe(context.Context, *ErrUnsubscribeReq) (*emptypb.Empty, error)

func (UnimplementedRulesServer) GetRuleDevices 

func (UnimplementedRulesServer) GetRuleDevices(context.Context, *RuleDevicesReq) (*RuleDevicesResp, error)

func (UnimplementedRulesServer) GetRuleDevicesID 

func (UnimplementedRulesServer) GetRuleDevicesID(context.Context, *RuleDevicesIDReq) (*RuleDevicesIDResp, error)

func (UnimplementedRulesServer) GetTableDetails 

func (UnimplementedRulesServer) GetTableDetails(context.Context, *ASGetTableDetailsReq) (*ASGetTableDetailsResp, error)

func (UnimplementedRulesServer) GetTableMap 

func (UnimplementedRulesServer) GetTableMap(context.Context, *ASGetTableMapReq) (*ASGetTableMapResp, error)

func (UnimplementedRulesServer) ListRuleTarget 

func (UnimplementedRulesServer) ListRuleTarget(context.Context, *ListRuleTargetReq) (*ListRuleTargetResp, error)

func (UnimplementedRulesServer) RemoveDeviceFromAllRule 

func (UnimplementedRulesServer) RemoveDeviceFromAllRule(context.Context, *RemoveDeviceFromAllRuleReq) (*emptypb.Empty, error)

func (UnimplementedRulesServer) RemoveDevicesFromRule 

func (UnimplementedRulesServer) RemoveDevicesFromRule(context.Context, *RemoveDevicesFromRuleReq) (*emptypb.Empty, error)

func (UnimplementedRulesServer) RuleCreate 

func (UnimplementedRulesServer) RuleCreate(context.Context, *RuleCreateReq) (*RuleCreateResp, error)

func (UnimplementedRulesServer) RuleDelete 

func (UnimplementedRulesServer) RuleDelete(context.Context, *RuleDeleteReq) (*emptypb.Empty, error)

func (UnimplementedRulesServer) RuleGet 

func (UnimplementedRulesServer) RuleGet(context.Context, *RuleGetReq) (*Rule, error)

func (UnimplementedRulesServer) RuleQuery 

func (UnimplementedRulesServer) RuleQuery(context.Context, *RuleQueryReq) (*RuleQueryResp, error)

func (UnimplementedRulesServer) RuleSQLUpdate 

func (UnimplementedRulesServer) RuleSQLUpdate(context.Context, *RuleSqlUpdateReq) (*RuleSqlUpdateResp, error)

func (UnimplementedRulesServer) RuleStatusSwitch 

func (UnimplementedRulesServer) RuleStatusSwitch(context.Context, *RuleStatusSwitchReq) (*RuleStatusSwitchResp, error)

func (UnimplementedRulesServer) RuleUpdate 

func (UnimplementedRulesServer) RuleUpdate(context.Context, *RuleUpdateReq) (*RuleUpdateResp, error)

func (UnimplementedRulesServer) TableList 

func (UnimplementedRulesServer) TableList(context.Context, *ASTableListReq) (*ASTableListResp, error)

func (UnimplementedRulesServer) TestConnectToKafka 

func (UnimplementedRulesServer) TestConnectToKafka(context.Context, *TestConnectToKafkaReq) (*emptypb.Empty, error)

func (UnimplementedRulesServer) UpdateRuleTarget 

func (UnimplementedRulesServer) UpdateRuleTarget(context.Context, *UpdateRuleTargetReq) (*UpdateRuleTargetResp, error)

func (UnimplementedRulesServer) UpdateTableMap 

func (UnimplementedRulesServer) UpdateTableMap(context.Context, *ASUpdateTableMapReq) (*ASUpdateTableMapResp, error)

type UnsafeRulesServer 

type UnsafeRulesServer interface {
	// contains filtered or unexported methods
}

UnsafeRulesServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RulesServer will result in compilation errors.

type UpdateRuleTargetReq 

type UpdateRuleTargetReq struct {
	Id       uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	TargetId uint64 `protobuf:"varint,2,opt,name=target_id,json=targetId,proto3" json:"target_id,omitempty"`
	Host     string `protobuf:"bytes,3,opt,name=host,proto3" json:"host,omitempty"`
	Value    string `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	// string ext = 5;
	SinkType string            `protobuf:"bytes,6,opt,name=sink_type,json=sinkType,proto3" json:"sink_type,omitempty"`
	SinkId   string            `protobuf:"bytes,7,opt,name=sink_id,json=sinkId,proto3" json:"sink_id,omitempty"`
	Tags     map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UpdateRuleTargetReq) Descriptor deprecated 

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

Deprecated: Use UpdateRuleTargetReq.ProtoReflect.Descriptor instead.

func (*UpdateRuleTargetReq) GetHost 

func (x *UpdateRuleTargetReq) GetHost() string

func (*UpdateRuleTargetReq) GetId 

func (x *UpdateRuleTargetReq) GetId() uint64

func (*UpdateRuleTargetReq) GetSinkId 

func (x *UpdateRuleTargetReq) GetSinkId() string

func (*UpdateRuleTargetReq) GetSinkType 

func (x *UpdateRuleTargetReq) GetSinkType() string

func (*UpdateRuleTargetReq) GetTags 

func (x *UpdateRuleTargetReq) GetTags() map[string]string

func (*UpdateRuleTargetReq) GetTargetId 

func (x *UpdateRuleTargetReq) GetTargetId() uint64

func (*UpdateRuleTargetReq) GetValue 

func (x *UpdateRuleTargetReq) GetValue() string

func (*UpdateRuleTargetReq) ProtoMessage 

func (*UpdateRuleTargetReq) ProtoMessage()

func (*UpdateRuleTargetReq) ProtoReflect 

func (x *UpdateRuleTargetReq) ProtoReflect() protoreflect.Message

func (*UpdateRuleTargetReq) Reset 

func (x *UpdateRuleTargetReq) Reset()

func (*UpdateRuleTargetReq) String 

func (x *UpdateRuleTargetReq) String() string

type UpdateRuleTargetResp 

type UpdateRuleTargetResp struct {
	Id       uint64            `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Type     uint32            `protobuf:"varint,2,opt,name=type,proto3" json:"type,omitempty"`
	Host     string            `protobuf:"bytes,3,opt,name=host,proto3" json:"host,omitempty"`
	Value    string            `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	SinkType string            `protobuf:"bytes,6,opt,name=sink_type,json=sinkType,proto3" json:"sink_type,omitempty"`
	SinkId   string            `protobuf:"bytes,7,opt,name=sink_id,json=sinkId,proto3" json:"sink_id,omitempty"`
	Fields   []*MapField       `protobuf:"bytes,8,rep,name=fields,proto3" json:"fields,omitempty"`
	Tags     map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UpdateRuleTargetResp) Descriptor deprecated 

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

Deprecated: Use UpdateRuleTargetResp.ProtoReflect.Descriptor instead.

func (*UpdateRuleTargetResp) GetFields 

func (x *UpdateRuleTargetResp) GetFields() []*MapField

func (*UpdateRuleTargetResp) GetHost 

func (x *UpdateRuleTargetResp) GetHost() string

func (*UpdateRuleTargetResp) GetId 

func (x *UpdateRuleTargetResp) GetId() uint64

func (*UpdateRuleTargetResp) GetSinkId 

func (x *UpdateRuleTargetResp) GetSinkId() string

func (*UpdateRuleTargetResp) GetSinkType 

func (x *UpdateRuleTargetResp) GetSinkType() string

func (*UpdateRuleTargetResp) GetTags 

func (x *UpdateRuleTargetResp) GetTags() map[string]string

func (*UpdateRuleTargetResp) GetType 

func (x *UpdateRuleTargetResp) GetType() uint32

func (*UpdateRuleTargetResp) GetValue 

func (x *UpdateRuleTargetResp) GetValue() string

func (*UpdateRuleTargetResp) ProtoMessage 

func (*UpdateRuleTargetResp) ProtoMessage()

func (*UpdateRuleTargetResp) ProtoReflect 

func (x *UpdateRuleTargetResp) ProtoReflect() protoreflect.Message

func (*UpdateRuleTargetResp) Reset 

func (x *UpdateRuleTargetResp) Reset()

func (*UpdateRuleTargetResp) String 

func (x *UpdateRuleTargetResp) String() string

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.