pipelinev1

package
v0.1.1 Latest Latest
Warning

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

Go to latest
Published: Jan 20, 2025 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_pipeline_v1_pipeline_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type CreateAlloyPipelinesRequest

type CreateAlloyPipelinesRequest struct {

	// The URL to write metrics to Grafana Cloud Mimir.
	MimirUrl string `protobuf:"bytes,1,opt,name=mimir_url,json=mimirUrl,proto3" json:"mimir_url,omitempty"`
	// The tenant username to write metrics to Grafana Cloud Mimir.
	MimirUsername string `protobuf:"bytes,2,opt,name=mimir_username,json=mimirUsername,proto3" json:"mimir_username,omitempty"`
	// The URL to write logs to Grafana Cloud Loki.
	LokiUrl string `protobuf:"bytes,3,opt,name=loki_url,json=lokiUrl,proto3" json:"loki_url,omitempty"`
	// The tenant username to write logs to Grafana Cloud Loki.
	LokiUsername string `protobuf:"bytes,4,opt,name=loki_username,json=lokiUsername,proto3" json:"loki_username,omitempty"`
	// contains filtered or unexported fields
}

CreateAlloyPipelinesRequest is the request to create initial alloy pipelines. This is used by the Fleet Management service to create an initial set of pipelines and is not intended to be used by end users.

func (*CreateAlloyPipelinesRequest) Descriptor deprecated

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

Deprecated: Use CreateAlloyPipelinesRequest.ProtoReflect.Descriptor instead.

func (*CreateAlloyPipelinesRequest) GetLokiUrl

func (x *CreateAlloyPipelinesRequest) GetLokiUrl() string

func (*CreateAlloyPipelinesRequest) GetLokiUsername

func (x *CreateAlloyPipelinesRequest) GetLokiUsername() string

func (*CreateAlloyPipelinesRequest) GetMimirUrl

func (x *CreateAlloyPipelinesRequest) GetMimirUrl() string

func (*CreateAlloyPipelinesRequest) GetMimirUsername

func (x *CreateAlloyPipelinesRequest) GetMimirUsername() string

func (*CreateAlloyPipelinesRequest) ProtoMessage

func (*CreateAlloyPipelinesRequest) ProtoMessage()

func (*CreateAlloyPipelinesRequest) ProtoReflect

func (*CreateAlloyPipelinesRequest) Reset

func (x *CreateAlloyPipelinesRequest) Reset()

func (*CreateAlloyPipelinesRequest) String

func (x *CreateAlloyPipelinesRequest) String() string

type CreateAlloyPipelinesResponse

type CreateAlloyPipelinesResponse struct {
	Pipelines *Pipelines `protobuf:"bytes,1,opt,name=pipelines,proto3" json:"pipelines,omitempty"`
	// contains filtered or unexported fields
}

CreateAlloyPipelinesResponse is the response to creating initial alloy pipelines.

func (*CreateAlloyPipelinesResponse) Descriptor deprecated

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

Deprecated: Use CreateAlloyPipelinesResponse.ProtoReflect.Descriptor instead.

func (*CreateAlloyPipelinesResponse) GetPipelines

func (x *CreateAlloyPipelinesResponse) GetPipelines() *Pipelines

func (*CreateAlloyPipelinesResponse) ProtoMessage

func (*CreateAlloyPipelinesResponse) ProtoMessage()

func (*CreateAlloyPipelinesResponse) ProtoReflect

func (*CreateAlloyPipelinesResponse) Reset

func (x *CreateAlloyPipelinesResponse) Reset()

func (*CreateAlloyPipelinesResponse) String

type CreatePipelineRequest

