v1

README

Pipeline

Pipeline is a data processing language that Observability Cloud provides. Pipeline supports text parsing of different formats of log data.

By writing a pipeline script, you can customize the structure of the log and use the cut fields as attributes.

By cutting out the attribute fields, we can quickly filter the relevant logs and perform data association analysis to help us quickly locate and solve problems.

Documentation

Overview

Package v1

Pipeline

Pipeline is a data processing language that Observability Cloud provides. Pipeline supports text parsing of different formats of log data.

By writing a pipeline script, you can customize the structure of the log and use the cut fields as attributes.

By cutting out the attribute fields, we can quickly filter the relevant logs and perform data association analysis to help us quickly locate and solve problems.

Code generated by Iacker. DO NOT EDIT IT.

Index

• Constants
• Variables
• type Pipeline
  • func (*Pipeline) Descriptor() ([]byte, []int)
  • func (x *Pipeline) GetCategory() string
  • func (x *Pipeline) GetContent() string
  • func (x *Pipeline) GetIsDefault() bool
  • func (x *Pipeline) GetIsForce() bool
  • func (x *Pipeline) GetName() string
  • func (x *Pipeline) GetSource() []string
  • func (x *Pipeline) GetTestData() string
  • func (*Pipeline) ProtoMessage()
  • func (x *Pipeline) ProtoReflect() protoreflect.Message
  • func (x *Pipeline) Reset()
  • func (x *Pipeline) String() string
  • func (m *Pipeline) Validate() error
  • func (m *Pipeline) ValidateAll() error
• type PipelineMultiError
  • func (m PipelineMultiError) AllErrors() []error
  • func (m PipelineMultiError) Error() string
• type PipelineValidationError
  • func (e PipelineValidationError) Cause() error
  • func (e PipelineValidationError) Error() string
  • func (e PipelineValidationError) ErrorName() string
  • func (e PipelineValidationError) Field() string
  • func (e PipelineValidationError) Key() bool
  • func (e PipelineValidationError) Reason() string

Constants

const (
	// PipelineCategoryLogging is the value of logging
	PipelineCategoryLogging = "logging"
	// PipelineCategoryObject is the value of object
	PipelineCategoryObject = "object"
	// PipelineCategoryCustomObject is the value of custom_object
	PipelineCategoryCustomObject = "custom_object"
	// PipelineCategoryNetwork is the value of network
	PipelineCategoryNetwork = "network"
	// PipelineCategoryTracing is the value of tracing
	PipelineCategoryTracing = "tracing"
	// PipelineCategoryRum is the value of RUM
	PipelineCategoryRum = "rum"
	// PipelineCategorySecurity is the value of security
	PipelineCategorySecurity = "security"
	// PipelineCategoryKeyevent is the value of keyevent
	PipelineCategoryKeyevent = "keyevent"
	// PipelineCategoryMetric is the value of metric
	PipelineCategoryMetric = "metric"
)

const ResourceType = "Pipeline"

ResourceType is the unique type name of Pipeline

Variables

var File_pkg_resources_pipeline_v1_pipeline_proto protoreflect.FileDescriptor

Types

type Pipeline

type Pipeline struct {

	// Name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Data source list
	Source []string `protobuf:"bytes,2,rep,name=source,proto3" json:"source,omitempty"`
	// Pipeline file content
	Content string `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
	// Test data
	TestData *string `protobuf:"bytes,4,opt,name=test_data,json=testData,proto3,oneof" json:"test_data,omitempty"`
	// Is Force Overwrite
	IsForce *bool `protobuf:"varint,5,opt,name=is_force,json=isForce,proto3,oneof" json:"is_force,omitempty"`
	// Category
	Category string `protobuf:"bytes,6,opt,name=category,proto3" json:"category,omitempty"`
	// Is Default Pipeline
	IsDefault *bool `protobuf:"varint,7,opt,name=is_default,json=isDefault,proto3,oneof" json:"is_default,omitempty"`
	// contains filtered or unexported fields
}

func (*Pipeline) Descriptor

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

Deprecated: Use Pipeline.ProtoReflect.Descriptor instead.

func (*Pipeline) GetCategory

func (x *Pipeline) GetCategory() string

func (*Pipeline) GetContent

func (x *Pipeline) GetContent() string

func (*Pipeline) GetIsDefault

func (x *Pipeline) GetIsDefault() bool

func (*Pipeline) GetIsForce

func (x *Pipeline) GetIsForce() bool

func (*Pipeline) GetName

func (x *Pipeline) GetName() string

func (*Pipeline) GetSource

func (x *Pipeline) GetSource() []string

func (*Pipeline) GetTestData

func (x *Pipeline) GetTestData() string

func (*Pipeline) ProtoMessage

func (*Pipeline) ProtoMessage()

func (*Pipeline) ProtoReflect

func (x *Pipeline) ProtoReflect() protoreflect.Message

func (*Pipeline) Reset

func (x *Pipeline) Reset()

func (*Pipeline) String

func (x *Pipeline) String() string

func (*Pipeline) Validate

func (m *Pipeline) Validate() error

Validate checks the field values on Pipeline with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Pipeline) ValidateAll

func (m *Pipeline) ValidateAll() error

ValidateAll checks the field values on Pipeline with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PipelineMultiError, or nil if none found.

type PipelineMultiError

type PipelineMultiError []error

PipelineMultiError is an error wrapping multiple validation errors returned by Pipeline.ValidateAll() if the designated constraints aren't met.

func (PipelineMultiError) AllErrors

func (m PipelineMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PipelineMultiError) Error

func (m PipelineMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type PipelineValidationError

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

PipelineValidationError is the validation error returned by Pipeline.Validate if the designated constraints aren't met.

func (PipelineValidationError) Cause

func (e PipelineValidationError) Cause() error

Cause function returns cause value.

func (PipelineValidationError) Error

func (e PipelineValidationError) Error() string

Error satisfies the builtin error interface

func (PipelineValidationError) ErrorName

func (e PipelineValidationError) ErrorName() string

ErrorName returns error name.

func (PipelineValidationError) Field

func (e PipelineValidationError) Field() string

Field function returns field value.

func (PipelineValidationError) Key

func (e PipelineValidationError) Key() bool

Key function returns key value.

func (PipelineValidationError) Reason

func (e PipelineValidationError) Reason() string

Reason function returns reason value.