rulepb

package
v1.0.1 Latest Latest
Warning

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

 Go to latest Published: Jan 21, 2021 License: Apache-2.0 Imports: 8 Imported by: 8

Documentation

Overview

Package rulepb is a generated protocol buffer package.

It is generated from these files: 

github.com/m3db/m3/src/metrics/generated/proto/rulepb/namespace.proto
github.com/m3db/m3/src/metrics/generated/proto/rulepb/rule.proto

It has these top-level messages: 

NamespaceSnapshot
Namespace
Namespaces
MappingRuleSnapshot
MappingRule
RollupTarget
RollupTargetV2
RollupRuleSnapshot
RollupRule
RuleSet

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthNamespace = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowNamespace   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthRule = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRule   = fmt.Errorf("proto: integer overflow")
)

Functions

This section is empty.

Types

type MappingRule 

type MappingRule struct {
	Uuid      string                 `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Snapshots []*MappingRuleSnapshot `protobuf:"bytes,2,rep,name=snapshots" json:"snapshots,omitempty"`
}

func (*MappingRule) Descriptor 

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

func (*MappingRule) GetSnapshots 

func (m *MappingRule) GetSnapshots() []*MappingRuleSnapshot

func (*MappingRule) GetUuid 

func (m *MappingRule) GetUuid() string

func (*MappingRule) Marshal 

func (m *MappingRule) Marshal() (dAtA []byte, err error)

func (*MappingRule) MarshalTo 

func (m *MappingRule) MarshalTo(dAtA []byte) (int, error)

func (*MappingRule) ProtoMessage 

func (*MappingRule) ProtoMessage()

func (*MappingRule) Reset 

func (m *MappingRule) Reset()

func (*MappingRule) Size 

func (m *MappingRule) Size() (n int)

func (*MappingRule) String 

func (m *MappingRule) String() string

func (*MappingRule) Unmarshal 

func (m *MappingRule) Unmarshal(dAtA []byte) error

type MappingRuleSnapshot 

type MappingRuleSnapshot struct {
	Name         string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Tombstoned   bool   `protobuf:"varint,2,opt,name=tombstoned,proto3" json:"tombstoned,omitempty"`
	CutoverNanos int64  `protobuf:"varint,3,opt,name=cutover_nanos,json=cutoverNanos,proto3" json:"cutover_nanos,omitempty"`
	Filter       string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// TODO(xichen): remove this and mark the field number reserved once all mapping rules are updated in KV.
	Policies           []*policypb.Policy              `protobuf:"bytes,5,rep,name=policies" json:"policies,omitempty"`
	LastUpdatedAtNanos int64                           `protobuf:"varint,6,opt,name=last_updated_at_nanos,json=lastUpdatedAtNanos,proto3" json:"last_updated_at_nanos,omitempty"`
	LastUpdatedBy      string                          `protobuf:"bytes,7,opt,name=last_updated_by,json=lastUpdatedBy,proto3" json:"last_updated_by,omitempty"`
	AggregationTypes   []aggregationpb.AggregationType `` /* 145-byte string literal not displayed */
	StoragePolicies    []*policypb.StoragePolicy       `protobuf:"bytes,9,rep,name=storage_policies,json=storagePolicies" json:"storage_policies,omitempty"`
	DropPolicy         policypb.DropPolicy             `protobuf:"varint,10,opt,name=drop_policy,json=dropPolicy,proto3,enum=policypb.DropPolicy" json:"drop_policy,omitempty"`
	Tags               []*metricpb.Tag                 `protobuf:"bytes,11,rep,name=tags" json:"tags,omitempty"`
}

func (*MappingRuleSnapshot) Descriptor 

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

func (*MappingRuleSnapshot) GetAggregationTypes 

func (m *MappingRuleSnapshot) GetAggregationTypes() []aggregationpb.AggregationType

func (*MappingRuleSnapshot) GetCutoverNanos 

func (m *MappingRuleSnapshot) GetCutoverNanos() int64

func (*MappingRuleSnapshot) GetDropPolicy 

func (m *MappingRuleSnapshot) GetDropPolicy() policypb.DropPolicy

func (*MappingRuleSnapshot) GetFilter 

func (m *MappingRuleSnapshot) GetFilter() string

func (*MappingRuleSnapshot) GetLastUpdatedAtNanos 

func (m *MappingRuleSnapshot) GetLastUpdatedAtNanos() int64

func (*MappingRuleSnapshot) GetLastUpdatedBy 

func (m *MappingRuleSnapshot) GetLastUpdatedBy() string

func (*MappingRuleSnapshot) GetName 

func (m *MappingRuleSnapshot) GetName() string

func (*MappingRuleSnapshot) GetPolicies 

func (m *MappingRuleSnapshot) GetPolicies() []*policypb.Policy

func (*MappingRuleSnapshot) GetStoragePolicies 

func (m *MappingRuleSnapshot) GetStoragePolicies() []*policypb.StoragePolicy

func (*MappingRuleSnapshot) GetTags added in v0.15.11 

func (m *MappingRuleSnapshot) GetTags() []*metricpb.Tag

func (*MappingRuleSnapshot) GetTombstoned 

func (m *MappingRuleSnapshot) GetTombstoned() bool

func (*MappingRuleSnapshot) Marshal 

func (m *MappingRuleSnapshot) Marshal() (dAtA []byte, err error)

func (*MappingRuleSnapshot) MarshalTo 

func (m *MappingRuleSnapshot) MarshalTo(dAtA []byte) (int, error)

func (*MappingRuleSnapshot) ProtoMessage 

func (*MappingRuleSnapshot) ProtoMessage()

func (*MappingRuleSnapshot) Reset 

func (m *MappingRuleSnapshot) Reset()

func (*MappingRuleSnapshot) Size 

func (m *MappingRuleSnapshot) Size() (n int)

func (*MappingRuleSnapshot) String 

func (m *MappingRuleSnapshot) String() string

func (*MappingRuleSnapshot) Unmarshal 

func (m *MappingRuleSnapshot) Unmarshal(dAtA []byte) error

type Namespace 

type Namespace struct {
	Name      string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Snapshots []*NamespaceSnapshot `protobuf:"bytes,2,rep,name=snapshots" json:"snapshots,omitempty"`
}

func (*Namespace) Descriptor 

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

func (*Namespace) GetName 

func (m *Namespace) GetName() string

func (*Namespace) GetSnapshots 

func (m *Namespace) GetSnapshots() []*NamespaceSnapshot

func (*Namespace) Marshal 

func (m *Namespace) Marshal() (dAtA []byte, err error)

func (*Namespace) MarshalTo 

func (m *Namespace) MarshalTo(dAtA []byte) (int, error)

func (*Namespace) ProtoMessage 

func (*Namespace) ProtoMessage()

func (*Namespace) Reset 

func (m *Namespace) Reset()

func (*Namespace) Size 

func (m *Namespace) Size() (n int)

func (*Namespace) String 

func (m *Namespace) String() string

func (*Namespace) Unmarshal 

func (m *Namespace) Unmarshal(dAtA []byte) error

type NamespaceSnapshot 

type NamespaceSnapshot struct {
	ForRulesetVersion  int32  `protobuf:"varint,1,opt,name=for_ruleset_version,json=forRulesetVersion,proto3" json:"for_ruleset_version,omitempty"`
	Tombstoned         bool   `protobuf:"varint,2,opt,name=tombstoned,proto3" json:"tombstoned,omitempty"`
	LastUpdatedAtNanos int64  `protobuf:"varint,3,opt,name=last_updated_at_nanos,json=lastUpdatedAtNanos,proto3" json:"last_updated_at_nanos,omitempty"`
	LastUpdatedBy      string `protobuf:"bytes,4,opt,name=last_updated_by,json=lastUpdatedBy,proto3" json:"last_updated_by,omitempty"`
}

func (*NamespaceSnapshot) Descriptor 

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

func (*NamespaceSnapshot) GetForRulesetVersion 

func (m *NamespaceSnapshot) GetForRulesetVersion() int32

func (*NamespaceSnapshot) GetLastUpdatedAtNanos 

func (m *NamespaceSnapshot) GetLastUpdatedAtNanos() int64

func (*NamespaceSnapshot) GetLastUpdatedBy 

func (m *NamespaceSnapshot) GetLastUpdatedBy() string

func (*NamespaceSnapshot) GetTombstoned 

func (m *NamespaceSnapshot) GetTombstoned() bool

func (*NamespaceSnapshot) Marshal 

func (m *NamespaceSnapshot) Marshal() (dAtA []byte, err error)

func (*NamespaceSnapshot) MarshalTo 

func (m *NamespaceSnapshot) MarshalTo(dAtA []byte) (int, error)

func (*NamespaceSnapshot) ProtoMessage 

func (*NamespaceSnapshot) ProtoMessage()

func (*NamespaceSnapshot) Reset 

func (m *NamespaceSnapshot) Reset()

func (*NamespaceSnapshot) Size 

func (m *NamespaceSnapshot) Size() (n int)

func (*NamespaceSnapshot) String 

func (m *NamespaceSnapshot) String() string

func (*NamespaceSnapshot) Unmarshal 

func (m *NamespaceSnapshot) Unmarshal(dAtA []byte) error

type Namespaces 

type Namespaces struct {
	Namespaces []*Namespace `protobuf:"bytes,1,rep,name=namespaces" json:"namespaces,omitempty"`
}

func (*Namespaces) Descriptor 

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

func (*Namespaces) GetNamespaces 

func (m *Namespaces) GetNamespaces() []*Namespace

func (*Namespaces) Marshal 

func (m *Namespaces) Marshal() (dAtA []byte, err error)

func (*Namespaces) MarshalTo 

func (m *Namespaces) MarshalTo(dAtA []byte) (int, error)

func (*Namespaces) ProtoMessage 

func (*Namespaces) ProtoMessage()

func (*Namespaces) Reset 

func (m *Namespaces) Reset()

func (*Namespaces) Size 

func (m *Namespaces) Size() (n int)

func (*Namespaces) String 

func (m *Namespaces) String() string

func (*Namespaces) Unmarshal 

func (m *Namespaces) Unmarshal(dAtA []byte) error

type RollupRule 

type RollupRule struct {
	Uuid      string                `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Snapshots []*RollupRuleSnapshot `protobuf:"bytes,2,rep,name=snapshots" json:"snapshots,omitempty"`
}

