proto

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Feb 22, 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 (
	PipelineTriggerConfig_State_name = map[int32]string{
		0: "UNKNOWN",
		1: "ACTIVE",
		2: "DISABLED",
		3: "UNSUPPORTED",
	}
	PipelineTriggerConfig_State_value = map[string]int32{
		"UNKNOWN":     0,
		"ACTIVE":      1,
		"DISABLED":    2,
		"UNSUPPORTED": 3,
	}
)

Enum value maps for PipelineTriggerConfig_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 (
	EventType_name = map[int32]string{
		0:  "UNKNOWN_EVENT_TYPE",
		1:  "CREATED_NAMESPACE",
		5:  "DISABLED_PIPELINE",
		6:  "ENABLED_PIPELINE",
		7:  "CREATED_PIPELINE",
		8:  "ABANDONED_PIPELINE",
		10: "STARTED_RUN",
		11: "COMPLETED_RUN",
		15: "STARTED_TASK_RUN",
		16: "SCHEDULED_TASK_RUN",
		17: "COMPLETED_TASK_RUN",
		20: "FIRED_TRIGGER",
		21: "PROCESSED_TRIGGER",
		22: "RESOLVED_TRIGGER",
	}
	EventType_value = map[string]int32{
		"UNKNOWN_EVENT_TYPE": 0,
		"CREATED_NAMESPACE":  1,
		"DISABLED_PIPELINE":  5,
		"ENABLED_PIPELINE":   6,
		"CREATED_PIPELINE":   7,
		"ABANDONED_PIPELINE": 8,
		"STARTED_RUN":        10,
		"COMPLETED_RUN":      11,
		"STARTED_TASK_RUN":   15,
		"SCHEDULED_TASK_RUN": 16,
		"COMPLETED_TASK_RUN": 17,
		"FIRED_TRIGGER":      20,
		"PROCESSED_TRIGGER":  21,
		"RESOLVED_TRIGGER":   22,
	}
)

Enum value maps for EventType.

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 (
	EventCompletedRun_State_name = map[int32]string{
		0: "UNKNOWN",
		1: "PROCESSING",
		2: "WAITING",
		3: "RUNNING",
		4: "FAILED",
		5: "SUCCESS",
		6: "CANCELLED",
	}
	EventCompletedRun_State_value = map[string]int32{
		"UNKNOWN":    0,
		"PROCESSING": 1,
		"WAITING":    2,
		"RUNNING":    3,
		"FAILED":     4,
		"SUCCESS":    5,
		"CANCELLED":  6,
	}
)

Enum value maps for EventCompletedRun_State.

