rulepb

package
v0.15.0-rc.10 Latest Latest
Warning

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

Go to latest
Published: May 15, 2020 License: Apache-2.0 Imports: 7 Imported by: 0

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

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL