v1

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
}

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

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
}

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
}

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

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

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
}

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
}

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
}

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
}

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
}

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

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
}

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
}

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
}

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
}

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
}

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
}

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

type Error int32

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
}

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

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

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
}

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
}

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
}

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
}

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

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
}

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
}

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
}

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
}

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

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

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

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
}

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
}

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

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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
}

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)
}

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

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 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
}

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

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
}

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
}