applied

Documentation

Index

• type OpUnion
  • func (u OpUnion) Clone() OpUnion
  • func (u OpUnion) Equal(other OpUnion) bool
  • func (u *OpUnion) FromProto(pb pipelinepb.AppliedPipelineOp) error
  • func (u *OpUnion) Reset()
  • func (u OpUnion) String() string
  • func (u OpUnion) ToProto(pb *pipelinepb.AppliedPipelineOp) error
• type Pipeline
  • func NewPipeline(ops []OpUnion) Pipeline
  • func (p Pipeline) At(i int) OpUnion
  • func (p Pipeline) Clone() Pipeline
  • func (p Pipeline) Equal(other Pipeline) bool
  • func (p *Pipeline) FromProto(pb pipelinepb.AppliedPipeline) error
  • func (p Pipeline) IsEmpty() bool
  • func (p Pipeline) Len() int
  • func (p Pipeline) String() string
  • func (p Pipeline) SubPipeline(startInclusive int, endExclusive int) Pipeline
  • func (p Pipeline) ToProto(pb *pipelinepb.AppliedPipeline) error
• type RollupOp
  • func (op RollupOp) Clone() RollupOp
  • func (op RollupOp) Equal(other RollupOp) bool
  • func (op *RollupOp) FromProto(pb *pipelinepb.AppliedRollupOp) error
  • func (op RollupOp) String() string
  • func (op RollupOp) ToProto(pb *pipelinepb.AppliedRollupOp) error

Types

type OpUnion

type OpUnion struct {
	Type           pipeline.OpType
	Transformation pipeline.TransformationOp
	Rollup         RollupOp
}

OpUnion is a union of different types of operation.

func (OpUnion) Clone

func (u OpUnion) Clone() OpUnion

Clone clones an operation union.

func (OpUnion) Equal

func (u OpUnion) Equal(other OpUnion) bool

Equal determines whether two operation unions are equal.

func (*OpUnion) FromProto

func (u *OpUnion) FromProto(pb pipelinepb.AppliedPipelineOp) error

FromProto converts the protobuf message to an applied pipeline op in place.

func (*OpUnion) Reset

func (u *OpUnion) Reset()

Reset resets the operation union.

func (OpUnion) String

func (u OpUnion) String() string

func (OpUnion) ToProto

func (u OpUnion) ToProto(pb *pipelinepb.AppliedPipelineOp) error

ToProto converts the applied pipeline op to a protobuf message in place.

type Pipeline

type Pipeline struct {
	// contains filtered or unexported fields
}

Pipeline is a pipeline of operations.

var (
	// DefaultPipeline is a default pipeline.
	DefaultPipeline Pipeline
)

func NewPipeline

func NewPipeline(ops []OpUnion) Pipeline

NewPipeline creates a new pipeline.

func (Pipeline) At

func (p Pipeline) At(i int) OpUnion

At returns the operation at a given step.

func (Pipeline) Clone

func (p Pipeline) Clone() Pipeline

Clone clones the pipeline.

func (Pipeline) Equal

func (p Pipeline) Equal(other Pipeline) bool

Equal determines whether two pipelines are equal.

func (*Pipeline) FromProto

func (p *Pipeline) FromProto(pb pipelinepb.AppliedPipeline) error

FromProto converts the protobuf message to an applied pipeline in place.

func (Pipeline) IsEmpty

func (p Pipeline) IsEmpty() bool

IsEmpty determines whether a pipeline is empty.

func (Pipeline) Len

func (p Pipeline) Len() int

Len returns the number of steps in a pipeline.

func (Pipeline) String

func (p Pipeline) String() string

func (Pipeline) SubPipeline

func (p Pipeline) SubPipeline(startInclusive int, endExclusive int) Pipeline

SubPipeline returns a sub-pipeline containing operations between step `startInclusive` and step `endExclusive` of the current pipeline.

func (Pipeline) ToProto

func (p Pipeline) ToProto(pb *pipelinepb.AppliedPipeline) error

ToProto converts the applied pipeline to a protobuf message in place.

type RollupOp

type RollupOp struct {
	// Metric ID generated as a result of the rollup.
	ID []byte
	// Type of aggregations performed within each unique dimension combination.
	AggregationID aggregation.ID
}

RollupOp captures the rollup metadata after the operation is applied against a metric ID.

func (RollupOp) Clone

func (op RollupOp) Clone() RollupOp

Clone clones the rollup operation.

func (RollupOp) Equal

func (op RollupOp) Equal(other RollupOp) bool

Equal determines whether two rollup operations are equal.

func (*RollupOp) FromProto

func (op *RollupOp) FromProto(pb *pipelinepb.AppliedRollupOp) error

FromProto converts the protobuf message to an applied rollup op in place.

func (RollupOp) String

func (op RollupOp) String() string

func (RollupOp) ToProto

func (op RollupOp) ToProto(pb *pipelinepb.AppliedRollupOp) error

ToProto converts the applied rollup op to a protobuf message in place.