metadata_center

package
v0.0.0-...-b63aa1a Latest Latest
Warning

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

 Go to latest Published: Dec 18, 2019 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type StreamAlertRule 

type StreamAlertRule struct {
	//
	//告警规则id
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id" form:"id"`
	//
	//org
	Org int32 `protobuf:"varint,2,opt,name=org,proto3" json:"org" form:"org"`
	//
	//版本
	Version int32 `protobuf:"varint,3,opt,name=version,proto3" json:"version" form:"version"`
	//
	//版本id
	VersionId string `protobuf:"bytes,4,opt,name=versionId,proto3" json:"versionId" form:"versionId"`
	//
	//指标表名
	Schema string `protobuf:"bytes,5,opt,name=schema,proto3" json:"schema" form:"schema"`
	//
	//告警优先级
	Priority int32 `protobuf:"varint,6,opt,name=priority,proto3" json:"priority" form:"priority"`
	//
	//告警维度
	Dimensions []*StreamAlertRule_Dimensions `protobuf:"bytes,7,rep,name=dimensions,proto3" json:"dimensions" form:"dimensions"`
	//
	//告警指标
	Metric string `protobuf:"bytes,8,opt,name=metric,proto3" json:"metric" form:"metric"`
	//
	//告警比较器
	//bigger_than: 大于
	//smaller_than: 小于
	//equal: 等于
	//unequal: 不等于
	//include: 包含
	//exclude: 不包含
	//dynamic: 动态阈值
	//transition: 状态变更
	//
	Comparator string `protobuf:"bytes,9,opt,name=comparator,proto3" json:"comparator" form:"comparator"`
	//
	//告警条件
	Conditions []*StreamAlertRule_Conditions `protobuf:"bytes,10,rep,name=conditions,proto3" json:"conditions" form:"conditions"`
	//
	//告警命中数量
	AlertCount int32 `protobuf:"varint,11,opt,name=alertCount,proto3" json:"alertCount" form:"alertCount"`
	//
	//告警窗口
	AlertWindow int32 `protobuf:"varint,12,opt,name=alertWindow,proto3" json:"alertWindow" form:"alertWindow"`
	//
	//告警间隔
	AlertInterval int32 `protobuf:"varint,13,opt,name=alertInterval,proto3" json:"alertInterval" form:"alertInterval"`
	//
	//恢复窗口
	RecoverCount         int32    `protobuf:"varint,14,opt,name=recoverCount,proto3" json:"recoverCount" form:"recoverCount"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

告警规则

func (*StreamAlertRule) Descriptor 

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

func (*StreamAlertRule) GetAlertCount 

func (m *StreamAlertRule) GetAlertCount() int32

func (*StreamAlertRule) GetAlertInterval 

func (m *StreamAlertRule) GetAlertInterval() int32

func (*StreamAlertRule) GetAlertWindow 

func (m *StreamAlertRule) GetAlertWindow() int32

func (*StreamAlertRule) GetComparator 

func (m *StreamAlertRule) GetComparator() string

func (*StreamAlertRule) GetConditions 

func (m *StreamAlertRule) GetConditions() []*StreamAlertRule_Conditions

func (*StreamAlertRule) GetDimensions 

func (m *StreamAlertRule) GetDimensions() []*StreamAlertRule_Dimensions

func (*StreamAlertRule) GetId 

func (m *StreamAlertRule) GetId() string

func (*StreamAlertRule) GetMetric 

func (m *StreamAlertRule) GetMetric() string

func (*StreamAlertRule) GetOrg 

func (m *StreamAlertRule) GetOrg() int32

func (*StreamAlertRule) GetPriority 

func (m *StreamAlertRule) GetPriority() int32

func (*StreamAlertRule) GetRecoverCount 

func (m *StreamAlertRule) GetRecoverCount() int32

func (*StreamAlertRule) GetSchema 

func (m *StreamAlertRule) GetSchema() string

func (*StreamAlertRule) GetVersion 

func (m *StreamAlertRule) GetVersion() int32

func (*StreamAlertRule) GetVersionId 

func (m *StreamAlertRule) GetVersionId() string

func (*StreamAlertRule) ProtoMessage 

func (*StreamAlertRule) ProtoMessage()

func (*StreamAlertRule) Reset 

func (m *StreamAlertRule) Reset()

func (*StreamAlertRule) String 

func (m *StreamAlertRule) String() string

func (*StreamAlertRule) Validate 

func (this *StreamAlertRule) Validate() error

func (*StreamAlertRule) XXX_DiscardUnknown 

func (m *StreamAlertRule) XXX_DiscardUnknown()

func (*StreamAlertRule) XXX_Marshal 

func (m *StreamAlertRule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamAlertRule) XXX_Merge 

func (m *StreamAlertRule) XXX_Merge(src proto.Message)

func (*StreamAlertRule) XXX_Size 

func (m *StreamAlertRule) XXX_Size() int

func (*StreamAlertRule) XXX_Unmarshal 

func (m *StreamAlertRule) XXX_Unmarshal(b []byte) error

type StreamAlertRule_Conditions 

type StreamAlertRule_Conditions struct {
	//
	//告警条件
	Level int32 `protobuf:"varint,1,opt,name=level,proto3" json:"level" form:"level"`
	//
	//告警阈值
	Threshold            *types.Value `protobuf:"bytes,2,opt,name=threshold,proto3" json:"threshold" form:"threshold"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*StreamAlertRule_Conditions) Descriptor 

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

