proto

package
v0.0.1 Latest Latest
Warning

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

 Go to latest Published: Jan 5, 2022 License: GPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	TaskRequiredParentState_name = map[int32]string{
		0: "UNKNOWN",
		1: "ANY",
		2: "SUCCESSFUL",
		3: "FAILURE",
	}
	TaskRequiredParentState_value = map[string]int32{
		"UNKNOWN":    0,
		"ANY":        1,
		"SUCCESSFUL": 2,
		"FAILURE":    3,
	}
)

Enum value maps for TaskRequiredParentState.

View Source 
var (
	Pipeline_State_name = map[int32]string{
		0: "UNKNOWN",
		1: "ACTIVE",
		2: "DISABLED",
		3: "ABANDONED",
	}
	Pipeline_State_value = map[string]int32{
		"UNKNOWN":   0,
		"ACTIVE":    1,
		"DISABLED":  2,
		"ABANDONED": 3,
	}
)

Enum value maps for Pipeline_State.

View Source 
var (
	Run_State_name = map[int32]string{
		0: "UNKNOWN",
		1: "PROCESSING",
		2: "WAITING",
		3: "RUNNING",
		4: "FAILED",
		5: "SUCCESS",
		6: "CANCELLED",
	}
	Run_State_value = map[string]int32{
		"UNKNOWN":    0,
		"PROCESSING": 1,
		"WAITING":    2,
		"RUNNING":    3,
		"FAILED":     4,
		"SUCCESS":    5,
		"CANCELLED":  6,
	}
)

Enum value maps for Run_State.

View Source 
var (
	RunFailure_Kind_name = map[int32]string{
		0: "UNKNOWN",
		1: "ABNORMAL_EXIT",
		2: "SCHEDULER_ERROR",
		3: "FAILED_PRECONDITION",
		4: "CANCELLED",
	}
	RunFailure_Kind_value = map[string]int32{
		"UNKNOWN":             0,
		"ABNORMAL_EXIT":       1,
		"SCHEDULER_ERROR":     2,
		"FAILED_PRECONDITION": 3,
		"CANCELLED":           4,
	}
)

Enum value maps for RunFailure_Kind.

View Source 
var (
	TaskRunFailure_Kind_name = map[int32]string{
		0: "UNKNOWN",
		1: "ABNORMAL_EXIT",
		2: "SCHEDULER_ERROR",
		3: "FAILED_PRECONDITION",
		4: "CANCELLED",
		5: "ORPHANED",
	}
	TaskRunFailure_Kind_value = map[string]int32{
		"UNKNOWN":             0,
		"ABNORMAL_EXIT":       1,
		"SCHEDULER_ERROR":     2,
		"FAILED_PRECONDITION": 3,
		"CANCELLED":           4,
		"ORPHANED":            5,
	}
)

Enum value maps for TaskRunFailure_Kind.

View Source 
var (
	TaskRun_State_name = map[int32]string{
		0: "UNKNOWN",
		1: "PROCESSING",
		2: "WAITING",
		3: "RUNNING",
		4: "FAILED",
		5: "SUCCESS",
		6: "CANCELLED",
		7: "SKIPPED",
	}
	TaskRun_State_value = map[string]int32{
		"UNKNOWN":    0,
		"PROCESSING": 1,
		"WAITING":    2,
		"RUNNING":    3,
		"FAILED":     4,
		"SUCCESS":    5,
		"CANCELLED":  6,
		"SKIPPED":    7,
	}
)

Enum value maps for TaskRun_State.

View Source 
var (
	TriggerResult_State_name = map[int32]string{
		0: "UNKNOWN",
		1: "FAILURE",
		2: "SUCCESS",
		3: "SKIPPED",
	}
	TriggerResult_State_value = map[string]int32{
		"UNKNOWN": 0,
		"FAILURE": 1,
		"SUCCESS": 2,
		"SKIPPED": 3,
	}
)

Enum value maps for TriggerResult_State.

View Source 
var (
	Trigger_State_name = map[int32]string{
		0: "UNKNOWN",
		1: "PROCESSING",
		2: "WAITING",
		3: "RUNNING",
		4: "FAILED",
		5: "SUCCESS",
	}
	Trigger_State_value = map[string]int32{
		"UNKNOWN":    0,
		"PROCESSING": 1,
		"WAITING":    2,
		"RUNNING":    3,
		"FAILED":     4,
		"SUCCESS":    5,
	}
)

Enum value maps for Trigger_State.

View Source 
var (
	Token_Kind_name = map[int32]string{
		0: "UNKNOWN",
		1: "MANAGEMENT",
		2: "CLIENT",
	}
	Token_Kind_value = map[string]int32{
		"UNKNOWN":    0,
		"MANAGEMENT": 1,
		"CLIENT":     2,
	}
)

Enum value maps for Token_Kind.

View Source 
var (
	CreateTokenRequest_Kind_name = map[int32]string{
		0: "UNKNOWN",
		1: "MANAGEMENT",
		2: "CLIENT",
	}
	CreateTokenRequest_Kind_value = map[string]int32{
		"UNKNOWN":    0,
		"MANAGEMENT": 1,
		"CLIENT":     2,
	}
)

Enum value maps for CreateTokenRequest_Kind.

View Source 
var File_gofer_message_proto protoreflect.FileDescriptor
View Source 
var File_gofer_proto protoreflect.FileDescriptor
View Source 
var File_gofer_transport_proto protoreflect.FileDescriptor

Functions

func RegisterGoferServer 

func RegisterGoferServer(s grpc.ServiceRegistrar, srv GoferServer)

Types

type AbandonPipelineRequest 

type AbandonPipelineRequest struct {
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` // Unique namespace identifier
	Id          string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`                                      // Pipeline ID
	// contains filtered or unexported fields
}

func (*AbandonPipelineRequest) Descriptor deprecated 

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

Deprecated: Use AbandonPipelineRequest.ProtoReflect.Descriptor instead.

func (*AbandonPipelineRequest) GetId 

func (x *AbandonPipelineRequest) GetId() string

func (*AbandonPipelineRequest) GetNamespaceId 

func (x *AbandonPipelineRequest) GetNamespaceId() string

func (*AbandonPipelineRequest) ProtoMessage 

func (*AbandonPipelineRequest) ProtoMessage()

func (*AbandonPipelineRequest) ProtoReflect 

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

func (*AbandonPipelineRequest) Reset 

func (x *AbandonPipelineRequest) Reset()

func (*AbandonPipelineRequest) String 

func (x *AbandonPipelineRequest) String() string

type AbandonPipelineResponse 

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

func (*AbandonPipelineResponse) Descriptor deprecated 

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

Deprecated: Use AbandonPipelineResponse.ProtoReflect.Descriptor instead.

func (*AbandonPipelineResponse) ProtoMessage 

func (*AbandonPipelineResponse) ProtoMessage()

func (*AbandonPipelineResponse) ProtoReflect 

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

func (*AbandonPipelineResponse) Reset 

func (x *AbandonPipelineResponse) Reset()

func (*AbandonPipelineResponse) String 

func (x *AbandonPipelineResponse) String() string

type AddRegistryAuthRequest 

type AddRegistryAuthRequest struct {
	Registry string `protobuf:"bytes,1,opt,name=registry,proto3" json:"registry,omitempty"`
	User     string `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	Pass     string `protobuf:"bytes,3,opt,name=pass,proto3" json:"pass,omitempty"`
	// contains filtered or unexported fields
}

func (*AddRegistryAuthRequest) Descriptor deprecated 

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

Deprecated: Use AddRegistryAuthRequest.ProtoReflect.Descriptor instead.

func (*AddRegistryAuthRequest) GetPass 

func (x *AddRegistryAuthRequest) GetPass() string

func (*AddRegistryAuthRequest) GetRegistry 

func (x *AddRegistryAuthRequest) GetRegistry() string

func (*AddRegistryAuthRequest) GetUser 

func (x *AddRegistryAuthRequest) GetUser() string

func (*AddRegistryAuthRequest) ProtoMessage 

func (*AddRegistryAuthRequest) ProtoMessage()

func (*AddRegistryAuthRequest) ProtoReflect 

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

func (*AddRegistryAuthRequest) Reset 

func (x *AddRegistryAuthRequest) Reset()

func (*AddRegistryAuthRequest) String 

func (x *AddRegistryAuthRequest) String() string

type AddRegistryAuthResponse 

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

func (*AddRegistryAuthResponse) Descriptor deprecated 

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

Deprecated: Use AddRegistryAuthResponse.ProtoReflect.Descriptor instead.

func (*AddRegistryAuthResponse) ProtoMessage 

func (*AddRegistryAuthResponse) ProtoMessage()

func (*AddRegistryAuthResponse) ProtoReflect 

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

func (*AddRegistryAuthResponse) Reset 

func (x *AddRegistryAuthResponse) Reset()

func (*AddRegistryAuthResponse) String 

func (x *AddRegistryAuthResponse) String() string

type BatchGetRunsRequest 

type BatchGetRunsRequest struct {
	NamespaceId string  `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` // Unique namespace identifier
	PipelineId  string  `protobuf:"bytes,2,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	Ids         []int64 `protobuf:"varint,3,rep,packed,name=ids,proto3" json:"ids,omitempty"` // Run IDs
	// contains filtered or unexported fields
}

func (*BatchGetRunsRequest) Descriptor deprecated 

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

Deprecated: Use BatchGetRunsRequest.ProtoReflect.Descriptor instead.

func (*BatchGetRunsRequest) GetIds 

func (x *BatchGetRunsRequest) GetIds() []int64

func (*BatchGetRunsRequest) GetNamespaceId 

func (x *BatchGetRunsRequest) GetNamespaceId() string

func (*BatchGetRunsRequest) GetPipelineId 

func (x *BatchGetRunsRequest) GetPipelineId() string

func (*BatchGetRunsRequest) ProtoMessage 

func (*BatchGetRunsRequest) ProtoMessage()

func (*BatchGetRunsRequest) ProtoReflect 

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

func (*BatchGetRunsRequest) Reset 

func (x *BatchGetRunsRequest) Reset()

func (*BatchGetRunsRequest) String 

func (x *BatchGetRunsRequest) String() string

type BatchGetRunsResponse 

type BatchGetRunsResponse struct {
	Runs []*Run `protobuf:"bytes,1,rep,name=runs,proto3" json:"runs,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchGetRunsResponse) Descriptor deprecated 

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

Deprecated: Use BatchGetRunsResponse.ProtoReflect.Descriptor instead.

func (*BatchGetRunsResponse) GetRuns 

func (x *BatchGetRunsResponse) GetRuns() []*Run

func (*BatchGetRunsResponse) ProtoMessage 

func (*BatchGetRunsResponse) ProtoMessage()

func (*BatchGetRunsResponse) ProtoReflect 

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

func (*BatchGetRunsResponse) Reset 

func (x *BatchGetRunsResponse) Reset()

func (*BatchGetRunsResponse) String 

func (x *BatchGetRunsResponse) String() string

type BatchGetTriggerEventsRequest 

type BatchGetTriggerEventsRequest struct {
	NamespaceId          string  `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` // Unique namespace identifier
	PipelineId           string  `protobuf:"bytes,2,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	PipelineTriggerLabel string  `protobuf:"bytes,3,opt,name=pipeline_trigger_label,json=pipelineTriggerLabel,proto3" json:"pipeline_trigger_label,omitempty"`
	Ids                  []int64 `protobuf:"varint,4,rep,packed,name=ids,proto3" json:"ids,omitempty"` // Trigger Event IDs
	// contains filtered or unexported fields
}

func (*BatchGetTriggerEventsRequest) Descriptor deprecated 

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

Deprecated: Use BatchGetTriggerEventsRequest.ProtoReflect.Descriptor instead.

func (*BatchGetTriggerEventsRequest) GetIds 

func (x *BatchGetTriggerEventsRequest) GetIds() []int64

func (*BatchGetTriggerEventsRequest) GetNamespaceId 

func (x *BatchGetTriggerEventsRequest) GetNamespaceId() string

func (*BatchGetTriggerEventsRequest) GetPipelineId 

func (x *BatchGetTriggerEventsRequest) GetPipelineId() string

func (*BatchGetTriggerEventsRequest) GetPipelineTriggerLabel 

func (x *BatchGetTriggerEventsRequest) GetPipelineTriggerLabel() string

func (*BatchGetTriggerEventsRequest) ProtoMessage 

func (*BatchGetTriggerEventsRequest) ProtoMessage()

func (*BatchGetTriggerEventsRequest) ProtoReflect 

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

func (*BatchGetTriggerEventsRequest) Reset 

func (x *BatchGetTriggerEventsRequest) Reset()

func (*BatchGetTriggerEventsRequest) String 

func (x *BatchGetTriggerEventsRequest) String() string

type BatchGetTriggerEventsResponse 

type BatchGetTriggerEventsResponse struct {
	Events []*TriggerEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchGetTriggerEventsResponse) Descriptor deprecated 

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

Deprecated: Use BatchGetTriggerEventsResponse.ProtoReflect.Descriptor instead.

func (*BatchGetTriggerEventsResponse) GetEvents 

func (x *BatchGetTriggerEventsResponse) GetEvents() []*TriggerEvent

func (*BatchGetTriggerEventsResponse) ProtoMessage 

func (*BatchGetTriggerEventsResponse) ProtoMessage()

func (*BatchGetTriggerEventsResponse) ProtoReflect 

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

func (*BatchGetTriggerEventsResponse) Reset 

func (x *BatchGetTriggerEventsResponse) Reset()

func (*BatchGetTriggerEventsResponse) String 

func (x *BatchGetTriggerEventsResponse) String() string

type BootstrapTokenRequest 

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

func (*BootstrapTokenRequest) Descriptor deprecated 

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

Deprecated: Use BootstrapTokenRequest.ProtoReflect.Descriptor instead.

func (*BootstrapTokenRequest) ProtoMessage 

func (*BootstrapTokenRequest) ProtoMessage()

func (*BootstrapTokenRequest) ProtoReflect 

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

func (*BootstrapTokenRequest) Reset 

func (x *BootstrapTokenRequest) Reset()

func (*BootstrapTokenRequest) String 

func (x *BootstrapTokenRequest) String() string

type BootstrapTokenResponse 

type BootstrapTokenResponse struct {
	Details *Token `protobuf:"bytes,1,opt,name=details,proto3" json:"details,omitempty"`
	Token   string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*BootstrapTokenResponse) Descriptor deprecated 

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

Deprecated: Use BootstrapTokenResponse.ProtoReflect.Descriptor instead.

func (*BootstrapTokenResponse) GetDetails 

func (x *BootstrapTokenResponse) GetDetails() *Token

func (*BootstrapTokenResponse) GetToken 

func (x *BootstrapTokenResponse) GetToken() string

func (*BootstrapTokenResponse) ProtoMessage 

func (*BootstrapTokenResponse) ProtoMessage()

func (*BootstrapTokenResponse) ProtoReflect 

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

func (*BootstrapTokenResponse) Reset 

func (x *BootstrapTokenResponse) Reset()

func (*BootstrapTokenResponse) String 

func (x *BootstrapTokenResponse) String() string

type CancelAllRunsRequest 

