pipelinepb

package
v0.0.0-...-9649366 Latest Latest
Warning

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

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

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

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

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,omitempty"`
	Rollup         *AppliedRollupOp       `protobuf:"bytes,3,opt,name=rollup" json:"rollup,omitempty"`
}

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 (*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 */
}

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

Jump to

Keyboard shortcuts

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