type CreatePipelineRequest struct {

	// (required) The pipeline to create.
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// If set, validate the request and preview the response, but don't create the actual resource.
	ValidateOnly bool `protobuf:"varint,2,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// contains filtered or unexported fields
}

CreatePipelineRequest is the request to create a new pipeline.

func (*CreatePipelineRequest) Descriptor deprecated

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

Deprecated: Use CreatePipelineRequest.ProtoReflect.Descriptor instead.

func (*CreatePipelineRequest) GetPipeline

func (x *CreatePipelineRequest) GetPipeline() *Pipeline

func (*CreatePipelineRequest) GetValidateOnly

func (x *CreatePipelineRequest) GetValidateOnly() bool

func (*CreatePipelineRequest) ProtoMessage

func (*CreatePipelineRequest) ProtoMessage()

func (*CreatePipelineRequest) ProtoReflect

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

func (*CreatePipelineRequest) Reset

func (x *CreatePipelineRequest) Reset()

func (*CreatePipelineRequest) String

func (x *CreatePipelineRequest) String() string

type DeletePipelineRequest

type DeletePipelineRequest struct {

	// (required) The ID of the pipeline to delete.
	Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

DeletePipelineRequest is the request to delete a pipeline by its ID.

func (*DeletePipelineRequest) Descriptor deprecated

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

Deprecated: Use DeletePipelineRequest.ProtoReflect.Descriptor instead.

func (*DeletePipelineRequest) GetId

func (x *DeletePipelineRequest) GetId() string

func (*DeletePipelineRequest) ProtoMessage

func (*DeletePipelineRequest) ProtoMessage()

func (*DeletePipelineRequest) ProtoReflect

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

func (*DeletePipelineRequest) Reset

func (x *DeletePipelineRequest) Reset()

func (*DeletePipelineRequest) String

func (x *DeletePipelineRequest) String() string

type DeletePipelineResponse

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

DeletePipelineResponse is the response to deleting a pipeline. This message is empty and the results of the deletion are defined by the HTTP status code of the response.

func (*DeletePipelineResponse) Descriptor deprecated

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

Deprecated: Use DeletePipelineResponse.ProtoReflect.Descriptor instead.

func (*DeletePipelineResponse) ProtoMessage

func (*DeletePipelineResponse) ProtoMessage()

func (*DeletePipelineResponse) ProtoReflect

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

func (*DeletePipelineResponse) Reset

func (x *DeletePipelineResponse) Reset()

func (*DeletePipelineResponse) String

func (x *DeletePipelineResponse) String() string

type GetPipelineIDRequest

type GetPipelineIDRequest struct {

	// (required) The name of the pipeline to get the ID for.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

GetPipelineIDRequest is the request to retrieve a pipeline ID by its name.

func (*GetPipelineIDRequest) Descriptor deprecated

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

Deprecated: Use GetPipelineIDRequest.ProtoReflect.Descriptor instead.

func (*GetPipelineIDRequest) GetName

func (x *GetPipelineIDRequest) GetName() string

func (*GetPipelineIDRequest) ProtoMessage

func (*GetPipelineIDRequest) ProtoMessage()

func (*GetPipelineIDRequest) ProtoReflect

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

func (*GetPipelineIDRequest) Reset

func (x *GetPipelineIDRequest) Reset()

func (*GetPipelineIDRequest) String

func (x *GetPipelineIDRequest) String() string

type GetPipelineIDResponse

type GetPipelineIDResponse struct {

	// The ID of the pipeline.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

GetPipelineIDResponse is the response to retrieving a pipeline ID.

func (*GetPipelineIDResponse) Descriptor deprecated

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

Deprecated: Use GetPipelineIDResponse.ProtoReflect.Descriptor instead.

func (*GetPipelineIDResponse) GetId

func (x *GetPipelineIDResponse) GetId() string

func (*GetPipelineIDResponse) ProtoMessage

func (*GetPipelineIDResponse) ProtoMessage()

func (*GetPipelineIDResponse) ProtoReflect

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

func (*GetPipelineIDResponse) Reset

func (x *GetPipelineIDResponse) Reset()

func (*GetPipelineIDResponse) String

func (x *GetPipelineIDResponse) String() string

type GetPipelineRequest

type GetPipelineRequest struct {

	// (required) The ID of the pipeline to get.
	Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

GetPipelineRequest is the request to retrieve a pipeline by its ID.

func (*GetPipelineRequest) Descriptor deprecated

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

Deprecated: Use GetPipelineRequest.ProtoReflect.Descriptor instead.

func (*GetPipelineRequest) GetId

func (x *GetPipelineRequest) GetId() string

func (*GetPipelineRequest) ProtoMessage

func (*GetPipelineRequest) ProtoMessage()

func (*GetPipelineRequest) ProtoReflect

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

func (*GetPipelineRequest) Reset

func (x *GetPipelineRequest) Reset()

func (*GetPipelineRequest) String

func (x *GetPipelineRequest) String() string

type ListPipelinesRequest

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

ListPipelinesRequest is the request to get the full list of pipelines, including their contents and matchers.

func (*ListPipelinesRequest) Descriptor deprecated

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

Deprecated: Use ListPipelinesRequest.ProtoReflect.Descriptor instead.

func (*ListPipelinesRequest) ProtoMessage

func (*ListPipelinesRequest) ProtoMessage()

func (*ListPipelinesRequest) ProtoReflect

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

func (*ListPipelinesRequest) Reset

func (x *ListPipelinesRequest) Reset()

func (*ListPipelinesRequest) String

func (x *ListPipelinesRequest) String() string

type Pipeline

type Pipeline struct {

	// (required) The name of the pipeline. This is the unique identifier for the pipeline.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// (required) The configuration contents of the pipeline to be used by collectors.
	Contents string `protobuf:"bytes,2,opt,name=contents,proto3" json:"contents,omitempty"`
	// Matchers are used to match against collectors and assign pipelines to them.
	// They follow the syntax of the Prometheus [Alertmanager matchers](https://prometheus.io/docs/alerting/latest/configuration/#matcher)
	Matchers []string `protobuf:"bytes,3,rep,name=matchers,proto3" json:"matchers,omitempty"`
	// The timestamp when the pipeline was created.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=created_at,json=createdAt,proto3,oneof" json:"created_at,omitempty"`
	// The timestamp when the pipeline was last updated.
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=updated_at,json=updatedAt,proto3,oneof" json:"updated_at,omitempty"`
	// Whether the pipeline is enabled for collectors.
	Enabled *bool `protobuf:"varint,6,opt,name=enabled,proto3,oneof" json:"enabled,omitempty"`
	// The server-assigned ID of the pipeline.
	Id *string `protobuf:"bytes,7,opt,name=id,proto3,oneof" json:"id,omitempty"`
	// contains filtered or unexported fields
}