type CancelAllRunsRequest struct {
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` // Unique namespace identifier
	PipelineId  string `protobuf:"bytes,2,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	// force will cause Gofer to hard kill any outstanding task run containers.
	// Usually this means that the container receives a SIGKILL.
	Force bool `protobuf:"varint,3,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelAllRunsRequest) Descriptor deprecated 

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

Deprecated: Use CancelAllRunsRequest.ProtoReflect.Descriptor instead.

func (*CancelAllRunsRequest) GetForce 

func (x *CancelAllRunsRequest) GetForce() bool

func (*CancelAllRunsRequest) GetNamespaceId 

func (x *CancelAllRunsRequest) GetNamespaceId() string

func (*CancelAllRunsRequest) GetPipelineId 

func (x *CancelAllRunsRequest) GetPipelineId() string

func (*CancelAllRunsRequest) ProtoMessage 

func (*CancelAllRunsRequest) ProtoMessage()

func (*CancelAllRunsRequest) ProtoReflect 

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

func (*CancelAllRunsRequest) Reset 

func (x *CancelAllRunsRequest) Reset()

func (*CancelAllRunsRequest) String 

func (x *CancelAllRunsRequest) String() string

type CancelAllRunsResponse 

type CancelAllRunsResponse struct {
	Runs []int64 `protobuf:"varint,1,rep,packed,name=runs,proto3" json:"runs,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelAllRunsResponse) Descriptor deprecated 

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

Deprecated: Use CancelAllRunsResponse.ProtoReflect.Descriptor instead.

func (*CancelAllRunsResponse) GetRuns 

func (x *CancelAllRunsResponse) GetRuns() []int64

func (*CancelAllRunsResponse) ProtoMessage 

func (*CancelAllRunsResponse) ProtoMessage()

func (*CancelAllRunsResponse) ProtoReflect 

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

func (*CancelAllRunsResponse) Reset 

func (x *CancelAllRunsResponse) Reset()

func (*CancelAllRunsResponse) String 

func (x *CancelAllRunsResponse) String() string

type CancelRunRequest 

type CancelRunRequest struct {
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` // Unique namespace identifier
	PipelineId  string `protobuf:"bytes,2,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	Id          int64  `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty"` // Run ID
	// force will cause Gofer to hard kill any outstanding task run containers.
	// Usually this means that the container receives a SIGKILL.
	Force bool `protobuf:"varint,4,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelRunRequest) Descriptor deprecated 

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

Deprecated: Use CancelRunRequest.ProtoReflect.Descriptor instead.

func (*CancelRunRequest) GetForce 

func (x *CancelRunRequest) GetForce() bool

func (*CancelRunRequest) GetId 

func (x *CancelRunRequest) GetId() int64

func (*CancelRunRequest) GetNamespaceId 

func (x *CancelRunRequest) GetNamespaceId() string

func (*CancelRunRequest) GetPipelineId 

func (x *CancelRunRequest) GetPipelineId() string

func (*CancelRunRequest) ProtoMessage 

func (*CancelRunRequest) ProtoMessage()

func (*CancelRunRequest) ProtoReflect 

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

func (*CancelRunRequest) Reset 

func (x *CancelRunRequest) Reset()

func (*CancelRunRequest) String 

func (x *CancelRunRequest) String() string

type CancelRunResponse 

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

func (*CancelRunResponse) Descriptor deprecated 

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

Deprecated: Use CancelRunResponse.ProtoReflect.Descriptor instead.

func (*CancelRunResponse) ProtoMessage 

func (*CancelRunResponse) ProtoMessage()

func (*CancelRunResponse) ProtoReflect 

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

func (*CancelRunResponse) Reset 

func (x *CancelRunResponse) Reset()

func (*CancelRunResponse) String 

func (x *CancelRunResponse) String() string

type CancelTaskRunRequest 

type CancelTaskRunRequest struct {
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` // Unique namespace identifier
	PipelineId  string `protobuf:"bytes,2,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	RunId       int64  `protobuf:"varint,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	Id          string `protobuf:"bytes,4,opt,name=id,proto3" json:"id,omitempty"` // Task Run ID
	// force will cause Gofer to hard kill this task run containers.
	// Usually this means that the container receives a SIGKILL.
	Force bool `protobuf:"varint,5,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelTaskRunRequest) Descriptor deprecated 

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

Deprecated: Use CancelTaskRunRequest.ProtoReflect.Descriptor instead.

func (*CancelTaskRunRequest) GetForce 

func (x *CancelTaskRunRequest) GetForce() bool

func (*CancelTaskRunRequest) GetId 

func (x *CancelTaskRunRequest) GetId() string

func (*CancelTaskRunRequest) GetNamespaceId 

func (x *CancelTaskRunRequest) GetNamespaceId() string

func (*CancelTaskRunRequest) GetPipelineId 

func (x *CancelTaskRunRequest) GetPipelineId() string

func (*CancelTaskRunRequest) GetRunId 

func (x *CancelTaskRunRequest) GetRunId() int64

func (*CancelTaskRunRequest) ProtoMessage 

func (*CancelTaskRunRequest) ProtoMessage()

func (*CancelTaskRunRequest) ProtoReflect 

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

func (*CancelTaskRunRequest) Reset 

func (x *CancelTaskRunRequest) Reset()

func (*CancelTaskRunRequest) String 

func (x *CancelTaskRunRequest) String() string

type CancelTaskRunResponse 

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

func (*CancelTaskRunResponse) Descriptor deprecated 

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

Deprecated: Use CancelTaskRunResponse.ProtoReflect.Descriptor instead.

func (*CancelTaskRunResponse) ProtoMessage 

func (*CancelTaskRunResponse) ProtoMessage()

func (*CancelTaskRunResponse) ProtoReflect 

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

func (*CancelTaskRunResponse) Reset 

func (x *CancelTaskRunResponse) Reset()

func (*CancelTaskRunResponse) String 

func (x *CancelTaskRunResponse) String() string

type CreateNamespaceRequest 

type CreateNamespaceRequest struct {
	Id          string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name        string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateNamespaceRequest) Descriptor deprecated 

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

Deprecated: Use CreateNamespaceRequest.ProtoReflect.Descriptor instead.

func (*CreateNamespaceRequest) GetDescription 

func (x *CreateNamespaceRequest) GetDescription() string

func (*CreateNamespaceRequest) GetId 

func (x *CreateNamespaceRequest) GetId() string

func (*CreateNamespaceRequest) GetName 

func (x *CreateNamespaceRequest) GetName() string

func (*CreateNamespaceRequest) ProtoMessage 

func (*CreateNamespaceRequest) ProtoMessage()

func (*CreateNamespaceRequest) ProtoReflect 

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

func (*CreateNamespaceRequest) Reset 

func (x *CreateNamespaceRequest) Reset()

func (*CreateNamespaceRequest) String 

func (x *CreateNamespaceRequest) String() string

type CreateNamespaceResponse 

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

func (*CreateNamespaceResponse) Descriptor deprecated 

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

Deprecated: Use CreateNamespaceResponse.ProtoReflect.Descriptor instead.

func (*CreateNamespaceResponse) GetNamespace 

func (x *CreateNamespaceResponse) GetNamespace() *Namespace

func (*CreateNamespaceResponse) ProtoMessage 

func (*CreateNamespaceResponse) ProtoMessage()

func (*CreateNamespaceResponse) ProtoReflect 

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

func (*CreateNamespaceResponse) Reset 

func (x *CreateNamespaceResponse) Reset()

func (*CreateNamespaceResponse) String 

func (x *CreateNamespaceResponse) String() string

type CreatePipelineByURLRequest 

type CreatePipelineByURLRequest struct {

	// url represents the remote location where the pipeline configuration file
	// exists. This parameter takes urls in the form of hashicorp's
	// go-getter(https://github.com/hashicorp/go-getter#general-all-protocols).
	// This means that is supports a wide array of possibilities for remote
	// locations.
	// The most common use case is simply pointing to a file or folder within
	// remote source control:
	//    folder: `"github.com/clintjedwards/gofer.git//gofer"`
	//    file: `"github.com/clintjedwards/gofer.git//gofer.hcl"`
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

func (*CreatePipelineByURLRequest) Descriptor deprecated 

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

Deprecated: Use CreatePipelineByURLRequest.ProtoReflect.Descriptor instead.

func (*CreatePipelineByURLRequest) GetUrl 

func (x *CreatePipelineByURLRequest) GetUrl() string

func (*CreatePipelineByURLRequest) ProtoMessage 

func (*CreatePipelineByURLRequest) ProtoMessage()

func (*CreatePipelineByURLRequest) ProtoReflect 

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

func (*CreatePipelineByURLRequest) Reset 

func (x *CreatePipelineByURLRequest) Reset()

func (*CreatePipelineByURLRequest) String 

func (x *CreatePipelineByURLRequest) String() string

type CreatePipelineByURLResponse 

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

func (*CreatePipelineByURLResponse) Descriptor deprecated 

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

Deprecated: Use CreatePipelineByURLResponse.ProtoReflect.Descriptor instead.

func (*CreatePipelineByURLResponse) GetPipeline 

func (x *CreatePipelineByURLResponse) GetPipeline() *Pipeline

func (*CreatePipelineByURLResponse) ProtoMessage 

func (*CreatePipelineByURLResponse) ProtoMessage()

func (*CreatePipelineByURLResponse) ProtoReflect 

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

func (*CreatePipelineByURLResponse) Reset 

func (x *CreatePipelineByURLResponse) Reset()

func (*CreatePipelineByURLResponse) String 

func (x *CreatePipelineByURLResponse) String() string

type CreatePipelineRawRequest 

type CreatePipelineRawRequest struct {

	// Gofer pipeline config file byte string.
	Content []byte `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
	// path is a metadata parameter to where the pipeline file might be stored.
	// For example: for a command line application using this endpoint, the path
	// here might be the path of the pipeline file on the user's machine.
	// For a foreign API using this endpoint, the path could be something related
	// to endpoint responsible for creating the pipeline file.
	// This parameter is not used for anything particularly important and only
	// used for documentation purposes for the user.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*CreatePipelineRawRequest) Descriptor deprecated 

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

Deprecated: Use CreatePipelineRawRequest.ProtoReflect.Descriptor instead.

func (*CreatePipelineRawRequest) GetContent 

func (x *CreatePipelineRawRequest) GetContent() []byte

func (*CreatePipelineRawRequest) GetPath 

func (x *CreatePipelineRawRequest) GetPath() string

func (*CreatePipelineRawRequest) ProtoMessage 

func (*CreatePipelineRawRequest) ProtoMessage()

func (*CreatePipelineRawRequest) ProtoReflect 

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

func (*CreatePipelineRawRequest) Reset 

func (x *CreatePipelineRawRequest) Reset()

func (*CreatePipelineRawRequest) String 

func (x *CreatePipelineRawRequest) String() string

type CreatePipelineRawResponse 

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

func (*CreatePipelineRawResponse) Descriptor deprecated 

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

Deprecated: Use CreatePipelineRawResponse.ProtoReflect.Descriptor instead.

func (*CreatePipelineRawResponse) GetPipeline 

func (x *CreatePipelineRawResponse) GetPipeline() *Pipeline

func (*CreatePipelineRawResponse) ProtoMessage 

func (*CreatePipelineRawResponse) ProtoMessage()

func (*CreatePipelineRawResponse) ProtoReflect 

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

func (*CreatePipelineRawResponse) Reset 

func (x *CreatePipelineRawResponse) Reset()

func (*CreatePipelineRawResponse) String 

func (x *CreatePipelineRawResponse) String() string

type CreateTokenRequest 

type CreateTokenRequest struct {
	Kind       CreateTokenRequest_Kind `protobuf:"varint,1,opt,name=kind,proto3,enum=proto.CreateTokenRequest_Kind" json:"kind,omitempty"`
	Namespaces []string                `protobuf:"bytes,2,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	Metadata   map[string]string       `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateTokenRequest) Descriptor deprecated 

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

Deprecated: Use CreateTokenRequest.ProtoReflect.Descriptor instead.

func (*CreateTokenRequest) GetKind 

func (x *CreateTokenRequest) GetKind() CreateTokenRequest_Kind

func (*CreateTokenRequest) GetMetadata 

func (x *CreateTokenRequest) GetMetadata() map[string]string

func (*CreateTokenRequest) GetNamespaces 

func (x *CreateTokenRequest) GetNamespaces() []string

func (*CreateTokenRequest) ProtoMessage 

func (*CreateTokenRequest) ProtoMessage()

func (*CreateTokenRequest) ProtoReflect 

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

func (*CreateTokenRequest) Reset 

func (x *CreateTokenRequest) Reset()

func (*CreateTokenRequest) String 

func (x *CreateTokenRequest) String() string

type CreateTokenRequest_Kind 

type CreateTokenRequest_Kind int32
const (
	CreateTokenRequest_UNKNOWN    CreateTokenRequest_Kind = 0
	CreateTokenRequest_MANAGEMENT CreateTokenRequest_Kind = 1
	CreateTokenRequest_CLIENT     CreateTokenRequest_Kind = 2
)

func (CreateTokenRequest_Kind) Descriptor 

func (CreateTokenRequest_Kind) Descriptor() protoreflect.EnumDescriptor

func (CreateTokenRequest_Kind) Enum 

func (x CreateTokenRequest_Kind) Enum() *CreateTokenRequest_Kind

func (CreateTokenRequest_Kind) EnumDescriptor deprecated 

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

Deprecated: Use CreateTokenRequest_Kind.Descriptor instead.

func (CreateTokenRequest_Kind) Number 

func (x CreateTokenRequest_Kind) Number() protoreflect.EnumNumber

func (CreateTokenRequest_Kind) String 

func (x CreateTokenRequest_Kind) String() string

func (CreateTokenRequest_Kind) Type 

func (CreateTokenRequest_Kind) Type() protoreflect.EnumType

type CreateTokenResponse 

type CreateTokenResponse struct {
	Details *Token `protobuf:"bytes,1,opt,name=details,proto3" json:"details,omitempty"`
	Token   string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTokenResponse) Descriptor deprecated 

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

Deprecated: Use CreateTokenResponse.ProtoReflect.Descriptor instead.

func (*CreateTokenResponse) GetDetails 

func (x *CreateTokenResponse) GetDetails() *Token

func (*CreateTokenResponse) GetToken 

func (x *CreateTokenResponse) GetToken() string

func (*CreateTokenResponse) ProtoMessage 

func (*CreateTokenResponse) ProtoMessage()

func (*CreateTokenResponse) ProtoReflect 

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

func (*CreateTokenResponse) Reset 

func (x *CreateTokenResponse) Reset()

func (*CreateTokenResponse) String 

func (x *CreateTokenResponse) String() string

type DeleteNamespaceRequest 

type DeleteNamespaceRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Unique identifier
	// contains filtered or unexported fields
}

func (*DeleteNamespaceRequest) Descriptor deprecated 

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

Deprecated: Use DeleteNamespaceRequest.ProtoReflect.Descriptor instead.

func (*DeleteNamespaceRequest) GetId 

func (x *DeleteNamespaceRequest) GetId() string

func (*DeleteNamespaceRequest) ProtoMessage 

func (*DeleteNamespaceRequest) ProtoMessage()

func (*DeleteNamespaceRequest) ProtoReflect 

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

func (*DeleteNamespaceRequest) Reset 

func (x *DeleteNamespaceRequest) Reset()

func (*DeleteNamespaceRequest) String 

func (x *DeleteNamespaceRequest) String() string

type DeleteNamespaceResponse 

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

func (*DeleteNamespaceResponse) Descriptor deprecated 

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

Deprecated: Use DeleteNamespaceResponse.ProtoReflect.Descriptor instead.

func (*DeleteNamespaceResponse) ProtoMessage 

func (*DeleteNamespaceResponse) ProtoMessage()

func (*DeleteNamespaceResponse) ProtoReflect 

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

func (*DeleteNamespaceResponse) Reset 

func (x *DeleteNamespaceResponse) Reset()

func (*DeleteNamespaceResponse) String 

func (x *DeleteNamespaceResponse) String() string

type DeletePipelineObjectRequest 

type DeletePipelineObjectRequest struct {
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` // Unique namespace identifier
	PipelineId  string `protobuf:"bytes,2,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	Key         string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*DeletePipelineObjectRequest) Descriptor deprecated 

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

Deprecated: Use DeletePipelineObjectRequest.ProtoReflect.Descriptor instead.

func (*DeletePipelineObjectRequest) GetKey 

func (x *DeletePipelineObjectRequest) GetKey() string

func (*DeletePipelineObjectRequest) GetNamespaceId 

func (x *DeletePipelineObjectRequest) GetNamespaceId() string

func (*DeletePipelineObjectRequest) GetPipelineId 

func (x *DeletePipelineObjectRequest) GetPipelineId() string

func (*DeletePipelineObjectRequest) ProtoMessage 

func (*DeletePipelineObjectRequest) ProtoMessage()

func (*DeletePipelineObjectRequest) ProtoReflect 

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

func (*DeletePipelineObjectRequest) Reset 

func (x *DeletePipelineObjectRequest) Reset()

func (*DeletePipelineObjectRequest) String 

func (x *DeletePipelineObjectRequest) String() string

type DeletePipelineObjectResponse 

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

func (*DeletePipelineObjectResponse) Descriptor deprecated 

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

Deprecated: Use DeletePipelineObjectResponse.ProtoReflect.Descriptor instead.

func (*DeletePipelineObjectResponse) ProtoMessage 

func (*DeletePipelineObjectResponse) ProtoMessage()

func (*DeletePipelineObjectResponse) ProtoReflect 

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

func (*DeletePipelineObjectResponse) Reset 

func (x *DeletePipelineObjectResponse) Reset()

func (*DeletePipelineObjectResponse) String 

func (x *DeletePipelineObjectResponse) String() string

type DeleteRunObjectRequest 

type DeleteRunObjectRequest struct {
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` // Unique namespace identifier
	PipelineId  string `protobuf:"bytes,2,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	RunId       int64  `protobuf:"varint,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	Key         string `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRunObjectRequest) Descriptor deprecated 

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

Deprecated: Use DeleteRunObjectRequest.ProtoReflect.Descriptor instead.

func (*DeleteRunObjectRequest) GetKey 

func (x *DeleteRunObjectRequest) GetKey() string

func (*DeleteRunObjectRequest) GetNamespaceId 

func (x *DeleteRunObjectRequest) GetNamespaceId() string

func (*DeleteRunObjectRequest) GetPipelineId 

func (x *DeleteRunObjectRequest) GetPipelineId() string

func (*DeleteRunObjectRequest) GetRunId 

func (x *DeleteRunObjectRequest) GetRunId() int64

func (*DeleteRunObjectRequest) ProtoMessage 

func (*DeleteRunObjectRequest) ProtoMessage()

func (*DeleteRunObjectRequest) ProtoReflect 

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

func (*DeleteRunObjectRequest) Reset 

func (x *DeleteRunObjectRequest) Reset()

func (*DeleteRunObjectRequest) String 

func (x *DeleteRunObjectRequest) String() string

type DeleteRunObjectResponse 

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

func (*DeleteRunObjectResponse) Descriptor deprecated 

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

Deprecated: Use DeleteRunObjectResponse.ProtoReflect.Descriptor instead.

func (*DeleteRunObjectResponse) ProtoMessage 

func (*DeleteRunObjectResponse) ProtoMessage()

func (*DeleteRunObjectResponse) ProtoReflect 

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

func (*DeleteRunObjectResponse) Reset 

func (x *DeleteRunObjectResponse) Reset()

func (*DeleteRunObjectResponse) String 

func (x *DeleteRunObjectResponse) String() string

type DeleteTaskRunLogsRequest 

type DeleteTaskRunLogsRequest struct {
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` // Unique namespace identifier
	PipelineId  string `protobuf:"bytes,2,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	RunId       int64  `protobuf:"varint,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	Id          string `protobuf:"bytes,4,opt,name=id,proto3" json:"id,omitempty"` // Task Run ID
	// contains filtered or unexported fields
}

func (*DeleteTaskRunLogsRequest) Descriptor deprecated 

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

Deprecated: Use DeleteTaskRunLogsRequest.ProtoReflect.Descriptor instead.

func (*DeleteTaskRunLogsRequest) GetId 

func (x *DeleteTaskRunLogsRequest) GetId() string

func (*DeleteTaskRunLogsRequest) GetNamespaceId 

func (x *DeleteTaskRunLogsRequest) GetNamespaceId() string

func (*DeleteTaskRunLogsRequest) GetPipelineId 

func (x *DeleteTaskRunLogsRequest) GetPipelineId() string

func (*DeleteTaskRunLogsRequest) GetRunId 

func (x *DeleteTaskRunLogsRequest) GetRunId() int64

func (*DeleteTaskRunLogsRequest) ProtoMessage 

func (*DeleteTaskRunLogsRequest) ProtoMessage()

func (*DeleteTaskRunLogsRequest) ProtoReflect 

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

func (*DeleteTaskRunLogsRequest) Reset 

func (x *DeleteTaskRunLogsRequest) Reset()

func (*DeleteTaskRunLogsRequest) String 

func (x *DeleteTaskRunLogsRequest) String() string

type DeleteTaskRunLogsResponse 

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

func (*DeleteTaskRunLogsResponse) Descriptor deprecated 

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

Deprecated: Use DeleteTaskRunLogsResponse.ProtoReflect.Descriptor instead.

func (*DeleteTaskRunLogsResponse) ProtoMessage 

func (*DeleteTaskRunLogsResponse) ProtoMessage()

func (*DeleteTaskRunLogsResponse) ProtoReflect 

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

func (*DeleteTaskRunLogsResponse) Reset 

func (x *DeleteTaskRunLogsResponse) Reset()

func (*DeleteTaskRunLogsResponse) String 

func (x *DeleteTaskRunLogsResponse) String() string

type DeleteTokenRequest 

type DeleteTokenRequest struct {
	Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteTokenRequest) Descriptor deprecated 

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

Deprecated: Use DeleteTokenRequest.ProtoReflect.Descriptor instead.

func (*DeleteTokenRequest) GetToken 

func (x *DeleteTokenRequest) GetToken() string

func (*DeleteTokenRequest) ProtoMessage 

func (*DeleteTokenRequest) ProtoMessage()

func (*DeleteTokenRequest) ProtoReflect 

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

func (*DeleteTokenRequest) Reset 

func (x *DeleteTokenRequest) Reset()

func (*DeleteTokenRequest) String 

func (x *DeleteTokenRequest) String() string

type DeleteTokenResponse 

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

func (*DeleteTokenResponse) Descriptor deprecated 

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

Deprecated: Use DeleteTokenResponse.ProtoReflect.Descriptor instead.

func (*DeleteTokenResponse) ProtoMessage 

func (*DeleteTokenResponse) ProtoMessage()

func (*DeleteTokenResponse) ProtoReflect 

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

func (*DeleteTokenResponse) Reset 

func (x *DeleteTokenResponse) Reset()

func (*DeleteTokenResponse) String 

func (x *DeleteTokenResponse) String() string

type DisablePipelineRequest 

type DisablePipelineRequest struct {
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` // Unique namespace identifier
	Id          string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`                                      // Unique namespace identifier
	// contains filtered or unexported fields
}

func (*DisablePipelineRequest) Descriptor deprecated 

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

Deprecated: Use DisablePipelineRequest.ProtoReflect.Descriptor instead.

func (*DisablePipelineRequest) GetId 

func (x *DisablePipelineRequest) GetId() string

func (*DisablePipelineRequest) GetNamespaceId 

func (x *DisablePipelineRequest) GetNamespaceId() string

func (*DisablePipelineRequest) ProtoMessage 

func (*DisablePipelineRequest) ProtoMessage()

func (*DisablePipelineRequest) ProtoReflect 

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

func (*DisablePipelineRequest) Reset 

func (x *DisablePipelineRequest) Reset()

func (*DisablePipelineRequest) String 

func (x *DisablePipelineRequest) String() string

type DisablePipelineResponse 

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

func (*DisablePipelineResponse) Descriptor deprecated 

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

Deprecated: Use DisablePipelineResponse.ProtoReflect.Descriptor instead.

func (*DisablePipelineResponse) ProtoMessage 

func (*DisablePipelineResponse) ProtoMessage()

func (*DisablePipelineResponse) ProtoReflect 

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

func (*DisablePipelineResponse) Reset 

func (x *DisablePipelineResponse) Reset()

func (*DisablePipelineResponse) String 

func (x *DisablePipelineResponse) String() string

type DockerRegistryAuth 

type DockerRegistryAuth struct {
	Registry string `protobuf:"bytes,1,opt,name=registry,proto3" json:"registry,omitempty"`
	User     string `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	Created  int64  `protobuf:"varint,3,opt,name=created,proto3" json:"created,omitempty"`
	// contains filtered or unexported fields
}

func (*DockerRegistryAuth) Descriptor deprecated 

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

Deprecated: Use DockerRegistryAuth.ProtoReflect.Descriptor instead.

func (*DockerRegistryAuth) GetCreated 

func (x *DockerRegistryAuth) GetCreated() int64

func (*DockerRegistryAuth) GetRegistry 

func (x *DockerRegistryAuth) GetRegistry() string

func (*DockerRegistryAuth) GetUser 

func (x *DockerRegistryAuth) GetUser() string

func (*DockerRegistryAuth) ProtoMessage 

func (*DockerRegistryAuth) ProtoMessage()

func (*DockerRegistryAuth) ProtoReflect 

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

func (*DockerRegistryAuth) Reset 

func (x *DockerRegistryAuth) Reset()

func (*DockerRegistryAuth) String 

func (x *DockerRegistryAuth) String() string

type EnablePipelineRequest 

type EnablePipelineRequest struct {
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` // Unique namespace identifier
	Id          string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`                                      // Unique identifier
	// contains filtered or unexported fields
}

func (*EnablePipelineRequest) Descriptor deprecated 

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

Deprecated: Use EnablePipelineRequest.ProtoReflect.Descriptor instead.

func (*EnablePipelineRequest) GetId 

func (x *EnablePipelineRequest) GetId() string

func (*EnablePipelineRequest) GetNamespaceId 

func (x *EnablePipelineRequest) GetNamespaceId() string

func (*EnablePipelineRequest) ProtoMessage 

func (*EnablePipelineRequest) ProtoMessage()

func (*EnablePipelineRequest) ProtoReflect 

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

func (*EnablePipelineRequest) Reset 

func (x *EnablePipelineRequest) Reset()

func (*EnablePipelineRequest) String 

func (x *EnablePipelineRequest) String() string

type EnablePipelineResponse 

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

func (*EnablePipelineResponse) Descriptor deprecated 

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

Deprecated: Use EnablePipelineResponse.ProtoReflect.Descriptor instead.

func (*EnablePipelineResponse) ProtoMessage 

func (*EnablePipelineResponse) ProtoMessage()

func (*EnablePipelineResponse) ProtoReflect 

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

func (*EnablePipelineResponse) Reset 

func (x *EnablePipelineResponse) Reset()

func (*EnablePipelineResponse) String 

func (x *EnablePipelineResponse) String() string

type GetNamespaceRequest 

type GetNamespaceRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Unique identifier
	// contains filtered or unexported fields
}

func (*GetNamespaceRequest) Descriptor deprecated 

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

Deprecated: Use GetNamespaceRequest.ProtoReflect.Descriptor instead.

func (*GetNamespaceRequest) GetId 

func (x *GetNamespaceRequest) GetId() string

func (*GetNamespaceRequest) ProtoMessage 

func (*GetNamespaceRequest) ProtoMessage()

func (*GetNamespaceRequest) ProtoReflect 

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

func (*GetNamespaceRequest) Reset 

func (x *GetNamespaceRequest) Reset()

func (*GetNamespaceRequest) String 

func (x *GetNamespaceRequest) String() string

type GetNamespaceResponse 

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

func (*GetNamespaceResponse) Descriptor deprecated 

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

Deprecated: Use GetNamespaceResponse.ProtoReflect.Descriptor instead.

func (*GetNamespaceResponse) GetNamespace 

func (x *GetNamespaceResponse) GetNamespace() *Namespace

func (*GetNamespaceResponse) ProtoMessage 

func (*GetNamespaceResponse) ProtoMessage()

func (*GetNamespaceResponse) ProtoReflect 

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

func (*GetNamespaceResponse) Reset 

func (x *GetNamespaceResponse) Reset()

func (*GetNamespaceResponse) String 

func (x *GetNamespaceResponse) String() string

type GetPipelineObjectRequest 

type GetPipelineObjectRequest struct {
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` // Unique namespace identifier
	PipelineId  string `protobuf:"bytes,2,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	Key         string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPipelineObjectRequest) Descriptor deprecated 

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

Deprecated: Use GetPipelineObjectRequest.ProtoReflect.Descriptor instead.

func (*GetPipelineObjectRequest) GetKey 

func (x *GetPipelineObjectRequest) GetKey() string

func (*GetPipelineObjectRequest) GetNamespaceId 

func (x *GetPipelineObjectRequest) GetNamespaceId() string

func (*GetPipelineObjectRequest) GetPipelineId 

func (x *GetPipelineObjectRequest) GetPipelineId() string

func (*GetPipelineObjectRequest) ProtoMessage 

func (*GetPipelineObjectRequest) ProtoMessage()

func (*GetPipelineObjectRequest) ProtoReflect 

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

func (*GetPipelineObjectRequest) Reset 

func (x *GetPipelineObjectRequest) Reset()

func (*GetPipelineObjectRequest) String 

func (x *GetPipelineObjectRequest) String() string

type GetPipelineObjectResponse 

type GetPipelineObjectResponse struct {
	Content []byte `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPipelineObjectResponse) Descriptor deprecated 

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

Deprecated: Use GetPipelineObjectResponse.ProtoReflect.Descriptor instead.

func (*GetPipelineObjectResponse) GetContent 

func (x *GetPipelineObjectResponse) GetContent() []byte

func (*GetPipelineObjectResponse) ProtoMessage 

func (*GetPipelineObjectResponse) ProtoMessage()

func (*GetPipelineObjectResponse) ProtoReflect 

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

func (*GetPipelineObjectResponse) Reset 

func (x *GetPipelineObjectResponse) Reset()

func (*GetPipelineObjectResponse) String 

func (x *GetPipelineObjectResponse) String() string

type GetPipelineRequest 

type GetPipelineRequest struct {
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` // Unique namespace identifier
	Id          string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`                                      // Unique identifier
	// contains filtered or unexported fields
}

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) GetNamespaceId 

func (x *GetPipelineRequest) GetNamespaceId() 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 GetPipelineResponse 

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

func (*GetPipelineResponse) Descriptor deprecated 

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

Deprecated: Use GetPipelineResponse.ProtoReflect.Descriptor instead.

func (*GetPipelineResponse) GetPipeline 

func (x *GetPipelineResponse) GetPipeline() *Pipeline

func (*GetPipelineResponse) ProtoMessage 

func (*GetPipelineResponse) ProtoMessage()

func (*GetPipelineResponse) ProtoReflect 

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

func (*GetPipelineResponse) Reset 

func (x *GetPipelineResponse) Reset()

func (*GetPipelineResponse) String 

func (x *GetPipelineResponse) String() string

type GetRunObjectRequest 

type GetRunObjectRequest struct {
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` // Unique namespace identifier
	PipelineId  string `protobuf:"bytes,2,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	RunId       int64  `protobuf:"varint,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	Key         string `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRunObjectRequest) Descriptor deprecated 

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

Deprecated: Use GetRunObjectRequest.ProtoReflect.Descriptor instead.

func (*GetRunObjectRequest) GetKey 

func (x *GetRunObjectRequest) GetKey() string

func (*GetRunObjectRequest) GetNamespaceId 

func (x *GetRunObjectRequest) GetNamespaceId() string

func (*GetRunObjectRequest) GetPipelineId 

func (x *GetRunObjectRequest) GetPipelineId() string

func (*GetRunObjectRequest) GetRunId 

func (x *GetRunObjectRequest) GetRunId() int64

func (*GetRunObjectRequest) ProtoMessage 

func (*GetRunObjectRequest) ProtoMessage()

func (*GetRunObjectRequest) ProtoReflect 

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

func (*GetRunObjectRequest) Reset 

func (x *GetRunObjectRequest) Reset()

func (*GetRunObjectRequest) String 

func (x *GetRunObjectRequest) String() string

type GetRunObjectResponse 

type GetRunObjectResponse struct {
	Content []byte `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRunObjectResponse) Descriptor deprecated 

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

Deprecated: Use GetRunObjectResponse.ProtoReflect.Descriptor instead.

func (*GetRunObjectResponse) GetContent 

func (x *GetRunObjectResponse) GetContent() []byte

func (*GetRunObjectResponse) ProtoMessage 

func (*GetRunObjectResponse) ProtoMessage()

func (*GetRunObjectResponse) ProtoReflect 

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

func (*GetRunObjectResponse) Reset 

func (x *GetRunObjectResponse) Reset()

func (*GetRunObjectResponse) String 

func (x *GetRunObjectResponse) String() string

type GetRunRequest 

type GetRunRequest struct {
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` // Unique namespace identifier
	PipelineId  string `protobuf:"bytes,2,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	Id          int64  `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty"` // Run ID
	// contains filtered or unexported fields
}

func (*GetRunRequest) Descriptor deprecated 

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

Deprecated: Use GetRunRequest.ProtoReflect.Descriptor instead.

func (*GetRunRequest) GetId 

func (x *GetRunRequest) GetId() int64

func (*GetRunRequest) GetNamespaceId 

func (x *GetRunRequest) GetNamespaceId() string

func (*GetRunRequest) GetPipelineId 

func (x *GetRunRequest) GetPipelineId() string

func (*GetRunRequest) ProtoMessage 

func (*GetRunRequest) ProtoMessage()

func (*GetRunRequest) ProtoReflect 

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

func (*GetRunRequest) Reset 

func (x *GetRunRequest) Reset()

func (*GetRunRequest) String 

func (x *GetRunRequest) String() string

type GetRunResponse 

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

func (*GetRunResponse) Descriptor deprecated 

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

Deprecated: Use GetRunResponse.ProtoReflect.Descriptor instead.

func (*GetRunResponse) GetRun 

func (x *GetRunResponse) GetRun() *Run

func (*GetRunResponse) ProtoMessage 

func (*GetRunResponse) ProtoMessage()

func (*GetRunResponse) ProtoReflect 

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

func (*GetRunResponse) Reset 

func (x *GetRunResponse) Reset()

func (*GetRunResponse) String 

func (x *GetRunResponse) String() string

type GetSystemInfoRequest 

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

func (*GetSystemInfoRequest) Descriptor deprecated 

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

Deprecated: Use GetSystemInfoRequest.ProtoReflect.Descriptor instead.

func (*GetSystemInfoRequest) ProtoMessage 

func (*GetSystemInfoRequest) ProtoMessage()

func (*GetSystemInfoRequest) ProtoReflect 

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

func (*GetSystemInfoRequest) Reset 

func (x *GetSystemInfoRequest) Reset()

func (*GetSystemInfoRequest) String 

func (x *GetSystemInfoRequest) String() string

type GetSystemInfoResponse 

type GetSystemInfoResponse struct {
	BuildTime       string `protobuf:"bytes,1,opt,name=build_time,json=buildTime,proto3" json:"build_time,omitempty"`
	Commit          string `protobuf:"bytes,2,opt,name=commit,proto3" json:"commit,omitempty"`
	DevmodeEnabled  bool   `protobuf:"varint,3,opt,name=devmode_enabled,json=devmodeEnabled,proto3" json:"devmode_enabled,omitempty"`
	FrontendEnabled bool   `protobuf:"varint,4,opt,name=frontend_enabled,json=frontendEnabled,proto3" json:"frontend_enabled,omitempty"`
	Version         string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	AcceptNewEvents bool   `protobuf:"varint,6,opt,name=accept_new_events,json=acceptNewEvents,proto3" json:"accept_new_events,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSystemInfoResponse) Descriptor deprecated 

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

Deprecated: Use GetSystemInfoResponse.ProtoReflect.Descriptor instead.

func (*GetSystemInfoResponse) GetAcceptNewEvents 

func (x *GetSystemInfoResponse) GetAcceptNewEvents() bool

func (*GetSystemInfoResponse) GetBuildTime 

func (x *GetSystemInfoResponse) GetBuildTime() string

func (*GetSystemInfoResponse) GetCommit 

func (x *GetSystemInfoResponse) GetCommit() string

func (*GetSystemInfoResponse) GetDevmodeEnabled 

func (x *GetSystemInfoResponse) GetDevmodeEnabled() bool

func (*GetSystemInfoResponse) GetFrontendEnabled 

func (x *GetSystemInfoResponse) GetFrontendEnabled() bool

func (*GetSystemInfoResponse) GetVersion 

func (x *GetSystemInfoResponse) GetVersion() string

func (*GetSystemInfoResponse) ProtoMessage 

func (*GetSystemInfoResponse) ProtoMessage()

func (*GetSystemInfoResponse) ProtoReflect 

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

func (*GetSystemInfoResponse) Reset 

func (x *GetSystemInfoResponse) Reset()

func (*GetSystemInfoResponse) String 

func (x *GetSystemInfoResponse) String() string

type GetTaskRunLogsRequest 

type GetTaskRunLogsRequest struct {
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` // Unique namespace identifier
	PipelineId  string `protobuf:"bytes,2,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	RunId       int64  `protobuf:"varint,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	Id          string `protobuf:"bytes,4,opt,name=id,proto3" json:"id,omitempty"` // Task Run ID
	// contains filtered or unexported fields
}

func (*GetTaskRunLogsRequest) Descriptor deprecated 

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

Deprecated: Use GetTaskRunLogsRequest.ProtoReflect.Descriptor instead.

func (*GetTaskRunLogsRequest) GetId 

func (x *GetTaskRunLogsRequest) GetId() string

func (*GetTaskRunLogsRequest) GetNamespaceId 

func (x *GetTaskRunLogsRequest) GetNamespaceId() string

func (*GetTaskRunLogsRequest) GetPipelineId 

func (x *GetTaskRunLogsRequest) GetPipelineId() string

func (*GetTaskRunLogsRequest) GetRunId 

func (x *GetTaskRunLogsRequest) GetRunId() int64

func (*GetTaskRunLogsRequest) ProtoMessage 

func (*GetTaskRunLogsRequest) ProtoMessage()

func (*GetTaskRunLogsRequest) ProtoReflect 

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

func (*GetTaskRunLogsRequest) Reset 

func (x *GetTaskRunLogsRequest) Reset()

func (*GetTaskRunLogsRequest) String 

func (x *GetTaskRunLogsRequest) String() string

type GetTaskRunLogsResponse 

type GetTaskRunLogsResponse struct {
	LogLine string `protobuf:"bytes,1,opt,name=log_line,json=logLine,proto3" json:"log_line,omitempty"`  // The string content of the current log line.
	LineNum int64  `protobuf:"varint,2,opt,name=line_num,json=lineNum,proto3" json:"line_num,omitempty"` // The current line number.
	// contains filtered or unexported fields
}

func (*GetTaskRunLogsResponse) Descriptor deprecated 

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

Deprecated: Use GetTaskRunLogsResponse.ProtoReflect.Descriptor instead.

func (*GetTaskRunLogsResponse) GetLineNum 

func (x *GetTaskRunLogsResponse) GetLineNum() int64

func (*GetTaskRunLogsResponse) GetLogLine 

func (x *GetTaskRunLogsResponse) GetLogLine() string

func (*GetTaskRunLogsResponse) ProtoMessage 

func (*GetTaskRunLogsResponse) ProtoMessage()

func (*GetTaskRunLogsResponse) ProtoReflect 

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

func (*GetTaskRunLogsResponse) Reset 

func (x *GetTaskRunLogsResponse) Reset()

func (*GetTaskRunLogsResponse) String 

func (x *GetTaskRunLogsResponse) String() string

type GetTaskRunRequest 

type GetTaskRunRequest struct {
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` // Unique namespace identifier
	PipelineId  string `protobuf:"bytes,2,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	RunId       int64  `protobuf:"varint,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	Id          string `protobuf:"bytes,4,opt,name=id,proto3" json:"id,omitempty"` // Task Run ID
	// contains filtered or unexported fields
}

func (*GetTaskRunRequest) Descriptor deprecated 

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

Deprecated: Use GetTaskRunRequest.ProtoReflect.Descriptor instead.

func (*GetTaskRunRequest) GetId 

func (x *GetTaskRunRequest) GetId() string

func (*GetTaskRunRequest) GetNamespaceId 

func (x *GetTaskRunRequest) GetNamespaceId() string

func (*GetTaskRunRequest) GetPipelineId 

func (x *GetTaskRunRequest) GetPipelineId() string

func (*GetTaskRunRequest) GetRunId 

func (x *GetTaskRunRequest) GetRunId() int64

func (*GetTaskRunRequest) ProtoMessage 

func (*GetTaskRunRequest) ProtoMessage()

func (*GetTaskRunRequest) ProtoReflect 

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

func (*GetTaskRunRequest) Reset 

func (x *GetTaskRunRequest) Reset()

func (*GetTaskRunRequest) String 

func (x *GetTaskRunRequest) String() string

type GetTaskRunResponse 

type GetTaskRunResponse struct {
	TaskRun *TaskRun `protobuf:"bytes,1,opt,name=task_run,json=taskRun,proto3" json:"task_run,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTaskRunResponse) Descriptor deprecated 

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

Deprecated: Use GetTaskRunResponse.ProtoReflect.Descriptor instead.

func (*GetTaskRunResponse) GetTaskRun 

func (x *GetTaskRunResponse) GetTaskRun() *TaskRun

func (*GetTaskRunResponse) ProtoMessage 

func (*GetTaskRunResponse) ProtoMessage()

func (*GetTaskRunResponse) ProtoReflect 

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

func (*GetTaskRunResponse) Reset 

func (x *GetTaskRunResponse) Reset()

func (*GetTaskRunResponse) String 

func (x *GetTaskRunResponse) String() string

type GetTokenRequest 

type GetTokenRequest struct {
	Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTokenRequest) Descriptor deprecated 

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

Deprecated: Use GetTokenRequest.ProtoReflect.Descriptor instead.

func (*GetTokenRequest) GetToken 

func (x *GetTokenRequest) GetToken() string

func (*GetTokenRequest) ProtoMessage 

func (*GetTokenRequest) ProtoMessage()

func (*GetTokenRequest) ProtoReflect 

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

func (*GetTokenRequest) Reset 

func (x *GetTokenRequest) Reset()

func (*GetTokenRequest) String 

func (x *GetTokenRequest) String() string

type GetTokenResponse 

type GetTokenResponse struct {
	Details *Token `protobuf:"bytes,1,opt,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTokenResponse) Descriptor deprecated 

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

Deprecated: Use GetTokenResponse.ProtoReflect.Descriptor instead.

func (*GetTokenResponse) GetDetails 

func (x *GetTokenResponse) GetDetails() *Token

func (*GetTokenResponse) ProtoMessage 

func (*GetTokenResponse) ProtoMessage()

func (*GetTokenResponse) ProtoReflect 

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

func (*GetTokenResponse) Reset 

func (x *GetTokenResponse) Reset()

func (*GetTokenResponse) String 

func (x *GetTokenResponse) String() string

type GetTriggerEventRequest 

type GetTriggerEventRequest struct {
	NamespaceId          string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` // Unique namespace identifier
	PipelineId           string `protobuf:"bytes,2,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	PipelineTriggerLabel string `protobuf:"bytes,3,opt,name=pipeline_trigger_label,json=pipelineTriggerLabel,proto3" json:"pipeline_trigger_label,omitempty"`
	Id                   int64  `protobuf:"varint,4,opt,name=id,proto3" json:"id,omitempty"` // Trigger Event ID
	// contains filtered or unexported fields
}

func (*GetTriggerEventRequest) Descriptor deprecated 

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

Deprecated: Use GetTriggerEventRequest.ProtoReflect.Descriptor instead.

func (*GetTriggerEventRequest) GetId 

func (x *GetTriggerEventRequest) GetId() int64

func (*GetTriggerEventRequest) GetNamespaceId 

func (x *GetTriggerEventRequest) GetNamespaceId() string

func (*GetTriggerEventRequest) GetPipelineId 

func (x *GetTriggerEventRequest) GetPipelineId() string

func (*GetTriggerEventRequest) GetPipelineTriggerLabel 

func (x *GetTriggerEventRequest) GetPipelineTriggerLabel() string

func (*GetTriggerEventRequest) ProtoMessage 

func (*GetTriggerEventRequest) ProtoMessage()

func (*GetTriggerEventRequest) ProtoReflect 

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

func (*GetTriggerEventRequest) Reset 

func (x *GetTriggerEventRequest) Reset()

func (*GetTriggerEventRequest) String 

func (x *GetTriggerEventRequest) String() string

type GetTriggerEventResponse 

type GetTriggerEventResponse struct {
	Event *TriggerEvent `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTriggerEventResponse) Descriptor deprecated 

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

Deprecated: Use GetTriggerEventResponse.ProtoReflect.Descriptor instead.

func (*GetTriggerEventResponse) GetEvent 

func (x *GetTriggerEventResponse) GetEvent() *TriggerEvent

func (*GetTriggerEventResponse) ProtoMessage 

func (*GetTriggerEventResponse) ProtoMessage()

func (*GetTriggerEventResponse) ProtoReflect 

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

func (*GetTriggerEventResponse) Reset 

func (x *GetTriggerEventResponse) Reset()

func (*GetTriggerEventResponse) String 

func (x *GetTriggerEventResponse) String() string

type GetTriggerRequest 

type GetTriggerRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // The unique name for a particular trigger
	// contains filtered or unexported fields
}

func (*GetTriggerRequest) Descriptor deprecated 

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

Deprecated: Use GetTriggerRequest.ProtoReflect.Descriptor instead.

func (*GetTriggerRequest) GetName 

func (x *GetTriggerRequest) GetName() string

func (*GetTriggerRequest) ProtoMessage 

func (*GetTriggerRequest) ProtoMessage()

func (*GetTriggerRequest) ProtoReflect 

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

func (*GetTriggerRequest) Reset 

func (x *GetTriggerRequest) Reset()

func (*GetTriggerRequest) String 

func (x *GetTriggerRequest) String() string

type GetTriggerResponse 

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

func (*GetTriggerResponse) Descriptor deprecated 

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

Deprecated: Use GetTriggerResponse.ProtoReflect.Descriptor instead.

func (*GetTriggerResponse) GetTrigger 

func (x *GetTriggerResponse) GetTrigger() *Trigger

func (*GetTriggerResponse) ProtoMessage 

func (*GetTriggerResponse) ProtoMessage()

func (*GetTriggerResponse) ProtoReflect 

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

func (*GetTriggerResponse) Reset 

func (x *GetTriggerResponse) Reset()

func (*GetTriggerResponse) String 

func (x *GetTriggerResponse) String() string

type GoferClient 

type GoferClient interface {
	// ListNamespaces returns all registered namespaces.
	ListNamespaces(ctx context.Context, in *ListNamespacesRequest, opts ...grpc.CallOption) (*ListNamespacesResponse, error)
	// CreateNamespace creates a new namespace that separates pipelines.
	CreateNamespace(ctx context.Context, in *CreateNamespaceRequest, opts ...grpc.CallOption) (*CreateNamespaceResponse, error)
	// GetNamespace returns a single namespace by id.
	GetNamespace(ctx context.Context, in *GetNamespaceRequest, opts ...grpc.CallOption) (*GetNamespaceResponse, error)
	// UpdateNamespace updates the details of a particular namespace by id.
	UpdateNamespace(ctx context.Context, in *UpdateNamespaceRequest, opts ...grpc.CallOption) (*UpdateNamespaceResponse, error)
	// DeleteNamespace removes a namespace by id.
	DeleteNamespace(ctx context.Context, in *DeleteNamespaceRequest, opts ...grpc.CallOption) (*DeleteNamespaceResponse, error)
	// GetPipeline returns a single pipeline by ID.
	GetPipeline(ctx context.Context, in *GetPipelineRequest, opts ...grpc.CallOption) (*GetPipelineResponse, error)
	// ListPipelines returns all registered pipelines. Can control pagination by
	// offset && limit request parameters.
	// By default ListPipelines will return the first 100 pipelines ordered by
	// creation.
	ListPipelines(ctx context.Context, in *ListPipelinesRequest, opts ...grpc.CallOption) (*ListPipelinesResponse, error)
	// EnablePipeline allows a pipeline to execute runs by allowing it to receive
	// trigger events. See DisablePipeline to prevent a pipeline from executing
	// any more runs.
	EnablePipeline(ctx context.Context, in *EnablePipelineRequest, opts ...grpc.CallOption) (*EnablePipelineResponse, error)
	// DisablePipeline prevents the pipeline from executing runs. Any trigger
	// events that would normally cause the pipeline to be run are instead
	// discarded.
	DisablePipeline(ctx context.Context, in *DisablePipelineRequest, opts ...grpc.CallOption) (*DisablePipelineResponse, error)
	// CreatePipelineRaw creates a new pipeline from a raw byte string
	// representation of a pipeline config file. This is useful if you're
	// attempting to create the pipeline from a source that is not held in source
	// control or maybe not publicly available.
	CreatePipelineRaw(ctx context.Context, in *CreatePipelineRawRequest, opts ...grpc.CallOption) (*CreatePipelineRawResponse, error)
	// CreatePipelineByURL creates a new pipeline from a pipeline config stored
	// remotely. Many forms of a remote URL can be used here. You can view a full
	// list of accepted protocols and extra options here:
	// https://github.com/hashicorp/go-getter#general-all-protocols
	CreatePipelineByURL(ctx context.Context, in *CreatePipelineByURLRequest, opts ...grpc.CallOption) (*CreatePipelineByURLResponse, error)
	// UpdatePipelineRaw updates a pipeline by raw byte string representation of a
	// pipeline config file. Updating a pipeline requires the pipeline to adhere
	// to two states:
	//    1) The pipeline must not have any current runs in progress.
	//    2) The pipeline must be in a disabled state.
	UpdatePipelineRaw(ctx context.Context, in *UpdatePipelineRawRequest, opts ...grpc.CallOption) (*UpdatePipelineRawResponse, error)
	// UpdatePipelineByURL updates a pipeline from a pipeline config stored
	// remotely. Many forms of a remote URL can be used. You can view a full list
	// of accepted protocols and extra options here:
	// https://github.com/hashicorp/go-getter#general-all-protocols
	//
	// In order to update the pipeline, it must adhere to two states:
	//    1) The pipeline must not have any current runs in progress.
	//    2) The pipeline must be in a disabled state.
	UpdatePipelineByURL(ctx context.Context, in *UpdatePipelineByURLRequest, opts ...grpc.CallOption) (*UpdatePipelineByURLResponse, error)
	// AbandonPipeline disables a pipeline permanently. This removes all triggers
	// and prevents the pipeline from ever being triggered again.
	AbandonPipeline(ctx context.Context, in *AbandonPipelineRequest, opts ...grpc.CallOption) (*AbandonPipelineResponse, error)
	// GetTrigger returns details about a specific trigger.
	GetTrigger(ctx context.Context, in *GetTriggerRequest, opts ...grpc.CallOption) (*GetTriggerResponse, error)
	// ListTriggers lists all triggers currently registered within gofer.
	ListTriggers(ctx context.Context, in *ListTriggersRequest, opts ...grpc.CallOption) (*ListTriggersResponse, error)
	// GetTriggerEvent returns a specific trigger event for a pipeline by ID. This
	// is useful to check out the details of a specific triggered run instance.
	GetTriggerEvent(ctx context.Context, in *GetTriggerEventRequest, opts ...grpc.CallOption) (*GetTriggerEventResponse, error)
	// BatchGetTriggerEvents returns multiple trigger events by ID.
	BatchGetTriggerEvents(ctx context.Context, in *BatchGetTriggerEventsRequest, opts ...grpc.CallOption) (*BatchGetTriggerEventsResponse, error)
	// ListTriggerEvents returns a list of all trigger events by pipeline ID.
	// Pagination can be controlled via the offset and limit parameters of the
	// request.
	ListTriggerEvents(ctx context.Context, in *ListTriggerEventsRequest, opts ...grpc.CallOption) (*ListTriggerEventsResponse, error)
	// GetRun returns the details of a single run.
	GetRun(ctx context.Context, in *GetRunRequest, opts ...grpc.CallOption) (*GetRunResponse, error)
	// BatchGetRuns returns multiple runs by ID.
	BatchGetRuns(ctx context.Context, in *BatchGetRunsRequest, opts ...grpc.CallOption) (*BatchGetRunsResponse, error)
	// ListRuns returns a list of all runs by Pipeline ID. Pagination can be
	// controlled via the offset and limit parameters of the request.
	ListRuns(ctx context.Context, in *ListRunsRequest, opts ...grpc.CallOption) (*ListRunsResponse, error)
	// StartRun starts a new run for the given pipeline. Pipelines that are
	// started via API are marked as such. This RPC has the ability to choose to
	// only run a subset of a pipeline via the "only" flag. Which is not possible
	// via a trigger.
	StartRun(ctx context.Context, in *StartRunRequest, opts ...grpc.CallOption) (*StartRunResponse, error)
	// RetryRun simply takes the vars and settings from a previous run and re-uses
	// those to launch a new run. Useful for if you want the exact settings from a
	// previous run.
	RetryRun(ctx context.Context, in *RetryRunRequest, opts ...grpc.CallOption) (*RetryRunResponse, error)
	// CancelRun stops the execution of a run in progress. Any task runs that
	// might have been running at the time Are ask to stop gracefully(SIGINT)
	// unless the force parameter is used, in which case the task runs are stopped
	// instantly(SIGKILL) and the run is cancelled.
	CancelRun(ctx context.Context, in *CancelRunRequest, opts ...grpc.CallOption) (*CancelRunResponse, error)
	// CancelAllRuns stops the execution of any in-progress runs for a specific
	// pipeline by ID.
	CancelAllRuns(ctx context.Context, in *CancelAllRunsRequest, opts ...grpc.CallOption) (*CancelAllRunsResponse, error)
	// GetTaskRun returns the details of a single task run.
	GetTaskRun(ctx context.Context, in *GetTaskRunRequest, opts ...grpc.CallOption) (*GetTaskRunResponse, error)
	// ListTaskRuns returns all task runs for a current run by ID.
	ListTaskRuns(ctx context.Context, in *ListTaskRunsRequest, opts ...grpc.CallOption) (*ListTaskRunsResponse, error)
	// CancelTaskRun cancels a specific task run, sending the related container a
	// SIGINT signal. If the force flag is used we instead send the container a
	// SIGKILL signal.
	//
	// Task runs that are cancelled can cause other downstream task runs to be
	// skipped depending on those downstream task run dependencies.
	CancelTaskRun(ctx context.Context, in *CancelTaskRunRequest, opts ...grpc.CallOption) (*CancelTaskRunResponse, error)
	// GetTaskRunLogs returns logs for a specific task run line by line in a
	// stream. The logs are returns with both STDOUT and STDERR of the associated
	// container combined.
	GetTaskRunLogs(ctx context.Context, in *GetTaskRunLogsRequest, opts ...grpc.CallOption) (Gofer_GetTaskRunLogsClient, error)
	// DeleteTaskRunLogs removes a task run's associated log object. This is
	// useful for if logs mistakenly contain sensitive data.
	DeleteTaskRunLogs(ctx context.Context, in *DeleteTaskRunLogsRequest, opts ...grpc.CallOption) (*DeleteTaskRunLogsResponse, error)
	// GetPipelineObject returns a single pipeline object by pipeline ID and key.
	GetPipelineObject(ctx context.Context, in *GetPipelineObjectRequest, opts ...grpc.CallOption) (*GetPipelineObjectResponse, error)
	// PutPipelineObject uploads a single pipeline object by pipeline ID and key.
	// Objects which are put under the same key do not count towards the pipeline
	// object limit.
	PutPipelineObject(ctx context.Context, in *PutPipelineObjectRequest, opts ...grpc.CallOption) (*PutPipelineObjectResponse, error)
	// DeletePipelineObject removes a single pipeline object by pipeline ID and
	// key. Removing a pipeline object decrements the total count of the pipeline
	// object limit.
	DeletePipelineObject(ctx context.Context, in *DeletePipelineObjectRequest, opts ...grpc.CallOption) (*DeletePipelineObjectResponse, error)
	// GetRunObject returns the content of a single run object.
	GetRunObject(ctx context.Context, in *GetRunObjectRequest, opts ...grpc.CallOption) (*GetRunObjectResponse, error)
	// PutRunObject uploads the context of an object by run ID and key.
	PutRunObject(ctx context.Context, in *PutRunObjectRequest, opts ...grpc.CallOption) (*PutRunObjectResponse, error)
	// DeleteRunObject removes a specific run object by run ID and key.
	DeleteRunObject(ctx context.Context, in *DeleteRunObjectRequest, opts ...grpc.CallOption) (*DeleteRunObjectResponse, error)
	// GetSystemInfo returns system information and general health.
	GetSystemInfo(ctx context.Context, in *GetSystemInfoRequest, opts ...grpc.CallOption) (*GetSystemInfoResponse, error)
	// RepairOrphan is used when a single run has gotten into a state that does
	// not reflect what actually happened to the run. This can happen if the Gofer
	// service crashes for unforeseen reasons. Usually this route is not needed as
	// Gofer will make an attempt to resolve all orphaned runs upon startup. But
	// in the rare case that a run gets into a bad state during the service's
	// normal execution this route can be used to attempt to repair the orphaned
	// run or at the very least mark it as failed so it isn't stuck in a
	// unfinished state.
	RepairOrphan(ctx context.Context, in *RepairOrphanRequest, opts ...grpc.CallOption) (*RepairOrphanResponse, error)
	// ToggleEventIngress allows the admin to start or stop the execution of all
	// pipelines within Gofer. This can be useful under some security implications
	// or for the purposes of defining general downtime and service maintenance.
	ToggleEventIngress(ctx context.Context, in *ToggleEventIngressRequest, opts ...grpc.CallOption) (*ToggleEventIngressResponse, error)
	// CreateToken manifests a new API token; This token can be a management
	// token(the equivalent of root in Linux) or a client token. Management tokens
	// are the only tokens that can generate tokens.
	// Client tokens are used to manage which namespaces users have access to.
	CreateToken(ctx context.Context, in *CreateTokenRequest, opts ...grpc.CallOption) (*CreateTokenResponse, error)
	// BootstrapToken creates the initial management token used to create all
	// other tokens.
	BootstrapToken(ctx context.Context, in *BootstrapTokenRequest, opts ...grpc.CallOption) (*BootstrapTokenResponse, error)
	// GetToken returns information about a particular token;
	GetToken(ctx context.Context, in *GetTokenRequest, opts ...grpc.CallOption) (*GetTokenResponse, error)
	// DeleteToken removes a token.
	DeleteToken(ctx context.Context, in *DeleteTokenRequest, opts ...grpc.CallOption) (*DeleteTokenResponse, error)
	AddRegistryAuth(ctx context.Context, in *AddRegistryAuthRequest, opts ...grpc.CallOption) (*AddRegistryAuthResponse, error)
	RemoveRegistryAuth(ctx context.Context, in *RemoveRegistryAuthRequest, opts ...grpc.CallOption) (*RemoveRegistryAuthResponse, error)
	ListRegistryAuths(ctx context.Context, in *ListRegistryAuthsRequest, opts ...grpc.CallOption) (*ListRegistryAuthsResponse, error)
}

GoferClient is the client API for Gofer service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewGoferClient 

func NewGoferClient(cc grpc.ClientConnInterface) GoferClient

type GoferServer 

type GoferServer interface {
	// ListNamespaces returns all registered namespaces.
	ListNamespaces(context.Context, *ListNamespacesRequest) (*ListNamespacesResponse, error)
	// CreateNamespace creates a new namespace that separates pipelines.
	CreateNamespace(context.Context, *CreateNamespaceRequest) (*CreateNamespaceResponse, error)
	// GetNamespace returns a single namespace by id.
	GetNamespace(context.Context, *GetNamespaceRequest) (*GetNamespaceResponse, error)
	// UpdateNamespace updates the details of a particular namespace by id.
	UpdateNamespace(context.Context, *UpdateNamespaceRequest) (*UpdateNamespaceResponse, error)
	// DeleteNamespace removes a namespace by id.
	DeleteNamespace(context.Context, *DeleteNamespaceRequest) (*DeleteNamespaceResponse, error)
	// GetPipeline returns a single pipeline by ID.
	GetPipeline(context.Context, *GetPipelineRequest) (*GetPipelineResponse, error)
	// ListPipelines returns all registered pipelines. Can control pagination by
	// offset && limit request parameters.
	// By default ListPipelines will return the first 100 pipelines ordered by
	// creation.
	ListPipelines(context.Context, *ListPipelinesRequest) (*ListPipelinesResponse, error)
	// EnablePipeline allows a pipeline to execute runs by allowing it to receive
	// trigger events. See DisablePipeline to prevent a pipeline from executing
	// any more runs.
	EnablePipeline(context.Context, *EnablePipelineRequest) (*EnablePipelineResponse, error)
	// DisablePipeline prevents the pipeline from executing runs. Any trigger
	// events that would normally cause the pipeline to be run are instead
	// discarded.
	DisablePipeline(context.Context, *DisablePipelineRequest) (*DisablePipelineResponse, error)
	// CreatePipelineRaw creates a new pipeline from a raw byte string
	// representation of a pipeline config file. This is useful if you're
	// attempting to create the pipeline from a source that is not held in source
	// control or maybe not publicly available.
	CreatePipelineRaw(context.Context, *CreatePipelineRawRequest) (*CreatePipelineRawResponse, error)
	// CreatePipelineByURL creates a new pipeline from a pipeline config stored
	// remotely. Many forms of a remote URL can be used here. You can view a full
	// list of accepted protocols and extra options here:
	// https://github.com/hashicorp/go-getter#general-all-protocols
	CreatePipelineByURL(context.Context, *CreatePipelineByURLRequest) (*CreatePipelineByURLResponse, error)
	// UpdatePipelineRaw updates a pipeline by raw byte string representation of a
	// pipeline config file. Updating a pipeline requires the pipeline to adhere
	// to two states:
	//    1) The pipeline must not have any current runs in progress.
	//    2) The pipeline must be in a disabled state.
	UpdatePipelineRaw(context.Context, *UpdatePipelineRawRequest) (*UpdatePipelineRawResponse, error)
	// UpdatePipelineByURL updates a pipeline from a pipeline config stored
	// remotely. Many forms of a remote URL can be used. You can view a full list
	// of accepted protocols and extra options here:
	// https://github.com/hashicorp/go-getter#general-all-protocols
	//
	// In order to update the pipeline, it must adhere to two states:
	//    1) The pipeline must not have any current runs in progress.
	//    2) The pipeline must be in a disabled state.
	UpdatePipelineByURL(context.Context, *UpdatePipelineByURLRequest) (*UpdatePipelineByURLResponse, error)
	// AbandonPipeline disables a pipeline permanently. This removes all triggers
	// and prevents the pipeline from ever being triggered again.
	AbandonPipeline(context.Context, *AbandonPipelineRequest) (*AbandonPipelineResponse, error)
	// GetTrigger returns details about a specific trigger.
	GetTrigger(context.Context, *GetTriggerRequest) (*GetTriggerResponse, error)
	// ListTriggers lists all triggers currently registered within gofer.
	ListTriggers(context.Context, *ListTriggersRequest) (*ListTriggersResponse, error)
	// GetTriggerEvent returns a specific trigger event for a pipeline by ID. This
	// is useful to check out the details of a specific triggered run instance.
	GetTriggerEvent(context.Context, *GetTriggerEventRequest) (*GetTriggerEventResponse, error)
	// BatchGetTriggerEvents returns multiple trigger events by ID.
	BatchGetTriggerEvents(context.Context, *BatchGetTriggerEventsRequest) (*BatchGetTriggerEventsResponse, error)
	// ListTriggerEvents returns a list of all trigger events by pipeline ID.
	// Pagination can be controlled via the offset and limit parameters of the
	// request.
	ListTriggerEvents(context.Context, *ListTriggerEventsRequest) (*ListTriggerEventsResponse, error)
	// GetRun returns the details of a single run.
	GetRun(context.Context, *GetRunRequest) (*GetRunResponse, error)
	// BatchGetRuns returns multiple runs by ID.
	BatchGetRuns(context.Context, *BatchGetRunsRequest) (*BatchGetRunsResponse, error)
	// ListRuns returns a list of all runs by Pipeline ID. Pagination can be
	// controlled via the offset and limit parameters of the request.
	ListRuns(context.Context, *ListRunsRequest) (*ListRunsResponse, error)
	// StartRun starts a new run for the given pipeline. Pipelines that are
	// started via API are marked as such. This RPC has the ability to choose to
	// only run a subset of a pipeline via the "only" flag. Which is not possible
	// via a trigger.
	StartRun(context.Context, *StartRunRequest) (*StartRunResponse, error)
	// RetryRun simply takes the vars and settings from a previous run and re-uses
	// those to launch a new run. Useful for if you want the exact settings from a
	// previous run.
	RetryRun(context.Context, *RetryRunRequest) (*RetryRunResponse, error)
	// CancelRun stops the execution of a run in progress. Any task runs that
	// might have been running at the time Are ask to stop gracefully(SIGINT)
	// unless the force parameter is used, in which case the task runs are stopped
	// instantly(SIGKILL) and the run is cancelled.
	CancelRun(context.Context, *CancelRunRequest) (*CancelRunResponse, error)
	// CancelAllRuns stops the execution of any in-progress runs for a specific
	// pipeline by ID.
	CancelAllRuns(context.Context, *CancelAllRunsRequest) (*CancelAllRunsResponse, error)
	// GetTaskRun returns the details of a single task run.
	GetTaskRun(context.Context, *GetTaskRunRequest) (*GetTaskRunResponse, error)
	// ListTaskRuns returns all task runs for a current run by ID.
	ListTaskRuns(context.Context, *ListTaskRunsRequest) (*ListTaskRunsResponse, error)
	// CancelTaskRun cancels a specific task run, sending the related container a
	// SIGINT signal. If the force flag is used we instead send the container a
	// SIGKILL signal.
	//
	// Task runs that are cancelled can cause other downstream task runs to be
	// skipped depending on those downstream task run dependencies.
	CancelTaskRun(context.Context, *CancelTaskRunRequest) (*CancelTaskRunResponse, error)
	// GetTaskRunLogs returns logs for a specific task run line by line in a
	// stream. The logs are returns with both STDOUT and STDERR of the associated
	// container combined.
	GetTaskRunLogs(*GetTaskRunLogsRequest, Gofer_GetTaskRunLogsServer) error
	// DeleteTaskRunLogs removes a task run's associated log object. This is
	// useful for if logs mistakenly contain sensitive data.
	DeleteTaskRunLogs(context.Context, *DeleteTaskRunLogsRequest) (*DeleteTaskRunLogsResponse, error)
	// GetPipelineObject returns a single pipeline object by pipeline ID and key.
	GetPipelineObject(context.Context, *GetPipelineObjectRequest) (*GetPipelineObjectResponse, error)
	// PutPipelineObject uploads a single pipeline object by pipeline ID and key.
	// Objects which are put under the same key do not count towards the pipeline
	// object limit.
	PutPipelineObject(context.Context, *PutPipelineObjectRequest) (*PutPipelineObjectResponse, error)
	// DeletePipelineObject removes a single pipeline object by pipeline ID and
	// key. Removing a pipeline object decrements the total count of the pipeline
	// object limit.
	DeletePipelineObject(context.Context, *DeletePipelineObjectRequest) (*DeletePipelineObjectResponse, error)
	// GetRunObject returns the content of a single run object.
	GetRunObject(context.Context, *GetRunObjectRequest) (*GetRunObjectResponse, error)
	// PutRunObject uploads the context of an object by run ID and key.
	PutRunObject(context.Context, *PutRunObjectRequest) (*PutRunObjectResponse, error)
	// DeleteRunObject removes a specific run object by run ID and key.
	DeleteRunObject(context.Context, *DeleteRunObjectRequest) (*DeleteRunObjectResponse, error)
	// GetSystemInfo returns system information and general health.
	GetSystemInfo(context.Context, *GetSystemInfoRequest) (*GetSystemInfoResponse, error)
	// RepairOrphan is used when a single run has gotten into a state that does
	// not reflect what actually happened to the run. This can happen if the Gofer
	// service crashes for unforeseen reasons. Usually this route is not needed as
	// Gofer will make an attempt to resolve all orphaned runs upon startup. But
	// in the rare case that a run gets into a bad state during the service's
	// normal execution this route can be used to attempt to repair the orphaned
	// run or at the very least mark it as failed so it isn't stuck in a
	// unfinished state.
	RepairOrphan(context.Context, *RepairOrphanRequest) (*RepairOrphanResponse, error)
	// ToggleEventIngress allows the admin to start or stop the execution of all
	// pipelines within Gofer. This can be useful under some security implications
	// or for the purposes of defining general downtime and service maintenance.
	ToggleEventIngress(context.Context, *ToggleEventIngressRequest) (*ToggleEventIngressResponse, error)
	// CreateToken manifests a new API token; This token can be a management
	// token(the equivalent of root in Linux) or a client token. Management tokens
	// are the only tokens that can generate tokens.
	// Client tokens are used to manage which namespaces users have access to.
	CreateToken(context.Context, *CreateTokenRequest) (*CreateTokenResponse, error)
	// BootstrapToken creates the initial management token used to create all
	// other tokens.
	BootstrapToken(context.Context, *BootstrapTokenRequest) (*BootstrapTokenResponse, error)
	// GetToken returns information about a particular token;
	GetToken(context.Context, *GetTokenRequest) (*GetTokenResponse, error)
	// DeleteToken removes a token.
	DeleteToken(context.Context, *DeleteTokenRequest) (*DeleteTokenResponse, error)
	AddRegistryAuth(context.Context, *AddRegistryAuthRequest) (*AddRegistryAuthResponse, error)
	RemoveRegistryAuth(context.Context, *RemoveRegistryAuthRequest) (*RemoveRegistryAuthResponse, error)
	ListRegistryAuths(context.Context, *ListRegistryAuthsRequest) (*ListRegistryAuthsResponse, error)
	// contains filtered or unexported methods
}

GoferServer is the server API for Gofer service. All implementations must embed UnimplementedGoferServer for forward compatibility

type Gofer_GetTaskRunLogsClient 

type Gofer_GetTaskRunLogsClient interface {
	Recv() (*GetTaskRunLogsResponse, error)
	grpc.ClientStream
}

type Gofer_GetTaskRunLogsServer 

type Gofer_GetTaskRunLogsServer interface {
	Send(*GetTaskRunLogsResponse) error
	grpc.ServerStream
}

type ListNamespacesRequest 

type ListNamespacesRequest struct {

	// offset is a pagination parameter that defines where to start when counting
	// the list of objects to return.
	Offset int64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	// limit is a pagination parameter that defines how many objects to return
	// per result.
	Limit int64 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*ListNamespacesRequest) Descriptor deprecated 

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

Deprecated: Use ListNamespacesRequest.ProtoReflect.Descriptor instead.

func (*ListNamespacesRequest) GetLimit 

func (x *ListNamespacesRequest) GetLimit() int64

func (*ListNamespacesRequest) GetOffset 

func (x *ListNamespacesRequest) GetOffset() int64

func (*ListNamespacesRequest) ProtoMessage 

func (*ListNamespacesRequest) ProtoMessage()

func (*ListNamespacesRequest) ProtoReflect 

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

func (*ListNamespacesRequest) Reset 

func (x *ListNamespacesRequest) Reset()

func (*ListNamespacesRequest) String 

func (x *ListNamespacesRequest) String() string

type ListNamespacesResponse 

type ListNamespacesResponse struct {
	Namespaces []*Namespace `protobuf:"bytes,1,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	// offset is a pagination parameter that defines where to start when counting
	// the list of objects to return.
	Offset int64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*ListNamespacesResponse) Descriptor deprecated 

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

Deprecated: Use ListNamespacesResponse.ProtoReflect.Descriptor instead.

func (*ListNamespacesResponse) GetNamespaces 

func (x *ListNamespacesResponse) GetNamespaces() []*Namespace

func (*ListNamespacesResponse) GetOffset 

func (x *ListNamespacesResponse) GetOffset() int64

func (*ListNamespacesResponse) ProtoMessage 

func (*ListNamespacesResponse) ProtoMessage()

func (*ListNamespacesResponse) ProtoReflect 

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

func (*ListNamespacesResponse) Reset 

func (x *ListNamespacesResponse) Reset()

func (*ListNamespacesResponse) String 

func (x *ListNamespacesResponse) String() string

type ListPipelineObjectRequest 

type ListPipelineObjectRequest struct {
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` // Unique namespace identifier
	PipelineId  string `protobuf:"bytes,2,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ListPipelineObjectRequest) Descriptor deprecated 

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

Deprecated: Use ListPipelineObjectRequest.ProtoReflect.Descriptor instead.

func (*ListPipelineObjectRequest) GetNamespaceId 

func (x *ListPipelineObjectRequest) GetNamespaceId() string

func (*ListPipelineObjectRequest) GetPipelineId 

func (x *ListPipelineObjectRequest) GetPipelineId() string

func (*ListPipelineObjectRequest) ProtoMessage 

func (*ListPipelineObjectRequest) ProtoMessage()

func (*ListPipelineObjectRequest) ProtoReflect 

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

func (*ListPipelineObjectRequest) Reset 

func (x *ListPipelineObjectRequest) Reset()

func (*ListPipelineObjectRequest) String 

func (x *ListPipelineObjectRequest) String() string

type ListPipelineObjectResponse 

type ListPipelineObjectResponse struct {
	Keys []string `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*ListPipelineObjectResponse) Descriptor deprecated 

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

Deprecated: Use ListPipelineObjectResponse.ProtoReflect.Descriptor instead.

func (*ListPipelineObjectResponse) GetKeys 

func (x *ListPipelineObjectResponse) GetKeys() []string

func (*ListPipelineObjectResponse) ProtoMessage 

func (*ListPipelineObjectResponse) ProtoMessage()

func (*ListPipelineObjectResponse) ProtoReflect 

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

func (*ListPipelineObjectResponse) Reset 

func (x *ListPipelineObjectResponse) Reset()

func (*ListPipelineObjectResponse) String 

func (x *ListPipelineObjectResponse) String() string

type ListPipelinesRequest 

type ListPipelinesRequest struct {

	// offset is a pagination parameter that defines where to start when counting
	// the list of pipelines to return.
	Offset int64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	// limit is a pagination parameter that defines how many pipelines to return
	// per result.
	Limit       int64  `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	NamespaceId string `protobuf:"bytes,3,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` // Unique namespace identifier
	// contains filtered or unexported fields
}

func (*ListPipelinesRequest) Descriptor deprecated 

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

Deprecated: Use ListPipelinesRequest.ProtoReflect.Descriptor instead.

func (*ListPipelinesRequest) GetLimit 

func (x *ListPipelinesRequest) GetLimit() int64

func (*ListPipelinesRequest) GetNamespaceId 

func (x *ListPipelinesRequest) GetNamespaceId() string

func (*ListPipelinesRequest) GetOffset 

func (x *ListPipelinesRequest) GetOffset() int64

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 ListPipelinesResponse 

type ListPipelinesResponse struct {
	Pipelines []*Pipeline `protobuf:"bytes,1,rep,name=pipelines,proto3" json:"pipelines,omitempty"`
	// offset is a pagination parameter that defines where to start when counting
	// the list of pipelines to return.
	Offset int64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*ListPipelinesResponse) Descriptor deprecated 

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

Deprecated: Use ListPipelinesResponse.ProtoReflect.Descriptor instead.

func (*ListPipelinesResponse) GetOffset 

func (x *ListPipelinesResponse) GetOffset() int64

func (*ListPipelinesResponse) GetPipelines 

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

func (*ListPipelinesResponse) ProtoMessage 

func (*ListPipelinesResponse) ProtoMessage()

func (*ListPipelinesResponse) ProtoReflect 

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

func (*ListPipelinesResponse) Reset 

func (x *ListPipelinesResponse) Reset()

func (*ListPipelinesResponse) String 

func (x *ListPipelinesResponse) String() string

type ListRegistryAuthsRequest 

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

func (*ListRegistryAuthsRequest) Descriptor deprecated 

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

Deprecated: Use ListRegistryAuthsRequest.ProtoReflect.Descriptor instead.

func (*ListRegistryAuthsRequest) ProtoMessage 

func (*ListRegistryAuthsRequest) ProtoMessage()

func (*ListRegistryAuthsRequest) ProtoReflect 

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

func (*ListRegistryAuthsRequest) Reset 

func (x *ListRegistryAuthsRequest) Reset()

func (*ListRegistryAuthsRequest) String 

func (x *ListRegistryAuthsRequest) String() string

type ListRegistryAuthsResponse 

type ListRegistryAuthsResponse struct {
	Auths []*DockerRegistryAuth `protobuf:"bytes,1,rep,name=auths,proto3" json:"auths,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRegistryAuthsResponse) Descriptor deprecated 

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

Deprecated: Use ListRegistryAuthsResponse.ProtoReflect.Descriptor instead.

func (*ListRegistryAuthsResponse) GetAuths 

func (x *ListRegistryAuthsResponse) GetAuths() []*DockerRegistryAuth

func (*ListRegistryAuthsResponse) ProtoMessage 

func (*ListRegistryAuthsResponse) ProtoMessage()

func (*ListRegistryAuthsResponse) ProtoReflect 

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

func (*ListRegistryAuthsResponse) Reset 

func (x *ListRegistryAuthsResponse) Reset()

func (*ListRegistryAuthsResponse) String 

func (x *ListRegistryAuthsResponse) String() string

type ListRunObjectRequest 

type ListRunObjectRequest struct {
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` // Unique namespace identifier
	PipelineId  string `protobuf:"bytes,2,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	RunId       int64  `protobuf:"varint,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRunObjectRequest) Descriptor deprecated 

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

Deprecated: Use ListRunObjectRequest.ProtoReflect.Descriptor instead.

func (*ListRunObjectRequest) GetNamespaceId 

func (x *ListRunObjectRequest) GetNamespaceId() string

func (*ListRunObjectRequest) GetPipelineId 

func (x *ListRunObjectRequest) GetPipelineId() string

func (*ListRunObjectRequest) GetRunId 

func (x *ListRunObjectRequest) GetRunId() int64

func (*ListRunObjectRequest) ProtoMessage 

func (*ListRunObjectRequest) ProtoMessage()

func (*ListRunObjectRequest) ProtoReflect 

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

func (*ListRunObjectRequest) Reset 

func (x *ListRunObjectRequest) Reset()

func (*ListRunObjectRequest) String 

func (x *ListRunObjectRequest) String() string

type ListRunObjectResponse 

type ListRunObjectResponse struct {
	Keys []string `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRunObjectResponse) Descriptor deprecated 

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

Deprecated: Use ListRunObjectResponse.ProtoReflect.Descriptor instead.

func (*ListRunObjectResponse) GetKeys 

func (x *ListRunObjectResponse) GetKeys() []string

func (*ListRunObjectResponse) ProtoMessage 

func (*ListRunObjectResponse) ProtoMessage()

func (*ListRunObjectResponse) ProtoReflect 

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

func (*ListRunObjectResponse) Reset 

func (x *ListRunObjectResponse) Reset()

func (*ListRunObjectResponse) String 

func (x *ListRunObjectResponse) String() string

type ListRunsRequest 

type ListRunsRequest struct {

	// offset is a pagination parameter that defines where to start when
	// counting the list of pipelines to return
	Offset int64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	// limit is a pagination parameter that defines how many pipelines to return
	// per result.
	Limit       int64  `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	NamespaceId string `protobuf:"bytes,3,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` // Unique namespace identifier
	PipelineId  string `protobuf:"bytes,4,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRunsRequest) Descriptor deprecated 

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

Deprecated: Use ListRunsRequest.ProtoReflect.Descriptor instead.

func (*ListRunsRequest) GetLimit 

func (x *ListRunsRequest) GetLimit() int64

func (*ListRunsRequest) GetNamespaceId 

func (x *ListRunsRequest) GetNamespaceId() string

func (*ListRunsRequest) GetOffset 

func (x *ListRunsRequest) GetOffset() int64

func (*ListRunsRequest) GetPipelineId 

func (x *ListRunsRequest) GetPipelineId() string

func (*ListRunsRequest) ProtoMessage 

func (*ListRunsRequest) ProtoMessage()

func (*ListRunsRequest) ProtoReflect 

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

func (*ListRunsRequest) Reset 

func (x *ListRunsRequest) Reset()

func (*ListRunsRequest) String 

func (x *ListRunsRequest) String() string

type ListRunsResponse 

type ListRunsResponse struct {
	Runs []*Run `protobuf:"bytes,1,rep,name=runs,proto3" json:"runs,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRunsResponse) Descriptor deprecated 

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

Deprecated: Use ListRunsResponse.ProtoReflect.Descriptor instead.

func (*ListRunsResponse) GetRuns 

func (x *ListRunsResponse) GetRuns() []*Run

func (*ListRunsResponse) ProtoMessage 

func (*ListRunsResponse) ProtoMessage()

func (*ListRunsResponse) ProtoReflect 

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

func (*ListRunsResponse) Reset 

func (x *ListRunsResponse) Reset()

func (*ListRunsResponse) String 

func (x *ListRunsResponse) String() string

type ListTaskRunsRequest 

type ListTaskRunsRequest struct {
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` // Unique namespace identifier
	PipelineId  string `protobuf:"bytes,2,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	RunId       int64  `protobuf:"varint,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTaskRunsRequest) Descriptor deprecated 

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

Deprecated: Use ListTaskRunsRequest.ProtoReflect.Descriptor instead.

func (*ListTaskRunsRequest) GetNamespaceId 

func (x *ListTaskRunsRequest) GetNamespaceId() string

func (*ListTaskRunsRequest) GetPipelineId 

func (x *ListTaskRunsRequest) GetPipelineId() string

func (*ListTaskRunsRequest) GetRunId 

func (x *ListTaskRunsRequest) GetRunId() int64

func (*ListTaskRunsRequest) ProtoMessage 

func (*ListTaskRunsRequest) ProtoMessage()

func (*ListTaskRunsRequest) ProtoReflect 

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

func (*ListTaskRunsRequest) Reset 

func (x *ListTaskRunsRequest) Reset()

func (*ListTaskRunsRequest) String 

func (x *ListTaskRunsRequest) String() string

type ListTaskRunsResponse 

type ListTaskRunsResponse struct {
	TaskRuns []*TaskRun `protobuf:"bytes,1,rep,name=task_runs,json=taskRuns,proto3" json:"task_runs,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTaskRunsResponse) Descriptor deprecated 

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

Deprecated: Use ListTaskRunsResponse.ProtoReflect.Descriptor instead.

func (*ListTaskRunsResponse) GetTaskRuns 

func (x *ListTaskRunsResponse) GetTaskRuns() []*TaskRun

func (*ListTaskRunsResponse) ProtoMessage 

func (*ListTaskRunsResponse) ProtoMessage()

func (*ListTaskRunsResponse) ProtoReflect 

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

func (*ListTaskRunsResponse) Reset 

func (x *ListTaskRunsResponse) Reset()

func (*ListTaskRunsResponse) String 

func (x *ListTaskRunsResponse) String() string

type ListTriggerEventsRequest 

type ListTriggerEventsRequest struct {

	// offset is a pagination parameter that defines where to start when
	// counting the list of pipelines to return
	Offset int64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	// limit is a pagination parameter that defines how many pipelines to return
	// per result.
	Limit                int64  `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	NamespaceId          string `protobuf:"bytes,3,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` // Unique namespace identifier
	PipelineId           string `protobuf:"bytes,4,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	PipelineTriggerLabel string `protobuf:"bytes,5,opt,name=pipeline_trigger_label,json=pipelineTriggerLabel,proto3" json:"pipeline_trigger_label,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTriggerEventsRequest) Descriptor deprecated 

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

Deprecated: Use ListTriggerEventsRequest.ProtoReflect.Descriptor instead.

func (*ListTriggerEventsRequest) GetLimit 

func (x *ListTriggerEventsRequest) GetLimit() int64

func (*ListTriggerEventsRequest) GetNamespaceId 

func (x *ListTriggerEventsRequest) GetNamespaceId() string

func (*ListTriggerEventsRequest) GetOffset 

func (x *ListTriggerEventsRequest) GetOffset() int64

func (*ListTriggerEventsRequest) GetPipelineId 

func (x *ListTriggerEventsRequest) GetPipelineId() string

func (*ListTriggerEventsRequest) GetPipelineTriggerLabel 

func (x *ListTriggerEventsRequest) GetPipelineTriggerLabel() string

func (*ListTriggerEventsRequest) ProtoMessage 

func (*ListTriggerEventsRequest) ProtoMessage()

func (*ListTriggerEventsRequest) ProtoReflect 

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

func (*ListTriggerEventsRequest) Reset 

func (x *ListTriggerEventsRequest) Reset()

func (*ListTriggerEventsRequest) String 

func (x *ListTriggerEventsRequest) String() string

type ListTriggerEventsResponse 

type ListTriggerEventsResponse struct {
	Events []*TriggerEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTriggerEventsResponse) Descriptor deprecated 

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

Deprecated: Use ListTriggerEventsResponse.ProtoReflect.Descriptor instead.

func (*ListTriggerEventsResponse) GetEvents 

func (x *ListTriggerEventsResponse) GetEvents() []*TriggerEvent

func (*ListTriggerEventsResponse) ProtoMessage 

func (*ListTriggerEventsResponse) ProtoMessage()

func (*ListTriggerEventsResponse) ProtoReflect 

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

func (*ListTriggerEventsResponse) Reset 

func (x *ListTriggerEventsResponse) Reset()

func (*ListTriggerEventsResponse) String 

func (x *ListTriggerEventsResponse) String() string

type ListTriggersRequest 

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

func (*ListTriggersRequest) Descriptor deprecated 

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

Deprecated: Use ListTriggersRequest.ProtoReflect.Descriptor instead.

func (*ListTriggersRequest) ProtoMessage 

func (*ListTriggersRequest) ProtoMessage()

func (*ListTriggersRequest) ProtoReflect 

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

func (*ListTriggersRequest) Reset 

func (x *ListTriggersRequest) Reset()

func (*ListTriggersRequest) String 

func (x *ListTriggersRequest) String() string

type ListTriggersResponse 

type ListTriggersResponse struct {
	Triggers []*Trigger `protobuf:"bytes,1,rep,name=triggers,proto3" json:"triggers,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTriggersResponse) Descriptor deprecated 

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

Deprecated: Use ListTriggersResponse.ProtoReflect.Descriptor instead.

func (*ListTriggersResponse) GetTriggers 

func (x *ListTriggersResponse) GetTriggers() []*Trigger

func (*ListTriggersResponse) ProtoMessage 

func (*ListTriggersResponse) ProtoMessage()

func (*ListTriggersResponse) ProtoReflect 

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

func (*ListTriggersResponse) Reset 

func (x *ListTriggersResponse) Reset()

func (*ListTriggersResponse) String 

func (x *ListTriggersResponse) String() string

type Namespace 

type Namespace struct {
	Id          string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name        string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Created     int64  `protobuf:"varint,4,opt,name=created,proto3" json:"created,omitempty"`
	Deleted     int64  `protobuf:"varint,5,opt,name=deleted,proto3" json:"deleted,omitempty"`
	// contains filtered or unexported fields
}

func (*Namespace) Descriptor deprecated 

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

Deprecated: Use Namespace.ProtoReflect.Descriptor instead.

func (*Namespace) GetCreated 

func (x *Namespace) GetCreated() int64

func (*Namespace) GetDeleted 

func (x *Namespace) GetDeleted() int64

func (*Namespace) GetDescription 

func (x *Namespace) GetDescription() string

func (*Namespace) GetId 

func (x *Namespace) GetId() string

func (*Namespace) GetName 

func (x *Namespace) GetName() string

func (*Namespace) ProtoMessage 

func (*Namespace) ProtoMessage()

func (*Namespace) ProtoReflect 

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

func (*Namespace) Reset 

func (x *Namespace) Reset()

func (*Namespace) String 

func (x *Namespace) String() string

type Pipeline 

type Pipeline struct {
	Location    string                            `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
	Created     int64                             `protobuf:"varint,2,opt,name=created,proto3" json:"created,omitempty"`
	Description string                            `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Id          string                            `protobuf:"bytes,4,opt,name=id,proto3" json:"id,omitempty"`
	Namespace   string                            `protobuf:"bytes,5,opt,name=namespace,proto3" json:"namespace,omitempty"`
	LastRunTime int64                             `protobuf:"varint,6,opt,name=last_run_time,json=lastRunTime,proto3" json:"last_run_time,omitempty"`
	LastRunId   int64                             `protobuf:"varint,7,opt,name=last_run_id,json=lastRunId,proto3" json:"last_run_id,omitempty"`
	Updated     int64                             `protobuf:"varint,8,opt,name=updated,proto3" json:"updated,omitempty"`
	Name        string                            `protobuf:"bytes,9,opt,name=name,proto3" json:"name,omitempty"`
	Sequential  bool                              `protobuf:"varint,10,opt,name=sequential,proto3" json:"sequential,omitempty"`
	State       Pipeline_State                    `protobuf:"varint,11,opt,name=state,proto3,enum=proto.Pipeline_State" json:"state,omitempty"`
	Tasks       map[string]*Task                  `` /* 152-byte string literal not displayed */
	Triggers    map[string]*PipelineTriggerConfig `` /* 158-byte string literal not displayed */
	Objects     []string                          `protobuf:"bytes,14,rep,name=objects,proto3" json:"objects,omitempty"`
	// contains filtered or unexported fields
}

func (*Pipeline) Descriptor deprecated 

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

Deprecated: Use Pipeline.ProtoReflect.Descriptor instead.

func (*Pipeline) GetCreated 

func (x *Pipeline) GetCreated() int64

func (*Pipeline) GetDescription 

func (x *Pipeline) GetDescription() string

func (*Pipeline) GetId 

func (x *Pipeline) GetId() string

func (*Pipeline) GetLastRunId 

func (x *Pipeline) GetLastRunId() int64

func (*Pipeline) GetLastRunTime 

func (x *Pipeline) GetLastRunTime() int64

func (*Pipeline) GetLocation 

func (x *Pipeline) GetLocation() string

func (*Pipeline) GetName 

func (x *Pipeline) GetName() string

func (*Pipeline) GetNamespace 

func (x *Pipeline) GetNamespace() string

func (*Pipeline) GetObjects 

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

func (*Pipeline) GetSequential 

func (x *Pipeline) GetSequential() bool

func (*Pipeline) GetState 

func (x *Pipeline) GetState() Pipeline_State

func (*Pipeline) GetTasks 

func (x *Pipeline) GetTasks() map[string]*Task

func (*Pipeline) GetTriggers 

func (x *Pipeline) GetTriggers() map[string]*PipelineTriggerConfig

func (*Pipeline) GetUpdated 

func (x *Pipeline) GetUpdated() int64

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 PipelineTriggerConfig 

type PipelineTriggerConfig struct {
	Kind   string            `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
	Label  string            `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"`
	Config map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PipelineTriggerConfig) Descriptor deprecated 

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

Deprecated: Use PipelineTriggerConfig.ProtoReflect.Descriptor instead.

func (*PipelineTriggerConfig) GetConfig 

func (x *PipelineTriggerConfig) GetConfig() map[string]string

func (*PipelineTriggerConfig) GetKind 

func (x *PipelineTriggerConfig) GetKind() string

func (*PipelineTriggerConfig) GetLabel 

func (x *PipelineTriggerConfig) GetLabel() string

func (*PipelineTriggerConfig) ProtoMessage 

func (*PipelineTriggerConfig) ProtoMessage()

func (*PipelineTriggerConfig) ProtoReflect 

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

func (*PipelineTriggerConfig) Reset 

func (x *PipelineTriggerConfig) Reset()

func (*PipelineTriggerConfig) String 

func (x *PipelineTriggerConfig) String() string

type Pipeline_State 

type Pipeline_State int32
const (
	Pipeline_UNKNOWN   Pipeline_State = 0
	Pipeline_ACTIVE    Pipeline_State = 1
	Pipeline_DISABLED  Pipeline_State = 2
	Pipeline_ABANDONED Pipeline_State = 3
)

func (Pipeline_State) Descriptor 

func (Pipeline_State) Descriptor() protoreflect.EnumDescriptor

func (Pipeline_State) Enum 

func (x Pipeline_State) Enum() *Pipeline_State

func (Pipeline_State) EnumDescriptor deprecated 

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

Deprecated: Use Pipeline_State.Descriptor instead.

func (Pipeline_State) Number 

func (x Pipeline_State) Number() protoreflect.EnumNumber

func (Pipeline_State) String 

func (x Pipeline_State) String() string

func (Pipeline_State) Type 

func (Pipeline_State) Type() protoreflect.EnumType

type PutPipelineObjectRequest 

type PutPipelineObjectRequest struct {
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` // Unique namespace identifier
	PipelineId  string `protobuf:"bytes,2,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	Key         string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	Content     []byte `protobuf:"bytes,4,opt,name=content,proto3" json:"content,omitempty"`
	Force       bool   `protobuf:"varint,5,opt,name=force,proto3" json:"force,omitempty"` // Overwrites an already existing value.
	// contains filtered or unexported fields
}

func (*PutPipelineObjectRequest) Descriptor deprecated 

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

Deprecated: Use PutPipelineObjectRequest.ProtoReflect.Descriptor instead.

func (*PutPipelineObjectRequest) GetContent 

func (x *PutPipelineObjectRequest) GetContent() []byte

func (*PutPipelineObjectRequest) GetForce 

func (x *PutPipelineObjectRequest) GetForce() bool

func (*PutPipelineObjectRequest) GetKey 

func (x *PutPipelineObjectRequest) GetKey() string

func (*PutPipelineObjectRequest) GetNamespaceId 

func (x *PutPipelineObjectRequest) GetNamespaceId() string

func (*PutPipelineObjectRequest) GetPipelineId 

func (x *PutPipelineObjectRequest) GetPipelineId() string

func (*PutPipelineObjectRequest) ProtoMessage 

func (*PutPipelineObjectRequest) ProtoMessage()

func (*PutPipelineObjectRequest) ProtoReflect 

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

func (*PutPipelineObjectRequest) Reset 

func (x *PutPipelineObjectRequest) Reset()

func (*PutPipelineObjectRequest) String 

func (x *PutPipelineObjectRequest) String() string

type PutPipelineObjectResponse 

type PutPipelineObjectResponse struct {

	// The number of bytes uploaded.
	Bytes int64 `protobuf:"varint,1,opt,name=bytes,proto3" json:"bytes,omitempty"`
	// The total amount of objects for this particular pipeline.
	ObjectLimit int64 `protobuf:"varint,2,opt,name=object_limit,json=objectLimit,proto3" json:"object_limit,omitempty"`
	// The key for the object that was evicted for the latest key.
	ObjectEvicted string `protobuf:"bytes,3,opt,name=object_evicted,json=objectEvicted,proto3" json:"object_evicted,omitempty"`
	// contains filtered or unexported fields
}

func (*PutPipelineObjectResponse) Descriptor deprecated 

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

Deprecated: Use PutPipelineObjectResponse.ProtoReflect.Descriptor instead.

func (*PutPipelineObjectResponse) GetBytes 

func (x *PutPipelineObjectResponse) GetBytes() int64

func (*PutPipelineObjectResponse) GetObjectEvicted 

func (x *PutPipelineObjectResponse) GetObjectEvicted() string

func (*PutPipelineObjectResponse) GetObjectLimit 

func (x *PutPipelineObjectResponse) GetObjectLimit() int64

func (*PutPipelineObjectResponse) ProtoMessage 

func (*PutPipelineObjectResponse) ProtoMessage()

func (*PutPipelineObjectResponse) ProtoReflect 

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

func (*PutPipelineObjectResponse) Reset 

func (x *PutPipelineObjectResponse) Reset()

func (*PutPipelineObjectResponse) String 

func (x *PutPipelineObjectResponse) String() string

type PutRunObjectRequest 

type PutRunObjectRequest struct {
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` // Unique namespace identifier
	PipelineId  string `protobuf:"bytes,2,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	RunId       int64  `protobuf:"varint,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	Key         string `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	Content     []byte `protobuf:"bytes,5,opt,name=content,proto3" json:"content,omitempty"`
	Force       bool   `protobuf:"varint,6,opt,name=force,proto3" json:"force,omitempty"` // Overwrites an already existing value.
	// contains filtered or unexported fields
}

func (*PutRunObjectRequest) Descriptor deprecated 

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

Deprecated: Use PutRunObjectRequest.ProtoReflect.Descriptor instead.

func (*PutRunObjectRequest) GetContent 

func (x *PutRunObjectRequest) GetContent() []byte

func (*PutRunObjectRequest) GetForce 

func (x *PutRunObjectRequest) GetForce() bool

func (*PutRunObjectRequest) GetKey 

func (x *PutRunObjectRequest) GetKey() string

func (*PutRunObjectRequest) GetNamespaceId 

func (x *PutRunObjectRequest) GetNamespaceId() string

func (*PutRunObjectRequest) GetPipelineId 

func (x *PutRunObjectRequest) GetPipelineId() string

func (*PutRunObjectRequest) GetRunId 

func (x *PutRunObjectRequest) GetRunId() int64

func (*PutRunObjectRequest) ProtoMessage 

func (*PutRunObjectRequest) ProtoMessage()

func (*PutRunObjectRequest) ProtoReflect 

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

func (*PutRunObjectRequest) Reset 

func (x *PutRunObjectRequest) Reset()

func (*PutRunObjectRequest) String 

func (x *PutRunObjectRequest) String() string

type PutRunObjectResponse 

type PutRunObjectResponse struct {
	Bytes int64 `protobuf:"varint,1,opt,name=bytes,proto3" json:"bytes,omitempty"`
	// contains filtered or unexported fields
}

func (*PutRunObjectResponse) Descriptor deprecated 

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

Deprecated: Use PutRunObjectResponse.ProtoReflect.Descriptor instead.

func (*PutRunObjectResponse) GetBytes 

func (x *PutRunObjectResponse) GetBytes() int64

func (*PutRunObjectResponse) ProtoMessage 

func (*PutRunObjectResponse) ProtoMessage()

func (*PutRunObjectResponse) ProtoReflect 

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

func (*PutRunObjectResponse) Reset 

func (x *PutRunObjectResponse) Reset()

func (*PutRunObjectResponse) String 

func (x *PutRunObjectResponse) String() string

type RemoveRegistryAuthRequest 

type RemoveRegistryAuthRequest struct {
	Registry string `protobuf:"bytes,1,opt,name=registry,proto3" json:"registry,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveRegistryAuthRequest) Descriptor deprecated 

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

Deprecated: Use RemoveRegistryAuthRequest.ProtoReflect.Descriptor instead.

func (*RemoveRegistryAuthRequest) GetRegistry 

func (x *RemoveRegistryAuthRequest) GetRegistry() string

func (*RemoveRegistryAuthRequest) ProtoMessage 

func (*RemoveRegistryAuthRequest) ProtoMessage()

func (*RemoveRegistryAuthRequest) ProtoReflect 

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

func (*RemoveRegistryAuthRequest) Reset 

func (x *RemoveRegistryAuthRequest) Reset()

func (*RemoveRegistryAuthRequest) String 

func (x *RemoveRegistryAuthRequest) String() string

type RemoveRegistryAuthResponse 

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

func (*RemoveRegistryAuthResponse) Descriptor deprecated 

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

Deprecated: Use RemoveRegistryAuthResponse.ProtoReflect.Descriptor instead.

func (*RemoveRegistryAuthResponse) ProtoMessage 

func (*RemoveRegistryAuthResponse) ProtoMessage()

func (*RemoveRegistryAuthResponse) ProtoReflect 

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

func (*RemoveRegistryAuthResponse) Reset 

func (x *RemoveRegistryAuthResponse) Reset()

func (*RemoveRegistryAuthResponse) String 

func (x *RemoveRegistryAuthResponse) String() string

type RepairOrphanRequest 

type RepairOrphanRequest struct {
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` // Unique namespace identifier
	PipelineId  string `protobuf:"bytes,2,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	RunId       int64  `protobuf:"varint,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RepairOrphanRequest) Descriptor deprecated 

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

Deprecated: Use RepairOrphanRequest.ProtoReflect.Descriptor instead.

func (*RepairOrphanRequest) GetNamespaceId 

func (x *RepairOrphanRequest) GetNamespaceId() string

func (*RepairOrphanRequest) GetPipelineId 

func (x *RepairOrphanRequest) GetPipelineId() string

func (*RepairOrphanRequest) GetRunId 

func (x *RepairOrphanRequest) GetRunId() int64

func (*RepairOrphanRequest) ProtoMessage 

func (*RepairOrphanRequest) ProtoMessage()

func (*RepairOrphanRequest) ProtoReflect 

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

func (*RepairOrphanRequest) Reset 

func (x *RepairOrphanRequest) Reset()

func (*RepairOrphanRequest) String 

func (x *RepairOrphanRequest) String() string

type RepairOrphanResponse 

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

func (*RepairOrphanResponse) Descriptor deprecated 

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

Deprecated: Use RepairOrphanResponse.ProtoReflect.Descriptor instead.

func (*RepairOrphanResponse) ProtoMessage 

func (*RepairOrphanResponse) ProtoMessage()

func (*RepairOrphanResponse) ProtoReflect 

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

func (*RepairOrphanResponse) Reset 

func (x *RepairOrphanResponse) Reset()

func (*RepairOrphanResponse) String 

func (x *RepairOrphanResponse) String() string

type RetryRunRequest 

type RetryRunRequest struct {
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` // Unique namespace identifier
	PipelineId  string `protobuf:"bytes,2,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	Id          int64  `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty"` // Run ID
	// contains filtered or unexported fields
}

func (*RetryRunRequest) Descriptor deprecated 

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

Deprecated: Use RetryRunRequest.ProtoReflect.Descriptor instead.

func (*RetryRunRequest) GetId 

func (x *RetryRunRequest) GetId() int64

func (*RetryRunRequest) GetNamespaceId 

func (x *RetryRunRequest) GetNamespaceId() string

func (*RetryRunRequest) GetPipelineId 

func (x *RetryRunRequest) GetPipelineId() string

func (*RetryRunRequest) ProtoMessage 

func (*RetryRunRequest) ProtoMessage()

func (*RetryRunRequest) ProtoReflect 

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

func (*RetryRunRequest) Reset 

func (x *RetryRunRequest) Reset()

func (*RetryRunRequest) String 

func (x *RetryRunRequest) String() string

type RetryRunResponse 

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

func (*RetryRunResponse) Descriptor deprecated 

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

Deprecated: Use RetryRunResponse.ProtoReflect.Descriptor instead.

func (*RetryRunResponse) GetRun 

func (x *RetryRunResponse) GetRun() *Run

func (*RetryRunResponse) ProtoMessage 

func (*RetryRunResponse) ProtoMessage()

func (*RetryRunResponse) ProtoReflect 

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

func (*RetryRunResponse) Reset 

func (x *RetryRunResponse) Reset()

func (*RetryRunResponse) String 

func (x *RetryRunResponse) String() string

type Run 

type Run struct {
	Ended          int64             `protobuf:"varint,1,opt,name=ended,proto3" json:"ended,omitempty"`
	Failure        *RunFailure       `protobuf:"bytes,2,opt,name=failure,proto3" json:"failure,omitempty"`
	Id             int64             `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty"`
	NamespaceId    string            `protobuf:"bytes,4,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	PipelineId     string            `protobuf:"bytes,5,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	Started        int64             `protobuf:"varint,6,opt,name=started,proto3" json:"started,omitempty"`
	State          Run_State         `protobuf:"varint,7,opt,name=state,proto3,enum=proto.Run_State" json:"state,omitempty"`
	TaskRuns       []string          `protobuf:"bytes,8,rep,name=task_runs,json=taskRuns,proto3" json:"task_runs,omitempty"`
	Only           []string          `protobuf:"bytes,9,rep,name=only,proto3" json:"only,omitempty"`
	TriggerKind    string            `protobuf:"bytes,10,opt,name=trigger_kind,json=triggerKind,proto3" json:"trigger_kind,omitempty"`
	TriggerName    string            `protobuf:"bytes,11,opt,name=trigger_name,json=triggerName,proto3" json:"trigger_name,omitempty"`
	Variables      map[string]string `` /* 160-byte string literal not displayed */
	Objects        []string          `protobuf:"bytes,13,rep,name=objects,proto3" json:"objects,omitempty"`
	ObjectsExpired bool              `protobuf:"varint,14,opt,name=objects_expired,json=objectsExpired,proto3" json:"objects_expired,omitempty"`
	// contains filtered or unexported fields
}

func (*Run) Descriptor deprecated 

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

Deprecated: Use Run.ProtoReflect.Descriptor instead.

func (*Run) GetEnded 

func (x *Run) GetEnded() int64

func (*Run) GetFailure 

func (x *Run) GetFailure() *RunFailure

func (*Run) GetId 

func (x *Run) GetId() int64

func (*Run) GetNamespaceId 

func (x *Run) GetNamespaceId() string

func (*Run) GetObjects 

func (x *Run) GetObjects() []string

func (*Run) GetObjectsExpired 

func (x *Run) GetObjectsExpired() bool

func (*Run) GetOnly 

func (x *Run) GetOnly() []string

func (*Run) GetPipelineId 

func (x *Run) GetPipelineId() string

func (*Run) GetStarted 

func (x *Run) GetStarted() int64

func (*Run) GetState 

func (x *Run) GetState() Run_State

func (*Run) GetTaskRuns 

func (x *Run) GetTaskRuns() []string

func (*Run) GetTriggerKind 

func (x *Run) GetTriggerKind() string

func (*Run) GetTriggerName 

func (x *Run) GetTriggerName() string

func (*Run) GetVariables 

func (x *Run) GetVariables() map[string]string

func (*Run) ProtoMessage 

func (*Run) ProtoMessage()

func (*Run) ProtoReflect 

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

func (*Run) Reset 

func (x *Run) Reset()

func (*Run) String 

func (x *Run) String() string

type RunFailure 

type RunFailure struct {
	Kind        RunFailure_Kind `protobuf:"varint,1,opt,name=kind,proto3,enum=proto.RunFailure_Kind" json:"kind,omitempty"`
	Description string          `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*RunFailure) Descriptor deprecated 

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

Deprecated: Use RunFailure.ProtoReflect.Descriptor instead.

func (*RunFailure) GetDescription 

func (x *RunFailure) GetDescription() string

func (*RunFailure) GetKind 

func (x *RunFailure) GetKind() RunFailure_Kind

func (*RunFailure) ProtoMessage 

func (*RunFailure) ProtoMessage()

func (*RunFailure) ProtoReflect 

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

func (*RunFailure) Reset 

func (x *RunFailure) Reset()

func (*RunFailure) String 

func (x *RunFailure) String() string

type RunFailure_Kind 

type RunFailure_Kind int32
const (
	RunFailure_UNKNOWN             RunFailure_Kind = 0
	RunFailure_ABNORMAL_EXIT       RunFailure_Kind = 1
	RunFailure_SCHEDULER_ERROR     RunFailure_Kind = 2
	RunFailure_FAILED_PRECONDITION RunFailure_Kind = 3
	RunFailure_CANCELLED           RunFailure_Kind = 4
)

func (RunFailure_Kind) Descriptor 

func (RunFailure_Kind) Descriptor() protoreflect.EnumDescriptor

func (RunFailure_Kind) Enum 

func (x RunFailure_Kind) Enum() *RunFailure_Kind

func (RunFailure_Kind) EnumDescriptor deprecated 

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

Deprecated: Use RunFailure_Kind.Descriptor instead.

func (RunFailure_Kind) Number 

func (x RunFailure_Kind) Number() protoreflect.EnumNumber

func (RunFailure_Kind) String 

func (x RunFailure_Kind) String() string

func (RunFailure_Kind) Type 

func (RunFailure_Kind) Type() protoreflect.EnumType

type Run_State 

type Run_State int32
const (
	Run_UNKNOWN    Run_State = 0
	Run_PROCESSING Run_State = 1
	Run_WAITING    Run_State = 2
	Run_RUNNING    Run_State = 3
	Run_FAILED     Run_State = 4
	Run_SUCCESS    Run_State = 5
	Run_CANCELLED  Run_State = 6
)

func (Run_State) Descriptor 

func (Run_State) Descriptor() protoreflect.EnumDescriptor

func (Run_State) Enum 

func (x Run_State) Enum() *Run_State

func (Run_State) EnumDescriptor deprecated 

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

Deprecated: Use Run_State.Descriptor instead.

func (Run_State) Number 

func (x Run_State) Number() protoreflect.EnumNumber

func (Run_State) String 

func (x Run_State) String() string

func (Run_State) Type 

func (Run_State) Type() protoreflect.EnumType

type StartRunRequest 

type StartRunRequest struct {
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` // Unique namespace identifier
	PipelineId  string `protobuf:"bytes,2,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	// Only is an array of tasks which will run exclusively for this particular
	// run. Tasks still carry relevant dependencies. Run will return an error if
	// the dependencies of a task is also not met in the list of tasks included in
	// only.
	Only []string `protobuf:"bytes,3,rep,name=only,proto3" json:"only,omitempty"`
	// variables allows for the replacement of task environment variables, it
	// overrides all other environment variables if there is a name collision.
	Variables map[string]string `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StartRunRequest) Descriptor deprecated 

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

Deprecated: Use StartRunRequest.ProtoReflect.Descriptor instead.

func (*StartRunRequest) GetNamespaceId 

func (x *StartRunRequest) GetNamespaceId() string

func (*StartRunRequest) GetOnly 

func (x *StartRunRequest) GetOnly() []string

func (*StartRunRequest) GetPipelineId 

func (x *StartRunRequest) GetPipelineId() string

func (*StartRunRequest) GetVariables 

func (x *StartRunRequest) GetVariables() map[string]string

func (*StartRunRequest) ProtoMessage 

func (*StartRunRequest) ProtoMessage()

func (*StartRunRequest) ProtoReflect 

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

func (*StartRunRequest) Reset 

func (x *StartRunRequest) Reset()

func (*StartRunRequest) String 

func (x *StartRunRequest) String() string

type StartRunResponse 

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

func (*StartRunResponse) Descriptor deprecated 

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

Deprecated: Use StartRunResponse.ProtoReflect.Descriptor instead.

func (*StartRunResponse) GetRun 

func (x *StartRunResponse) GetRun() *Run

func (*StartRunResponse) ProtoMessage 

func (*StartRunResponse) ProtoMessage()

func (*StartRunResponse) ProtoReflect 

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

func (*StartRunResponse) Reset 

func (x *StartRunResponse) Reset()

func (*StartRunResponse) String 

func (x *StartRunResponse) String() string

type Task 

type Task struct {
	Id          string                             `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Description string                             `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	ImageName   string                             `protobuf:"bytes,3,opt,name=image_name,json=imageName,proto3" json:"image_name,omitempty"`
	DependsOn   map[string]TaskRequiredParentState `` /* 212-byte string literal not displayed */
	EnvVars     map[string]string                  `` /* 170-byte string literal not displayed */
	Secrets     map[string]string                  `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Task) Descriptor deprecated 

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetDependsOn 

func (x *Task) GetDependsOn() map[string]TaskRequiredParentState

func (*Task) GetDescription 

func (x *Task) GetDescription() string

func (*Task) GetEnvVars 

func (x *Task) GetEnvVars() map[string]string

func (*Task) GetId 

func (x *Task) GetId() string

func (*Task) GetImageName 

func (x *Task) GetImageName() string

func (*Task) GetSecrets 

func (x *Task) GetSecrets() map[string]string

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) ProtoReflect 

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

func (*Task) Reset 

func (x *Task) Reset()

func (*Task) String 

func (x *Task) String() string

type TaskRequiredParentState 

type TaskRequiredParentState int32
const (
	TaskRequiredParentState_UNKNOWN    TaskRequiredParentState = 0
	TaskRequiredParentState_ANY        TaskRequiredParentState = 1
	TaskRequiredParentState_SUCCESSFUL TaskRequiredParentState = 2
	TaskRequiredParentState_FAILURE    TaskRequiredParentState = 3
)

func (TaskRequiredParentState) Descriptor 

func (TaskRequiredParentState) Descriptor() protoreflect.EnumDescriptor

func (TaskRequiredParentState) Enum 

func (x TaskRequiredParentState) Enum() *TaskRequiredParentState

func (TaskRequiredParentState) EnumDescriptor deprecated 

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

Deprecated: Use TaskRequiredParentState.Descriptor instead.

func (TaskRequiredParentState) Number 

func (x TaskRequiredParentState) Number() protoreflect.EnumNumber

func (TaskRequiredParentState) String 

func (x TaskRequiredParentState) String() string

func (TaskRequiredParentState) Type 

func (TaskRequiredParentState) Type() protoreflect.EnumType

type TaskRun 

type TaskRun struct {
	Created     int64           `protobuf:"varint,1,opt,name=created,proto3" json:"created,omitempty"`
	Ended       int64           `protobuf:"varint,2,opt,name=ended,proto3" json:"ended,omitempty"`
	ExitCode    int64           `protobuf:"varint,3,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	Failure     *TaskRunFailure `protobuf:"bytes,4,opt,name=failure,proto3" json:"failure,omitempty"`
	Id          string          `protobuf:"bytes,5,opt,name=id,proto3" json:"id,omitempty"`
	LogsExpired bool            `protobuf:"varint,6,opt,name=logs_expired,json=logsExpired,proto3" json:"logs_expired,omitempty"`
	LogsRemoved bool            `protobuf:"varint,7,opt,name=logs_removed,json=logsRemoved,proto3" json:"logs_removed,omitempty"`
	NamespaceId string          `protobuf:"bytes,8,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	PipelineId  string          `protobuf:"bytes,9,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	RunId       int64           `protobuf:"varint,10,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	SchedulerId string          `protobuf:"bytes,11,opt,name=scheduler_id,json=schedulerId,proto3" json:"scheduler_id,omitempty"`
	Started     int64           `protobuf:"varint,12,opt,name=started,proto3" json:"started,omitempty"`
	State       TaskRun_State   `protobuf:"varint,13,opt,name=state,proto3,enum=proto.TaskRun_State" json:"state,omitempty"`
	Task        *Task           `protobuf:"bytes,14,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskRun) Descriptor deprecated 

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

Deprecated: Use TaskRun.ProtoReflect.Descriptor instead.

func (*TaskRun) GetCreated 

func (x *TaskRun) GetCreated() int64

func (*TaskRun) GetEnded 

func (x *TaskRun) GetEnded() int64

func (*TaskRun) GetExitCode 

func (x *TaskRun) GetExitCode() int64

func (*TaskRun) GetFailure 

func (x *TaskRun) GetFailure() *TaskRunFailure

func (*TaskRun) GetId 

func (x *TaskRun) GetId() string

func (*TaskRun) GetLogsExpired 

func (x *TaskRun) GetLogsExpired() bool

func (*TaskRun) GetLogsRemoved 

func (x *TaskRun) GetLogsRemoved() bool

func (*TaskRun) GetNamespaceId 

func (x *TaskRun) GetNamespaceId() string

func (*TaskRun) GetPipelineId 

func (x *TaskRun) GetPipelineId() string

func (*TaskRun) GetRunId 

func (x *TaskRun) GetRunId() int64

func (*TaskRun) GetSchedulerId 

func (x *TaskRun) GetSchedulerId() string

func (*TaskRun) GetStarted 

func (x *TaskRun) GetStarted() int64

func (*TaskRun) GetState 

func (x *TaskRun) GetState() TaskRun_State

func (*TaskRun) GetTask 

func (x *TaskRun) GetTask() *Task

func (*TaskRun) ProtoMessage 

func (*TaskRun) ProtoMessage()

func (*TaskRun) ProtoReflect 

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

func (*TaskRun) Reset 

func (x *TaskRun) Reset()

func (*TaskRun) String 

func (x *TaskRun) String() string

type TaskRunFailure 

type TaskRunFailure struct {
	Kind        TaskRunFailure_Kind `protobuf:"varint,1,opt,name=kind,proto3,enum=proto.TaskRunFailure_Kind" json:"kind,omitempty"`
	Description string              `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskRunFailure) Descriptor deprecated 

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

Deprecated: Use TaskRunFailure.ProtoReflect.Descriptor instead.

func (*TaskRunFailure) GetDescription 

func (x *TaskRunFailure) GetDescription() string

func (*TaskRunFailure) GetKind 

func (x *TaskRunFailure) GetKind() TaskRunFailure_Kind

func (*TaskRunFailure) ProtoMessage 

func (*TaskRunFailure) ProtoMessage()

func (*TaskRunFailure) ProtoReflect 

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

func (*TaskRunFailure) Reset 

func (x *TaskRunFailure) Reset()

func (*TaskRunFailure) String 

func (x *TaskRunFailure) String() string

type TaskRunFailure_Kind 

type TaskRunFailure_Kind int32
const (
	TaskRunFailure_UNKNOWN             TaskRunFailure_Kind = 0
	TaskRunFailure_ABNORMAL_EXIT       TaskRunFailure_Kind = 1
	TaskRunFailure_SCHEDULER_ERROR     TaskRunFailure_Kind = 2
	TaskRunFailure_FAILED_PRECONDITION TaskRunFailure_Kind = 3
	TaskRunFailure_CANCELLED           TaskRunFailure_Kind = 4
	TaskRunFailure_ORPHANED            TaskRunFailure_Kind = 5
)

func (TaskRunFailure_Kind) Descriptor 

func (TaskRunFailure_Kind) Descriptor() protoreflect.EnumDescriptor

func (TaskRunFailure_Kind) Enum 

func (x TaskRunFailure_Kind) Enum() *TaskRunFailure_Kind

func (TaskRunFailure_Kind) EnumDescriptor deprecated 

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

Deprecated: Use TaskRunFailure_Kind.Descriptor instead.

func (TaskRunFailure_Kind) Number 

func (x TaskRunFailure_Kind) Number() protoreflect.EnumNumber

func (TaskRunFailure_Kind) String 

func (x TaskRunFailure_Kind) String() string

func (TaskRunFailure_Kind) Type 

func (TaskRunFailure_Kind) Type() protoreflect.EnumType

type TaskRun_State 

type TaskRun_State int32
const (
	TaskRun_UNKNOWN    TaskRun_State = 0
	TaskRun_PROCESSING TaskRun_State = 1
	TaskRun_WAITING    TaskRun_State = 2
	TaskRun_RUNNING    TaskRun_State = 3
	TaskRun_FAILED     TaskRun_State = 4
	TaskRun_SUCCESS    TaskRun_State = 5
	TaskRun_CANCELLED  TaskRun_State = 6
	TaskRun_SKIPPED    TaskRun_State = 7
)

func (TaskRun_State) Descriptor 

func (TaskRun_State) Descriptor() protoreflect.EnumDescriptor

func (TaskRun_State) Enum 

func (x TaskRun_State) Enum() *TaskRun_State

func (TaskRun_State) EnumDescriptor deprecated 

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

Deprecated: Use TaskRun_State.Descriptor instead.

func (TaskRun_State) Number 

func (x TaskRun_State) Number() protoreflect.EnumNumber

func (TaskRun_State) String 

func (x TaskRun_State) String() string

func (TaskRun_State) Type 

func (TaskRun_State) Type() protoreflect.EnumType

type ToggleEventIngressRequest 

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

func (*ToggleEventIngressRequest) Descriptor deprecated 

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

Deprecated: Use ToggleEventIngressRequest.ProtoReflect.Descriptor instead.

func (*ToggleEventIngressRequest) ProtoMessage 

func (*ToggleEventIngressRequest) ProtoMessage()

func (*ToggleEventIngressRequest) ProtoReflect 

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

func (*ToggleEventIngressRequest) Reset 

func (x *ToggleEventIngressRequest) Reset()

func (*ToggleEventIngressRequest) String 

func (x *ToggleEventIngressRequest) String() string

type ToggleEventIngressResponse 

type ToggleEventIngressResponse struct {

	// The current value for the boolean that controls event ingress.
	Value bool `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*ToggleEventIngressResponse) Descriptor deprecated 

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

Deprecated: Use ToggleEventIngressResponse.ProtoReflect.Descriptor instead.

func (*ToggleEventIngressResponse) GetValue 

func (x *ToggleEventIngressResponse) GetValue() bool

func (*ToggleEventIngressResponse) ProtoMessage 

func (*ToggleEventIngressResponse) ProtoMessage()

func (*ToggleEventIngressResponse) ProtoReflect 

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

func (*ToggleEventIngressResponse) Reset 

func (x *ToggleEventIngressResponse) Reset()

func (*ToggleEventIngressResponse) String 

func (x *ToggleEventIngressResponse) String() string

type Token 

type Token struct {
	Created    int64             `protobuf:"varint,1,opt,name=created,proto3" json:"created,omitempty"`
	Kind       Token_Kind        `protobuf:"varint,2,opt,name=kind,proto3,enum=proto.Token_Kind" json:"kind,omitempty"`
	Namespaces []string          `protobuf:"bytes,3,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	Metadata   map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Token) Descriptor deprecated 

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

Deprecated: Use Token.ProtoReflect.Descriptor instead.

func (*Token) GetCreated 

func (x *Token) GetCreated() int64

func (*Token) GetKind 

func (x *Token) GetKind() Token_Kind

func (*Token) GetMetadata 

func (x *Token) GetMetadata() map[string]string

func (*Token) GetNamespaces 

func (x *Token) GetNamespaces() []string

func (*Token) ProtoMessage 

func (*Token) ProtoMessage()

func (*Token) ProtoReflect 

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

func (*Token) Reset 

func (x *Token) Reset()

func (*Token) String 

func (x *Token) String() string

type Token_Kind 

type Token_Kind int32
const (
	Token_UNKNOWN    Token_Kind = 0
	Token_MANAGEMENT Token_Kind = 1
	Token_CLIENT     Token_Kind = 2
)

func (Token_Kind) Descriptor 

func (Token_Kind) Descriptor() protoreflect.EnumDescriptor

func (Token_Kind) Enum 

func (x Token_Kind) Enum() *Token_Kind

func (Token_Kind) EnumDescriptor deprecated 

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

Deprecated: Use Token_Kind.Descriptor instead.

func (Token_Kind) Number 

func (x Token_Kind) Number() protoreflect.EnumNumber

func (Token_Kind) String 

func (x Token_Kind) String() string

func (Token_Kind) Type 

func (Token_Kind) Type() protoreflect.EnumType

type Trigger 

type Trigger struct {
	Kind          string        `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
	Url           string        `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	SchedulerId   string        `protobuf:"bytes,3,opt,name=scheduler_id,json=schedulerId,proto3" json:"scheduler_id,omitempty"`
	Started       int64         `protobuf:"varint,4,opt,name=started,proto3" json:"started,omitempty"`
	State         Trigger_State `protobuf:"varint,5,opt,name=state,proto3,enum=proto.Trigger_State" json:"state,omitempty"`
	Documentation string        `protobuf:"bytes,6,opt,name=documentation,proto3" json:"documentation,omitempty"`
	// contains filtered or unexported fields
}

func (*Trigger) Descriptor deprecated 

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

Deprecated: Use Trigger.ProtoReflect.Descriptor instead.

func (*Trigger) GetDocumentation 

func (x *Trigger) GetDocumentation() string

func (*Trigger) GetKind 

func (x *Trigger) GetKind() string

func (*Trigger) GetSchedulerId 

func (x *Trigger) GetSchedulerId() string

func (*Trigger) GetStarted 

func (x *Trigger) GetStarted() int64

func (*Trigger) GetState 

func (x *Trigger) GetState() Trigger_State

func (*Trigger) GetUrl 

func (x *Trigger) GetUrl() string

func (*Trigger) ProtoMessage 

func (*Trigger) ProtoMessage()

func (*Trigger) ProtoReflect 

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

func (*Trigger) Reset 

func (x *Trigger) Reset()

func (*Trigger) String 

func (x *Trigger) String() string

type TriggerEvent 

type TriggerEvent struct {
	Id                   int64             `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Received             int64             `protobuf:"varint,2,opt,name=received,proto3" json:"received,omitempty"`
	Processed            int64             `protobuf:"varint,3,opt,name=processed,proto3" json:"processed,omitempty"`
	PipelineTriggerLabel string            `protobuf:"bytes,4,opt,name=pipeline_trigger_label,json=pipelineTriggerLabel,proto3" json:"pipeline_trigger_label,omitempty"`
	PipelineId           string            `protobuf:"bytes,5,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	NamespaceId          string            `protobuf:"bytes,6,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	Result               *TriggerResult    `protobuf:"bytes,7,opt,name=result,proto3" json:"result,omitempty"`
	Metadata             map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TriggerEvent) Descriptor deprecated 

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

Deprecated: Use TriggerEvent.ProtoReflect.Descriptor instead.

func (*TriggerEvent) GetId 

func (x *TriggerEvent) GetId() int64

func (*TriggerEvent) GetMetadata 

func (x *TriggerEvent) GetMetadata() map[string]string

func (*TriggerEvent) GetNamespaceId 

func (x *TriggerEvent) GetNamespaceId() string

func (*TriggerEvent) GetPipelineId 

func (x *TriggerEvent) GetPipelineId() string

func (*TriggerEvent) GetPipelineTriggerLabel 

func (x *TriggerEvent) GetPipelineTriggerLabel() string

func (*TriggerEvent) GetProcessed 

func (x *TriggerEvent) GetProcessed() int64

func (*TriggerEvent) GetReceived 

func (x *TriggerEvent) GetReceived() int64

func (*TriggerEvent) GetResult 

func (x *TriggerEvent) GetResult() *TriggerResult

func (*TriggerEvent) ProtoMessage 

func (*TriggerEvent) ProtoMessage()

func (*TriggerEvent) ProtoReflect 

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

func (*TriggerEvent) Reset 

func (x *TriggerEvent) Reset()

func (*TriggerEvent) String 

func (x *TriggerEvent) String() string

type TriggerResult 

type TriggerResult struct {
	State   TriggerResult_State `protobuf:"varint,1,opt,name=state,proto3,enum=proto.TriggerResult_State" json:"state,omitempty"`
	Details string              `protobuf:"bytes,2,opt,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

func (*TriggerResult) Descriptor deprecated 

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

Deprecated: Use TriggerResult.ProtoReflect.Descriptor instead.

func (*TriggerResult) GetDetails 

func (x *TriggerResult) GetDetails() string

func (*TriggerResult) GetState 

func (x *TriggerResult) GetState() TriggerResult_State

func (*TriggerResult) ProtoMessage 

func (*TriggerResult) ProtoMessage()

func (*TriggerResult) ProtoReflect 

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

func (*TriggerResult) Reset 

func (x *TriggerResult) Reset()

func (*TriggerResult) String 

func (x *TriggerResult) String() string

type TriggerResult_State 

type TriggerResult_State int32
const (
	TriggerResult_UNKNOWN TriggerResult_State = 0
	TriggerResult_FAILURE TriggerResult_State = 1
	TriggerResult_SUCCESS TriggerResult_State = 2
	TriggerResult_SKIPPED TriggerResult_State = 3
)

func (TriggerResult_State) Descriptor 

func (TriggerResult_State) Descriptor() protoreflect.EnumDescriptor

func (TriggerResult_State) Enum 

func (x TriggerResult_State) Enum() *TriggerResult_State

func (TriggerResult_State) EnumDescriptor deprecated 

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

Deprecated: Use TriggerResult_State.Descriptor instead.

func (TriggerResult_State) Number 

func (x TriggerResult_State) Number() protoreflect.EnumNumber

func (TriggerResult_State) String 

func (x TriggerResult_State) String() string

func (TriggerResult_State) Type 

func (TriggerResult_State) Type() protoreflect.EnumType

type Trigger_State 

type Trigger_State int32
const (
	Trigger_UNKNOWN    Trigger_State = 0
	Trigger_PROCESSING Trigger_State = 1
	Trigger_WAITING    Trigger_State = 2
	Trigger_RUNNING    Trigger_State = 3
	Trigger_FAILED     Trigger_State = 4
	Trigger_SUCCESS    Trigger_State = 5
)

func (Trigger_State) Descriptor 

func (Trigger_State) Descriptor() protoreflect.EnumDescriptor

func (Trigger_State) Enum 

func (x Trigger_State) Enum() *Trigger_State

func (Trigger_State) EnumDescriptor deprecated 

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

Deprecated: Use Trigger_State.Descriptor instead.

func (Trigger_State) Number 

func (x Trigger_State) Number() protoreflect.EnumNumber

func (Trigger_State) String 

func (x Trigger_State) String() string

func (Trigger_State) Type 

func (Trigger_State) Type() protoreflect.EnumType

type UnimplementedGoferServer 

type UnimplementedGoferServer struct {
}

UnimplementedGoferServer must be embedded to have forward compatible implementations.

func (UnimplementedGoferServer) AbandonPipeline 

func (UnimplementedGoferServer) AbandonPipeline(context.Context, *AbandonPipelineRequest) (*AbandonPipelineResponse, error)

func (UnimplementedGoferServer) AddRegistryAuth 

func (UnimplementedGoferServer) AddRegistryAuth(context.Context, *AddRegistryAuthRequest) (*AddRegistryAuthResponse, error)

func (UnimplementedGoferServer) BatchGetRuns 

func (UnimplementedGoferServer) BatchGetRuns(context.Context, *BatchGetRunsRequest) (*BatchGetRunsResponse, error)

func (UnimplementedGoferServer) BatchGetTriggerEvents 

func (UnimplementedGoferServer) BatchGetTriggerEvents(context.Context, *BatchGetTriggerEventsRequest) (*BatchGetTriggerEventsResponse, error)

func (UnimplementedGoferServer) BootstrapToken 

func (UnimplementedGoferServer) BootstrapToken(context.Context, *BootstrapTokenRequest) (*BootstrapTokenResponse, error)

func (UnimplementedGoferServer) CancelAllRuns 

func (UnimplementedGoferServer) CancelAllRuns(context.Context, *CancelAllRunsRequest) (*CancelAllRunsResponse, error)

func (UnimplementedGoferServer) CancelRun 

func (UnimplementedGoferServer) CancelRun(context.Context, *CancelRunRequest) (*CancelRunResponse, error)

func (UnimplementedGoferServer) CancelTaskRun 

func (UnimplementedGoferServer) CancelTaskRun(context.Context, *CancelTaskRunRequest) (*CancelTaskRunResponse, error)

func (UnimplementedGoferServer) CreateNamespace 

func (UnimplementedGoferServer) CreateNamespace(context.Context, *CreateNamespaceRequest) (*CreateNamespaceResponse, error)

func (UnimplementedGoferServer) CreatePipelineByURL 

func (UnimplementedGoferServer) CreatePipelineByURL(context.Context, *CreatePipelineByURLRequest) (*CreatePipelineByURLResponse, error)

func (UnimplementedGoferServer) CreatePipelineRaw 

func (UnimplementedGoferServer) CreatePipelineRaw(context.Context, *CreatePipelineRawRequest) (*CreatePipelineRawResponse, error)

func (UnimplementedGoferServer) CreateToken 

func (UnimplementedGoferServer) CreateToken(context.Context, *CreateTokenRequest) (*CreateTokenResponse, error)

func (UnimplementedGoferServer) DeleteNamespace 

func (UnimplementedGoferServer) DeleteNamespace(context.Context, *DeleteNamespaceRequest) (*DeleteNamespaceResponse, error)

func (UnimplementedGoferServer) DeletePipelineObject 

func (UnimplementedGoferServer) DeletePipelineObject(context.Context, *DeletePipelineObjectRequest) (*DeletePipelineObjectResponse, error)

func (UnimplementedGoferServer) DeleteRunObject 

func (UnimplementedGoferServer) DeleteRunObject(context.Context, *DeleteRunObjectRequest) (*DeleteRunObjectResponse, error)

func (UnimplementedGoferServer) DeleteTaskRunLogs 

func (UnimplementedGoferServer) DeleteTaskRunLogs(context.Context, *DeleteTaskRunLogsRequest) (*DeleteTaskRunLogsResponse, error)

func (UnimplementedGoferServer) DeleteToken 

func (UnimplementedGoferServer) DeleteToken(context.Context, *DeleteTokenRequest) (*DeleteTokenResponse, error)

func (UnimplementedGoferServer) DisablePipeline 

func (UnimplementedGoferServer) DisablePipeline(context.Context, *DisablePipelineRequest) (*DisablePipelineResponse, error)

func (UnimplementedGoferServer) EnablePipeline 

func (UnimplementedGoferServer) EnablePipeline(context.Context, *EnablePipelineRequest) (*EnablePipelineResponse, error)

func (UnimplementedGoferServer) GetNamespace 

func (UnimplementedGoferServer) GetNamespace(context.Context, *GetNamespaceRequest) (*GetNamespaceResponse, error)

func (UnimplementedGoferServer) GetPipeline 

func (UnimplementedGoferServer) GetPipeline(context.Context, *GetPipelineRequest) (*GetPipelineResponse, error)

func (UnimplementedGoferServer) GetPipelineObject 

func (UnimplementedGoferServer) GetPipelineObject(context.Context, *GetPipelineObjectRequest) (*GetPipelineObjectResponse, error)

func (UnimplementedGoferServer) GetRun 

func (UnimplementedGoferServer) GetRun(context.Context, *GetRunRequest) (*GetRunResponse, error)

func (UnimplementedGoferServer) GetRunObject 

func (UnimplementedGoferServer) GetRunObject(context.Context, *GetRunObjectRequest) (*GetRunObjectResponse, error)

func (UnimplementedGoferServer) GetSystemInfo 

func (UnimplementedGoferServer) GetSystemInfo(context.Context, *GetSystemInfoRequest) (*GetSystemInfoResponse, error)

func (UnimplementedGoferServer) GetTaskRun 

func (UnimplementedGoferServer) GetTaskRun(context.Context, *GetTaskRunRequest) (*GetTaskRunResponse, error)

func (UnimplementedGoferServer) GetTaskRunLogs 

func (UnimplementedGoferServer) GetTaskRunLogs(*GetTaskRunLogsRequest, Gofer_GetTaskRunLogsServer) error

func (UnimplementedGoferServer) GetToken 

func (UnimplementedGoferServer) GetToken(context.Context, *GetTokenRequest) (*GetTokenResponse, error)

func (UnimplementedGoferServer) GetTrigger 

func (UnimplementedGoferServer) GetTrigger(context.Context, *GetTriggerRequest) (*GetTriggerResponse, error)

func (UnimplementedGoferServer) GetTriggerEvent 

func (UnimplementedGoferServer) GetTriggerEvent(context.Context, *GetTriggerEventRequest) (*GetTriggerEventResponse, error)

func (UnimplementedGoferServer) ListNamespaces 

func (UnimplementedGoferServer) ListNamespaces(context.Context, *ListNamespacesRequest) (*ListNamespacesResponse, error)

func (UnimplementedGoferServer) ListPipelines 

func (UnimplementedGoferServer) ListPipelines(context.Context, *ListPipelinesRequest) (*ListPipelinesResponse, error)

func (UnimplementedGoferServer) ListRegistryAuths 

func (UnimplementedGoferServer) ListRegistryAuths(context.Context, *ListRegistryAuthsRequest) (*ListRegistryAuthsResponse, error)

func (UnimplementedGoferServer) ListRuns 

func (UnimplementedGoferServer) ListRuns(context.Context, *ListRunsRequest) (*ListRunsResponse, error)

func (UnimplementedGoferServer) ListTaskRuns 

func (UnimplementedGoferServer) ListTaskRuns(context.Context, *ListTaskRunsRequest) (*ListTaskRunsResponse, error)

func (UnimplementedGoferServer) ListTriggerEvents 

func (UnimplementedGoferServer) ListTriggerEvents(context.Context, *ListTriggerEventsRequest) (*ListTriggerEventsResponse, error)

func (UnimplementedGoferServer) ListTriggers 

func (UnimplementedGoferServer) ListTriggers(context.Context, *ListTriggersRequest) (*ListTriggersResponse, error)

func (UnimplementedGoferServer) PutPipelineObject 

func (UnimplementedGoferServer) PutPipelineObject(context.Context, *PutPipelineObjectRequest) (*PutPipelineObjectResponse, error)

func (UnimplementedGoferServer) PutRunObject 

func (UnimplementedGoferServer) PutRunObject(context.Context, *PutRunObjectRequest) (*PutRunObjectResponse, error)

func (UnimplementedGoferServer) RemoveRegistryAuth 

func (UnimplementedGoferServer) RemoveRegistryAuth(context.Context, *RemoveRegistryAuthRequest) (*RemoveRegistryAuthResponse, error)

func (UnimplementedGoferServer) RepairOrphan 

func (UnimplementedGoferServer) RepairOrphan(context.Context, *RepairOrphanRequest) (*RepairOrphanResponse, error)

func (UnimplementedGoferServer) RetryRun 

func (UnimplementedGoferServer) RetryRun(context.Context, *RetryRunRequest) (*RetryRunResponse, error)

func (UnimplementedGoferServer) StartRun 

func (UnimplementedGoferServer) StartRun(context.Context, *StartRunRequest) (*StartRunResponse, error)

func (UnimplementedGoferServer) ToggleEventIngress 

func (UnimplementedGoferServer) ToggleEventIngress(context.Context, *ToggleEventIngressRequest) (*ToggleEventIngressResponse, error)

func (UnimplementedGoferServer) UpdateNamespace 

func (UnimplementedGoferServer) UpdateNamespace(context.Context, *UpdateNamespaceRequest) (*UpdateNamespaceResponse, error)

func (UnimplementedGoferServer) UpdatePipelineByURL 

func (UnimplementedGoferServer) UpdatePipelineByURL(context.Context, *UpdatePipelineByURLRequest) (*UpdatePipelineByURLResponse, error)

func (UnimplementedGoferServer) UpdatePipelineRaw 

func (UnimplementedGoferServer) UpdatePipelineRaw(context.Context, *UpdatePipelineRawRequest) (*UpdatePipelineRawResponse, error)

type UnsafeGoferServer 

type UnsafeGoferServer interface {
	// contains filtered or unexported methods
}

UnsafeGoferServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to GoferServer will result in compilation errors.

type UpdateNamespaceRequest 

type UpdateNamespaceRequest struct {
	Id          string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name        string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateNamespaceRequest) Descriptor deprecated 

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

Deprecated: Use UpdateNamespaceRequest.ProtoReflect.Descriptor instead.

func (*UpdateNamespaceRequest) GetDescription 

func (x *UpdateNamespaceRequest) GetDescription() string

func (*UpdateNamespaceRequest) GetId 

func (x *UpdateNamespaceRequest) GetId() string

func (*UpdateNamespaceRequest) GetName 

func (x *UpdateNamespaceRequest) GetName() string

func (*UpdateNamespaceRequest) ProtoMessage 

func (*UpdateNamespaceRequest) ProtoMessage()

func (*UpdateNamespaceRequest) ProtoReflect 

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

func (*UpdateNamespaceRequest) Reset 

func (x *UpdateNamespaceRequest) Reset()

func (*UpdateNamespaceRequest) String 

func (x *UpdateNamespaceRequest) String() string

type UpdateNamespaceResponse 

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

func (*UpdateNamespaceResponse) Descriptor deprecated 

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

Deprecated: Use UpdateNamespaceResponse.ProtoReflect.Descriptor instead.

func (*UpdateNamespaceResponse) GetNamespace 

func (x *UpdateNamespaceResponse) GetNamespace() *Namespace

func (*UpdateNamespaceResponse) ProtoMessage 

func (*UpdateNamespaceResponse) ProtoMessage()

func (*UpdateNamespaceResponse) ProtoReflect 

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

func (*UpdateNamespaceResponse) Reset 

func (x *UpdateNamespaceResponse) Reset()

func (*UpdateNamespaceResponse) String 

func (x *UpdateNamespaceResponse) String() string

type UpdatePipelineByURLRequest 

type UpdatePipelineByURLRequest struct {
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` // Unique namespace identifier
	Id          string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`                                      // Unique namespace identifier
	// url represents the remote location where the pipeline configuration file
	// exists. This parameter takes urls in the form of hashicorp's
	// go-getter(https://github.com/hashicorp/go-getter#general-all-protocols).
	// This means that is supports a wide array of possibilities for remote
	// locations.
	// The most common use case is simply pointing to a file or folder within
	// remote source control:
	//    folder: `"github.com/clintjedwards/gofer.git//gofer"`
	//    file: `"github.com/clintjedwards/gofer.git//gofer.hcl"`
	Url string `protobuf:"bytes,3,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdatePipelineByURLRequest) Descriptor deprecated 

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

Deprecated: Use UpdatePipelineByURLRequest.ProtoReflect.Descriptor instead.

func (*UpdatePipelineByURLRequest) GetId 

func (x *UpdatePipelineByURLRequest) GetId() string

func (*UpdatePipelineByURLRequest) GetNamespaceId 

func (x *UpdatePipelineByURLRequest) GetNamespaceId() string

func (*UpdatePipelineByURLRequest) GetUrl 

func (x *UpdatePipelineByURLRequest) GetUrl() string

func (*UpdatePipelineByURLRequest) ProtoMessage 

func (*UpdatePipelineByURLRequest) ProtoMessage()

func (*UpdatePipelineByURLRequest) ProtoReflect 

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

func (*UpdatePipelineByURLRequest) Reset 

func (x *UpdatePipelineByURLRequest) Reset()

func (*UpdatePipelineByURLRequest) String 

func (x *UpdatePipelineByURLRequest) String() string

type UpdatePipelineByURLResponse 

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

func (*UpdatePipelineByURLResponse) Descriptor deprecated 

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

Deprecated: Use UpdatePipelineByURLResponse.ProtoReflect.Descriptor instead.

func (*UpdatePipelineByURLResponse) GetPipeline 

func (x *UpdatePipelineByURLResponse) GetPipeline() *Pipeline

func (*UpdatePipelineByURLResponse) ProtoMessage 

func (*UpdatePipelineByURLResponse) ProtoMessage()

func (*UpdatePipelineByURLResponse) ProtoReflect 

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

func (*UpdatePipelineByURLResponse) Reset 

func (x *UpdatePipelineByURLResponse) Reset()

func (*UpdatePipelineByURLResponse) String 

func (x *UpdatePipelineByURLResponse) String() string

type UpdatePipelineRawRequest 

type UpdatePipelineRawRequest struct {
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` // Unique namespace identifier
	Id          string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`                                      // Unique identifier
	// Gofer pipeline config file byte string.
	Content []byte `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
	// path is a metadata parameter to where the pipeline file might be stored.
	// For example: for a command line application using this endpoint, the path
	// here might be the path of the pipeline file on the user's machine.
	// For a foreign API using this endpoint, the path could be something related
	// to endpoint responsible for creating the pipeline file.
	// This parameter is not used for anything particularly important and only
	// used for documentation purposes for the user.
	Path string `protobuf:"bytes,4,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdatePipelineRawRequest) Descriptor deprecated 

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

Deprecated: Use UpdatePipelineRawRequest.ProtoReflect.Descriptor instead.

func (*UpdatePipelineRawRequest) GetContent 

func (x *UpdatePipelineRawRequest) GetContent() []byte

func (*UpdatePipelineRawRequest) GetId 

func (x *UpdatePipelineRawRequest) GetId() string

func (*UpdatePipelineRawRequest) GetNamespaceId 

func (x *UpdatePipelineRawRequest) GetNamespaceId() string

func (*UpdatePipelineRawRequest) GetPath 

func (x *UpdatePipelineRawRequest) GetPath() string

func (*UpdatePipelineRawRequest) ProtoMessage 

func (*UpdatePipelineRawRequest) ProtoMessage()

func (*UpdatePipelineRawRequest) ProtoReflect 

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

func (*UpdatePipelineRawRequest) Reset 

func (x *UpdatePipelineRawRequest) Reset()

func (*UpdatePipelineRawRequest) String 

func (x *UpdatePipelineRawRequest) String() string

type UpdatePipelineRawResponse 

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

func (*UpdatePipelineRawResponse) Descriptor deprecated 

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

Deprecated: Use UpdatePipelineRawResponse.ProtoReflect.Descriptor instead.

func (*UpdatePipelineRawResponse) GetPipeline 

func (x *UpdatePipelineRawResponse) GetPipeline() *Pipeline

func (*UpdatePipelineRawResponse) ProtoMessage 

func (*UpdatePipelineRawResponse) ProtoMessage()

func (*UpdatePipelineRawResponse) ProtoReflect 

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

func (*UpdatePipelineRawResponse) Reset 

func (x *UpdatePipelineRawResponse) Reset()

func (*UpdatePipelineRawResponse) String 

func (x *UpdatePipelineRawResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.