func (*StreamAlertRule_Conditions) GetLevel 

func (m *StreamAlertRule_Conditions) GetLevel() int32

func (*StreamAlertRule_Conditions) GetThreshold 

func (m *StreamAlertRule_Conditions) GetThreshold() *types.Value

func (*StreamAlertRule_Conditions) ProtoMessage 

func (*StreamAlertRule_Conditions) ProtoMessage()

func (*StreamAlertRule_Conditions) Reset 

func (m *StreamAlertRule_Conditions) Reset()

func (*StreamAlertRule_Conditions) String 

func (m *StreamAlertRule_Conditions) String() string

func (*StreamAlertRule_Conditions) Validate 

func (this *StreamAlertRule_Conditions) Validate() error

func (*StreamAlertRule_Conditions) XXX_DiscardUnknown 

func (m *StreamAlertRule_Conditions) XXX_DiscardUnknown()

func (*StreamAlertRule_Conditions) XXX_Marshal 

func (m *StreamAlertRule_Conditions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamAlertRule_Conditions) XXX_Merge 

func (m *StreamAlertRule_Conditions) XXX_Merge(src proto.Message)

func (*StreamAlertRule_Conditions) XXX_Size 

func (m *StreamAlertRule_Conditions) XXX_Size() int

func (*StreamAlertRule_Conditions) XXX_Unmarshal 

func (m *StreamAlertRule_Conditions) XXX_Unmarshal(b []byte) error

type StreamAlertRule_Dimensions 