View Source 
var (
	EventCompletedTaskRun_State_name = map[int32]string{
		0: "UNKNOWN",
		1: "PROCESSING",
		2: "WAITING",
		3: "RUNNING",
		4: "FAILED",
		5: "SUCCESS",
		6: "CANCELLED",
		7: "SKIPPED",
	}
	EventCompletedTaskRun_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 EventCompletedTaskRun_State.

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_events_proto protoreflect.FileDescriptor
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
View Source 
var Gofer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.Gofer",
	HandlerType: (*GoferServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListNamespaces",
			Handler:    _Gofer_ListNamespaces_Handler,
		},
		{
			MethodName: "CreateNamespace",
			Handler:    _Gofer_CreateNamespace_Handler,
		},
		{
			MethodName: "GetNamespace",
			Handler:    _Gofer_GetNamespace_Handler,
		},
		{
			MethodName: "UpdateNamespace",
			Handler:    _Gofer_UpdateNamespace_Handler,
		},
		{
			MethodName: "DeleteNamespace",
			Handler:    _Gofer_DeleteNamespace_Handler,
		},
		{
			MethodName: "GetPipeline",
			Handler:    _Gofer_GetPipeline_Handler,
		},
		{
			MethodName: "ListPipelines",
			Handler:    _Gofer_ListPipelines_Handler,
		},
		{
			MethodName: "EnablePipeline",
			Handler:    _Gofer_EnablePipeline_Handler,
		},
		{
			MethodName: "DisablePipeline",
			Handler:    _Gofer_DisablePipeline_Handler,
		},
		{
			MethodName: "CreatePipelineRaw",
			Handler:    _Gofer_CreatePipelineRaw_Handler,
		},
		{
			MethodName: "CreatePipelineByURL",
			Handler:    _Gofer_CreatePipelineByURL_Handler,
		},
		{
			MethodName: "UpdatePipelineRaw",
			Handler:    _Gofer_UpdatePipelineRaw_Handler,
		},
		{
			MethodName: "UpdatePipelineByURL",
			Handler:    _Gofer_UpdatePipelineByURL_Handler,
		},
		{
			MethodName: "AbandonPipeline",
			Handler:    _Gofer_AbandonPipeline_Handler,
		},
		{
			MethodName: "GetTrigger",
			Handler:    _Gofer_GetTrigger_Handler,
		},
		{
			MethodName: "ListTriggers",
			Handler:    _Gofer_ListTriggers_Handler,
		},
		{
			MethodName: "GetEvent",
			Handler:    _Gofer_GetEvent_Handler,
		},
		{
			MethodName: "GetRun",
			Handler:    _Gofer_GetRun_Handler,
		},
		{
			MethodName: "BatchGetRuns",
			Handler:    _Gofer_BatchGetRuns_Handler,
		},
		{
			MethodName: "ListRuns",
			Handler:    _Gofer_ListRuns_Handler,
		},
		{
			MethodName: "StartRun",
			Handler:    _Gofer_StartRun_Handler,
		},
		{
			MethodName: "RetryRun",
			Handler:    _Gofer_RetryRun_Handler,
		},
		{
			MethodName: "CancelRun",
			Handler:    _Gofer_CancelRun_Handler,
		},
		{
			MethodName: "CancelAllRuns",
			Handler:    _Gofer_CancelAllRuns_Handler,
		},
		{
			MethodName: "GetTaskRun",
			Handler:    _Gofer_GetTaskRun_Handler,
		},
		{
			MethodName: "ListTaskRuns",
			Handler:    _Gofer_ListTaskRuns_Handler,
		},
		{
			MethodName: "CancelTaskRun",
			Handler:    _Gofer_CancelTaskRun_Handler,
		},
		{
			MethodName: "DeleteTaskRunLogs",
			Handler:    _Gofer_DeleteTaskRunLogs_Handler,
		},
		{
			MethodName: "GetPipelineObject",
			Handler:    _Gofer_GetPipelineObject_Handler,
		},
		{
			MethodName: "PutPipelineObject",
			Handler:    _Gofer_PutPipelineObject_Handler,
		},
		{
			MethodName: "DeletePipelineObject",
			Handler:    _Gofer_DeletePipelineObject_Handler,
		},
		{
			MethodName: "GetRunObject",
			Handler:    _Gofer_GetRunObject_Handler,
		},
		{
			MethodName: "PutRunObject",
			Handler:    _Gofer_PutRunObject_Handler,
		},
		{
			MethodName: "DeleteRunObject",
			Handler:    _Gofer_DeleteRunObject_Handler,
		},
		{
			MethodName: "GetSecret",
			Handler:    _Gofer_GetSecret_Handler,
		},
		{
			MethodName: "PutSecret",
			Handler:    _Gofer_PutSecret_Handler,
		},
		{
			MethodName: "DeleteSecret",
			Handler:    _Gofer_DeleteSecret_Handler,
		},
		{
			MethodName: "GetSystemInfo",
			Handler:    _Gofer_GetSystemInfo_Handler,
		},
		{
			MethodName: "RepairOrphan",
			Handler:    _Gofer_RepairOrphan_Handler,
		},
		{
			MethodName: "ToggleEventIngress",
			Handler:    _Gofer_ToggleEventIngress_Handler,
		},
		{
			MethodName: "CreateToken",
			Handler:    _Gofer_CreateToken_Handler,
		},
		{
			MethodName: "BootstrapToken",
			Handler:    _Gofer_BootstrapToken_Handler,
		},
		{
			MethodName: "GetToken",
			Handler:    _Gofer_GetToken_Handler,
		},
		{
			MethodName: "DeleteToken",
			Handler:    _Gofer_DeleteToken_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ListEvents",
			Handler:       _Gofer_ListEvents_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetTaskRunLogs",
			Handler:       _Gofer_GetTaskRunLogs_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "gofer.proto",
}

Gofer_ServiceDesc is the grpc.ServiceDesc for Gofer service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

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 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 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 DeleteSecretRequest added in v0.0.3 

type DeleteSecretRequest 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 (*DeleteSecretRequest) Descriptor deprecated added in v0.0.3 

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

Deprecated: Use DeleteSecretRequest.ProtoReflect.Descriptor instead.

func (*DeleteSecretRequest) GetKey added in v0.0.3 

func (x *DeleteSecretRequest) GetKey() string

func (*DeleteSecretRequest) GetNamespaceId added in v0.0.3 

func (x *DeleteSecretRequest) GetNamespaceId() string

func (*DeleteSecretRequest) GetPipelineId added in v0.0.3 

func (x *DeleteSecretRequest) GetPipelineId() string

func (*DeleteSecretRequest) ProtoMessage added in v0.0.3 

func (*DeleteSecretRequest) ProtoMessage()

func (*DeleteSecretRequest) ProtoReflect added in v0.0.3 

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

func (*DeleteSecretRequest) Reset added in v0.0.3 

func (x *DeleteSecretRequest) Reset()

func (*DeleteSecretRequest) String added in v0.0.3 

func (x *DeleteSecretRequest) String() string

type DeleteSecretResponse added in v0.0.3 

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

func (*DeleteSecretResponse) Descriptor deprecated added in v0.0.3 

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

Deprecated: Use DeleteSecretResponse.ProtoReflect.Descriptor instead.

func (*DeleteSecretResponse) ProtoMessage added in v0.0.3 

func (*DeleteSecretResponse) ProtoMessage()

func (*DeleteSecretResponse) ProtoReflect added in v0.0.3 

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

func (*DeleteSecretResponse) Reset added in v0.0.3 

func (x *DeleteSecretResponse) Reset()

func (*DeleteSecretResponse) String added in v0.0.3 

func (x *DeleteSecretResponse) 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 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 EventAbandonedPipeline added in v0.1.0 

type EventAbandonedPipeline struct {
	Metadata    *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	NamespaceId string    `protobuf:"bytes,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	PipelineId  string    `protobuf:"bytes,3,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	// contains filtered or unexported fields
}

func (*EventAbandonedPipeline) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use EventAbandonedPipeline.ProtoReflect.Descriptor instead.

func (*EventAbandonedPipeline) GetMetadata added in v0.1.0 

func (x *EventAbandonedPipeline) GetMetadata() *Metadata

func (*EventAbandonedPipeline) GetNamespaceId added in v0.1.0 

func (x *EventAbandonedPipeline) GetNamespaceId() string

func (*EventAbandonedPipeline) GetPipelineId added in v0.1.0 

func (x *EventAbandonedPipeline) GetPipelineId() string

func (*EventAbandonedPipeline) ProtoMessage added in v0.1.0 

func (*EventAbandonedPipeline) ProtoMessage()

func (*EventAbandonedPipeline) ProtoReflect added in v0.1.0 

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

func (*EventAbandonedPipeline) Reset added in v0.1.0 

func (x *EventAbandonedPipeline) Reset()

func (*EventAbandonedPipeline) String added in v0.1.0 

func (x *EventAbandonedPipeline) String() string

type EventCompletedRun added in v0.1.0 

type EventCompletedRun struct {
	Metadata    *Metadata               `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	NamespaceId string                  `protobuf:"bytes,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	PipelineId  string                  `protobuf:"bytes,3,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	RunId       int64                   `protobuf:"varint,4,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	State       EventCompletedRun_State `protobuf:"varint,5,opt,name=state,proto3,enum=proto.EventCompletedRun_State" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*EventCompletedRun) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use EventCompletedRun.ProtoReflect.Descriptor instead.

func (*EventCompletedRun) GetMetadata added in v0.1.0 

func (x *EventCompletedRun) GetMetadata() *Metadata

func (*EventCompletedRun) GetNamespaceId added in v0.1.0 

func (x *EventCompletedRun) GetNamespaceId() string

func (*EventCompletedRun) GetPipelineId added in v0.1.0 

func (x *EventCompletedRun) GetPipelineId() string

func (*EventCompletedRun) GetRunId added in v0.1.0 

func (x *EventCompletedRun) GetRunId() int64

func (*EventCompletedRun) GetState added in v0.1.0 

func (x *EventCompletedRun) GetState() EventCompletedRun_State

func (*EventCompletedRun) ProtoMessage added in v0.1.0 

func (*EventCompletedRun) ProtoMessage()

func (*EventCompletedRun) ProtoReflect added in v0.1.0 

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

func (*EventCompletedRun) Reset added in v0.1.0 

func (x *EventCompletedRun) Reset()

func (*EventCompletedRun) String added in v0.1.0 

func (x *EventCompletedRun) String() string

type EventCompletedRun_State added in v0.1.0 

type EventCompletedRun_State int32
const (
	EventCompletedRun_UNKNOWN    EventCompletedRun_State = 0
	EventCompletedRun_PROCESSING EventCompletedRun_State = 1
	EventCompletedRun_WAITING    EventCompletedRun_State = 2
	EventCompletedRun_RUNNING    EventCompletedRun_State = 3
	EventCompletedRun_FAILED     EventCompletedRun_State = 4
	EventCompletedRun_SUCCESS    EventCompletedRun_State = 5
	EventCompletedRun_CANCELLED  EventCompletedRun_State = 6
)

func (EventCompletedRun_State) Descriptor added in v0.1.0 

func (EventCompletedRun_State) Descriptor() protoreflect.EnumDescriptor

func (EventCompletedRun_State) Enum added in v0.1.0 

func (x EventCompletedRun_State) Enum() *EventCompletedRun_State

func (EventCompletedRun_State) EnumDescriptor deprecated added in v0.1.0 

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

Deprecated: Use EventCompletedRun_State.Descriptor instead.

func (EventCompletedRun_State) Number added in v0.1.0 

func (x EventCompletedRun_State) Number() protoreflect.EnumNumber

func (EventCompletedRun_State) String added in v0.1.0 

func (x EventCompletedRun_State) String() string

func (EventCompletedRun_State) Type added in v0.1.0 

func (EventCompletedRun_State) Type() protoreflect.EnumType

type EventCompletedTaskRun added in v0.1.0 

type EventCompletedTaskRun struct {
	Metadata    *Metadata                   `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	NamespaceId string                      `protobuf:"bytes,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	PipelineId  string                      `protobuf:"bytes,3,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	RunId       int64                       `protobuf:"varint,4,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	TaskRunId   string                      `protobuf:"bytes,5,opt,name=task_run_id,json=taskRunId,proto3" json:"task_run_id,omitempty"`
	State       EventCompletedTaskRun_State `protobuf:"varint,6,opt,name=state,proto3,enum=proto.EventCompletedTaskRun_State" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*EventCompletedTaskRun) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use EventCompletedTaskRun.ProtoReflect.Descriptor instead.

func (*EventCompletedTaskRun) GetMetadata added in v0.1.0 

func (x *EventCompletedTaskRun) GetMetadata() *Metadata

func (*EventCompletedTaskRun) GetNamespaceId added in v0.1.0 

func (x *EventCompletedTaskRun) GetNamespaceId() string

func (*EventCompletedTaskRun) GetPipelineId added in v0.1.0 

func (x *EventCompletedTaskRun) GetPipelineId() string

func (*EventCompletedTaskRun) GetRunId added in v0.1.0 

func (x *EventCompletedTaskRun) GetRunId() int64

func (*EventCompletedTaskRun) GetState added in v0.1.0 

func (x *EventCompletedTaskRun) GetState() EventCompletedTaskRun_State

func (*EventCompletedTaskRun) GetTaskRunId added in v0.1.0 

func (x *EventCompletedTaskRun) GetTaskRunId() string

func (*EventCompletedTaskRun) ProtoMessage added in v0.1.0 

func (*EventCompletedTaskRun) ProtoMessage()

func (*EventCompletedTaskRun) ProtoReflect added in v0.1.0 

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

func (*EventCompletedTaskRun) Reset added in v0.1.0 

func (x *EventCompletedTaskRun) Reset()

func (*EventCompletedTaskRun) String added in v0.1.0 

func (x *EventCompletedTaskRun) String() string

type EventCompletedTaskRun_State added in v0.1.0 

type EventCompletedTaskRun_State int32
const (
	EventCompletedTaskRun_UNKNOWN    EventCompletedTaskRun_State = 0
	EventCompletedTaskRun_PROCESSING EventCompletedTaskRun_State = 1
	EventCompletedTaskRun_WAITING    EventCompletedTaskRun_State = 2
	EventCompletedTaskRun_RUNNING    EventCompletedTaskRun_State = 3
	EventCompletedTaskRun_FAILED     EventCompletedTaskRun_State = 4
	EventCompletedTaskRun_SUCCESS    EventCompletedTaskRun_State = 5
	EventCompletedTaskRun_CANCELLED  EventCompletedTaskRun_State = 6
	EventCompletedTaskRun_SKIPPED    EventCompletedTaskRun_State = 7
)

func (EventCompletedTaskRun_State) Descriptor added in v0.1.0 

func (EventCompletedTaskRun_State) Descriptor() protoreflect.EnumDescriptor

func (EventCompletedTaskRun_State) Enum added in v0.1.0 

func (x EventCompletedTaskRun_State) Enum() *EventCompletedTaskRun_State

func (EventCompletedTaskRun_State) EnumDescriptor deprecated added in v0.1.0 

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

Deprecated: Use EventCompletedTaskRun_State.Descriptor instead.

func (EventCompletedTaskRun_State) Number added in v0.1.0 

func (x EventCompletedTaskRun_State) Number() protoreflect.EnumNumber

func (EventCompletedTaskRun_State) String added in v0.1.0 

func (x EventCompletedTaskRun_State) String() string

func (EventCompletedTaskRun_State) Type added in v0.1.0 

func (EventCompletedTaskRun_State) Type() protoreflect.EnumType

type EventCreatedNamespace added in v0.1.0 

type EventCreatedNamespace struct {
	Metadata    *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	NamespaceId string    `protobuf:"bytes,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	// contains filtered or unexported fields
}

func (*EventCreatedNamespace) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use EventCreatedNamespace.ProtoReflect.Descriptor instead.

func (*EventCreatedNamespace) GetMetadata added in v0.1.0 

func (x *EventCreatedNamespace) GetMetadata() *Metadata

func (*EventCreatedNamespace) GetNamespaceId added in v0.1.0 

func (x *EventCreatedNamespace) GetNamespaceId() string

func (*EventCreatedNamespace) ProtoMessage added in v0.1.0 

func (*EventCreatedNamespace) ProtoMessage()

func (*EventCreatedNamespace) ProtoReflect added in v0.1.0 

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

func (*EventCreatedNamespace) Reset added in v0.1.0 

func (x *EventCreatedNamespace) Reset()

func (*EventCreatedNamespace) String added in v0.1.0 

func (x *EventCreatedNamespace) String() string

type EventCreatedPipeline added in v0.1.0 

type EventCreatedPipeline struct {
	Metadata    *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	NamespaceId string    `protobuf:"bytes,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	PipelineId  string    `protobuf:"bytes,3,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	// contains filtered or unexported fields
}

func (*EventCreatedPipeline) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use EventCreatedPipeline.ProtoReflect.Descriptor instead.

func (*EventCreatedPipeline) GetMetadata added in v0.1.0 

func (x *EventCreatedPipeline) GetMetadata() *Metadata

func (*EventCreatedPipeline) GetNamespaceId added in v0.1.0 

func (x *EventCreatedPipeline) GetNamespaceId() string

func (*EventCreatedPipeline) GetPipelineId added in v0.1.0 

func (x *EventCreatedPipeline) GetPipelineId() string

func (*EventCreatedPipeline) ProtoMessage added in v0.1.0 

func (*EventCreatedPipeline) ProtoMessage()

func (*EventCreatedPipeline) ProtoReflect added in v0.1.0 

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

func (*EventCreatedPipeline) Reset added in v0.1.0 

func (x *EventCreatedPipeline) Reset()

func (*EventCreatedPipeline) String added in v0.1.0 

func (x *EventCreatedPipeline) String() string

type EventDisabledPipeline added in v0.1.0 

type EventDisabledPipeline struct {
	Metadata    *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	NamespaceId string    `protobuf:"bytes,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	PipelineId  string    `protobuf:"bytes,3,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	// contains filtered or unexported fields
}

func (*EventDisabledPipeline) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use EventDisabledPipeline.ProtoReflect.Descriptor instead.

func (*EventDisabledPipeline) GetMetadata added in v0.1.0 

func (x *EventDisabledPipeline) GetMetadata() *Metadata

func (*EventDisabledPipeline) GetNamespaceId added in v0.1.0 

func (x *EventDisabledPipeline) GetNamespaceId() string

func (*EventDisabledPipeline) GetPipelineId added in v0.1.0 

func (x *EventDisabledPipeline) GetPipelineId() string

func (*EventDisabledPipeline) ProtoMessage added in v0.1.0 

func (*EventDisabledPipeline) ProtoMessage()

func (*EventDisabledPipeline) ProtoReflect added in v0.1.0 

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

func (*EventDisabledPipeline) Reset added in v0.1.0 

func (x *EventDisabledPipeline) Reset()

func (*EventDisabledPipeline) String added in v0.1.0 

func (x *EventDisabledPipeline) String() string

type EventEnabledPipeline added in v0.1.0 

type EventEnabledPipeline struct {
	Metadata    *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	NamespaceId string    `protobuf:"bytes,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	PipelineId  string    `protobuf:"bytes,3,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	// contains filtered or unexported fields
}

func (*EventEnabledPipeline) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use EventEnabledPipeline.ProtoReflect.Descriptor instead.

func (*EventEnabledPipeline) GetMetadata added in v0.1.0 

func (x *EventEnabledPipeline) GetMetadata() *Metadata

func (*EventEnabledPipeline) GetNamespaceId added in v0.1.0 

func (x *EventEnabledPipeline) GetNamespaceId() string

func (*EventEnabledPipeline) GetPipelineId added in v0.1.0 

func (x *EventEnabledPipeline) GetPipelineId() string

func (*EventEnabledPipeline) ProtoMessage added in v0.1.0 

func (*EventEnabledPipeline) ProtoMessage()

func (*EventEnabledPipeline) ProtoReflect added in v0.1.0 

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

func (*EventEnabledPipeline) Reset added in v0.1.0 

func (x *EventEnabledPipeline) Reset()

func (*EventEnabledPipeline) String added in v0.1.0 

func (x *EventEnabledPipeline) String() string

type EventFiredTrigger added in v0.1.0 

type EventFiredTrigger struct {
	Metadata        *Metadata         `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Label           string            `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"`
	Pipeline        string            `protobuf:"bytes,3,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	Namespace       string            `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Result          *TriggerResult    `protobuf:"bytes,5,opt,name=result,proto3" json:"result,omitempty"`
	TriggerMetadata map[string]string `` /* 194-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*EventFiredTrigger) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use EventFiredTrigger.ProtoReflect.Descriptor instead.

func (*EventFiredTrigger) GetLabel added in v0.1.0 

func (x *EventFiredTrigger) GetLabel() string

func (*EventFiredTrigger) GetMetadata added in v0.1.0 

func (x *EventFiredTrigger) GetMetadata() *Metadata

func (*EventFiredTrigger) GetNamespace added in v0.1.0 

func (x *EventFiredTrigger) GetNamespace() string

func (*EventFiredTrigger) GetPipeline added in v0.1.0 

func (x *EventFiredTrigger) GetPipeline() string

func (*EventFiredTrigger) GetResult added in v0.1.0 

func (x *EventFiredTrigger) GetResult() *TriggerResult

func (*EventFiredTrigger) GetTriggerMetadata added in v0.1.0 

func (x *EventFiredTrigger) GetTriggerMetadata() map[string]string

func (*EventFiredTrigger) ProtoMessage added in v0.1.0 

func (*EventFiredTrigger) ProtoMessage()

func (*EventFiredTrigger) ProtoReflect added in v0.1.0 

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

func (*EventFiredTrigger) Reset added in v0.1.0 

func (x *EventFiredTrigger) Reset()

func (*EventFiredTrigger) String added in v0.1.0 

func (x *EventFiredTrigger) String() string

type EventProcessedTrigger added in v0.1.0 

type EventProcessedTrigger struct {
	Metadata        *Metadata         `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Label           string            `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"`
	Pipeline        string            `protobuf:"bytes,3,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	Namespace       string            `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Result          *TriggerResult    `protobuf:"bytes,5,opt,name=result,proto3" json:"result,omitempty"`
	TriggerMetadata map[string]string `` /* 194-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*EventProcessedTrigger) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use EventProcessedTrigger.ProtoReflect.Descriptor instead.

func (*EventProcessedTrigger) GetLabel added in v0.1.0 

func (x *EventProcessedTrigger) GetLabel() string

func (*EventProcessedTrigger) GetMetadata added in v0.1.0 

func (x *EventProcessedTrigger) GetMetadata() *Metadata

func (*EventProcessedTrigger) GetNamespace added in v0.1.0 

func (x *EventProcessedTrigger) GetNamespace() string

func (*EventProcessedTrigger) GetPipeline added in v0.1.0 

func (x *EventProcessedTrigger) GetPipeline() string

func (*EventProcessedTrigger) GetResult added in v0.1.0 

func (x *EventProcessedTrigger) GetResult() *TriggerResult

func (*EventProcessedTrigger) GetTriggerMetadata added in v0.1.0 

func (x *EventProcessedTrigger) GetTriggerMetadata() map[string]string

func (*EventProcessedTrigger) ProtoMessage added in v0.1.0 

func (*EventProcessedTrigger) ProtoMessage()

func (*EventProcessedTrigger) ProtoReflect added in v0.1.0 

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

func (*EventProcessedTrigger) Reset added in v0.1.0 

func (x *EventProcessedTrigger) Reset()

func (*EventProcessedTrigger) String added in v0.1.0 

func (x *EventProcessedTrigger) String() string

type EventResolvedTrigger added in v0.1.0 

type EventResolvedTrigger struct {
	Metadata        *Metadata         `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Label           string            `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"`
	Pipeline        string            `protobuf:"bytes,3,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	Namespace       string            `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Result          *TriggerResult    `protobuf:"bytes,5,opt,name=result,proto3" json:"result,omitempty"`
	TriggerMetadata map[string]string `` /* 194-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*EventResolvedTrigger) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use EventResolvedTrigger.ProtoReflect.Descriptor instead.

func (*EventResolvedTrigger) GetLabel added in v0.1.0 

func (x *EventResolvedTrigger) GetLabel() string

func (*EventResolvedTrigger) GetMetadata added in v0.1.0 

func (x *EventResolvedTrigger) GetMetadata() *Metadata

func (*EventResolvedTrigger) GetNamespace added in v0.1.0 

func (x *EventResolvedTrigger) GetNamespace() string

func (*EventResolvedTrigger) GetPipeline added in v0.1.0 

func (x *EventResolvedTrigger) GetPipeline() string

func (*EventResolvedTrigger) GetResult added in v0.1.0 

func (x *EventResolvedTrigger) GetResult() *TriggerResult

func (*EventResolvedTrigger) GetTriggerMetadata added in v0.1.0 

func (x *EventResolvedTrigger) GetTriggerMetadata() map[string]string

func (*EventResolvedTrigger) ProtoMessage added in v0.1.0 

func (*EventResolvedTrigger) ProtoMessage()

func (*EventResolvedTrigger) ProtoReflect added in v0.1.0 

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

func (*EventResolvedTrigger) Reset added in v0.1.0 

func (x *EventResolvedTrigger) Reset()

func (*EventResolvedTrigger) String added in v0.1.0 

func (x *EventResolvedTrigger) String() string

type EventScheduledTaskRun added in v0.1.0 

type EventScheduledTaskRun struct {
	Metadata    *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	NamespaceId string    `protobuf:"bytes,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	PipelineId  string    `protobuf:"bytes,3,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	RunId       int64     `protobuf:"varint,4,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	TaskRunId   string    `protobuf:"bytes,5,opt,name=task_run_id,json=taskRunId,proto3" json:"task_run_id,omitempty"`
	// contains filtered or unexported fields
}

func (*EventScheduledTaskRun) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use EventScheduledTaskRun.ProtoReflect.Descriptor instead.

func (*EventScheduledTaskRun) GetMetadata added in v0.1.0 

func (x *EventScheduledTaskRun) GetMetadata() *Metadata

func (*EventScheduledTaskRun) GetNamespaceId added in v0.1.0 

func (x *EventScheduledTaskRun) GetNamespaceId() string

func (*EventScheduledTaskRun) GetPipelineId added in v0.1.0 

func (x *EventScheduledTaskRun) GetPipelineId() string

func (*EventScheduledTaskRun) GetRunId added in v0.1.0 

func (x *EventScheduledTaskRun) GetRunId() int64

func (*EventScheduledTaskRun) GetTaskRunId added in v0.1.0 

func (x *EventScheduledTaskRun) GetTaskRunId() string

func (*EventScheduledTaskRun) ProtoMessage added in v0.1.0 

func (*EventScheduledTaskRun) ProtoMessage()

func (*EventScheduledTaskRun) ProtoReflect added in v0.1.0 

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

func (*EventScheduledTaskRun) Reset added in v0.1.0 

func (x *EventScheduledTaskRun) Reset()

func (*EventScheduledTaskRun) String added in v0.1.0 

func (x *EventScheduledTaskRun) String() string

type EventStartedRun added in v0.1.0 

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

func (*EventStartedRun) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use EventStartedRun.ProtoReflect.Descriptor instead.

func (*EventStartedRun) GetMetadata added in v0.1.0 

func (x *EventStartedRun) GetMetadata() *Metadata

func (*EventStartedRun) GetNamespaceId added in v0.1.0 

func (x *EventStartedRun) GetNamespaceId() string

func (*EventStartedRun) GetPipelineId added in v0.1.0 

func (x *EventStartedRun) GetPipelineId() string

func (*EventStartedRun) GetRunId added in v0.1.0 

func (x *EventStartedRun) GetRunId() int64

func (*EventStartedRun) ProtoMessage added in v0.1.0 

func (*EventStartedRun) ProtoMessage()

func (*EventStartedRun) ProtoReflect added in v0.1.0 

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

func (*EventStartedRun) Reset added in v0.1.0 

func (x *EventStartedRun) Reset()

func (*EventStartedRun) String added in v0.1.0 

func (x *EventStartedRun) String() string

type EventStartedTaskRun added in v0.1.0 

type EventStartedTaskRun struct {
	Metadata    *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	NamespaceId string    `protobuf:"bytes,2,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	PipelineId  string    `protobuf:"bytes,3,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	RunId       int64     `protobuf:"varint,4,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	TaskRunId   string    `protobuf:"bytes,5,opt,name=task_run_id,json=taskRunId,proto3" json:"task_run_id,omitempty"`
	// contains filtered or unexported fields
}

func (*EventStartedTaskRun) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use EventStartedTaskRun.ProtoReflect.Descriptor instead.

func (*EventStartedTaskRun) GetMetadata added in v0.1.0 

func (x *EventStartedTaskRun) GetMetadata() *Metadata

func (*EventStartedTaskRun) GetNamespaceId added in v0.1.0 

func (x *EventStartedTaskRun) GetNamespaceId() string

func (*EventStartedTaskRun) GetPipelineId added in v0.1.0 

func (x *EventStartedTaskRun) GetPipelineId() string

func (*EventStartedTaskRun) GetRunId added in v0.1.0 

func (x *EventStartedTaskRun) GetRunId() int64

func (*EventStartedTaskRun) GetTaskRunId added in v0.1.0 

func (x *EventStartedTaskRun) GetTaskRunId() string

func (*EventStartedTaskRun) ProtoMessage added in v0.1.0 

func (*EventStartedTaskRun) ProtoMessage()

func (*EventStartedTaskRun) ProtoReflect added in v0.1.0 

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

func (*EventStartedTaskRun) Reset added in v0.1.0 

func (x *EventStartedTaskRun) Reset()

func (*EventStartedTaskRun) String added in v0.1.0 

func (x *EventStartedTaskRun) String() string

type EventType added in v0.1.0 

type EventType int32
const (
	EventType_UNKNOWN_EVENT_TYPE EventType = 0
	EventType_CREATED_NAMESPACE  EventType = 1
	EventType_DISABLED_PIPELINE  EventType = 5
	EventType_ENABLED_PIPELINE   EventType = 6
	EventType_CREATED_PIPELINE   EventType = 7
	EventType_ABANDONED_PIPELINE EventType = 8
	EventType_STARTED_RUN        EventType = 10
	EventType_COMPLETED_RUN      EventType = 11
	EventType_STARTED_TASK_RUN   EventType = 15
	EventType_SCHEDULED_TASK_RUN EventType = 16
	EventType_COMPLETED_TASK_RUN EventType = 17
	EventType_FIRED_TRIGGER      EventType = 20
	EventType_PROCESSED_TRIGGER  EventType = 21
	EventType_RESOLVED_TRIGGER   EventType = 22
)

func (EventType) Descriptor added in v0.1.0 

func (EventType) Descriptor() protoreflect.EnumDescriptor

func (EventType) Enum added in v0.1.0 

func (x EventType) Enum() *EventType

func (EventType) EnumDescriptor deprecated added in v0.1.0 

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

Deprecated: Use EventType.Descriptor instead.

func (EventType) Number added in v0.1.0 

func (x EventType) Number() protoreflect.EnumNumber

func (EventType) String added in v0.1.0 

func (x EventType) String() string

func (EventType) Type added in v0.1.0 

func (EventType) Type() protoreflect.EnumType

type GetEventRequest added in v0.1.0 

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

func (*GetEventRequest) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use GetEventRequest.ProtoReflect.Descriptor instead.

func (*GetEventRequest) GetId added in v0.1.0 

func (x *GetEventRequest) GetId() int64

func (*GetEventRequest) ProtoMessage added in v0.1.0 

func (*GetEventRequest) ProtoMessage()

func (*GetEventRequest) ProtoReflect added in v0.1.0 

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

func (*GetEventRequest) Reset added in v0.1.0 

func (x *GetEventRequest) Reset()

func (*GetEventRequest) String added in v0.1.0 

func (x *GetEventRequest) String() string

type GetEventResponse added in v0.1.0 

type GetEventResponse struct {
	Kind EventType `protobuf:"varint,1,opt,name=kind,proto3,enum=proto.EventType" json:"kind,omitempty"`
	// Types that are assignable to Event:
	//	*GetEventResponse_CreatedNamespaceEvent
	//	*GetEventResponse_DisabledPipelineEvent
	//	*GetEventResponse_EnabledPipelineEvent
	//	*GetEventResponse_CreatedPipelineEvent
	//	*GetEventResponse_AbandonedPipelineEvent
	//	*GetEventResponse_StartedRunEvent
	//	*GetEventResponse_CompletedRunEvent
	//	*GetEventResponse_StartedTaskRunEvent
	//	*GetEventResponse_ScheduledTaskRunEvent
	//	*GetEventResponse_CompletedTaskRunEvent
	//	*GetEventResponse_FiredTriggerEvent
	//	*GetEventResponse_ProcessedTriggerEvent
	//	*GetEventResponse_ResolvedTriggerEvent
	Event isGetEventResponse_Event `protobuf_oneof:"event"`
	// contains filtered or unexported fields
}

func (*GetEventResponse) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use GetEventResponse.ProtoReflect.Descriptor instead.

func (*GetEventResponse) GetAbandonedPipelineEvent added in v0.1.0 

func (x *GetEventResponse) GetAbandonedPipelineEvent() *EventAbandonedPipeline

func (*GetEventResponse) GetCompletedRunEvent added in v0.1.0 

func (x *GetEventResponse) GetCompletedRunEvent() *EventCompletedRun

func (*GetEventResponse) GetCompletedTaskRunEvent added in v0.1.0 

func (x *GetEventResponse) GetCompletedTaskRunEvent() *EventCompletedTaskRun

func (*GetEventResponse) GetCreatedNamespaceEvent added in v0.1.0 

func (x *GetEventResponse) GetCreatedNamespaceEvent() *EventCreatedNamespace

func (*GetEventResponse) GetCreatedPipelineEvent added in v0.1.0 

func (x *GetEventResponse) GetCreatedPipelineEvent() *EventCreatedPipeline

func (*GetEventResponse) GetDisabledPipelineEvent added in v0.1.0 

func (x *GetEventResponse) GetDisabledPipelineEvent() *EventDisabledPipeline

func (*GetEventResponse) GetEnabledPipelineEvent added in v0.1.0 

func (x *GetEventResponse) GetEnabledPipelineEvent() *EventEnabledPipeline

func (*GetEventResponse) GetEvent added in v0.1.0 

func (m *GetEventResponse) GetEvent() isGetEventResponse_Event

func (*GetEventResponse) GetFiredTriggerEvent added in v0.1.0 

func (x *GetEventResponse) GetFiredTriggerEvent() *EventFiredTrigger

func (*GetEventResponse) GetKind added in v0.1.0 

func (x *GetEventResponse) GetKind() EventType

func (*GetEventResponse) GetProcessedTriggerEvent added in v0.1.0 

func (x *GetEventResponse) GetProcessedTriggerEvent() *EventProcessedTrigger

func (*GetEventResponse) GetResolvedTriggerEvent added in v0.1.0 

func (x *GetEventResponse) GetResolvedTriggerEvent() *EventResolvedTrigger

func (*GetEventResponse) GetScheduledTaskRunEvent added in v0.1.0 

func (x *GetEventResponse) GetScheduledTaskRunEvent() *EventScheduledTaskRun

func (*GetEventResponse) GetStartedRunEvent added in v0.1.0 

func (x *GetEventResponse) GetStartedRunEvent() *EventStartedRun

func (*GetEventResponse) GetStartedTaskRunEvent added in v0.1.0 

func (x *GetEventResponse) GetStartedTaskRunEvent() *EventStartedTaskRun

func (*GetEventResponse) ProtoMessage added in v0.1.0 

func (*GetEventResponse) ProtoMessage()

func (*GetEventResponse) ProtoReflect added in v0.1.0 

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

func (*GetEventResponse) Reset added in v0.1.0 

func (x *GetEventResponse) Reset()

func (*GetEventResponse) String added in v0.1.0 

func (x *GetEventResponse) String() string

type GetEventResponse_AbandonedPipelineEvent added in v0.1.0 

type GetEventResponse_AbandonedPipelineEvent struct {
	AbandonedPipelineEvent *EventAbandonedPipeline `protobuf:"bytes,8,opt,name=abandoned_pipeline_event,json=abandonedPipelineEvent,proto3,oneof"`
}

type GetEventResponse_CompletedRunEvent added in v0.1.0 

type GetEventResponse_CompletedRunEvent struct {
	CompletedRunEvent *EventCompletedRun `protobuf:"bytes,11,opt,name=completed_run_event,json=completedRunEvent,proto3,oneof"`
}

type GetEventResponse_CompletedTaskRunEvent added in v0.1.0 

type GetEventResponse_CompletedTaskRunEvent struct {
	CompletedTaskRunEvent *EventCompletedTaskRun `protobuf:"bytes,17,opt,name=completed_task_run_event,json=completedTaskRunEvent,proto3,oneof"`
}

type GetEventResponse_CreatedNamespaceEvent added in v0.1.0 

type GetEventResponse_CreatedNamespaceEvent struct {
	CreatedNamespaceEvent *EventCreatedNamespace `protobuf:"bytes,2,opt,name=created_namespace_event,json=createdNamespaceEvent,proto3,oneof"`
}

type GetEventResponse_CreatedPipelineEvent added in v0.1.0 

type GetEventResponse_CreatedPipelineEvent struct {
	CreatedPipelineEvent *EventCreatedPipeline `protobuf:"bytes,7,opt,name=created_pipeline_event,json=createdPipelineEvent,proto3,oneof"`
}

type GetEventResponse_DisabledPipelineEvent added in v0.1.0 

type GetEventResponse_DisabledPipelineEvent struct {
	DisabledPipelineEvent *EventDisabledPipeline `protobuf:"bytes,5,opt,name=disabled_pipeline_event,json=disabledPipelineEvent,proto3,oneof"`
}

type GetEventResponse_EnabledPipelineEvent added in v0.1.0 

type GetEventResponse_EnabledPipelineEvent struct {
	EnabledPipelineEvent *EventEnabledPipeline `protobuf:"bytes,6,opt,name=enabled_pipeline_event,json=enabledPipelineEvent,proto3,oneof"`
}

type GetEventResponse_FiredTriggerEvent added in v0.1.0 

type GetEventResponse_FiredTriggerEvent struct {
	FiredTriggerEvent *EventFiredTrigger `protobuf:"bytes,20,opt,name=fired_trigger_event,json=firedTriggerEvent,proto3,oneof"`
}

type GetEventResponse_ProcessedTriggerEvent added in v0.1.0 

type GetEventResponse_ProcessedTriggerEvent struct {
	ProcessedTriggerEvent *EventProcessedTrigger `protobuf:"bytes,21,opt,name=processed_trigger_event,json=processedTriggerEvent,proto3,oneof"`
}

type GetEventResponse_ResolvedTriggerEvent added in v0.1.0 

type GetEventResponse_ResolvedTriggerEvent struct {
	ResolvedTriggerEvent *EventResolvedTrigger `protobuf:"bytes,22,opt,name=resolved_trigger_event,json=resolvedTriggerEvent,proto3,oneof"`
}

type GetEventResponse_ScheduledTaskRunEvent added in v0.1.0 

type GetEventResponse_ScheduledTaskRunEvent struct {
	ScheduledTaskRunEvent *EventScheduledTaskRun `protobuf:"bytes,16,opt,name=scheduled_task_run_event,json=scheduledTaskRunEvent,proto3,oneof"`
}

type GetEventResponse_StartedRunEvent added in v0.1.0 

type GetEventResponse_StartedRunEvent struct {
	StartedRunEvent *EventStartedRun `protobuf:"bytes,10,opt,name=started_run_event,json=startedRunEvent,proto3,oneof"`
}

type GetEventResponse_StartedTaskRunEvent added in v0.1.0 

type GetEventResponse_StartedTaskRunEvent struct {
	StartedTaskRunEvent *EventStartedTaskRun `protobuf:"bytes,15,opt,name=started_task_run_event,json=startedTaskRunEvent,proto3,oneof"`
}

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 GetSecretRequest added in v0.0.3 

type GetSecretRequest 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 (*GetSecretRequest) Descriptor deprecated added in v0.0.3 

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

Deprecated: Use GetSecretRequest.ProtoReflect.Descriptor instead.

func (*GetSecretRequest) GetKey added in v0.0.3 

func (x *GetSecretRequest) GetKey() string

func (*GetSecretRequest) GetNamespaceId added in v0.0.3 

func (x *GetSecretRequest) GetNamespaceId() string

func (*GetSecretRequest) GetPipelineId added in v0.0.3 

func (x *GetSecretRequest) GetPipelineId() string

func (*GetSecretRequest) ProtoMessage added in v0.0.3 

func (*GetSecretRequest) ProtoMessage()

func (*GetSecretRequest) ProtoReflect added in v0.0.3 

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

func (*GetSecretRequest) Reset added in v0.0.3 

func (x *GetSecretRequest) Reset()

func (*GetSecretRequest) String added in v0.0.3 

func (x *GetSecretRequest) String() string

type GetSecretResponse added in v0.0.3 

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

func (*GetSecretResponse) Descriptor deprecated added in v0.0.3 

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

Deprecated: Use GetSecretResponse.ProtoReflect.Descriptor instead.

func (*GetSecretResponse) GetContent added in v0.0.3 

func (x *GetSecretResponse) GetContent() string

func (*GetSecretResponse) ProtoMessage added in v0.0.3 

func (*GetSecretResponse) ProtoMessage()

func (*GetSecretResponse) ProtoReflect added in v0.0.3 

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

func (*GetSecretResponse) Reset added in v0.0.3 

func (x *GetSecretResponse) Reset()

func (*GetSecretResponse) String added in v0.0.3 

func (x *GetSecretResponse) 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 {
	Commit                  string `protobuf:"bytes,1,opt,name=commit,proto3" json:"commit,omitempty"`
	DevmodeEnabled          bool   `protobuf:"varint,2,opt,name=devmode_enabled,json=devmodeEnabled,proto3" json:"devmode_enabled,omitempty"`
	FrontendEnabled         bool   `protobuf:"varint,3,opt,name=frontend_enabled,json=frontendEnabled,proto3" json:"frontend_enabled,omitempty"`
	Version                 string `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	IgnorePipelineRunEvents bool   `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetSystemInfoResponse) Descriptor deprecated 

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

Deprecated: Use GetSystemInfoResponse.ProtoReflect.Descriptor instead.

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) GetIgnorePipelineRunEvents added in v0.1.0 

func (x *GetSystemInfoResponse) GetIgnorePipelineRunEvents() 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 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)
	// GetEvent returns the details of a single event.
	GetEvent(ctx context.Context, in *GetEventRequest, opts ...grpc.CallOption) (*GetEventResponse, error)
	// ListEvents returns a streaming list of all events, ordered by
	// oldest to newest.
	ListEvents(ctx context.Context, in *ListEventsRequest, opts ...grpc.CallOption) (Gofer_ListEventsClient, 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)
	// GetSecret returns a single secret by pipeline ID and key.
	GetSecret(ctx context.Context, in *GetSecretRequest, opts ...grpc.CallOption) (*GetSecretResponse, error)
	// PutSecret uploads a single secret by pipeline ID and key.
	PutSecret(ctx context.Context, in *PutSecretRequest, opts ...grpc.CallOption) (*PutSecretResponse, error)
	// DeleteSecret removes a single secret by pipeline ID and
	// key.
	DeleteSecret(ctx context.Context, in *DeleteSecretRequest, opts ...grpc.CallOption) (*DeleteSecretResponse, 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)
}

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)
	// GetEvent returns the details of a single event.
	GetEvent(context.Context, *GetEventRequest) (*GetEventResponse, error)
	// ListEvents returns a streaming list of all events, ordered by
	// oldest to newest.
	ListEvents(*ListEventsRequest, Gofer_ListEventsServer) 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)
	// GetSecret returns a single secret by pipeline ID and key.
	GetSecret(context.Context, *GetSecretRequest) (*GetSecretResponse, error)
	// PutSecret uploads a single secret by pipeline ID and key.
	PutSecret(context.Context, *PutSecretRequest) (*PutSecretResponse, error)
	// DeleteSecret removes a single secret by pipeline ID and
	// key.
	DeleteSecret(context.Context, *DeleteSecretRequest) (*DeleteSecretResponse, 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)
	// 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 Gofer_ListEventsClient added in v0.1.0 

type Gofer_ListEventsClient interface {
	Recv() (*ListEventsResponse, error)
	grpc.ClientStream
}

type Gofer_ListEventsServer added in v0.1.0 

type Gofer_ListEventsServer interface {
	Send(*ListEventsResponse) error
	grpc.ServerStream
}

type ListEventsRequest added in v0.1.0 

type ListEventsRequest struct {

	// defaults to false; meaning oldest to newest events by default.
	Reverse bool `protobuf:"varint,1,opt,name=reverse,proto3" json:"reverse,omitempty"`
	// Tell Gofer to continually stream new events instead of closing the stream
	// after it gets to the end.
	Follow bool `protobuf:"varint,2,opt,name=follow,proto3" json:"follow,omitempty"`
	// contains filtered or unexported fields
}

func (*ListEventsRequest) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use ListEventsRequest.ProtoReflect.Descriptor instead.

func (*ListEventsRequest) GetFollow added in v0.1.0 

func (x *ListEventsRequest) GetFollow() bool

func (*ListEventsRequest) GetReverse added in v0.1.0 

func (x *ListEventsRequest) GetReverse() bool

func (*ListEventsRequest) ProtoMessage added in v0.1.0 

func (*ListEventsRequest) ProtoMessage()

func (*ListEventsRequest) ProtoReflect added in v0.1.0 

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

func (*ListEventsRequest) Reset added in v0.1.0 

func (x *ListEventsRequest) Reset()

func (*ListEventsRequest) String added in v0.1.0 

func (x *ListEventsRequest) String() string

type ListEventsResponse added in v0.1.0 

type ListEventsResponse struct {
	Kind EventType `protobuf:"varint,1,opt,name=kind,proto3,enum=proto.EventType" json:"kind,omitempty"`
	// Types that are assignable to Event:
	//	*ListEventsResponse_CreatedNamespaceEvent
	//	*ListEventsResponse_DisabledPipelineEvent
	//	*ListEventsResponse_EnabledPipelineEvent
	//	*ListEventsResponse_CreatedPipelineEvent
	//	*ListEventsResponse_AbandonedPipelineEvent
	//	*ListEventsResponse_StartedRunEvent
	//	*ListEventsResponse_CompletedRunEvent
	//	*ListEventsResponse_StartedTaskRunEvent
	//	*ListEventsResponse_ScheduledTaskRunEvent
	//	*ListEventsResponse_CompletedTaskRunEvent
	//	*ListEventsResponse_FiredTriggerEvent
	//	*ListEventsResponse_ProcessedTriggerEvent
	//	*ListEventsResponse_ResolvedTriggerEvent
	Event isListEventsResponse_Event `protobuf_oneof:"event"`
	// contains filtered or unexported fields
}

func (*ListEventsResponse) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use ListEventsResponse.ProtoReflect.Descriptor instead.

func (*ListEventsResponse) GetAbandonedPipelineEvent added in v0.1.0 

func (x *ListEventsResponse) GetAbandonedPipelineEvent() *EventAbandonedPipeline

func (*ListEventsResponse) GetCompletedRunEvent added in v0.1.0 

func (x *ListEventsResponse) GetCompletedRunEvent() *EventCompletedRun

func (*ListEventsResponse) GetCompletedTaskRunEvent added in v0.1.0 

func (x *ListEventsResponse) GetCompletedTaskRunEvent() *EventCompletedTaskRun

func (*ListEventsResponse) GetCreatedNamespaceEvent added in v0.1.0 

func (x *ListEventsResponse) GetCreatedNamespaceEvent() *EventCreatedNamespace

func (*ListEventsResponse) GetCreatedPipelineEvent added in v0.1.0 

func (x *ListEventsResponse) GetCreatedPipelineEvent() *EventCreatedPipeline

func (*ListEventsResponse) GetDisabledPipelineEvent added in v0.1.0 

func (x *ListEventsResponse) GetDisabledPipelineEvent() *EventDisabledPipeline

func (*ListEventsResponse) GetEnabledPipelineEvent added in v0.1.0 

func (x *ListEventsResponse) GetEnabledPipelineEvent() *EventEnabledPipeline

func (*ListEventsResponse) GetEvent added in v0.1.0 

func (m *ListEventsResponse) GetEvent() isListEventsResponse_Event

func (*ListEventsResponse) GetFiredTriggerEvent added in v0.1.0 

func (x *ListEventsResponse) GetFiredTriggerEvent() *EventFiredTrigger

func (*ListEventsResponse) GetKind added in v0.1.0 

func (x *ListEventsResponse) GetKind() EventType

func (*ListEventsResponse) GetProcessedTriggerEvent added in v0.1.0 

func (x *ListEventsResponse) GetProcessedTriggerEvent() *EventProcessedTrigger

func (*ListEventsResponse) GetResolvedTriggerEvent added in v0.1.0 

func (x *ListEventsResponse) GetResolvedTriggerEvent() *EventResolvedTrigger

func (*ListEventsResponse) GetScheduledTaskRunEvent added in v0.1.0 

func (x *ListEventsResponse) GetScheduledTaskRunEvent() *EventScheduledTaskRun

func (*ListEventsResponse) GetStartedRunEvent added in v0.1.0 

func (x *ListEventsResponse) GetStartedRunEvent() *EventStartedRun

func (*ListEventsResponse) GetStartedTaskRunEvent added in v0.1.0 

func (x *ListEventsResponse) GetStartedTaskRunEvent() *EventStartedTaskRun

func (*ListEventsResponse) ProtoMessage added in v0.1.0 

func (*ListEventsResponse) ProtoMessage()

func (*ListEventsResponse) ProtoReflect added in v0.1.0 

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

func (*ListEventsResponse) Reset added in v0.1.0 

func (x *ListEventsResponse) Reset()

func (*ListEventsResponse) String added in v0.1.0 

func (x *ListEventsResponse) String() string

type ListEventsResponse_AbandonedPipelineEvent added in v0.1.0 

type ListEventsResponse_AbandonedPipelineEvent struct {
	AbandonedPipelineEvent *EventAbandonedPipeline `protobuf:"bytes,8,opt,name=abandoned_pipeline_event,json=abandonedPipelineEvent,proto3,oneof"`
}

type ListEventsResponse_CompletedRunEvent added in v0.1.0 

type ListEventsResponse_CompletedRunEvent struct {
	CompletedRunEvent *EventCompletedRun `protobuf:"bytes,11,opt,name=completed_run_event,json=completedRunEvent,proto3,oneof"`
}

type ListEventsResponse_CompletedTaskRunEvent added in v0.1.0 

type ListEventsResponse_CompletedTaskRunEvent struct {
	CompletedTaskRunEvent *EventCompletedTaskRun `protobuf:"bytes,17,opt,name=completed_task_run_event,json=completedTaskRunEvent,proto3,oneof"`
}

type ListEventsResponse_CreatedNamespaceEvent added in v0.1.0 

type ListEventsResponse_CreatedNamespaceEvent struct {
	CreatedNamespaceEvent *EventCreatedNamespace `protobuf:"bytes,2,opt,name=created_namespace_event,json=createdNamespaceEvent,proto3,oneof"`
}

type ListEventsResponse_CreatedPipelineEvent added in v0.1.0 

type ListEventsResponse_CreatedPipelineEvent struct {
	CreatedPipelineEvent *EventCreatedPipeline `protobuf:"bytes,7,opt,name=created_pipeline_event,json=createdPipelineEvent,proto3,oneof"`
}

type ListEventsResponse_DisabledPipelineEvent added in v0.1.0 

type ListEventsResponse_DisabledPipelineEvent struct {
	DisabledPipelineEvent *EventDisabledPipeline `protobuf:"bytes,5,opt,name=disabled_pipeline_event,json=disabledPipelineEvent,proto3,oneof"`
}

type ListEventsResponse_EnabledPipelineEvent added in v0.1.0 

type ListEventsResponse_EnabledPipelineEvent struct {
	EnabledPipelineEvent *EventEnabledPipeline `protobuf:"bytes,6,opt,name=enabled_pipeline_event,json=enabledPipelineEvent,proto3,oneof"`
}

type ListEventsResponse_FiredTriggerEvent added in v0.1.0 

type ListEventsResponse_FiredTriggerEvent struct {
	FiredTriggerEvent *EventFiredTrigger `protobuf:"bytes,20,opt,name=fired_trigger_event,json=firedTriggerEvent,proto3,oneof"`
}

type ListEventsResponse_ProcessedTriggerEvent added in v0.1.0 

type ListEventsResponse_ProcessedTriggerEvent struct {
	ProcessedTriggerEvent *EventProcessedTrigger `protobuf:"bytes,21,opt,name=processed_trigger_event,json=processedTriggerEvent,proto3,oneof"`
}

type ListEventsResponse_ResolvedTriggerEvent added in v0.1.0 

type ListEventsResponse_ResolvedTriggerEvent struct {
	ResolvedTriggerEvent *EventResolvedTrigger `protobuf:"bytes,22,opt,name=resolved_trigger_event,json=resolvedTriggerEvent,proto3,oneof"`
}

type ListEventsResponse_ScheduledTaskRunEvent added in v0.1.0 

type ListEventsResponse_ScheduledTaskRunEvent struct {
	ScheduledTaskRunEvent *EventScheduledTaskRun `protobuf:"bytes,16,opt,name=scheduled_task_run_event,json=scheduledTaskRunEvent,proto3,oneof"`
}

type ListEventsResponse_StartedRunEvent added in v0.1.0 

type ListEventsResponse_StartedRunEvent struct {
	StartedRunEvent *EventStartedRun `protobuf:"bytes,10,opt,name=started_run_event,json=startedRunEvent,proto3,oneof"`
}

type ListEventsResponse_StartedTaskRunEvent added in v0.1.0 

type ListEventsResponse_StartedTaskRunEvent struct {
	StartedTaskRunEvent *EventStartedTaskRun `protobuf:"bytes,15,opt,name=started_task_run_event,json=startedTaskRunEvent,proto3,oneof"`
}

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 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 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 Metadata added in v0.1.0 

type Metadata struct {
	EventId int64     `protobuf:"varint,1,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	Kind    EventType `protobuf:"varint,2,opt,name=kind,proto3,enum=proto.EventType" json:"kind,omitempty"`
	Emitted int64     `protobuf:"varint,3,opt,name=emitted,proto3" json:"emitted,omitempty"`
	// contains filtered or unexported fields
}

func (*Metadata) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) GetEmitted added in v0.1.0 

func (x *Metadata) GetEmitted() int64

func (*Metadata) GetEventId added in v0.1.0 

func (x *Metadata) GetEventId() int64

func (*Metadata) GetKind added in v0.1.0 

func (x *Metadata) GetKind() EventType

func (*Metadata) ProtoMessage added in v0.1.0 

func (*Metadata) ProtoMessage()

func (*Metadata) ProtoReflect added in v0.1.0 

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

func (*Metadata) Reset added in v0.1.0 

func (x *Metadata) Reset()

func (*Metadata) String added in v0.1.0 

func (x *Metadata) 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 */
	State  PipelineTriggerConfig_State `protobuf:"varint,4,opt,name=state,proto3,enum=proto.PipelineTriggerConfig_State" json:"state,omitempty"`
	Events []string                    `protobuf:"bytes,5,rep,name=events,proto3" json:"events,omitempty"`
	// 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) GetEvents added in v0.1.0 

func (x *PipelineTriggerConfig) GetEvents() []string

func (*PipelineTriggerConfig) GetKind 

func (x *PipelineTriggerConfig) GetKind() string

func (*PipelineTriggerConfig) GetLabel 

func (x *PipelineTriggerConfig) GetLabel() string

func (*PipelineTriggerConfig) GetState added in v0.0.3 

func (x *PipelineTriggerConfig) GetState() PipelineTriggerConfig_State

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 PipelineTriggerConfig_State added in v0.0.3 

type PipelineTriggerConfig_State int32
const (
	PipelineTriggerConfig_UNKNOWN     PipelineTriggerConfig_State = 0
	PipelineTriggerConfig_ACTIVE      PipelineTriggerConfig_State = 1
	PipelineTriggerConfig_DISABLED    PipelineTriggerConfig_State = 2
	PipelineTriggerConfig_UNSUPPORTED PipelineTriggerConfig_State = 3
)

func (PipelineTriggerConfig_State) Descriptor added in v0.0.3 

func (PipelineTriggerConfig_State) Descriptor() protoreflect.EnumDescriptor

func (PipelineTriggerConfig_State) Enum added in v0.0.3 

func (x PipelineTriggerConfig_State) Enum() *PipelineTriggerConfig_State

func (PipelineTriggerConfig_State) EnumDescriptor deprecated added in v0.0.3 

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

Deprecated: Use PipelineTriggerConfig_State.Descriptor instead.

func (PipelineTriggerConfig_State) Number added in v0.0.3 

func (x PipelineTriggerConfig_State) Number() protoreflect.EnumNumber

func (PipelineTriggerConfig_State) String added in v0.0.3 

func (x PipelineTriggerConfig_State) String() string

func (PipelineTriggerConfig_State) Type added in v0.0.3 

func (PipelineTriggerConfig_State) Type() protoreflect.EnumType

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 PutSecretRequest added in v0.0.3 

type PutSecretRequest 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     string `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 (*PutSecretRequest) Descriptor deprecated added in v0.0.3 

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

Deprecated: Use PutSecretRequest.ProtoReflect.Descriptor instead.

func (*PutSecretRequest) GetContent added in v0.0.3 

func (x *PutSecretRequest) GetContent() string

func (*PutSecretRequest) GetForce added in v0.0.3 

func (x *PutSecretRequest) GetForce() bool

func (*PutSecretRequest) GetKey added in v0.0.3 

func (x *PutSecretRequest) GetKey() string

func (*PutSecretRequest) GetNamespaceId added in v0.0.3 

func (x *PutSecretRequest) GetNamespaceId() string

func (*PutSecretRequest) GetPipelineId added in v0.0.3 

func (x *PutSecretRequest) GetPipelineId() string

func (*PutSecretRequest) ProtoMessage added in v0.0.3 

func (*PutSecretRequest) ProtoMessage()

func (*PutSecretRequest) ProtoReflect added in v0.0.3 

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

func (*PutSecretRequest) Reset added in v0.0.3 

func (x *PutSecretRequest) Reset()

func (*PutSecretRequest) String added in v0.0.3 

func (x *PutSecretRequest) String() string

type PutSecretResponse added in v0.0.3 

type PutSecretResponse struct {

	// The number of bytes uploaded.
	Bytes int64 `protobuf:"varint,1,opt,name=bytes,proto3" json:"bytes,omitempty"`
	// contains filtered or unexported fields
}

func (*PutSecretResponse) Descriptor deprecated added in v0.0.3 

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

Deprecated: Use PutSecretResponse.ProtoReflect.Descriptor instead.

func (*PutSecretResponse) GetBytes added in v0.0.3 

func (x *PutSecretResponse) GetBytes() int64

func (*PutSecretResponse) ProtoMessage added in v0.0.3 

func (*PutSecretResponse) ProtoMessage()

func (*PutSecretResponse) ProtoReflect added in v0.0.3 

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

func (*PutSecretResponse) Reset added in v0.0.3 

func (x *PutSecretResponse) Reset()

func (*PutSecretResponse) String added in v0.0.3 

func (x *PutSecretResponse) String() string

type RegistryAuth added in v0.0.3 

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

func (*RegistryAuth) Descriptor deprecated added in v0.0.3 

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

Deprecated: Use RegistryAuth.ProtoReflect.Descriptor instead.

func (*RegistryAuth) GetPass added in v0.0.3 

func (x *RegistryAuth) GetPass() string

func (*RegistryAuth) GetUser added in v0.0.3 

func (x *RegistryAuth) GetUser() string

func (*RegistryAuth) ProtoMessage added in v0.0.3 

func (*RegistryAuth) ProtoMessage()

func (*RegistryAuth) ProtoReflect added in v0.0.3 

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

func (*RegistryAuth) Reset added in v0.0.3 

func (x *RegistryAuth) Reset()

func (*RegistryAuth) String added in v0.0.3 

func (x *RegistryAuth) 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"`
	Image       string                             `protobuf:"bytes,3,opt,name=image,proto3" json:"image,omitempty"`
	DependsOn   map[string]TaskRequiredParentState `` /* 212-byte string literal not displayed */
	EnvVars     map[string]string                  `` /* 170-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) GetImage added in v0.0.3 

func (x *Task) GetImage() 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 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) BatchGetRuns 

func (UnimplementedGoferServer) BatchGetRuns(context.Context, *BatchGetRunsRequest) (*BatchGetRunsResponse, 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) DeleteSecret added in v0.0.3 

func (UnimplementedGoferServer) DeleteSecret(context.Context, *DeleteSecretRequest) (*DeleteSecretResponse, 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) GetEvent added in v0.1.0 

func (UnimplementedGoferServer) GetEvent(context.Context, *GetEventRequest) (*GetEventResponse, 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) GetSecret added in v0.0.3 

func (UnimplementedGoferServer) GetSecret(context.Context, *GetSecretRequest) (*GetSecretResponse, 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) ListEvents added in v0.1.0 

func (UnimplementedGoferServer) ListEvents(*ListEventsRequest, Gofer_ListEventsServer) 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) ListRuns 

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

func (UnimplementedGoferServer) ListTaskRuns 

func (UnimplementedGoferServer) ListTaskRuns(context.Context, *ListTaskRunsRequest) (*ListTaskRunsResponse, 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) PutSecret added in v0.0.3 

func (UnimplementedGoferServer) PutSecret(context.Context, *PutSecretRequest) (*PutSecretResponse, 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.