pipelinev1

package
v1.0.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	PipelineRevision_Operation_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "INSERT",
		2: "UPDATE",
		3: "DELETE",
	}
	PipelineRevision_Operation_value = map[string]int32{
		"UNSPECIFIED": 0,
		"INSERT":      1,
		"UPDATE":      2,
		"DELETE":      3,
	}
)

Enum value maps for PipelineRevision_Operation.

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 GetPipelineRevisionRequest added in v0.2.0

type GetPipelineRevisionRequest struct {

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

GetPipelineRevisionRequest is the request to retrieve a pipeline revision by its ID.

func (*GetPipelineRevisionRequest) Descriptor deprecated added in v0.2.0

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

Deprecated: Use GetPipelineRevisionRequest.ProtoReflect.Descriptor instead.

func (*GetPipelineRevisionRequest) GetRevisionId added in v0.2.0

func (x *GetPipelineRevisionRequest) GetRevisionId() string

func (*GetPipelineRevisionRequest) ProtoMessage added in v0.2.0

func (*GetPipelineRevisionRequest) ProtoMessage()

func (*GetPipelineRevisionRequest) ProtoReflect added in v0.2.0

func (*GetPipelineRevisionRequest) Reset added in v0.2.0

func (x *GetPipelineRevisionRequest) Reset()

func (*GetPipelineRevisionRequest) String added in v0.2.0

func (x *GetPipelineRevisionRequest) String() string

type ListPipelineRevisionsRequest added in v0.2.0

type ListPipelineRevisionsRequest struct {

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

ListPipelineRevisionsRequest is the request to get the full list of pipeline revisions for a pipeline.

func (*ListPipelineRevisionsRequest) Descriptor deprecated added in v0.2.0

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

Deprecated: Use ListPipelineRevisionsRequest.ProtoReflect.Descriptor instead.

func (*ListPipelineRevisionsRequest) GetId added in v0.2.0

func (*ListPipelineRevisionsRequest) ProtoMessage added in v0.2.0

func (*ListPipelineRevisionsRequest) ProtoMessage()

func (*ListPipelineRevisionsRequest) ProtoReflect added in v0.2.0

func (*ListPipelineRevisionsRequest) Reset added in v0.2.0

func (x *ListPipelineRevisionsRequest) Reset()

func (*ListPipelineRevisionsRequest) String added in v0.2.0

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 ListPipelinesRevisionsRequest added in v0.2.0

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

ListPipelinesRevisionsRequest is the request to get the full list of pipeline revisions.

func (*ListPipelinesRevisionsRequest) Descriptor deprecated added in v0.2.0

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

Deprecated: Use ListPipelinesRevisionsRequest.ProtoReflect.Descriptor instead.

func (*ListPipelinesRevisionsRequest) ProtoMessage added in v0.2.0

func (*ListPipelinesRevisionsRequest) ProtoMessage()

func (*ListPipelinesRevisionsRequest) ProtoReflect added in v0.2.0

func (*ListPipelinesRevisionsRequest) Reset added in v0.2.0

func (x *ListPipelinesRevisionsRequest) Reset()

func (*ListPipelinesRevisionsRequest) String added in v0.2.0

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 PipelineRevision added in v0.2.0

type PipelineRevision struct {

	// The server-assigned ID of the pipeline revision.
	RevisionId string `protobuf:"bytes,1,opt,name=revision_id,json=revisionId,proto3" json:"revision_id,omitempty"`
	// The snapshot of the pipeline at the time.
	Snapshot *Pipeline `protobuf:"bytes,2,opt,name=snapshot,proto3" json:"snapshot,omitempty"`
	// The timestamp when the pipeline revision was created.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// The operation that was performed on the pipeline.
	Operation PipelineRevision_Operation `protobuf:"varint,4,opt,name=operation,proto3,enum=pipeline.v1.PipelineRevision_Operation" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

A PipelineRevision is a snapshot of a pipeline at a specific point in time.

func (*PipelineRevision) Descriptor deprecated added in v0.2.0

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

Deprecated: Use PipelineRevision.ProtoReflect.Descriptor instead.

func (*PipelineRevision) GetCreatedAt added in v0.2.0

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

func (*PipelineRevision) GetOperation added in v0.2.0

func (x *PipelineRevision) GetOperation() PipelineRevision_Operation

func (*PipelineRevision) GetRevisionId added in v0.2.0

func (x *PipelineRevision) GetRevisionId() string

func (*PipelineRevision) GetSnapshot added in v0.2.0

func (x *PipelineRevision) GetSnapshot() *Pipeline

func (*PipelineRevision) ProtoMessage added in v0.2.0

func (*PipelineRevision) ProtoMessage()

func (*PipelineRevision) ProtoReflect added in v0.2.0

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

func (*PipelineRevision) Reset added in v0.2.0

func (x *PipelineRevision) Reset()

func (*PipelineRevision) String added in v0.2.0

func (x *PipelineRevision) String() string

type PipelineRevision_Operation added in v0.2.0

type PipelineRevision_Operation int32
const (
	PipelineRevision_UNSPECIFIED PipelineRevision_Operation = 0
	PipelineRevision_INSERT      PipelineRevision_Operation = 1
	PipelineRevision_UPDATE      PipelineRevision_Operation = 2
	PipelineRevision_DELETE      PipelineRevision_Operation = 3
)

func (PipelineRevision_Operation) Descriptor added in v0.2.0

func (PipelineRevision_Operation) Enum added in v0.2.0

func (PipelineRevision_Operation) EnumDescriptor deprecated added in v0.2.0

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

Deprecated: Use PipelineRevision_Operation.Descriptor instead.

func (PipelineRevision_Operation) Number added in v0.2.0

func (PipelineRevision_Operation) String added in v0.2.0

func (PipelineRevision_Operation) Type added in v0.2.0

type PipelineRevisions added in v0.2.0

type PipelineRevisions struct {
	PipelineRevisions []*PipelineRevision `protobuf:"bytes,1,rep,name=pipeline_revisions,json=pipelineRevisions,proto3" json:"pipeline_revisions,omitempty"`
	// contains filtered or unexported fields
}

PipelineRevisions represents a list of pipeline revisions.

func (*PipelineRevisions) Descriptor deprecated added in v0.2.0

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

Deprecated: Use PipelineRevisions.ProtoReflect.Descriptor instead.

func (*PipelineRevisions) GetPipelineRevisions added in v0.2.0

func (x *PipelineRevisions) GetPipelineRevisions() []*PipelineRevision

func (*PipelineRevisions) ProtoMessage added in v0.2.0

func (*PipelineRevisions) ProtoMessage()

func (*PipelineRevisions) ProtoReflect added in v0.2.0

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

func (*PipelineRevisions) Reset added in v0.2.0

func (x *PipelineRevisions) Reset()

func (*PipelineRevisions) String added in v0.2.0

func (x *PipelineRevisions) 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