type StreamAlertRule_Dimensions struct {
	//
	//告警维度前台展示名字
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name" form:"name"`
	//
	//告警维度值数组
	Values               []string `protobuf:"bytes,2,rep,name=values,proto3" json:"values" form:"values"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamAlertRule_Dimensions) Descriptor 

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

func (*StreamAlertRule_Dimensions) GetName 

func (m *StreamAlertRule_Dimensions) GetName() string

func (*StreamAlertRule_Dimensions) GetValues 

func (m *StreamAlertRule_Dimensions) GetValues() []string

func (*StreamAlertRule_Dimensions) ProtoMessage 

func (*StreamAlertRule_Dimensions) ProtoMessage()

func (*StreamAlertRule_Dimensions) Reset 

func (m *StreamAlertRule_Dimensions) Reset()

func (*StreamAlertRule_Dimensions) String 

func (m *StreamAlertRule_Dimensions) String() string

func (*StreamAlertRule_Dimensions) Validate 

func (this *StreamAlertRule_Dimensions) Validate() error

func (*StreamAlertRule_Dimensions) XXX_DiscardUnknown 

func (m *StreamAlertRule_Dimensions) XXX_DiscardUnknown()

func (*StreamAlertRule_Dimensions) XXX_Marshal 

func (m *StreamAlertRule_Dimensions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamAlertRule_Dimensions) XXX_Merge 

func (m *StreamAlertRule_Dimensions) XXX_Merge(src proto.Message)

func (*StreamAlertRule_Dimensions) XXX_Size 

func (m *StreamAlertRule_Dimensions) XXX_Size() int

func (*StreamAlertRule_Dimensions) XXX_Unmarshal 

func (m *StreamAlertRule_Dimensions) XXX_Unmarshal(b []byte) error

type StreamAlertStates 

type StreamAlertStates struct {
	//
	//org
	Org int32 `protobuf:"varint,1,opt,name=org,proto3" json:"org" form:"org"`
	//
	//状态数据变更命令
	//upsert：插入/更新指定的状态数据
	//delete：删除指定的状态数据
	//retain：仅保留指定的状态数据
	//
	Command string `protobuf:"bytes,2,opt,name=command,proto3" json:"command" form:"command"`
	//
	//状态数据列表
	Payload              []*StreamAlertRule `protobuf:"bytes,3,rep,name=payload,proto3" json:"payload" form:"payload"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

告警状态数据

func (*StreamAlertStates) Descriptor 

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

func (*StreamAlertStates) GetCommand 

func (m *StreamAlertStates) GetCommand() string

func (*StreamAlertStates) GetOrg 

func (m *StreamAlertStates) GetOrg() int32

func (*StreamAlertStates) GetPayload 

func (m *StreamAlertStates) GetPayload() []*StreamAlertRule

func (*StreamAlertStates) ProtoMessage 

func (*StreamAlertStates) ProtoMessage()

func (*StreamAlertStates) Reset 

func (m *StreamAlertStates) Reset()

func (*StreamAlertStates) String 

func (m *StreamAlertStates) String() string

func (*StreamAlertStates) Validate 

func (this *StreamAlertStates) Validate() error

func (*StreamAlertStates) XXX_DiscardUnknown 

func (m *StreamAlertStates) XXX_DiscardUnknown()

func (*StreamAlertStates) XXX_Marshal 

func (m *StreamAlertStates) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamAlertStates) XXX_Merge 

func (m *StreamAlertStates) XXX_Merge(src proto.Message)

func (*StreamAlertStates) XXX_Size 

func (m *StreamAlertStates) XXX_Size() int

func (*StreamAlertStates) XXX_Unmarshal 

func (m *StreamAlertStates) XXX_Unmarshal(b []byte) error

type StreamMetricSchema 

type StreamMetricSchema struct {
	//
	//id
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id" form:"id"`
	//
	//org
	Org int32 `protobuf:"varint,2,opt,name=org,proto3" json:"org" form:"org"`
	//
	//指标版本
	Version int32 `protobuf:"varint,3,opt,name=version,proto3" json:"version" form:"version"`
	//
	//指标统计类型
	MetricType string `protobuf:"bytes,4,opt,name=metricType,proto3" json:"metricType" form:"metricType"`
	//
	//指标数据类型
	DataType             string   `protobuf:"bytes,5,opt,name=dataType,proto3" json:"dataType" form:"dataType"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

指标项

func (*StreamMetricSchema) Descriptor 

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

func (*StreamMetricSchema) GetDataType 

func (m *StreamMetricSchema) GetDataType() string

func (*StreamMetricSchema) GetId 

func (m *StreamMetricSchema) GetId() string

func (*StreamMetricSchema) GetMetricType 

func (m *StreamMetricSchema) GetMetricType() string

func (*StreamMetricSchema) GetOrg 

func (m *StreamMetricSchema) GetOrg() int32

func (*StreamMetricSchema) GetVersion 

func (m *StreamMetricSchema) GetVersion() int32

func (*StreamMetricSchema) ProtoMessage 

func (*StreamMetricSchema) ProtoMessage()

func (*StreamMetricSchema) Reset 

func (m *StreamMetricSchema) Reset()

func (*StreamMetricSchema) String 

func (m *StreamMetricSchema) String() string

func (*StreamMetricSchema) Validate 

func (this *StreamMetricSchema) Validate() error

func (*StreamMetricSchema) XXX_DiscardUnknown 

func (m *StreamMetricSchema) XXX_DiscardUnknown()

func (*StreamMetricSchema) XXX_Marshal 

func (m *StreamMetricSchema) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamMetricSchema) XXX_Merge 

func (m *StreamMetricSchema) XXX_Merge(src proto.Message)

func (*StreamMetricSchema) XXX_Size 

func (m *StreamMetricSchema) XXX_Size() int

func (*StreamMetricSchema) XXX_Unmarshal 

func (m *StreamMetricSchema) XXX_Unmarshal(b []byte) error

type StreamMetricStates 

type StreamMetricStates struct {
	//
	//org
	Org int32 `protobuf:"varint,1,opt,name=org,proto3" json:"org" form:"org"`
	//
	//状态数据变更命令
	//upsert：插入/更新指定的状态数据
	//delete：删除指定的状态数据
	//retain：仅保留指定的状态数据
	//
	Command string `protobuf:"bytes,2,opt,name=command,proto3" json:"command" form:"command"`
	//
	//状态数据列表
	Payload              []*StreamMetricSchema `protobuf:"bytes,3,rep,name=payload,proto3" json:"payload" form:"payload"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

指标状态数据

func (*StreamMetricStates) Descriptor 

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

func (*StreamMetricStates) GetCommand 

func (m *StreamMetricStates) GetCommand() string

func (*StreamMetricStates) GetOrg 

func (m *StreamMetricStates) GetOrg() int32

func (*StreamMetricStates) GetPayload 

func (m *StreamMetricStates) GetPayload() []*StreamMetricSchema

func (*StreamMetricStates) ProtoMessage 

func (*StreamMetricStates) ProtoMessage()

func (*StreamMetricStates) Reset 

func (m *StreamMetricStates) Reset()

func (*StreamMetricStates) String 

func (m *StreamMetricStates) String() string

func (*StreamMetricStates) Validate 

func (this *StreamMetricStates) Validate() error

func (*StreamMetricStates) XXX_DiscardUnknown 

func (m *StreamMetricStates) XXX_DiscardUnknown()

func (*StreamMetricStates) XXX_Marshal 

func (m *StreamMetricStates) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamMetricStates) XXX_Merge 

func (m *StreamMetricStates) XXX_Merge(src proto.Message)

func (*StreamMetricStates) XXX_Size 

func (m *StreamMetricStates) XXX_Size() int

func (*StreamMetricStates) XXX_Unmarshal 

func (m *StreamMetricStates) XXX_Unmarshal(b []byte) error

type StreamMetricsSchema 

type StreamMetricsSchema struct {
	//
	//id
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id" form:"id"`
	//
	//org
	Org int32 `protobuf:"varint,2,opt,name=org,proto3" json:"org" form:"org"`
	//
	//指标表版本
	Version int32 `protobuf:"varint,3,opt,name=version,proto3" json:"version" form:"version"`
	//
	//指标表名称
	Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name" form:"name"`
	//
	//维度列表
	Dimensions []*StreamMetricsSchemaField `protobuf:"bytes,5,rep,name=dimensions,proto3" json:"dimensions" form:"dimensions"`
	//
	//指标列表
	Metrics              []*StreamMetricsSchemaField `protobuf:"bytes,6,rep,name=metrics,proto3" json:"metrics" form:"metrics"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

指标表

func (*StreamMetricsSchema) Descriptor 

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

func (*StreamMetricsSchema) GetDimensions 

func (m *StreamMetricsSchema) GetDimensions() []*StreamMetricsSchemaField

func (*StreamMetricsSchema) GetId 

func (m *StreamMetricsSchema) GetId() string

func (*StreamMetricsSchema) GetMetrics 

func (m *StreamMetricsSchema) GetMetrics() []*StreamMetricsSchemaField

func (*StreamMetricsSchema) GetName 

func (m *StreamMetricsSchema) GetName() string

func (*StreamMetricsSchema) GetOrg 

func (m *StreamMetricsSchema) GetOrg() int32

func (*StreamMetricsSchema) GetVersion 

func (m *StreamMetricsSchema) GetVersion() int32

func (*StreamMetricsSchema) ProtoMessage 

func (*StreamMetricsSchema) ProtoMessage()

func (*StreamMetricsSchema) Reset 

func (m *StreamMetricsSchema) Reset()

func (*StreamMetricsSchema) String 

func (m *StreamMetricsSchema) String() string

func (*StreamMetricsSchema) Validate 

func (this *StreamMetricsSchema) Validate() error

func (*StreamMetricsSchema) XXX_DiscardUnknown 

func (m *StreamMetricsSchema) XXX_DiscardUnknown()

func (*StreamMetricsSchema) XXX_Marshal 

func (m *StreamMetricsSchema) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamMetricsSchema) XXX_Merge 

func (m *StreamMetricsSchema) XXX_Merge(src proto.Message)

func (*StreamMetricsSchema) XXX_Size 

func (m *StreamMetricsSchema) XXX_Size() int

func (*StreamMetricsSchema) XXX_Unmarshal 

func (m *StreamMetricsSchema) XXX_Unmarshal(b []byte) error

type StreamMetricsSchemaField 

type StreamMetricsSchemaField struct {
	//
	//字段名称
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name" form:"name"`
	//
	//字段类型
	Type                 string   `protobuf:"bytes,2,opt,name=type,proto3" json:"type" form:"type"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

指标表字段

func (*StreamMetricsSchemaField) Descriptor 

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

func (*StreamMetricsSchemaField) GetName 

func (m *StreamMetricsSchemaField) GetName() string

func (*StreamMetricsSchemaField) GetType 

func (m *StreamMetricsSchemaField) GetType() string

func (*StreamMetricsSchemaField) ProtoMessage 

func (*StreamMetricsSchemaField) ProtoMessage()

func (*StreamMetricsSchemaField) Reset 

func (m *StreamMetricsSchemaField) Reset()

func (*StreamMetricsSchemaField) String 

func (m *StreamMetricsSchemaField) String() string

func (*StreamMetricsSchemaField) Validate 

func (this *StreamMetricsSchemaField) Validate() error

func (*StreamMetricsSchemaField) XXX_DiscardUnknown 

func (m *StreamMetricsSchemaField) XXX_DiscardUnknown()

func (*StreamMetricsSchemaField) XXX_Marshal 

func (m *StreamMetricsSchemaField) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamMetricsSchemaField) XXX_Merge 

func (m *StreamMetricsSchemaField) XXX_Merge(src proto.Message)

func (*StreamMetricsSchemaField) XXX_Size 

func (m *StreamMetricsSchemaField) XXX_Size() int

func (*StreamMetricsSchemaField) XXX_Unmarshal 

func (m *StreamMetricsSchemaField) XXX_Unmarshal(b []byte) error

type StreamMetricsStates 

type StreamMetricsStates struct {
	//
	//org
	Org int32 `protobuf:"varint,1,opt,name=org,proto3" json:"org" form:"org"`
	//
	//状态数据变更命令
	//upsert：插入/更新指定的状态数据
	//delete：删除指定的状态数据
	//retain：仅保留指定的状态数据
	//
	Command string `protobuf:"bytes,2,opt,name=command,proto3" json:"command" form:"command"`
	//
	//状态数据列表
	Payload              []*StreamMetricsSchema `protobuf:"bytes,3,rep,name=payload,proto3" json:"payload" form:"payload"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

指标表状态数据

func (*StreamMetricsStates) Descriptor 

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

func (*StreamMetricsStates) GetCommand 

func (m *StreamMetricsStates) GetCommand() string

func (*StreamMetricsStates) GetOrg 

func (m *StreamMetricsStates) GetOrg() int32

func (*StreamMetricsStates) GetPayload 

func (m *StreamMetricsStates) GetPayload() []*StreamMetricsSchema

func (*StreamMetricsStates) ProtoMessage 

func (*StreamMetricsStates) ProtoMessage()

func (*StreamMetricsStates) Reset 

func (m *StreamMetricsStates) Reset()

func (*StreamMetricsStates) String 

func (m *StreamMetricsStates) String() string

func (*StreamMetricsStates) Validate 

func (this *StreamMetricsStates) Validate() error

func (*StreamMetricsStates) XXX_DiscardUnknown 

func (m *StreamMetricsStates) XXX_DiscardUnknown()

func (*StreamMetricsStates) XXX_Marshal 

func (m *StreamMetricsStates) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamMetricsStates) XXX_Merge 