func (*RollupRule) Descriptor 

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

func (*RollupRule) GetSnapshots 

func (m *RollupRule) GetSnapshots() []*RollupRuleSnapshot

func (*RollupRule) GetUuid 

func (m *RollupRule) GetUuid() string

func (*RollupRule) Marshal 

func (m *RollupRule) Marshal() (dAtA []byte, err error)

func (*RollupRule) MarshalTo 

func (m *RollupRule) MarshalTo(dAtA []byte) (int, error)

func (*RollupRule) ProtoMessage 

func (*RollupRule) ProtoMessage()

func (*RollupRule) Reset 

func (m *RollupRule) Reset()

func (*RollupRule) Size 

func (m *RollupRule) Size() (n int)

func (*RollupRule) String 

func (m *RollupRule) String() string

func (*RollupRule) Unmarshal 

func (m *RollupRule) Unmarshal(dAtA []byte) error

type RollupRuleSnapshot 

type RollupRuleSnapshot struct {
	Name         string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Tombstoned   bool   `protobuf:"varint,2,opt,name=tombstoned,proto3" json:"tombstoned,omitempty"`
	CutoverNanos int64  `protobuf:"varint,3,opt,name=cutover_nanos,json=cutoverNanos,proto3" json:"cutover_nanos,omitempty"`
	Filter       string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// TODO(xichen): remove this and mark the field number reserved once all rollup rules are updated in KV.
	Targets            []*RollupTarget `protobuf:"bytes,5,rep,name=targets" json:"targets,omitempty"`
	LastUpdatedAtNanos int64           `protobuf:"varint,6,opt,name=last_updated_at_nanos,json=lastUpdatedAtNanos,proto3" json:"last_updated_at_nanos,omitempty"`
	LastUpdatedBy      string          `protobuf:"bytes,7,opt,name=last_updated_by,json=lastUpdatedBy,proto3" json:"last_updated_by,omitempty"`
	// TODO(xichen): rename this once all rules are updated in KV.
	TargetsV2    []*RollupTargetV2 `protobuf:"bytes,8,rep,name=targets_v2,json=targetsV2" json:"targets_v2,omitempty"`
	KeepOriginal bool              `protobuf:"varint,9,opt,name=keep_original,json=keepOriginal,proto3" json:"keep_original,omitempty"`
}

