pipelinepb

package
v1.2.0 Latest Latest
Warning

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

 Go to latest Published: Sep 10, 2021 License: Apache-2.0 Imports: 7 Imported by: 10

Documentation

Overview

Package pipelinepb is a generated protocol buffer package.

It is generated from these files: 

github.com/m3db/m3/src/metrics/generated/proto/pipelinepb/pipeline.proto

It has these top-level messages: 

AggregationOp
TransformationOp
RollupOp
PipelineOp
Pipeline
AppliedRollupOp
AppliedPipelineOp
AppliedPipeline

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthPipeline = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPipeline   = fmt.Errorf("proto: integer overflow")
)
View Source 
var AppliedPipelineOp_Type_name = map[int32]string{
	0: "UNKNOWN",
	1: "TRANSFORMATION",
	2: "ROLLUP",
}
View Source 
var AppliedPipelineOp_Type_value = map[string]int32{
	"UNKNOWN":        0,
	"TRANSFORMATION": 1,
	"ROLLUP":         2,
}
View Source 
var PipelineOp_Type_name = map[int32]string{
	0: "UNKNOWN",
	1: "AGGREGATION",
	2: "TRANSFORMATION",
	3: "ROLLUP",
}
View Source 
var PipelineOp_Type_value = map[string]int32{
	"UNKNOWN":        0,
	"AGGREGATION":    1,
	"TRANSFORMATION": 2,
	"ROLLUP":         3,
}
View Source 
var RollupOp_Type_name = map[int32]string{
	0: "GROUP_BY",
	1: "EXCLUDE_BY",
}
View Source 
var RollupOp_Type_value = map[string]int32{
	"GROUP_BY":   0,
	"EXCLUDE_BY": 1,
}

Functions

This section is empty.

Types

type AggregationOp 

type AggregationOp struct {
	Type aggregationpb.AggregationType `protobuf:"varint,1,opt,name=type,proto3,enum=aggregationpb.AggregationType" json:"type,omitempty"`
}

func (*AggregationOp) Descriptor 

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

func (*AggregationOp) GetType 

func (m *AggregationOp) GetType() aggregationpb.AggregationType

func (*AggregationOp) Marshal 

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

func (*AggregationOp) MarshalTo 

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

func (*AggregationOp) ProtoMessage 

func (*AggregationOp) ProtoMessage()

func (*AggregationOp) Reset 

func (m *AggregationOp) Reset()

func (*AggregationOp) Size 

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

func (*AggregationOp) String 

func (m *AggregationOp) String() string

func (*AggregationOp) Unmarshal 

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

type AppliedPipeline 

type AppliedPipeline struct {
	Ops []AppliedPipelineOp `protobuf:"bytes,1,rep,name=ops" json:"ops"`
}

AppliedPipelineOp is a pipeline containing operations that have been applied against a metric.

func (*AppliedPipeline) Descriptor 

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

func (*AppliedPipeline) GetOps 

func (m *AppliedPipeline) GetOps() []AppliedPipelineOp

func (*AppliedPipeline) Marshal 

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

func (*AppliedPipeline) MarshalTo 

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

func (*AppliedPipeline) ProtoMessage 

func (*AppliedPipeline) ProtoMessage()

func (*AppliedPipeline) Reset 

func (m *AppliedPipeline) Reset()

func (*AppliedPipeline) Reuse added in v1.2.0 

func (m *AppliedPipeline) Reuse()

func (*AppliedPipeline) Size 

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

func (*AppliedPipeline) String 

func (m *AppliedPipeline) String() string

func (*AppliedPipeline) Unmarshal 

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

Unmarshal is a manual copy of the generated Unmarshal that allows reusing slices.

type AppliedPipelineOp 

type AppliedPipelineOp struct {
	Type           AppliedPipelineOp_Type `protobuf:"varint,1,opt,name=type,proto3,enum=pipelinepb.AppliedPipelineOp_Type" json:"type,omitempty"`
	Transformation TransformationOp       `protobuf:"bytes,2,opt,name=transformation" json:"transformation"`
	Rollup         AppliedRollupOp        `protobuf:"bytes,3,opt,name=rollup" json:"rollup"`
}