func (m *StreamMetricsStates) XXX_Merge(src proto.Message)

func (*StreamMetricsStates) XXX_Size 

func (m *StreamMetricsStates) XXX_Size() int

func (*StreamMetricsStates) XXX_Unmarshal 

func (m *StreamMetricsStates) XXX_Unmarshal(b []byte) error

type StreamTranslatePackage 

type StreamTranslatePackage struct {
	//
	//id
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id" form:"id"`
	//
	//org
	Org int32 `protobuf:"varint,2,opt,name=org,proto3" json:"org" form:"org"`
	//
	//版本
	Version int32 `protobuf:"varint,3,opt,name=version,proto3" json:"version" form:"version"`
	//
	//关联的指标表列表
	Schemas []string `protobuf:"bytes,4,rep,name=schemas,proto3" json:"schemas" form:"schemas"`
	//
	//匹配字段列表
	MatchFields []string `protobuf:"bytes,5,rep,name=matchFields,proto3" json:"matchFields" form:"matchFields"`
	//
	//匹配数据列表
	MatchData            []*StreamTranslatePackage_MatchData `protobuf:"bytes,6,rep,name=matchData,proto3" json:"matchData" form:"matchData"`
	XXX_NoUnkeyedLiteral struct{}                            `json:"-"`
	XXX_unrecognized     []byte                              `json:"-"`
	XXX_sizecache        int32                               `json:"-"`
}

翻译数据包

func (*StreamTranslatePackage) Descriptor 

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

func (*StreamTranslatePackage) GetId 

func (m *StreamTranslatePackage) GetId() string

func (*StreamTranslatePackage) GetMatchData 

func (m *StreamTranslatePackage) GetMatchData() []*StreamTranslatePackage_MatchData

func (*StreamTranslatePackage) GetMatchFields 

func (m *StreamTranslatePackage) GetMatchFields() []string

func (*StreamTranslatePackage) GetOrg 

func (m *StreamTranslatePackage) GetOrg() int32

func (*StreamTranslatePackage) GetSchemas 

func (m *StreamTranslatePackage) GetSchemas() []string

func (*StreamTranslatePackage) GetVersion 

func (m *StreamTranslatePackage) GetVersion() int32

func (*StreamTranslatePackage) ProtoMessage 

func (*StreamTranslatePackage) ProtoMessage()

func (*StreamTranslatePackage) Reset 

func (m *StreamTranslatePackage) Reset()

func (*StreamTranslatePackage) String 

func (m *StreamTranslatePackage) String() string

func (*StreamTranslatePackage) Validate 

func (this *StreamTranslatePackage) Validate() error

func (*StreamTranslatePackage) XXX_DiscardUnknown 

func (m *StreamTranslatePackage) XXX_DiscardUnknown()

func (*StreamTranslatePackage) XXX_Marshal 

func (m *StreamTranslatePackage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamTranslatePackage) XXX_Merge 

func (m *StreamTranslatePackage) XXX_Merge(src proto.Message)

func (*StreamTranslatePackage) XXX_Size 

func (m *StreamTranslatePackage) XXX_Size() int

func (*StreamTranslatePackage) XXX_Unmarshal 

func (m *StreamTranslatePackage) XXX_Unmarshal(b []byte) error

type StreamTranslatePackage_MatchData 

type StreamTranslatePackage_MatchData struct {
	//
	//匹配键
	MatchKey string `protobuf:"bytes,1,opt,name=matchKey,proto3" json:"matchKey" form:"matchKey"`
	//
	//关联的资源
	Resource *StreamTranslatePackage_MatchData_Resource `protobuf:"bytes,2,opt,name=resource,proto3" json:"resource" form:"resource"`
	//
	//关联的标签列表
	Tags                 []*StreamTranslatePackage_MatchData_Tags `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags" form:"tags"`
	XXX_NoUnkeyedLiteral struct{}                                 `json:"-"`
	XXX_unrecognized     []byte                                   `json:"-"`
	XXX_sizecache        int32                                    `json:"-"`
}