func (*RollupRuleSnapshot) Descriptor 

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

func (*RollupRuleSnapshot) GetCutoverNanos 

func (m *RollupRuleSnapshot) GetCutoverNanos() int64

func (*RollupRuleSnapshot) GetFilter 

func (m *RollupRuleSnapshot) GetFilter() string

func (*RollupRuleSnapshot) GetKeepOriginal added in v1.0.0 

func (m *RollupRuleSnapshot) GetKeepOriginal() bool

func (*RollupRuleSnapshot) GetLastUpdatedAtNanos 

func (m *RollupRuleSnapshot) GetLastUpdatedAtNanos() int64

func (*RollupRuleSnapshot) GetLastUpdatedBy 

func (m *RollupRuleSnapshot) GetLastUpdatedBy() string

func (*RollupRuleSnapshot) GetName 

func (m *RollupRuleSnapshot) GetName() string

func (*RollupRuleSnapshot) GetTargets 

func (m *RollupRuleSnapshot) GetTargets() []*RollupTarget

func (*RollupRuleSnapshot) GetTargetsV2 

func (m *RollupRuleSnapshot) GetTargetsV2() []*RollupTargetV2

func (*RollupRuleSnapshot) GetTombstoned 

func (m *RollupRuleSnapshot) GetTombstoned() bool