AppliedPipelineOp is a pipeline operation that has been applied against a metric.

func (*AppliedPipelineOp) Descriptor 

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

func (*AppliedPipelineOp) GetRollup 

func (m *AppliedPipelineOp) GetRollup() AppliedRollupOp

func (*AppliedPipelineOp) GetTransformation 

func (m *AppliedPipelineOp) GetTransformation() TransformationOp

func (*AppliedPipelineOp) GetType 

func (m *AppliedPipelineOp) GetType() AppliedPipelineOp_Type

func (*AppliedPipelineOp) Marshal 

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

func (*AppliedPipelineOp) MarshalTo 

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

func (*AppliedPipelineOp) ProtoMessage 

func (*AppliedPipelineOp) ProtoMessage()

func (*AppliedPipelineOp) Reset 

func (m *AppliedPipelineOp) Reset()

func (*AppliedPipelineOp) Size 

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

func (*AppliedPipelineOp) String 

func (m *AppliedPipelineOp) String() string

func (*AppliedPipelineOp) Unmarshal 

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

type AppliedPipelineOp_Type 

type AppliedPipelineOp_Type int32
const (
	AppliedPipelineOp_UNKNOWN        AppliedPipelineOp_Type = 0
	AppliedPipelineOp_TRANSFORMATION AppliedPipelineOp_Type = 1
	AppliedPipelineOp_ROLLUP         AppliedPipelineOp_Type = 2
)

func (AppliedPipelineOp_Type) EnumDescriptor 

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

func (AppliedPipelineOp_Type) String 

func (x AppliedPipelineOp_Type) String() string

type AppliedRollupOp 

type AppliedRollupOp struct {
	Id            []byte                      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	AggregationId aggregationpb.AggregationID `protobuf:"bytes,2,opt,name=aggregation_id,json=aggregationId" json:"aggregation_id"`
}

AppliedRollupOp is a rollup operation that has been applied against a metric.

func (*AppliedRollupOp) Descriptor 

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

func (*AppliedRollupOp) GetAggregationId 

func (m *AppliedRollupOp) GetAggregationId() aggregationpb.AggregationID

func (*AppliedRollupOp) GetId 

func (m *AppliedRollupOp) GetId() []byte

func (*AppliedRollupOp) Marshal 

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

func (*AppliedRollupOp) MarshalTo 

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

func (*AppliedRollupOp) ProtoMessage 

func (*AppliedRollupOp) ProtoMessage()

func (*AppliedRollupOp) Reset 

func (m *AppliedRollupOp) Reset()

func (*AppliedRollupOp) Size 

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

func (*AppliedRollupOp) String 

func (m *AppliedRollupOp) String() string

func (*AppliedRollupOp) Unmarshal 

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

type Pipeline 

type Pipeline struct {
	Ops []PipelineOp `protobuf:"bytes,1,rep,name=ops" json:"ops"`
}

func (*Pipeline) Descriptor 

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

func (*Pipeline) GetOps 

func (m *Pipeline) GetOps() []PipelineOp

func (*Pipeline) Marshal 

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

func (*Pipeline) MarshalTo 

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

func (*Pipeline) ProtoMessage 

func (*Pipeline) ProtoMessage()

func (*Pipeline) Reset 

func (m *Pipeline) Reset()

func (*Pipeline) Size 

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

func (*Pipeline) String 

func (m *Pipeline) String() string

func (*Pipeline) Unmarshal 

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

type PipelineOp 

type PipelineOp struct {
	Type           PipelineOp_Type   `protobuf:"varint,1,opt,name=type,proto3,enum=pipelinepb.PipelineOp_Type" json:"type,omitempty"`
	Aggregation    *AggregationOp    `protobuf:"bytes,2,opt,name=aggregation" json:"aggregation,omitempty"`
	Transformation *TransformationOp `protobuf:"bytes,3,opt,name=transformation" json:"transformation,omitempty"`
	Rollup         *RollupOp         `protobuf:"bytes,4,opt,name=rollup" json:"rollup,omitempty"`
}