func (*StreamTranslatePackage_MatchData) Descriptor 

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

func (*StreamTranslatePackage_MatchData) GetMatchKey 

func (m *StreamTranslatePackage_MatchData) GetMatchKey() string

func (*StreamTranslatePackage_MatchData) GetResource 

func (m *StreamTranslatePackage_MatchData) GetResource() *StreamTranslatePackage_MatchData_Resource

func (*StreamTranslatePackage_MatchData) GetTags 

func (m *StreamTranslatePackage_MatchData) GetTags() []*StreamTranslatePackage_MatchData_Tags

func (*StreamTranslatePackage_MatchData) ProtoMessage 

func (*StreamTranslatePackage_MatchData) ProtoMessage()

func (*StreamTranslatePackage_MatchData) Reset 

func (m *StreamTranslatePackage_MatchData) Reset()

func (*StreamTranslatePackage_MatchData) String 

func (m *StreamTranslatePackage_MatchData) String() string

func (*StreamTranslatePackage_MatchData) Validate 

func (this *StreamTranslatePackage_MatchData) Validate() error

func (*StreamTranslatePackage_MatchData) XXX_DiscardUnknown 

func (m *StreamTranslatePackage_MatchData) XXX_DiscardUnknown()

func (*StreamTranslatePackage_MatchData) XXX_Marshal 

func (m *StreamTranslatePackage_MatchData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamTranslatePackage_MatchData) XXX_Merge 

func (m *StreamTranslatePackage_MatchData) XXX_Merge(src proto.Message)

func (*StreamTranslatePackage_MatchData) XXX_Size 

func (m *StreamTranslatePackage_MatchData) XXX_Size() int

func (*StreamTranslatePackage_MatchData) XXX_Unmarshal 

func (m *StreamTranslatePackage_MatchData) XXX_Unmarshal(b []byte) error

type StreamTranslatePackage_MatchData_Resource 