func (*RollupRuleSnapshot) Marshal 

func (m *RollupRuleSnapshot) Marshal() (dAtA []byte, err error)

func (*RollupRuleSnapshot) MarshalTo 

func (m *RollupRuleSnapshot) MarshalTo(dAtA []byte) (int, error)

func (*RollupRuleSnapshot) ProtoMessage 

func (*RollupRuleSnapshot) ProtoMessage()

func (*RollupRuleSnapshot) Reset 

func (m *RollupRuleSnapshot) Reset()

func (*RollupRuleSnapshot) Size 

func (m *RollupRuleSnapshot) Size() (n int)

func (*RollupRuleSnapshot) String 

func (m *RollupRuleSnapshot) String() string

func (*RollupRuleSnapshot) Unmarshal 

func (m *RollupRuleSnapshot) Unmarshal(dAtA []byte) error

type RollupTarget 

type RollupTarget struct {
	Name     string             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Tags     []string           `protobuf:"bytes,2,rep,name=tags" json:"tags,omitempty"`
	Policies []*policypb.Policy `protobuf:"bytes,3,rep,name=policies" json:"policies,omitempty"`
}

TODO(xichen): remove this once all rules are updated in KV.

func (*RollupTarget) Descriptor 

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

func (*RollupTarget) GetName 

func (m *RollupTarget) GetName() string

func (*RollupTarget) GetPolicies 

func (m *RollupTarget) GetPolicies() []*policypb.Policy

func (*RollupTarget) GetTags 

func (m *RollupTarget) GetTags() []string

func (*RollupTarget) Marshal 

func (m *RollupTarget) Marshal() (dAtA []byte, err error)

func (*RollupTarget) MarshalTo 

func (m *RollupTarget) MarshalTo(dAtA []byte) (int, error)

func (*RollupTarget) ProtoMessage 

func (*RollupTarget) ProtoMessage()

func (*RollupTarget) Reset 

func (m *RollupTarget) Reset()

func (*RollupTarget) Size 

func (m *RollupTarget) Size() (n int)

func (*RollupTarget) String 

func (m *RollupTarget) String() string

func (*RollupTarget) Unmarshal 

func (m *RollupTarget) Unmarshal(dAtA []byte) error

type RollupTargetV2 

type RollupTargetV2 struct {
	Pipeline        *pipelinepb.Pipeline      `protobuf:"bytes,1,opt,name=pipeline" json:"pipeline,omitempty"`
	StoragePolicies []*policypb.StoragePolicy `protobuf:"bytes,2,rep,name=storage_policies,json=storagePolicies" json:"storage_policies,omitempty"`
}