func (*PipelineOp) Descriptor 

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

func (*PipelineOp) GetAggregation 

func (m *PipelineOp) GetAggregation() *AggregationOp

func (*PipelineOp) GetRollup 

func (m *PipelineOp) GetRollup() *RollupOp

func (*PipelineOp) GetTransformation 

func (m *PipelineOp) GetTransformation() *TransformationOp

func (*PipelineOp) GetType 

func (m *PipelineOp) GetType() PipelineOp_Type

func (*PipelineOp) Marshal 

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

func (*PipelineOp) MarshalTo 

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

func (*PipelineOp) ProtoMessage 

func (*PipelineOp) ProtoMessage()

func (*PipelineOp) Reset 

func (m *PipelineOp) Reset()

func (*PipelineOp) Size 

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

func (*PipelineOp) String 

func (m *PipelineOp) String() string

func (*PipelineOp) Unmarshal 

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

type PipelineOp_Type 

type PipelineOp_Type int32
const (
	PipelineOp_UNKNOWN        PipelineOp_Type = 0
	PipelineOp_AGGREGATION    PipelineOp_Type = 1
	PipelineOp_TRANSFORMATION PipelineOp_Type = 2
	PipelineOp_ROLLUP         PipelineOp_Type = 3
)

func (PipelineOp_Type) EnumDescriptor 

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

func (PipelineOp_Type) String 

func (x PipelineOp_Type) String() string

type RollupOp 

type RollupOp struct {
	NewName          string                          `protobuf:"bytes,1,opt,name=new_name,json=newName,proto3" json:"new_name,omitempty"`
	Tags             []string                        `protobuf:"bytes,2,rep,name=tags" json:"tags,omitempty"`
	AggregationTypes []aggregationpb.AggregationType `` /* 145-byte string literal not displayed */
	Type             RollupOp_Type                   `protobuf:"varint,4,opt,name=type,proto3,enum=pipelinepb.RollupOp_Type" json:"type,omitempty"`
}

func (*RollupOp) Descriptor 

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

func (*RollupOp) GetAggregationTypes 

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

func (*RollupOp) GetNewName 

func (m *RollupOp) GetNewName() string

func (*RollupOp) GetTags 

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

func (*RollupOp) GetType added in v1.2.0 

func (m *RollupOp) GetType() RollupOp_Type

func (*RollupOp) Marshal 

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

func (*RollupOp) MarshalTo 

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

func (*RollupOp) ProtoMessage 

func (*RollupOp) ProtoMessage()

func (*RollupOp) Reset 

func (m *RollupOp) Reset()

func (*RollupOp) Size 

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

func (*RollupOp) String 

func (m *RollupOp) String() string

func (*RollupOp) Unmarshal 

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

type RollupOp_Type added in v1.2.0 

type RollupOp_Type int32
const (
	RollupOp_GROUP_BY   RollupOp_Type = 0
	RollupOp_EXCLUDE_BY RollupOp_Type = 1
)

func (RollupOp_Type) EnumDescriptor added in v1.2.0 

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

func (RollupOp_Type) String added in v1.2.0 

func (x RollupOp_Type) String() string

type TransformationOp 

type TransformationOp struct {
	Type transformationpb.TransformationType `protobuf:"varint,1,opt,name=type,proto3,enum=transformationpb.TransformationType" json:"type,omitempty"`
}

func (*TransformationOp) Descriptor 

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

func (*TransformationOp) GetType 

func (m *TransformationOp) GetType() transformationpb.TransformationType

func (*TransformationOp) Marshal 

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

func (*TransformationOp) MarshalTo 

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

func (*TransformationOp) ProtoMessage 

func (*TransformationOp) ProtoMessage()

func (*TransformationOp) Reset 

func (m *TransformationOp) Reset()

func (*TransformationOp) Size 

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

func (*TransformationOp) String 

func (m *TransformationOp) String() string

func (*TransformationOp) Unmarshal 

func (m *TransformationOp) 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.