type StreamTranslatePackage_MatchData_Resource struct {
	//
	//关联的模型id
	ObjectId string `protobuf:"bytes,1,opt,name=objectId,proto3" json:"objectId" form:"objectId"`
	//
	//关联的实例id列表
	Instances            []string `protobuf:"bytes,2,rep,name=instances,proto3" json:"instances" form:"instances"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamTranslatePackage_MatchData_Resource) Descriptor 

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

func (*StreamTranslatePackage_MatchData_Resource) GetInstances 

func (m *StreamTranslatePackage_MatchData_Resource) GetInstances() []string

func (*StreamTranslatePackage_MatchData_Resource) GetObjectId 

func (m *StreamTranslatePackage_MatchData_Resource) GetObjectId() string

func (*StreamTranslatePackage_MatchData_Resource) ProtoMessage 

func (*StreamTranslatePackage_MatchData_Resource) ProtoMessage()

func (*StreamTranslatePackage_MatchData_Resource) Reset 

func (m *StreamTranslatePackage_MatchData_Resource) Reset()

func (*StreamTranslatePackage_MatchData_Resource) String 

func (m *StreamTranslatePackage_MatchData_Resource) String() string

func (*StreamTranslatePackage_MatchData_Resource) Validate 

func (this *StreamTranslatePackage_MatchData_Resource) Validate() error

func (*StreamTranslatePackage_MatchData_Resource) XXX_DiscardUnknown 

func (m *StreamTranslatePackage_MatchData_Resource) XXX_DiscardUnknown()

func (*StreamTranslatePackage_MatchData_Resource) XXX_Marshal 

func (m *StreamTranslatePackage_MatchData_Resource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamTranslatePackage_MatchData_Resource) XXX_Merge 

func (m *StreamTranslatePackage_MatchData_Resource) XXX_Merge(src proto.Message)

func (*StreamTranslatePackage_MatchData_Resource) XXX_Size 

func (m *StreamTranslatePackage_MatchData_Resource) XXX_Size() int

func (*StreamTranslatePackage_MatchData_Resource) XXX_Unmarshal 

func (m *StreamTranslatePackage_MatchData_Resource) XXX_Unmarshal(b []byte) error

type StreamTranslatePackage_MatchData_Tags 

type StreamTranslatePackage_MatchData_Tags struct {
	//
	//标签名
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key" form:"key"`
	//
	//标签值
	Value                []string `protobuf:"bytes,2,rep,name=value,proto3" json:"value" form:"value"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamTranslatePackage_MatchData_Tags) Descriptor 

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

func (*StreamTranslatePackage_MatchData_Tags) GetKey 

func (m *StreamTranslatePackage_MatchData_Tags) GetKey() string

func (*StreamTranslatePackage_MatchData_Tags) GetValue 

func (m *StreamTranslatePackage_MatchData_Tags) GetValue() []string

func (*StreamTranslatePackage_MatchData_Tags) ProtoMessage 

func (*StreamTranslatePackage_MatchData_Tags) ProtoMessage()

func (*StreamTranslatePackage_MatchData_Tags) Reset 

func (m *StreamTranslatePackage_MatchData_Tags) Reset()

func (*StreamTranslatePackage_MatchData_Tags) String 

func (m *StreamTranslatePackage_MatchData_Tags) String() string

func (*StreamTranslatePackage_MatchData_Tags) Validate 

func (this *StreamTranslatePackage_MatchData_Tags) Validate() error

func (*StreamTranslatePackage_MatchData_Tags) XXX_DiscardUnknown 

func (m *StreamTranslatePackage_MatchData_Tags) XXX_DiscardUnknown()

func (*StreamTranslatePackage_MatchData_Tags) XXX_Marshal 

func (m *StreamTranslatePackage_MatchData_Tags) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamTranslatePackage_MatchData_Tags) XXX_Merge 

func (m *StreamTranslatePackage_MatchData_Tags) XXX_Merge(src proto.Message)

func (*StreamTranslatePackage_MatchData_Tags) XXX_Size 

func (m *StreamTranslatePackage_MatchData_Tags) XXX_Size() int

func (*StreamTranslatePackage_MatchData_Tags) XXX_Unmarshal 

func (m *StreamTranslatePackage_MatchData_Tags) XXX_Unmarshal(b []byte) error

type StreamTranslateStates 

type StreamTranslateStates struct {
	//
	//org
	Org int32 `protobuf:"varint,1,opt,name=org,proto3" json:"org" form:"org"`
	//
	//状态数据变更命令
	//upsert：插入/更新指定的状态数据
	//delete：删除指定的状态数据
	//retain：仅保留指定的状态数据
	//
	Command string `protobuf:"bytes,2,opt,name=command,proto3" json:"command" form:"command"`
	//
	//状态数据列表
	Payload              []*StreamTranslatePackage `protobuf:"bytes,3,rep,name=payload,proto3" json:"payload" form:"payload"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

翻译状态数据

func (*StreamTranslateStates) Descriptor 

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

func (*StreamTranslateStates) GetCommand 

func (m *StreamTranslateStates) GetCommand() string

func (*StreamTranslateStates) GetOrg 

func (m *StreamTranslateStates) GetOrg() int32

func (*StreamTranslateStates) GetPayload 

func (m *StreamTranslateStates) GetPayload() []*StreamTranslatePackage

func (*StreamTranslateStates) ProtoMessage 

func (*StreamTranslateStates) ProtoMessage()

func (*StreamTranslateStates) Reset 

func (m *StreamTranslateStates) Reset()

func (*StreamTranslateStates) String 

func (m *StreamTranslateStates) String() string

func (*StreamTranslateStates) Validate 

func (this *StreamTranslateStates) Validate() error

func (*StreamTranslateStates) XXX_DiscardUnknown 

func (m *StreamTranslateStates) XXX_DiscardUnknown()

func (*StreamTranslateStates) XXX_Marshal 

func (m *StreamTranslateStates) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamTranslateStates) XXX_Merge 

func (m *StreamTranslateStates) XXX_Merge(src proto.Message)

func (*StreamTranslateStates) XXX_Size 

func (m *StreamTranslateStates) XXX_Size() int

func (*StreamTranslateStates) XXX_Unmarshal 

func (m *StreamTranslateStates) XXX_Unmarshal(b []byte) error

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.