TODO(xichen): rename this once all rules are updated in KV.

func (*RollupTargetV2) Descriptor 

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

func (*RollupTargetV2) GetPipeline 

func (m *RollupTargetV2) GetPipeline() *pipelinepb.Pipeline

func (*RollupTargetV2) GetStoragePolicies 

func (m *RollupTargetV2) GetStoragePolicies() []*policypb.StoragePolicy

func (*RollupTargetV2) Marshal 

func (m *RollupTargetV2) Marshal() (dAtA []byte, err error)

func (*RollupTargetV2) MarshalTo 

func (m *RollupTargetV2) MarshalTo(dAtA []byte) (int, error)

func (*RollupTargetV2) ProtoMessage 

func (*RollupTargetV2) ProtoMessage()

func (*RollupTargetV2) Reset 

func (m *RollupTargetV2) Reset()

func (*RollupTargetV2) Size 

func (m *RollupTargetV2) Size() (n int)

func (*RollupTargetV2) String 

func (m *RollupTargetV2) String() string

func (*RollupTargetV2) Unmarshal 

func (m *RollupTargetV2) Unmarshal(dAtA []byte) error

type RuleSet 

type RuleSet struct {
	Uuid               string         `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Namespace          string         `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	CreatedAtNanos     int64          `protobuf:"varint,3,opt,name=created_at_nanos,json=createdAtNanos,proto3" json:"created_at_nanos,omitempty"`
	LastUpdatedAtNanos int64          `protobuf:"varint,4,opt,name=last_updated_at_nanos,json=lastUpdatedAtNanos,proto3" json:"last_updated_at_nanos,omitempty"`
	Tombstoned         bool           `protobuf:"varint,5,opt,name=tombstoned,proto3" json:"tombstoned,omitempty"`
	CutoverNanos       int64          `protobuf:"varint,6,opt,name=cutover_nanos,json=cutoverNanos,proto3" json:"cutover_nanos,omitempty"`
	MappingRules       []*MappingRule `protobuf:"bytes,7,rep,name=mapping_rules,json=mappingRules" json:"mapping_rules,omitempty"`
	RollupRules        []*RollupRule  `protobuf:"bytes,8,rep,name=rollup_rules,json=rollupRules" json:"rollup_rules,omitempty"`
	LastUpdatedBy      string         `protobuf:"bytes,9,opt,name=last_updated_by,json=lastUpdatedBy,proto3" json:"last_updated_by,omitempty"`
}

func (*RuleSet) Descriptor 

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

func (*RuleSet) GetCreatedAtNanos 

func (m *RuleSet) GetCreatedAtNanos() int64

func (*RuleSet) GetCutoverNanos 

func (m *RuleSet) GetCutoverNanos() int64

func (*RuleSet) GetLastUpdatedAtNanos 

func (m *RuleSet) GetLastUpdatedAtNanos() int64

func (*RuleSet) GetLastUpdatedBy 

func (m *RuleSet) GetLastUpdatedBy() string

func (*RuleSet) GetMappingRules 

func (m *RuleSet) GetMappingRules() []*MappingRule

func (*RuleSet) GetNamespace 

func (m *RuleSet) GetNamespace() string

func (*RuleSet) GetRollupRules 

func (m *RuleSet) GetRollupRules() []*RollupRule

func (*RuleSet) GetTombstoned 

func (m *RuleSet) GetTombstoned() bool

func (*RuleSet) GetUuid 

func (m *RuleSet) GetUuid() string

func (*RuleSet) Marshal 

func (m *RuleSet) Marshal() (dAtA []byte, err error)

func (*RuleSet) MarshalTo 

func (m *RuleSet) MarshalTo(dAtA []byte) (int, error)

func (*RuleSet) ProtoMessage 

func (*RuleSet) ProtoMessage()

func (*RuleSet) Reset 

func (m *RuleSet) Reset()

func (*RuleSet) Size 

func (m *RuleSet) Size() (n int)

func (*RuleSet) String 

func (m *RuleSet) String() string

func (*RuleSet) Unmarshal 

func (m *RuleSet) Unmarshal(dAtA []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.