Documentation
¶
Index ¶
- Variables
- type CreateAlloyPipelinesRequest
- func (*CreateAlloyPipelinesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateAlloyPipelinesRequest) GetLokiUrl() string
- func (x *CreateAlloyPipelinesRequest) GetLokiUsername() string
- func (x *CreateAlloyPipelinesRequest) GetMimirUrl() string
- func (x *CreateAlloyPipelinesRequest) GetMimirUsername() string
- func (*CreateAlloyPipelinesRequest) ProtoMessage()
- func (x *CreateAlloyPipelinesRequest) ProtoReflect() protoreflect.Message
- func (x *CreateAlloyPipelinesRequest) Reset()
- func (x *CreateAlloyPipelinesRequest) String() string
- type CreateAlloyPipelinesResponse
- func (*CreateAlloyPipelinesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateAlloyPipelinesResponse) GetPipelines() *Pipelines
- func (*CreateAlloyPipelinesResponse) ProtoMessage()
- func (x *CreateAlloyPipelinesResponse) ProtoReflect() protoreflect.Message
- func (x *CreateAlloyPipelinesResponse) Reset()
- func (x *CreateAlloyPipelinesResponse) String() string
- type CreatePipelineRequest
- func (*CreatePipelineRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreatePipelineRequest) GetPipeline() *Pipeline
- func (x *CreatePipelineRequest) GetValidateOnly() bool
- func (*CreatePipelineRequest) ProtoMessage()
- func (x *CreatePipelineRequest) ProtoReflect() protoreflect.Message
- func (x *CreatePipelineRequest) Reset()
- func (x *CreatePipelineRequest) String() string
- type DeletePipelineRequest
- func (*DeletePipelineRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeletePipelineRequest) GetId() string
- func (*DeletePipelineRequest) ProtoMessage()
- func (x *DeletePipelineRequest) ProtoReflect() protoreflect.Message
- func (x *DeletePipelineRequest) Reset()
- func (x *DeletePipelineRequest) String() string
- type DeletePipelineResponse
- type GetPipelineIDRequest
- func (*GetPipelineIDRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetPipelineIDRequest) GetName() string
- func (*GetPipelineIDRequest) ProtoMessage()
- func (x *GetPipelineIDRequest) ProtoReflect() protoreflect.Message
- func (x *GetPipelineIDRequest) Reset()
- func (x *GetPipelineIDRequest) String() string
- type GetPipelineIDResponse
- func (*GetPipelineIDResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetPipelineIDResponse) GetId() string
- func (*GetPipelineIDResponse) ProtoMessage()
- func (x *GetPipelineIDResponse) ProtoReflect() protoreflect.Message
- func (x *GetPipelineIDResponse) Reset()
- func (x *GetPipelineIDResponse) String() string
- type GetPipelineRequest
- type GetPipelineRevisionRequest
- func (*GetPipelineRevisionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetPipelineRevisionRequest) GetRevisionId() string
- func (*GetPipelineRevisionRequest) ProtoMessage()
- func (x *GetPipelineRevisionRequest) ProtoReflect() protoreflect.Message
- func (x *GetPipelineRevisionRequest) Reset()
- func (x *GetPipelineRevisionRequest) String() string
- type ListPipelineRevisionsRequest
- func (*ListPipelineRevisionsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListPipelineRevisionsRequest) GetId() string
- func (*ListPipelineRevisionsRequest) ProtoMessage()
- func (x *ListPipelineRevisionsRequest) ProtoReflect() protoreflect.Message
- func (x *ListPipelineRevisionsRequest) Reset()
- func (x *ListPipelineRevisionsRequest) String() string
- type ListPipelinesRequest
- type ListPipelinesRevisionsRequest
- func (*ListPipelinesRevisionsRequest) Descriptor() ([]byte, []int)deprecated
- func (*ListPipelinesRevisionsRequest) ProtoMessage()
- func (x *ListPipelinesRevisionsRequest) ProtoReflect() protoreflect.Message
- func (x *ListPipelinesRevisionsRequest) Reset()
- func (x *ListPipelinesRevisionsRequest) String() string
- type Pipeline
- func (*Pipeline) Descriptor() ([]byte, []int)deprecated
- func (x *Pipeline) GetContents() string
- func (x *Pipeline) GetCreatedAt() *timestamppb.Timestamp
- func (x *Pipeline) GetEnabled() bool
- func (x *Pipeline) GetId() string
- func (x *Pipeline) GetMatchers() []string
- func (x *Pipeline) GetName() string
- func (x *Pipeline) GetUpdatedAt() *timestamppb.Timestamp
- func (*Pipeline) ProtoMessage()
- func (x *Pipeline) ProtoReflect() protoreflect.Message
- func (x *Pipeline) Reset()
- func (x *Pipeline) String() string
- type PipelineRevision
- func (*PipelineRevision) Descriptor() ([]byte, []int)deprecated
- func (x *PipelineRevision) GetCreatedAt() *timestamppb.Timestamp
- func (x *PipelineRevision) GetOperation() PipelineRevision_Operation
- func (x *PipelineRevision) GetRevisionId() string
- func (x *PipelineRevision) GetSnapshot() *Pipeline
- func (*PipelineRevision) ProtoMessage()
- func (x *PipelineRevision) ProtoReflect() protoreflect.Message
- func (x *PipelineRevision) Reset()
- func (x *PipelineRevision) String() string
- type PipelineRevision_Operation
- func (PipelineRevision_Operation) Descriptor() protoreflect.EnumDescriptor
- func (x PipelineRevision_Operation) Enum() *PipelineRevision_Operation
- func (PipelineRevision_Operation) EnumDescriptor() ([]byte, []int)deprecated
- func (x PipelineRevision_Operation) Number() protoreflect.EnumNumber
- func (x PipelineRevision_Operation) String() string
- func (PipelineRevision_Operation) Type() protoreflect.EnumType
- type PipelineRevisions
- func (*PipelineRevisions) Descriptor() ([]byte, []int)deprecated
- func (x *PipelineRevisions) GetPipelineRevisions() []*PipelineRevision
- func (*PipelineRevisions) ProtoMessage()
- func (x *PipelineRevisions) ProtoReflect() protoreflect.Message
- func (x *PipelineRevisions) Reset()
- func (x *PipelineRevisions) String() string
- type Pipelines
- type UpdatePipelineRequest
- func (*UpdatePipelineRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdatePipelineRequest) GetPipeline() *Pipeline
- func (x *UpdatePipelineRequest) GetValidateOnly() bool
- func (*UpdatePipelineRequest) ProtoMessage()
- func (x *UpdatePipelineRequest) ProtoReflect() protoreflect.Message
- func (x *UpdatePipelineRequest) Reset()
- func (x *UpdatePipelineRequest) String() string
- type UpsertPipelineRequest
- func (*UpsertPipelineRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpsertPipelineRequest) GetPipeline() *Pipeline
- func (*UpsertPipelineRequest) ProtoMessage()
- func (x *UpsertPipelineRequest) ProtoReflect() protoreflect.Message
- func (x *UpsertPipelineRequest) Reset()
- func (x *UpsertPipelineRequest) String() string
Constants ¶
This section is empty.
Variables ¶
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.
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 (x *CreateAlloyPipelinesRequest) ProtoReflect() protoreflect.Message
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 (x *CreateAlloyPipelinesResponse) ProtoReflect() protoreflect.Message
func (*CreateAlloyPipelinesResponse) Reset ¶
func (x *CreateAlloyPipelinesResponse) Reset()
func (*CreateAlloyPipelinesResponse) String ¶
func (x *CreateAlloyPipelinesResponse) String() 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 (x *GetPipelineRevisionRequest) ProtoReflect() protoreflect.Message
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 (x *ListPipelineRevisionsRequest) GetId() string
func (*ListPipelineRevisionsRequest) ProtoMessage ¶ added in v0.2.0
func (*ListPipelineRevisionsRequest) ProtoMessage()
func (*ListPipelineRevisionsRequest) ProtoReflect ¶ added in v0.2.0
func (x *ListPipelineRevisionsRequest) ProtoReflect() protoreflect.Message
func (*ListPipelineRevisionsRequest) Reset ¶ added in v0.2.0
func (x *ListPipelineRevisionsRequest) Reset()
func (*ListPipelineRevisionsRequest) String ¶ added in v0.2.0
func (x *ListPipelineRevisionsRequest) 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 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 (x *ListPipelinesRevisionsRequest) ProtoReflect() protoreflect.Message
func (*ListPipelinesRevisionsRequest) Reset ¶ added in v0.2.0
func (x *ListPipelinesRevisionsRequest) Reset()
func (*ListPipelinesRevisionsRequest) String ¶ added in v0.2.0
func (x *ListPipelinesRevisionsRequest) 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) GetContents ¶
func (*Pipeline) GetCreatedAt ¶
func (x *Pipeline) GetCreatedAt() *timestamppb.Timestamp
func (*Pipeline) GetEnabled ¶
func (*Pipeline) GetMatchers ¶
func (*Pipeline) GetUpdatedAt ¶
func (x *Pipeline) GetUpdatedAt() *timestamppb.Timestamp
func (*Pipeline) ProtoMessage ¶
func (*Pipeline) ProtoMessage()
func (*Pipeline) ProtoReflect ¶
func (x *Pipeline) ProtoReflect() protoreflect.Message
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) Descriptor() protoreflect.EnumDescriptor
func (PipelineRevision_Operation) Enum ¶ added in v0.2.0
func (x PipelineRevision_Operation) Enum() *PipelineRevision_Operation
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 (x PipelineRevision_Operation) Number() protoreflect.EnumNumber
func (PipelineRevision_Operation) String ¶ added in v0.2.0
func (x PipelineRevision_Operation) String() string
func (PipelineRevision_Operation) Type ¶ added in v0.2.0
func (PipelineRevision_Operation) Type() protoreflect.EnumType
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) GetPipelines ¶
func (*Pipelines) ProtoMessage ¶
func (*Pipelines) ProtoMessage()
func (*Pipelines) ProtoReflect ¶
func (x *Pipelines) ProtoReflect() protoreflect.Message
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