A Pipeline is a self-contained snippet of configuration that can be assigned to collectors based on matchers.

func (*Pipeline) Descriptor deprecated

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

Deprecated: Use Pipeline.ProtoReflect.Descriptor instead.

func (*Pipeline) GetContents

func (x *Pipeline) GetContents() string

func (*Pipeline) GetCreatedAt

func (x *Pipeline) GetCreatedAt() *timestamppb.Timestamp

func (*Pipeline) GetEnabled

func (x *Pipeline) GetEnabled() bool

func (*Pipeline) GetId

func (x *Pipeline) GetId() string

func (*Pipeline) GetMatchers

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

func (*Pipeline) GetName

func (x *Pipeline) GetName() string

func (*Pipeline) GetUpdatedAt

func (x *Pipeline) GetUpdatedAt() *timestamppb.Timestamp

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

type Pipelines

type Pipelines struct {
	Pipelines []*Pipeline `protobuf:"bytes,1,rep,name=pipelines,proto3" json:"pipelines,omitempty"`
	// contains filtered or unexported fields
}

Pipelines represents a list of pipelines.

func (*Pipelines) Descriptor deprecated

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

Deprecated: Use Pipelines.ProtoReflect.Descriptor instead.

func (*Pipelines) GetPipelines

func (x *Pipelines) GetPipelines() []*Pipeline

func (*Pipelines) ProtoMessage

func (*Pipelines) ProtoMessage()

func (*Pipelines) ProtoReflect

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

func (*Pipelines) Reset

func (x *Pipelines) Reset()

func (*Pipelines) String

func (x *Pipelines) String() string

type UpdatePipelineRequest

type UpdatePipelineRequest struct {

	// (required) The contents of the pipeline to update. This will replace the existing pipeline contents,
	// so any fields that are not set will end up being removed.
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// If set, validate the request and preview the response, but don't update the actual resource.
	ValidateOnly bool `protobuf:"varint,2,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// contains filtered or unexported fields
}

UpdatePipelineRequest is the request to update an existing pipeline. If the pipeline does not already exist, this will return a 404 'NOT_FOUND' error.

func (*UpdatePipelineRequest) Descriptor deprecated

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

Deprecated: Use UpdatePipelineRequest.ProtoReflect.Descriptor instead.

func (*UpdatePipelineRequest) GetPipeline

func (x *UpdatePipelineRequest) GetPipeline() *Pipeline

func (*UpdatePipelineRequest) GetValidateOnly

func (x *UpdatePipelineRequest) GetValidateOnly() bool

func (*UpdatePipelineRequest) ProtoMessage

func (*UpdatePipelineRequest) ProtoMessage()

func (*UpdatePipelineRequest) ProtoReflect

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

func (*UpdatePipelineRequest) Reset

func (x *UpdatePipelineRequest) Reset()

func (*UpdatePipelineRequest) String

func (x *UpdatePipelineRequest) String() string

type UpsertPipelineRequest

type UpsertPipelineRequest struct {

	// (required) The pipeline to create or update. If the pipeline already exists, it will be updated and
	// like UpdatePipelineRequest, any fields that are not set will be removed.
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// contains filtered or unexported fields
}

UpsertPipelineRequest is the request to create a new pipeline *or* update an existing one.

func (*UpsertPipelineRequest) Descriptor deprecated

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

Deprecated: Use UpsertPipelineRequest.ProtoReflect.Descriptor instead.

func (*UpsertPipelineRequest) GetPipeline

func (x *UpsertPipelineRequest) GetPipeline() *Pipeline

func (*UpsertPipelineRequest) ProtoMessage

func (*UpsertPipelineRequest) ProtoMessage()

func (*UpsertPipelineRequest) ProtoReflect

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

func (*UpsertPipelineRequest) Reset

func (x *UpsertPipelineRequest) Reset()

func (*UpsertPipelineRequest) String

func (x *UpsertPipelineRequest) String() string

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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