_go

package
v0.6.2 Latest Latest
Warning

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

Go to latest
Published: Mar 6, 2024 License: GPL-3.0 Imports: 8 Imported by: 2

Documentation

Index

Constants

View Source
const (
	Gofer_GetSystemInfo_FullMethodName                        = "/proto.Gofer/GetSystemInfo"
	Gofer_RepairOrphan_FullMethodName                         = "/proto.Gofer/RepairOrphan"
	Gofer_ToggleEventIngress_FullMethodName                   = "/proto.Gofer/ToggleEventIngress"
	Gofer_CreateToken_FullMethodName                          = "/proto.Gofer/CreateToken"
	Gofer_BootstrapToken_FullMethodName                       = "/proto.Gofer/BootstrapToken"
	Gofer_ListTokens_FullMethodName                           = "/proto.Gofer/ListTokens"
	Gofer_GetToken_FullMethodName                             = "/proto.Gofer/GetToken"
	Gofer_EnableToken_FullMethodName                          = "/proto.Gofer/EnableToken"
	Gofer_DisableToken_FullMethodName                         = "/proto.Gofer/DisableToken"
	Gofer_DeleteToken_FullMethodName                          = "/proto.Gofer/DeleteToken"
	Gofer_ListNamespaces_FullMethodName                       = "/proto.Gofer/ListNamespaces"
	Gofer_CreateNamespace_FullMethodName                      = "/proto.Gofer/CreateNamespace"
	Gofer_GetNamespace_FullMethodName                         = "/proto.Gofer/GetNamespace"
	Gofer_UpdateNamespace_FullMethodName                      = "/proto.Gofer/UpdateNamespace"
	Gofer_DeleteNamespace_FullMethodName                      = "/proto.Gofer/DeleteNamespace"
	Gofer_GetPipeline_FullMethodName                          = "/proto.Gofer/GetPipeline"
	Gofer_ListPipelines_FullMethodName                        = "/proto.Gofer/ListPipelines"
	Gofer_EnablePipeline_FullMethodName                       = "/proto.Gofer/EnablePipeline"
	Gofer_DisablePipeline_FullMethodName                      = "/proto.Gofer/DisablePipeline"
	Gofer_DeployPipeline_FullMethodName                       = "/proto.Gofer/DeployPipeline"
	Gofer_DeletePipeline_FullMethodName                       = "/proto.Gofer/DeletePipeline"
	Gofer_RegisterPipelineConfig_FullMethodName               = "/proto.Gofer/RegisterPipelineConfig"
	Gofer_ListPipelineConfigs_FullMethodName                  = "/proto.Gofer/ListPipelineConfigs"
	Gofer_GetPipelineConfig_FullMethodName                    = "/proto.Gofer/GetPipelineConfig"
	Gofer_DeletePipelineConfig_FullMethodName                 = "/proto.Gofer/DeletePipelineConfig"
	Gofer_CreatePipelineExtensionSubscription_FullMethodName  = "/proto.Gofer/CreatePipelineExtensionSubscription"
	Gofer_ListPipelineExtensionSubscriptions_FullMethodName   = "/proto.Gofer/ListPipelineExtensionSubscriptions"
	Gofer_GetPipelineExtensionSubscription_FullMethodName     = "/proto.Gofer/GetPipelineExtensionSubscription"
	Gofer_EnablePipelineExtensionSubscription_FullMethodName  = "/proto.Gofer/EnablePipelineExtensionSubscription"
	Gofer_DisablePipelineExtensionSubscription_FullMethodName = "/proto.Gofer/DisablePipelineExtensionSubscription"
	Gofer_DeletePipelineExtensionSubscription_FullMethodName  = "/proto.Gofer/DeletePipelineExtensionSubscription"
	Gofer_ListDeployments_FullMethodName                      = "/proto.Gofer/ListDeployments"
	Gofer_GetDeployment_FullMethodName                        = "/proto.Gofer/GetDeployment"
	Gofer_GetRun_FullMethodName                               = "/proto.Gofer/GetRun"
	Gofer_ListRuns_FullMethodName                             = "/proto.Gofer/ListRuns"
	Gofer_StartRun_FullMethodName                             = "/proto.Gofer/StartRun"
	Gofer_RetryRun_FullMethodName                             = "/proto.Gofer/RetryRun"
	Gofer_CancelRun_FullMethodName                            = "/proto.Gofer/CancelRun"
	Gofer_CancelAllRuns_FullMethodName                        = "/proto.Gofer/CancelAllRuns"
	Gofer_GetTaskRun_FullMethodName                           = "/proto.Gofer/GetTaskRun"
	Gofer_ListTaskRuns_FullMethodName                         = "/proto.Gofer/ListTaskRuns"
	Gofer_CancelTaskRun_FullMethodName                        = "/proto.Gofer/CancelTaskRun"
	Gofer_AttachToTaskRun_FullMethodName                      = "/proto.Gofer/AttachToTaskRun"
	Gofer_GetTaskRunLogs_FullMethodName                       = "/proto.Gofer/GetTaskRunLogs"
	Gofer_DeleteTaskRunLogs_FullMethodName                    = "/proto.Gofer/DeleteTaskRunLogs"
	Gofer_GetExtension_FullMethodName                         = "/proto.Gofer/GetExtension"
	Gofer_ListExtensions_FullMethodName                       = "/proto.Gofer/ListExtensions"
	Gofer_RunExtensionInstaller_FullMethodName                = "/proto.Gofer/RunExtensionInstaller"
	Gofer_RunPipelineConfigurator_FullMethodName              = "/proto.Gofer/RunPipelineConfigurator"
	Gofer_InstallExtension_FullMethodName                     = "/proto.Gofer/InstallExtension"
	Gofer_UninstallExtension_FullMethodName                   = "/proto.Gofer/UninstallExtension"
	Gofer_EnableExtension_FullMethodName                      = "/proto.Gofer/EnableExtension"
	Gofer_DisableExtension_FullMethodName                     = "/proto.Gofer/DisableExtension"
	Gofer_ListPipelineObjects_FullMethodName                  = "/proto.Gofer/ListPipelineObjects"
	Gofer_GetPipelineObject_FullMethodName                    = "/proto.Gofer/GetPipelineObject"
	Gofer_PutPipelineObject_FullMethodName                    = "/proto.Gofer/PutPipelineObject"
	Gofer_DeletePipelineObject_FullMethodName                 = "/proto.Gofer/DeletePipelineObject"
	Gofer_ListRunObjects_FullMethodName                       = "/proto.Gofer/ListRunObjects"
	Gofer_GetRunObject_FullMethodName                         = "/proto.Gofer/GetRunObject"
	Gofer_PutRunObject_FullMethodName                         = "/proto.Gofer/PutRunObject"
	Gofer_DeleteRunObject_FullMethodName                      = "/proto.Gofer/DeleteRunObject"
	Gofer_GetPipelineSecret_FullMethodName                    = "/proto.Gofer/GetPipelineSecret"
	Gofer_ListPipelineSecrets_FullMethodName                  = "/proto.Gofer/ListPipelineSecrets"
	Gofer_PutPipelineSecret_FullMethodName                    = "/proto.Gofer/PutPipelineSecret"
	Gofer_DeletePipelineSecret_FullMethodName                 = "/proto.Gofer/DeletePipelineSecret"
	Gofer_GetGlobalSecret_FullMethodName                      = "/proto.Gofer/GetGlobalSecret"
	Gofer_ListGlobalSecrets_FullMethodName                    = "/proto.Gofer/ListGlobalSecrets"
	Gofer_PutGlobalSecret_FullMethodName                      = "/proto.Gofer/PutGlobalSecret"
	Gofer_DeleteGlobalSecret_FullMethodName                   = "/proto.Gofer/DeleteGlobalSecret"
	Gofer_GetEvent_FullMethodName                             = "/proto.Gofer/GetEvent"
	Gofer_ListEvents_FullMethodName                           = "/proto.Gofer/ListEvents"
)
View Source
const (
	ExtensionService_Init_FullMethodName                    = "/proto.ExtensionService/Init"
	ExtensionService_Info_FullMethodName                    = "/proto.ExtensionService/Info"
	ExtensionService_Subscribe_FullMethodName               = "/proto.ExtensionService/Subscribe"
	ExtensionService_Unsubscribe_FullMethodName             = "/proto.ExtensionService/Unsubscribe"
	ExtensionService_Shutdown_FullMethodName                = "/proto.ExtensionService/Shutdown"
	ExtensionService_ExternalEvent_FullMethodName           = "/proto.ExtensionService/ExternalEvent"
	ExtensionService_RunExtensionInstaller_FullMethodName   = "/proto.ExtensionService/RunExtensionInstaller"
	ExtensionService_RunPipelineConfigurator_FullMethodName = "/proto.ExtensionService/RunPipelineConfigurator"
)

Variables

View Source
var (
	PipelineMetadata_PipelineState_name = map[int32]string{
		0: "PIPELINE_STATE_UNKNOWN",
		1: "ACTIVE",
		2: "DISABLED",
	}
	PipelineMetadata_PipelineState_value = map[string]int32{
		"PIPELINE_STATE_UNKNOWN": 0,
		"ACTIVE":                 1,
		"DISABLED":               2,
	}
)

Enum value maps for PipelineMetadata_PipelineState.

View Source
var (
	PipelineConfig_PipelineConfigState_name = map[int32]string{
		0: "PIPELINE_CONFIG_STATE_UNKNOWN",
		1: "UNRELEASED",
		2: "LIVE",
		3: "DEPRECATED",
	}
	PipelineConfig_PipelineConfigState_value = map[string]int32{
		"PIPELINE_CONFIG_STATE_UNKNOWN": 0,
		"UNRELEASED":                    1,
		"LIVE":                          2,
		"DEPRECATED":                    3,
	}
)

Enum value maps for PipelineConfig_PipelineConfigState.

View Source
var (
	PipelineExtensionSubscriptionStatusReason_PipelineExtensionSubscriptionStatusReasonKind_name = map[int32]string{
		0: "PIPELINE_EXTENSION_STATUS_REASON_UNKNOWN",
		1: "ACTIVE",
		2: "ERROR",
		3: "DISABLED",
	}
	PipelineExtensionSubscriptionStatusReason_PipelineExtensionSubscriptionStatusReasonKind_value = map[string]int32{
		"PIPELINE_EXTENSION_STATUS_REASON_UNKNOWN": 0,
		"ACTIVE":   1,
		"ERROR":    2,
		"DISABLED": 3,
	}
)

Enum value maps for PipelineExtensionSubscriptionStatusReason_PipelineExtensionSubscriptionStatusReasonKind.

View Source
var (
	PipelineExtensionSubscription_Status_name = map[int32]string{
		0: "STATUS_UNKNOWN",
		1: "ACTIVE",
		2: "ERROR",
		3: "DISABLED",
	}
	PipelineExtensionSubscription_Status_value = map[string]int32{
		"STATUS_UNKNOWN": 0,
		"ACTIVE":         1,
		"ERROR":          2,
		"DISABLED":       3,
	}
)

Enum value maps for PipelineExtensionSubscription_Status.

View Source
var (
	DeploymentStatusReason_DeploymentStatusReasonKind_name = map[int32]string{
		0: "DEPLOYMENT_STATUS_REASON_UNKNOWN",
	}
	DeploymentStatusReason_DeploymentStatusReasonKind_value = map[string]int32{
		"DEPLOYMENT_STATUS_REASON_UNKNOWN": 0,
	}
)

Enum value maps for DeploymentStatusReason_DeploymentStatusReasonKind.

View Source
var (
	Deployment_DeploymentState_name = map[int32]string{
		0: "DEPLOYMENT_STATE_UNKNOWN",
		1: "RUNNING",
		2: "COMPLETE",
	}
	Deployment_DeploymentState_value = map[string]int32{
		"DEPLOYMENT_STATE_UNKNOWN": 0,
		"RUNNING":                  1,
		"COMPLETE":                 2,
	}
)

Enum value maps for Deployment_DeploymentState.

View Source
var (
	Deployment_DeploymentStatus_name = map[int32]string{
		0: "DEPLOYMENT_STATUS_UNKNOWN",
		1: "FAILED",
		2: "SUCCESSFUL",
	}
	Deployment_DeploymentStatus_value = map[string]int32{
		"DEPLOYMENT_STATUS_UNKNOWN": 0,
		"FAILED":                    1,
		"SUCCESSFUL":                2,
	}
)

Enum value maps for Deployment_DeploymentStatus.

View Source
var (
	Run_RunState_name = map[int32]string{
		0: "RUN_STATE_UNKNOWN",
		1: "PENDING",
		2: "RUNNING",
		3: "COMPLETE",
	}
	Run_RunState_value = map[string]int32{
		"RUN_STATE_UNKNOWN": 0,
		"PENDING":           1,
		"RUNNING":           2,
		"COMPLETE":          3,
	}
)

Enum value maps for Run_RunState.

View Source
var (
	Run_RunStatus_name = map[int32]string{
		0: "RUN_STATUS_UNKNOWN",
		1: "SUCCESSFUL",
		2: "FAILED",
		3: "CANCELLED",
	}
	Run_RunStatus_value = map[string]int32{
		"RUN_STATUS_UNKNOWN": 0,
		"SUCCESSFUL":         1,
		"FAILED":             2,
		"CANCELLED":          3,
	}
)

Enum value maps for Run_RunStatus.

View Source
var (
	RunStatusReason_RunStatusReasonKind_name = map[int32]string{
		0: "RUN_STATUS_REASON_UNKNOWN",
		1: "ABNORMAL_EXIT",
		2: "SCHEDULER_ERROR",
		3: "FAILED_PRECONDITION",
		4: "USER_CANCELLED",
		5: "ADMIN_CANCELLED",
	}
	RunStatusReason_RunStatusReasonKind_value = map[string]int32{
		"RUN_STATUS_REASON_UNKNOWN": 0,
		"ABNORMAL_EXIT":             1,
		"SCHEDULER_ERROR":           2,
		"FAILED_PRECONDITION":       3,
		"USER_CANCELLED":            4,
		"ADMIN_CANCELLED":           5,
	}
)

Enum value maps for RunStatusReason_RunStatusReasonKind.

View Source
var (
	Task_RequiredParentStatus_name = map[int32]string{
		0: "REQUIRED_PARENT_STATUS_UNKNOWN",
		1: "ANY",
		2: "SUCCESS",
		3: "FAILURE",
	}
	Task_RequiredParentStatus_value = map[string]int32{
		"REQUIRED_PARENT_STATUS_UNKNOWN": 0,
		"ANY":                            1,
		"SUCCESS":                        2,
		"FAILURE":                        3,
	}
)

Enum value maps for Task_RequiredParentStatus.

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

Enum value maps for TaskRunStatusReason_Reason.

View Source
var (
	TaskRun_TaskRunState_name = map[int32]string{
		0: "UNKNOWN_STATE",
		1: "PROCESSING",
		2: "WAITING",
		3: "RUNNING",
		4: "COMPLETE",
	}
	TaskRun_TaskRunState_value = map[string]int32{
		"UNKNOWN_STATE": 0,
		"PROCESSING":    1,
		"WAITING":       2,
		"RUNNING":       3,
		"COMPLETE":      4,
	}
)

Enum value maps for TaskRun_TaskRunState.

View Source
var (
	TaskRun_TaskRunStatus_name = map[int32]string{
		0: "UNKNOWN_STATUS",
		1: "SUCCESSFUL",
		2: "FAILED",
		3: "CANCELLED",
		4: "SKIPPED",
	}
	TaskRun_TaskRunStatus_value = map[string]int32{
		"UNKNOWN_STATUS": 0,
		"SUCCESSFUL":     1,
		"FAILED":         2,
		"CANCELLED":      3,
		"SKIPPED":        4,
	}
)

Enum value maps for TaskRun_TaskRunStatus.

View Source
var (
	Extension_ExtensionState_name = map[int32]string{
		0: "UNKNOWN_STATE",
		1: "PROCESSING",
		2: "RUNNING",
		3: "EXITED",
	}
	Extension_ExtensionState_value = map[string]int32{
		"UNKNOWN_STATE": 0,
		"PROCESSING":    1,
		"RUNNING":       2,
		"EXITED":        3,
	}
)

Enum value maps for Extension_ExtensionState.

View Source
var (
	Extension_ExtensionStatus_name = map[int32]string{
		0: "UNKNOWN_STATUS",
		1: "ENABLED",
		2: "DISABLED",
	}
	Extension_ExtensionStatus_value = map[string]int32{
		"UNKNOWN_STATUS": 0,
		"ENABLED":        1,
		"DISABLED":       2,
	}
)

Enum value maps for Extension_ExtensionStatus.

View Source
var (
	ExtensionRegistration_ExtensionStatus_name = map[int32]string{
		0: "UNKNOWN_STATUS",
		1: "ENABLED",
		2: "DISABLED",
	}
	ExtensionRegistration_ExtensionStatus_value = map[string]int32{
		"UNKNOWN_STATUS": 0,
		"ENABLED":        1,
		"DISABLED":       2,
	}
)

Enum value maps for ExtensionRegistration_ExtensionStatus.

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 (
	ExtensionResult_Status_name = map[int32]string{
		0: "UNKNOWN",
		1: "FAILURE",
		2: "SUCCESS",
		3: "SKIPPED",
	}
	ExtensionResult_Status_value = map[string]int32{
		"UNKNOWN": 0,
		"FAILURE": 1,
		"SUCCESS": 2,
		"SKIPPED": 3,
	}
)

Enum value maps for ExtensionResult_Status.

View Source
var (
	Initiator_Type_name = map[int32]string{
		0: "UNKNOWN",
		1: "BOT",
		2: "HUMAN",
		3: "EXTENSION",
	}
	Initiator_Type_value = map[string]int32{
		"UNKNOWN":   0,
		"BOT":       1,
		"HUMAN":     2,
		"EXTENSION": 3,
	}
)

Enum value maps for Initiator_Type.

View Source
var (
	UserPipelineTaskConfig_RequiredParentStatus_name = map[int32]string{
		0: "REQUIRED_PARENT_STATUS_UNKNOWN",
		1: "ANY",
		2: "SUCCESS",
		3: "FAILURE",
	}
	UserPipelineTaskConfig_RequiredParentStatus_value = map[string]int32{
		"REQUIRED_PARENT_STATUS_UNKNOWN": 0,
		"ANY":                            1,
		"SUCCESS":                        2,
		"FAILURE":                        3,
	}
)

Enum value maps for UserPipelineTaskConfig_RequiredParentStatus.

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 ExtensionService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.ExtensionService",
	HandlerType: (*ExtensionServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Init",
			Handler:    _ExtensionService_Init_Handler,
		},
		{
			MethodName: "Info",
			Handler:    _ExtensionService_Info_Handler,
		},
		{
			MethodName: "Subscribe",
			Handler:    _ExtensionService_Subscribe_Handler,
		},
		{
			MethodName: "Unsubscribe",
			Handler:    _ExtensionService_Unsubscribe_Handler,
		},
		{
			MethodName: "Shutdown",
			Handler:    _ExtensionService_Shutdown_Handler,
		},
		{
			MethodName: "ExternalEvent",
			Handler:    _ExtensionService_ExternalEvent_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "RunExtensionInstaller",
			Handler:       _ExtensionService_RunExtensionInstaller_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "RunPipelineConfigurator",
			Handler:       _ExtensionService_RunPipelineConfigurator_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "gofer.proto",
}

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

View Source
var File_gofer_message_api_proto protoreflect.FileDescriptor
View Source
var File_gofer_message_sdk_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: "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: "ListTokens",
			Handler:    _Gofer_ListTokens_Handler,
		},
		{
			MethodName: "GetToken",
			Handler:    _Gofer_GetToken_Handler,
		},
		{
			MethodName: "EnableToken",
			Handler:    _Gofer_EnableToken_Handler,
		},
		{
			MethodName: "DisableToken",
			Handler:    _Gofer_DisableToken_Handler,
		},
		{
			MethodName: "DeleteToken",
			Handler:    _Gofer_DeleteToken_Handler,
		},
		{
			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: "DeployPipeline",
			Handler:    _Gofer_DeployPipeline_Handler,
		},
		{
			MethodName: "DeletePipeline",
			Handler:    _Gofer_DeletePipeline_Handler,
		},
		{
			MethodName: "RegisterPipelineConfig",
			Handler:    _Gofer_RegisterPipelineConfig_Handler,
		},
		{
			MethodName: "ListPipelineConfigs",
			Handler:    _Gofer_ListPipelineConfigs_Handler,
		},
		{
			MethodName: "GetPipelineConfig",
			Handler:    _Gofer_GetPipelineConfig_Handler,
		},
		{
			MethodName: "DeletePipelineConfig",
			Handler:    _Gofer_DeletePipelineConfig_Handler,
		},
		{
			MethodName: "CreatePipelineExtensionSubscription",
			Handler:    _Gofer_CreatePipelineExtensionSubscription_Handler,
		},
		{
			MethodName: "ListPipelineExtensionSubscriptions",
			Handler:    _Gofer_ListPipelineExtensionSubscriptions_Handler,
		},
		{
			MethodName: "GetPipelineExtensionSubscription",
			Handler:    _Gofer_GetPipelineExtensionSubscription_Handler,
		},
		{
			MethodName: "EnablePipelineExtensionSubscription",
			Handler:    _Gofer_EnablePipelineExtensionSubscription_Handler,
		},
		{
			MethodName: "DisablePipelineExtensionSubscription",
			Handler:    _Gofer_DisablePipelineExtensionSubscription_Handler,
		},
		{
			MethodName: "DeletePipelineExtensionSubscription",
			Handler:    _Gofer_DeletePipelineExtensionSubscription_Handler,
		},
		{
			MethodName: "ListDeployments",
			Handler:    _Gofer_ListDeployments_Handler,
		},
		{
			MethodName: "GetDeployment",
			Handler:    _Gofer_GetDeployment_Handler,
		},
		{
			MethodName: "GetRun",
			Handler:    _Gofer_GetRun_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: "GetExtension",
			Handler:    _Gofer_GetExtension_Handler,
		},
		{
			MethodName: "ListExtensions",
			Handler:    _Gofer_ListExtensions_Handler,
		},
		{
			MethodName: "InstallExtension",
			Handler:    _Gofer_InstallExtension_Handler,
		},
		{
			MethodName: "UninstallExtension",
			Handler:    _Gofer_UninstallExtension_Handler,
		},
		{
			MethodName: "EnableExtension",
			Handler:    _Gofer_EnableExtension_Handler,
		},
		{
			MethodName: "DisableExtension",
			Handler:    _Gofer_DisableExtension_Handler,
		},
		{
			MethodName: "ListPipelineObjects",
			Handler:    _Gofer_ListPipelineObjects_Handler,
		},
		{
			MethodName: "GetPipelineObject",
			Handler:    _Gofer_GetPipelineObject_Handler,
		},
		{
			MethodName: "PutPipelineObject",
			Handler:    _Gofer_PutPipelineObject_Handler,
		},
		{
			MethodName: "DeletePipelineObject",
			Handler:    _Gofer_DeletePipelineObject_Handler,
		},
		{
			MethodName: "ListRunObjects",
			Handler:    _Gofer_ListRunObjects_Handler,
		},
		{
			MethodName: "GetRunObject",
			Handler:    _Gofer_GetRunObject_Handler,
		},
		{
			MethodName: "PutRunObject",
			Handler:    _Gofer_PutRunObject_Handler,
		},
		{
			MethodName: "DeleteRunObject",
			Handler:    _Gofer_DeleteRunObject_Handler,
		},
		{
			MethodName: "GetPipelineSecret",
			Handler:    _Gofer_GetPipelineSecret_Handler,
		},
		{
			MethodName: "ListPipelineSecrets",
			Handler:    _Gofer_ListPipelineSecrets_Handler,
		},
		{
			MethodName: "PutPipelineSecret",
			Handler:    _Gofer_PutPipelineSecret_Handler,
		},
		{
			MethodName: "DeletePipelineSecret",
			Handler:    _Gofer_DeletePipelineSecret_Handler,
		},
		{
			MethodName: "GetGlobalSecret",
			Handler:    _Gofer_GetGlobalSecret_Handler,
		},
		{
			MethodName: "ListGlobalSecrets",
			Handler:    _Gofer_ListGlobalSecrets_Handler,
		},
		{
			MethodName: "PutGlobalSecret",
			Handler:    _Gofer_PutGlobalSecret_Handler,
		},
		{
			MethodName: "DeleteGlobalSecret",
			Handler:    _Gofer_DeleteGlobalSecret_Handler,
		},
		{
			MethodName: "GetEvent",
			Handler:    _Gofer_GetEvent_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "AttachToTaskRun",
			Handler:       _Gofer_AttachToTaskRun_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "GetTaskRunLogs",
			Handler:       _Gofer_GetTaskRunLogs_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "RunExtensionInstaller",
			Handler:       _Gofer_RunExtensionInstaller_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "RunPipelineConfigurator",
			Handler:       _Gofer_RunPipelineConfigurator_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "ListEvents",
			Handler:       _Gofer_ListEvents_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 RegisterExtensionServiceServer added in v0.5.0

func RegisterExtensionServiceServer(s grpc.ServiceRegistrar, srv ExtensionServiceServer)

func RegisterGoferServer

func RegisterGoferServer(s grpc.ServiceRegistrar, srv GoferServer)

Types

type AttachToTaskRunInit added in v0.6.0

type AttachToTaskRunInit 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
	Command     []string `protobuf:"bytes,5,rep,name=command,proto3" json:"command,omitempty"` // Which command to execute in container
	// contains filtered or unexported fields
}

func (*AttachToTaskRunInit) Descriptor deprecated added in v0.6.0

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

Deprecated: Use AttachToTaskRunInit.ProtoReflect.Descriptor instead.

func (*AttachToTaskRunInit) GetCommand added in v0.6.0

func (x *AttachToTaskRunInit) GetCommand() []string

func (*AttachToTaskRunInit) GetId added in v0.6.0

func (x *AttachToTaskRunInit) GetId() string

func (*AttachToTaskRunInit) GetNamespaceId added in v0.6.0

func (x *AttachToTaskRunInit) GetNamespaceId() string

func (*AttachToTaskRunInit) GetPipelineId added in v0.6.0

func (x *AttachToTaskRunInit) GetPipelineId() string

func (*AttachToTaskRunInit) GetRunId added in v0.6.0

func (x *AttachToTaskRunInit) GetRunId() int64

func (*AttachToTaskRunInit) ProtoMessage added in v0.6.0

func (*AttachToTaskRunInit) ProtoMessage()

func (*AttachToTaskRunInit) ProtoReflect added in v0.6.0

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

func (*AttachToTaskRunInit) Reset added in v0.6.0

func (x *AttachToTaskRunInit) Reset()

func (*AttachToTaskRunInit) String added in v0.6.0

func (x *AttachToTaskRunInit) String() string

type AttachToTaskRunInput added in v0.6.0

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

func (*AttachToTaskRunInput) Descriptor deprecated added in v0.6.0

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

Deprecated: Use AttachToTaskRunInput.ProtoReflect.Descriptor instead.

func (*AttachToTaskRunInput) GetInput added in v0.6.0

func (x *AttachToTaskRunInput) GetInput() string

func (*AttachToTaskRunInput) ProtoMessage added in v0.6.0

func (*AttachToTaskRunInput) ProtoMessage()

func (*AttachToTaskRunInput) ProtoReflect added in v0.6.0

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

func (*AttachToTaskRunInput) Reset added in v0.6.0

func (x *AttachToTaskRunInput) Reset()

func (*AttachToTaskRunInput) String added in v0.6.0

func (x *AttachToTaskRunInput) String() string

type AttachToTaskRunOutput added in v0.6.0

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

func (*AttachToTaskRunOutput) Descriptor deprecated added in v0.6.0

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

Deprecated: Use AttachToTaskRunOutput.ProtoReflect.Descriptor instead.

func (*AttachToTaskRunOutput) GetOutput added in v0.6.0

func (x *AttachToTaskRunOutput) GetOutput() string

func (*AttachToTaskRunOutput) ProtoMessage added in v0.6.0

func (*AttachToTaskRunOutput) ProtoMessage()

func (*AttachToTaskRunOutput) ProtoReflect added in v0.6.0

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

func (*AttachToTaskRunOutput) Reset added in v0.6.0

func (x *AttachToTaskRunOutput) Reset()

func (*AttachToTaskRunOutput) String added in v0.6.0

func (x *AttachToTaskRunOutput) String() string

type AttachToTaskRunRequest added in v0.6.0

type AttachToTaskRunRequest struct {

	// Types that are assignable to RequestType:
	//
	//	*AttachToTaskRunRequest_Init
	//	*AttachToTaskRunRequest_Input
	RequestType isAttachToTaskRunRequest_RequestType `protobuf_oneof:"requestType"`
	// contains filtered or unexported fields
}

func (*AttachToTaskRunRequest) Descriptor deprecated added in v0.6.0

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

Deprecated: Use AttachToTaskRunRequest.ProtoReflect.Descriptor instead.

func (*AttachToTaskRunRequest) GetInit added in v0.6.0

func (*AttachToTaskRunRequest) GetInput added in v0.6.0

func (*AttachToTaskRunRequest) GetRequestType added in v0.6.0

func (m *AttachToTaskRunRequest) GetRequestType() isAttachToTaskRunRequest_RequestType

func (*AttachToTaskRunRequest) ProtoMessage added in v0.6.0

func (*AttachToTaskRunRequest) ProtoMessage()

func (*AttachToTaskRunRequest) ProtoReflect added in v0.6.0

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

func (*AttachToTaskRunRequest) Reset added in v0.6.0

func (x *AttachToTaskRunRequest) Reset()

func (*AttachToTaskRunRequest) String added in v0.6.0

func (x *AttachToTaskRunRequest) String() string

type AttachToTaskRunRequest_Init added in v0.6.0

type AttachToTaskRunRequest_Init struct {
	// On the first request an init request sets up the connection to the
	// container.
	Init *AttachToTaskRunInit `protobuf:"bytes,1,opt,name=init,proto3,oneof"`
}

type AttachToTaskRunRequest_Input added in v0.6.0

type AttachToTaskRunRequest_Input struct {
	// On following requests an input request passes text to the container.
	Input *AttachToTaskRunInput `protobuf:"bytes,2,opt,name=input,proto3,oneof"`
}

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"`
	RunId       int64  `protobuf:"varint,3,opt,name=run_id,json=runId,proto3" json:"run_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) GetNamespaceId

func (x *CancelRunRequest) GetNamespaceId() string

func (*CancelRunRequest) GetPipelineId

func (x *CancelRunRequest) GetPipelineId() string

func (*CancelRunRequest) GetRunId

func (x *CancelRunRequest) GetRunId() int64

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 CreatePipelineExtensionSubscriptionRequest added in v0.5.0

type CreatePipelineExtensionSubscriptionRequest 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"`    // Unique pipeline identifier
	ExtensionName  string            `protobuf:"bytes,3,opt,name=extension_name,json=extensionName,proto3" json:"extension_name,omitempty"`
	ExtensionLabel string            `protobuf:"bytes,4,opt,name=extension_label,json=extensionLabel,proto3" json:"extension_label,omitempty"`
	Settings       map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreatePipelineExtensionSubscriptionRequest) Descriptor deprecated added in v0.5.0

Deprecated: Use CreatePipelineExtensionSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*CreatePipelineExtensionSubscriptionRequest) GetExtensionLabel added in v0.5.0

func (x *CreatePipelineExtensionSubscriptionRequest) GetExtensionLabel() string

func (*CreatePipelineExtensionSubscriptionRequest) GetExtensionName added in v0.5.0

func (x *CreatePipelineExtensionSubscriptionRequest) GetExtensionName() string

func (*CreatePipelineExtensionSubscriptionRequest) GetNamespaceId added in v0.5.0

func (*CreatePipelineExtensionSubscriptionRequest) GetPipelineId added in v0.5.0

func (*CreatePipelineExtensionSubscriptionRequest) GetSettings added in v0.5.0

func (*CreatePipelineExtensionSubscriptionRequest) ProtoMessage added in v0.5.0

func (*CreatePipelineExtensionSubscriptionRequest) ProtoReflect added in v0.5.0

func (*CreatePipelineExtensionSubscriptionRequest) Reset added in v0.5.0

func (*CreatePipelineExtensionSubscriptionRequest) String added in v0.5.0

type CreatePipelineExtensionSubscriptionResponse added in v0.5.0

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

func (*CreatePipelineExtensionSubscriptionResponse) Descriptor deprecated added in v0.5.0

Deprecated: Use CreatePipelineExtensionSubscriptionResponse.ProtoReflect.Descriptor instead.

func (*CreatePipelineExtensionSubscriptionResponse) ProtoMessage added in v0.5.0

func (*CreatePipelineExtensionSubscriptionResponse) ProtoReflect added in v0.5.0

func (*CreatePipelineExtensionSubscriptionResponse) Reset added in v0.5.0

func (*CreatePipelineExtensionSubscriptionResponse) String added in v0.5.0

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 */
	// Accepts golang duration strings
	// https://pkg.golang.ir/time#ParseDuration
	Expires string `protobuf:"bytes,4,opt,name=expires,proto3" json:"expires,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTokenRequest) Descriptor deprecated

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

Deprecated: Use CreateTokenRequest.ProtoReflect.Descriptor instead.

func (*CreateTokenRequest) GetExpires

func (x *CreateTokenRequest) GetExpires() string

func (*CreateTokenRequest) GetKind

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

func (CreateTokenRequest_Kind) EnumDescriptor deprecated

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

Deprecated: Use CreateTokenRequest_Kind.Descriptor instead.

func (CreateTokenRequest_Kind) Number

func (CreateTokenRequest_Kind) String

func (x CreateTokenRequest_Kind) String() string

func (CreateTokenRequest_Kind) Type

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 DeleteGlobalSecretRequest

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

func (*DeleteGlobalSecretRequest) Descriptor deprecated

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

Deprecated: Use DeleteGlobalSecretRequest.ProtoReflect.Descriptor instead.

func (*DeleteGlobalSecretRequest) GetKey

func (x *DeleteGlobalSecretRequest) GetKey() string

func (*DeleteGlobalSecretRequest) ProtoMessage

func (*DeleteGlobalSecretRequest) ProtoMessage()

func (*DeleteGlobalSecretRequest) ProtoReflect

func (*DeleteGlobalSecretRequest) Reset

func (x *DeleteGlobalSecretRequest) Reset()

func (*DeleteGlobalSecretRequest) String

func (x *DeleteGlobalSecretRequest) String() string

type DeleteGlobalSecretResponse

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

func (*DeleteGlobalSecretResponse) Descriptor deprecated

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

Deprecated: Use DeleteGlobalSecretResponse.ProtoReflect.Descriptor instead.

func (*DeleteGlobalSecretResponse) ProtoMessage

func (*DeleteGlobalSecretResponse) ProtoMessage()

func (*DeleteGlobalSecretResponse) ProtoReflect

func (*DeleteGlobalSecretResponse) Reset

func (x *DeleteGlobalSecretResponse) Reset()

func (*DeleteGlobalSecretResponse) String

func (x *DeleteGlobalSecretResponse) 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 DeletePipelineConfigRequest added in v0.5.0

type DeletePipelineConfigRequest 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"`    // Unique pipeline identifier
	// Pipeline version to retrieve. 0 Deletes the currently active version.
	Version int64 `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*DeletePipelineConfigRequest) Descriptor deprecated added in v0.5.0

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

Deprecated: Use DeletePipelineConfigRequest.ProtoReflect.Descriptor instead.

func (*DeletePipelineConfigRequest) GetNamespaceId added in v0.5.0

func (x *DeletePipelineConfigRequest) GetNamespaceId() string

func (*DeletePipelineConfigRequest) GetPipelineId added in v0.5.0

func (x *DeletePipelineConfigRequest) GetPipelineId() string

func (*DeletePipelineConfigRequest) GetVersion added in v0.5.0

func (x *DeletePipelineConfigRequest) GetVersion() int64

func (*DeletePipelineConfigRequest) ProtoMessage added in v0.5.0

func (*DeletePipelineConfigRequest) ProtoMessage()

func (*DeletePipelineConfigRequest) ProtoReflect added in v0.5.0

func (*DeletePipelineConfigRequest) Reset added in v0.5.0

func (x *DeletePipelineConfigRequest) Reset()

func (*DeletePipelineConfigRequest) String added in v0.5.0

func (x *DeletePipelineConfigRequest) String() string

type DeletePipelineConfigResponse added in v0.5.0

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

func (*DeletePipelineConfigResponse) Descriptor deprecated added in v0.5.0

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

Deprecated: Use DeletePipelineConfigResponse.ProtoReflect.Descriptor instead.

func (*DeletePipelineConfigResponse) ProtoMessage added in v0.5.0

func (*DeletePipelineConfigResponse) ProtoMessage()

func (*DeletePipelineConfigResponse) ProtoReflect added in v0.5.0

func (*DeletePipelineConfigResponse) Reset added in v0.5.0

func (x *DeletePipelineConfigResponse) Reset()

func (*DeletePipelineConfigResponse) String added in v0.5.0

type DeletePipelineExtensionSubscriptionRequest added in v0.5.0

type DeletePipelineExtensionSubscriptionRequest 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"`    // Unique pipeline identifier
	ExtensionName  string `protobuf:"bytes,3,opt,name=extension_name,json=extensionName,proto3" json:"extension_name,omitempty"`
	ExtensionLabel string `protobuf:"bytes,4,opt,name=extension_label,json=extensionLabel,proto3" json:"extension_label,omitempty"`
	// contains filtered or unexported fields
}

func (*DeletePipelineExtensionSubscriptionRequest) Descriptor deprecated added in v0.5.0

Deprecated: Use DeletePipelineExtensionSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*DeletePipelineExtensionSubscriptionRequest) GetExtensionLabel added in v0.5.0

func (x *DeletePipelineExtensionSubscriptionRequest) GetExtensionLabel() string

func (*DeletePipelineExtensionSubscriptionRequest) GetExtensionName added in v0.5.0

func (x *DeletePipelineExtensionSubscriptionRequest) GetExtensionName() string

func (*DeletePipelineExtensionSubscriptionRequest) GetNamespaceId added in v0.5.0

func (*DeletePipelineExtensionSubscriptionRequest) GetPipelineId added in v0.5.0

func (*DeletePipelineExtensionSubscriptionRequest) ProtoMessage added in v0.5.0

func (*DeletePipelineExtensionSubscriptionRequest) ProtoReflect added in v0.5.0

func (*DeletePipelineExtensionSubscriptionRequest) Reset added in v0.5.0

func (*DeletePipelineExtensionSubscriptionRequest) String added in v0.5.0

type DeletePipelineExtensionSubscriptionResponse added in v0.5.0

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

func (*DeletePipelineExtensionSubscriptionResponse) Descriptor deprecated added in v0.5.0

Deprecated: Use DeletePipelineExtensionSubscriptionResponse.ProtoReflect.Descriptor instead.

func (*DeletePipelineExtensionSubscriptionResponse) ProtoMessage added in v0.5.0

func (*DeletePipelineExtensionSubscriptionResponse) ProtoReflect added in v0.5.0

func (*DeletePipelineExtensionSubscriptionResponse) Reset added in v0.5.0

func (*DeletePipelineExtensionSubscriptionResponse) String added in v0.5.0

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 (*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 (*DeletePipelineObjectResponse) Reset

func (x *DeletePipelineObjectResponse) Reset()

func (*DeletePipelineObjectResponse) String

type DeletePipelineRequest

type DeletePipelineRequest 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 (*DeletePipelineRequest) Descriptor deprecated

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

Deprecated: Use DeletePipelineRequest.ProtoReflect.Descriptor instead.

func (*DeletePipelineRequest) GetId

func (x *DeletePipelineRequest) GetId() string

func (*DeletePipelineRequest) GetNamespaceId

func (x *DeletePipelineRequest) GetNamespaceId() string

func (*DeletePipelineRequest) ProtoMessage

func (*DeletePipelineRequest) ProtoMessage()

func (*DeletePipelineRequest) ProtoReflect

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

func (*DeletePipelineRequest) Reset

func (x *DeletePipelineRequest) Reset()

func (*DeletePipelineRequest) String

func (x *DeletePipelineRequest) String() string

type DeletePipelineResponse

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

func (*DeletePipelineResponse) Descriptor deprecated

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

Deprecated: Use DeletePipelineResponse.ProtoReflect.Descriptor instead.

func (*DeletePipelineResponse) ProtoMessage

func (*DeletePipelineResponse) ProtoMessage()

func (*DeletePipelineResponse) ProtoReflect

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

func (*DeletePipelineResponse) Reset

func (x *DeletePipelineResponse) Reset()

func (*DeletePipelineResponse) String

func (x *DeletePipelineResponse) String() string

type DeletePipelineSecretRequest

type DeletePipelineSecretRequest 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 (*DeletePipelineSecretRequest) Descriptor deprecated

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

Deprecated: Use DeletePipelineSecretRequest.ProtoReflect.Descriptor instead.

func (*DeletePipelineSecretRequest) GetKey

func (x *DeletePipelineSecretRequest) GetKey() string

func (*DeletePipelineSecretRequest) GetNamespaceId

func (x *DeletePipelineSecretRequest) GetNamespaceId() string

func (*DeletePipelineSecretRequest) GetPipelineId

func (x *DeletePipelineSecretRequest) GetPipelineId() string

func (*DeletePipelineSecretRequest) ProtoMessage

func (*DeletePipelineSecretRequest) ProtoMessage()

func (*DeletePipelineSecretRequest) ProtoReflect

func (*DeletePipelineSecretRequest) Reset

func (x *DeletePipelineSecretRequest) Reset()

func (*DeletePipelineSecretRequest) String

func (x *DeletePipelineSecretRequest) String() string

type DeletePipelineSecretResponse

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

func (*DeletePipelineSecretResponse) Descriptor deprecated

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

Deprecated: Use DeletePipelineSecretResponse.ProtoReflect.Descriptor instead.

func (*DeletePipelineSecretResponse) ProtoMessage

func (*DeletePipelineSecretResponse) ProtoMessage()

func (*DeletePipelineSecretResponse) ProtoReflect

func (*DeletePipelineSecretResponse) Reset

func (x *DeletePipelineSecretResponse) Reset()

func (*DeletePipelineSecretResponse) String

type DeleteRunObjectRequest

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

func (*DeleteRunObjectRequest) Descriptor deprecated

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

Deprecated: Use DeleteRunObjectRequest.ProtoReflect.Descriptor instead.

func (*DeleteRunObjectRequest) GetKey

func (x *DeleteRunObjectRequest) GetKey() string

func (*DeleteRunObjectRequest) GetNamespaceId

func (x *DeleteRunObjectRequest) GetNamespaceId() string

func (*DeleteRunObjectRequest) GetPipelineId

func (x *DeleteRunObjectRequest) GetPipelineId() string

func (*DeleteRunObjectRequest) GetRunId

func (x *DeleteRunObjectRequest) GetRunId() int64

func (*DeleteRunObjectRequest) ProtoMessage

func (*DeleteRunObjectRequest) ProtoMessage()

func (*DeleteRunObjectRequest) ProtoReflect

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

func (*DeleteRunObjectRequest) Reset

func (x *DeleteRunObjectRequest) Reset()

func (*DeleteRunObjectRequest) String

func (x *DeleteRunObjectRequest) String() string

type DeleteRunObjectResponse

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

func (*DeleteRunObjectResponse) Descriptor deprecated

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

Deprecated: Use DeleteRunObjectResponse.ProtoReflect.Descriptor instead.

func (*DeleteRunObjectResponse) ProtoMessage

func (*DeleteRunObjectResponse) ProtoMessage()

func (*DeleteRunObjectResponse) ProtoReflect

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

func (*DeleteRunObjectResponse) Reset

func (x *DeleteRunObjectResponse) Reset()

func (*DeleteRunObjectResponse) String

func (x *DeleteRunObjectResponse) String() string

type DeleteTaskRunLogsRequest

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

func (*DeleteTaskRunLogsRequest) Descriptor deprecated

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

Deprecated: Use DeleteTaskRunLogsRequest.ProtoReflect.Descriptor instead.

func (*DeleteTaskRunLogsRequest) GetId

func (x *DeleteTaskRunLogsRequest) GetId() string

func (*DeleteTaskRunLogsRequest) GetNamespaceId

func (x *DeleteTaskRunLogsRequest) GetNamespaceId() string

func (*DeleteTaskRunLogsRequest) GetPipelineId

func (x *DeleteTaskRunLogsRequest) GetPipelineId() string

func (*DeleteTaskRunLogsRequest) GetRunId

func (x *DeleteTaskRunLogsRequest) GetRunId() int64

func (*DeleteTaskRunLogsRequest) ProtoMessage

func (*DeleteTaskRunLogsRequest) ProtoMessage()

func (*DeleteTaskRunLogsRequest) ProtoReflect

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

func (*DeleteTaskRunLogsRequest) Reset

func (x *DeleteTaskRunLogsRequest) Reset()

func (*DeleteTaskRunLogsRequest) String

func (x *DeleteTaskRunLogsRequest) String() string

type DeleteTaskRunLogsResponse

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

func (*DeleteTaskRunLogsResponse) Descriptor deprecated

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

Deprecated: Use DeleteTaskRunLogsResponse.ProtoReflect.Descriptor instead.

func (*DeleteTaskRunLogsResponse) ProtoMessage

func (*DeleteTaskRunLogsResponse) ProtoMessage()

func (*DeleteTaskRunLogsResponse) ProtoReflect

func (*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 DeployPipelineRequest added in v0.5.0

type DeployPipelineRequest 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"`
	Version     int64  `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	Force       bool   `protobuf:"varint,4,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

func (*DeployPipelineRequest) Descriptor deprecated added in v0.5.0

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

Deprecated: Use DeployPipelineRequest.ProtoReflect.Descriptor instead.

func (*DeployPipelineRequest) GetForce added in v0.5.0

func (x *DeployPipelineRequest) GetForce() bool

func (*DeployPipelineRequest) GetId added in v0.5.0

func (x *DeployPipelineRequest) GetId() string

func (*DeployPipelineRequest) GetNamespaceId added in v0.5.0

func (x *DeployPipelineRequest) GetNamespaceId() string

func (*DeployPipelineRequest) GetVersion added in v0.5.0

func (x *DeployPipelineRequest) GetVersion() int64

func (*DeployPipelineRequest) ProtoMessage added in v0.5.0

func (*DeployPipelineRequest) ProtoMessage()

func (*DeployPipelineRequest) ProtoReflect added in v0.5.0

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

func (*DeployPipelineRequest) Reset added in v0.5.0

func (x *DeployPipelineRequest) Reset()

func (*DeployPipelineRequest) String added in v0.5.0

func (x *DeployPipelineRequest) String() string

type DeployPipelineResponse added in v0.5.0

type DeployPipelineResponse struct {
	DeploymentId int64 `protobuf:"varint,1,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeployPipelineResponse) Descriptor deprecated added in v0.5.0

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

Deprecated: Use DeployPipelineResponse.ProtoReflect.Descriptor instead.

func (*DeployPipelineResponse) GetDeploymentId added in v0.5.0

func (x *DeployPipelineResponse) GetDeploymentId() int64

func (*DeployPipelineResponse) ProtoMessage added in v0.5.0

func (*DeployPipelineResponse) ProtoMessage()

func (*DeployPipelineResponse) ProtoReflect added in v0.5.0

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

func (*DeployPipelineResponse) Reset added in v0.5.0

func (x *DeployPipelineResponse) Reset()

func (*DeployPipelineResponse) String added in v0.5.0

func (x *DeployPipelineResponse) String() string

type Deployment added in v0.5.0

type Deployment struct {
	Namespace    string                      `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Pipeline     string                      `protobuf:"bytes,2,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	Id           int64                       `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty"`
	StartVersion int64                       `protobuf:"varint,4,opt,name=start_version,json=startVersion,proto3" json:"start_version,omitempty"`
	EndVersion   int64                       `protobuf:"varint,5,opt,name=end_version,json=endVersion,proto3" json:"end_version,omitempty"`
	Started      int64                       `protobuf:"varint,6,opt,name=started,proto3" json:"started,omitempty"`
	Ended        int64                       `protobuf:"varint,7,opt,name=ended,proto3" json:"ended,omitempty"`
	State        Deployment_DeploymentState  `protobuf:"varint,8,opt,name=state,proto3,enum=proto.Deployment_DeploymentState" json:"state,omitempty"`
	Status       Deployment_DeploymentStatus `protobuf:"varint,9,opt,name=status,proto3,enum=proto.Deployment_DeploymentStatus" json:"status,omitempty"`
	StatusReason *DeploymentStatusReason     `protobuf:"bytes,10,opt,name=status_reason,json=statusReason,proto3" json:"status_reason,omitempty"`
	Logs         []*Event                    `protobuf:"bytes,11,rep,name=logs,proto3" json:"logs,omitempty"`
	// contains filtered or unexported fields
}

func (*Deployment) Descriptor deprecated added in v0.5.0

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

Deprecated: Use Deployment.ProtoReflect.Descriptor instead.

func (*Deployment) GetEndVersion added in v0.5.0

func (x *Deployment) GetEndVersion() int64

func (*Deployment) GetEnded added in v0.5.0

func (x *Deployment) GetEnded() int64

func (*Deployment) GetId added in v0.5.0

func (x *Deployment) GetId() int64

func (*Deployment) GetLogs added in v0.5.0

func (x *Deployment) GetLogs() []*Event

func (*Deployment) GetNamespace added in v0.5.0

func (x *Deployment) GetNamespace() string

func (*Deployment) GetPipeline added in v0.5.0

func (x *Deployment) GetPipeline() string

func (*Deployment) GetStartVersion added in v0.5.0

func (x *Deployment) GetStartVersion() int64

func (*Deployment) GetStarted added in v0.5.0

func (x *Deployment) GetStarted() int64

func (*Deployment) GetState added in v0.5.0

func (x *Deployment) GetState() Deployment_DeploymentState

func (*Deployment) GetStatus added in v0.5.0

func (x *Deployment) GetStatus() Deployment_DeploymentStatus

func (*Deployment) GetStatusReason added in v0.5.0

func (x *Deployment) GetStatusReason() *DeploymentStatusReason

func (*Deployment) ProtoMessage added in v0.5.0

func (*Deployment) ProtoMessage()

func (*Deployment) ProtoReflect added in v0.5.0

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

func (*Deployment) Reset added in v0.5.0

func (x *Deployment) Reset()

func (*Deployment) String added in v0.5.0

func (x *Deployment) String() string

type DeploymentStatusReason added in v0.5.0

type DeploymentStatusReason struct {
	Reason      DeploymentStatusReason_DeploymentStatusReasonKind `` /* 127-byte string literal not displayed */
	Description string                                            `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*DeploymentStatusReason) Descriptor deprecated added in v0.5.0

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

Deprecated: Use DeploymentStatusReason.ProtoReflect.Descriptor instead.

func (*DeploymentStatusReason) GetDescription added in v0.5.0

func (x *DeploymentStatusReason) GetDescription() string

func (*DeploymentStatusReason) GetReason added in v0.5.0

func (*DeploymentStatusReason) ProtoMessage added in v0.5.0

func (*DeploymentStatusReason) ProtoMessage()

func (*DeploymentStatusReason) ProtoReflect added in v0.5.0

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

func (*DeploymentStatusReason) Reset added in v0.5.0

func (x *DeploymentStatusReason) Reset()

func (*DeploymentStatusReason) String added in v0.5.0

func (x *DeploymentStatusReason) String() string

type DeploymentStatusReason_DeploymentStatusReasonKind added in v0.5.0

type DeploymentStatusReason_DeploymentStatusReasonKind int32
const (
	DeploymentStatusReason_DEPLOYMENT_STATUS_REASON_UNKNOWN DeploymentStatusReason_DeploymentStatusReasonKind = 0
)

func (DeploymentStatusReason_DeploymentStatusReasonKind) Descriptor added in v0.5.0

func (DeploymentStatusReason_DeploymentStatusReasonKind) Enum added in v0.5.0

func (DeploymentStatusReason_DeploymentStatusReasonKind) EnumDescriptor deprecated added in v0.5.0

Deprecated: Use DeploymentStatusReason_DeploymentStatusReasonKind.Descriptor instead.

func (DeploymentStatusReason_DeploymentStatusReasonKind) Number added in v0.5.0

func (DeploymentStatusReason_DeploymentStatusReasonKind) String added in v0.5.0

func (DeploymentStatusReason_DeploymentStatusReasonKind) Type added in v0.5.0

type Deployment_DeploymentState added in v0.5.0

type Deployment_DeploymentState int32
const (
	Deployment_DEPLOYMENT_STATE_UNKNOWN Deployment_DeploymentState = 0
	Deployment_RUNNING                  Deployment_DeploymentState = 1
	Deployment_COMPLETE                 Deployment_DeploymentState = 2
)

func (Deployment_DeploymentState) Descriptor added in v0.5.0

func (Deployment_DeploymentState) Enum added in v0.5.0

func (Deployment_DeploymentState) EnumDescriptor deprecated added in v0.5.0

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

Deprecated: Use Deployment_DeploymentState.Descriptor instead.

func (Deployment_DeploymentState) Number added in v0.5.0

func (Deployment_DeploymentState) String added in v0.5.0

func (Deployment_DeploymentState) Type added in v0.5.0

type Deployment_DeploymentStatus added in v0.5.0

type Deployment_DeploymentStatus int32
const (
	Deployment_DEPLOYMENT_STATUS_UNKNOWN Deployment_DeploymentStatus = 0
	Deployment_FAILED                    Deployment_DeploymentStatus = 1
	Deployment_SUCCESSFUL                Deployment_DeploymentStatus = 2
)

func (Deployment_DeploymentStatus) Descriptor added in v0.5.0

func (Deployment_DeploymentStatus) Enum added in v0.5.0

func (Deployment_DeploymentStatus) EnumDescriptor deprecated added in v0.5.0

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

Deprecated: Use Deployment_DeploymentStatus.Descriptor instead.

func (Deployment_DeploymentStatus) Number added in v0.5.0

func (Deployment_DeploymentStatus) String added in v0.5.0

func (Deployment_DeploymentStatus) Type added in v0.5.0

type DisableExtensionRequest added in v0.5.0

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

func (*DisableExtensionRequest) Descriptor deprecated added in v0.5.0

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

Deprecated: Use DisableExtensionRequest.ProtoReflect.Descriptor instead.

func (*DisableExtensionRequest) GetName added in v0.5.0

func (x *DisableExtensionRequest) GetName() string

func (*DisableExtensionRequest) ProtoMessage added in v0.5.0

func (*DisableExtensionRequest) ProtoMessage()

func (*DisableExtensionRequest) ProtoReflect added in v0.5.0

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

func (*DisableExtensionRequest) Reset added in v0.5.0

func (x *DisableExtensionRequest) Reset()

func (*DisableExtensionRequest) String added in v0.5.0

func (x *DisableExtensionRequest) String() string

type DisableExtensionResponse added in v0.5.0

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

func (*DisableExtensionResponse) Descriptor deprecated added in v0.5.0

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

Deprecated: Use DisableExtensionResponse.ProtoReflect.Descriptor instead.

func (*DisableExtensionResponse) ProtoMessage added in v0.5.0

func (*DisableExtensionResponse) ProtoMessage()

func (*DisableExtensionResponse) ProtoReflect added in v0.5.0

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

func (*DisableExtensionResponse) Reset added in v0.5.0

func (x *DisableExtensionResponse) Reset()

func (*DisableExtensionResponse) String added in v0.5.0

func (x *DisableExtensionResponse) String() string

type DisablePipelineExtensionSubscriptionRequest added in v0.5.0

type DisablePipelineExtensionSubscriptionRequest 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"`    // Unique pipeline identifier
	ExtensionName  string `protobuf:"bytes,3,opt,name=extension_name,json=extensionName,proto3" json:"extension_name,omitempty"`
	ExtensionLabel string `protobuf:"bytes,4,opt,name=extension_label,json=extensionLabel,proto3" json:"extension_label,omitempty"`
	// contains filtered or unexported fields
}

func (*DisablePipelineExtensionSubscriptionRequest) Descriptor deprecated added in v0.5.0

Deprecated: Use DisablePipelineExtensionSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*DisablePipelineExtensionSubscriptionRequest) GetExtensionLabel added in v0.5.0

func (x *DisablePipelineExtensionSubscriptionRequest) GetExtensionLabel() string

func (*DisablePipelineExtensionSubscriptionRequest) GetExtensionName added in v0.5.0

func (*DisablePipelineExtensionSubscriptionRequest) GetNamespaceId added in v0.5.0

func (*DisablePipelineExtensionSubscriptionRequest) GetPipelineId added in v0.5.0

func (*DisablePipelineExtensionSubscriptionRequest) ProtoMessage added in v0.5.0

func (*DisablePipelineExtensionSubscriptionRequest) ProtoReflect added in v0.5.0

func (*DisablePipelineExtensionSubscriptionRequest) Reset added in v0.5.0

func (*DisablePipelineExtensionSubscriptionRequest) String added in v0.5.0

type DisablePipelineExtensionSubscriptionResponse added in v0.5.0

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

func (*DisablePipelineExtensionSubscriptionResponse) Descriptor deprecated added in v0.5.0

Deprecated: Use DisablePipelineExtensionSubscriptionResponse.ProtoReflect.Descriptor instead.

func (*DisablePipelineExtensionSubscriptionResponse) ProtoMessage added in v0.5.0

func (*DisablePipelineExtensionSubscriptionResponse) ProtoReflect added in v0.5.0

func (*DisablePipelineExtensionSubscriptionResponse) Reset added in v0.5.0

func (*DisablePipelineExtensionSubscriptionResponse) String added in v0.5.0

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 DisableTokenRequest

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

func (*DisableTokenRequest) Descriptor deprecated

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

Deprecated: Use DisableTokenRequest.ProtoReflect.Descriptor instead.

func (*DisableTokenRequest) GetToken

func (x *DisableTokenRequest) GetToken() string

func (*DisableTokenRequest) ProtoMessage

func (*DisableTokenRequest) ProtoMessage()

func (*DisableTokenRequest) ProtoReflect

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

func (*DisableTokenRequest) Reset

func (x *DisableTokenRequest) Reset()

func (*DisableTokenRequest) String

func (x *DisableTokenRequest) String() string

type DisableTokenResponse

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

func (*DisableTokenResponse) Descriptor deprecated

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

Deprecated: Use DisableTokenResponse.ProtoReflect.Descriptor instead.

func (*DisableTokenResponse) ProtoMessage

func (*DisableTokenResponse) ProtoMessage()

func (*DisableTokenResponse) ProtoReflect

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

func (*DisableTokenResponse) Reset

func (x *DisableTokenResponse) Reset()

func (*DisableTokenResponse) String

func (x *DisableTokenResponse) String() string

type EnableExtensionRequest added in v0.5.0

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

func (*EnableExtensionRequest) Descriptor deprecated added in v0.5.0

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

Deprecated: Use EnableExtensionRequest.ProtoReflect.Descriptor instead.

func (*EnableExtensionRequest) GetName added in v0.5.0

func (x *EnableExtensionRequest) GetName() string

func (*EnableExtensionRequest) ProtoMessage added in v0.5.0

func (*EnableExtensionRequest) ProtoMessage()

func (*EnableExtensionRequest) ProtoReflect added in v0.5.0

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

func (*EnableExtensionRequest) Reset added in v0.5.0

func (x *EnableExtensionRequest) Reset()

func (*EnableExtensionRequest) String added in v0.5.0

func (x *EnableExtensionRequest) String() string

type EnableExtensionResponse added in v0.5.0

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

func (*EnableExtensionResponse) Descriptor deprecated added in v0.5.0

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

Deprecated: Use EnableExtensionResponse.ProtoReflect.Descriptor instead.

func (*EnableExtensionResponse) ProtoMessage added in v0.5.0

func (*EnableExtensionResponse) ProtoMessage()

func (*EnableExtensionResponse) ProtoReflect added in v0.5.0

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

func (*EnableExtensionResponse) Reset added in v0.5.0

func (x *EnableExtensionResponse) Reset()

func (*EnableExtensionResponse) String added in v0.5.0

func (x *EnableExtensionResponse) String() string

type EnablePipelineExtensionSubscriptionRequest added in v0.5.0

type EnablePipelineExtensionSubscriptionRequest 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"`    // Unique pipeline identifier
	ExtensionName  string `protobuf:"bytes,3,opt,name=extension_name,json=extensionName,proto3" json:"extension_name,omitempty"`
	ExtensionLabel string `protobuf:"bytes,4,opt,name=extension_label,json=extensionLabel,proto3" json:"extension_label,omitempty"`
	// contains filtered or unexported fields
}

func (*EnablePipelineExtensionSubscriptionRequest) Descriptor deprecated added in v0.5.0

Deprecated: Use EnablePipelineExtensionSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*EnablePipelineExtensionSubscriptionRequest) GetExtensionLabel added in v0.5.0

func (x *EnablePipelineExtensionSubscriptionRequest) GetExtensionLabel() string

func (*EnablePipelineExtensionSubscriptionRequest) GetExtensionName added in v0.5.0

func (x *EnablePipelineExtensionSubscriptionRequest) GetExtensionName() string

func (*EnablePipelineExtensionSubscriptionRequest) GetNamespaceId added in v0.5.0

func (*EnablePipelineExtensionSubscriptionRequest) GetPipelineId added in v0.5.0

func (*EnablePipelineExtensionSubscriptionRequest) ProtoMessage added in v0.5.0

func (*EnablePipelineExtensionSubscriptionRequest) ProtoReflect added in v0.5.0

func (*EnablePipelineExtensionSubscriptionRequest) Reset added in v0.5.0

func (*EnablePipelineExtensionSubscriptionRequest) String added in v0.5.0

type EnablePipelineExtensionSubscriptionResponse added in v0.5.0

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

func (*EnablePipelineExtensionSubscriptionResponse) Descriptor deprecated added in v0.5.0

Deprecated: Use EnablePipelineExtensionSubscriptionResponse.ProtoReflect.Descriptor instead.

func (*EnablePipelineExtensionSubscriptionResponse) ProtoMessage added in v0.5.0

func (*EnablePipelineExtensionSubscriptionResponse) ProtoReflect added in v0.5.0

func (*EnablePipelineExtensionSubscriptionResponse) Reset added in v0.5.0

func (*EnablePipelineExtensionSubscriptionResponse) String added in v0.5.0

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 EnableTokenRequest

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

func (*EnableTokenRequest) Descriptor deprecated

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

Deprecated: Use EnableTokenRequest.ProtoReflect.Descriptor instead.

func (*EnableTokenRequest) GetToken

func (x *EnableTokenRequest) GetToken() string

func (*EnableTokenRequest) ProtoMessage

func (*EnableTokenRequest) ProtoMessage()

func (*EnableTokenRequest) ProtoReflect

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

func (*EnableTokenRequest) Reset

func (x *EnableTokenRequest) Reset()

func (*EnableTokenRequest) String

func (x *EnableTokenRequest) String() string

type EnableTokenResponse

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

func (*EnableTokenResponse) Descriptor deprecated

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

Deprecated: Use EnableTokenResponse.ProtoReflect.Descriptor instead.

func (*EnableTokenResponse) ProtoMessage

func (*EnableTokenResponse) ProtoMessage()

func (*EnableTokenResponse) ProtoReflect

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

func (*EnableTokenResponse) Reset

func (x *EnableTokenResponse) Reset()

func (*EnableTokenResponse) String

func (x *EnableTokenResponse) String() string

type Event

type Event struct {
	Id      int64  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Type    string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`       // What type of event
	Details string `protobuf:"bytes,3,opt,name=details,proto3" json:"details,omitempty"` // Json output of the event
	Emitted int64  `protobuf:"varint,4,opt,name=emitted,proto3" json:"emitted,omitempty"`
	// contains filtered or unexported fields
}

func (*Event) Descriptor deprecated

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetDetails

func (x *Event) GetDetails() string

func (*Event) GetEmitted

func (x *Event) GetEmitted() int64

func (*Event) GetId

func (x *Event) GetId() int64

func (*Event) GetType added in v0.5.0

func (x *Event) GetType() string

func (*Event) ProtoMessage

func (*Event) ProtoMessage()

func (*Event) ProtoReflect

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

func (*Event) Reset

func (x *Event) Reset()

func (*Event) String

func (x *Event) String() string

type Extension added in v0.5.0

type Extension struct {
	Name          string                    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Image         string                    `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	Url           string                    `protobuf:"bytes,3,opt,name=url,proto3" json:"url,omitempty"`
	Started       int64                     `protobuf:"varint,4,opt,name=started,proto3" json:"started,omitempty"`
	State         Extension_ExtensionState  `protobuf:"varint,5,opt,name=state,proto3,enum=proto.Extension_ExtensionState" json:"state,omitempty"`
	Status        Extension_ExtensionStatus `protobuf:"varint,6,opt,name=status,proto3,enum=proto.Extension_ExtensionStatus" json:"status,omitempty"`
	Documentation string                    `protobuf:"bytes,7,opt,name=documentation,proto3" json:"documentation,omitempty"`
	// contains filtered or unexported fields
}

func (*Extension) Descriptor deprecated added in v0.5.0

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

Deprecated: Use Extension.ProtoReflect.Descriptor instead.

func (*Extension) GetDocumentation added in v0.5.0

func (x *Extension) GetDocumentation() string

func (*Extension) GetImage added in v0.5.0

func (x *Extension) GetImage() string

func (*Extension) GetName added in v0.5.0

func (x *Extension) GetName() string

func (*Extension) GetStarted added in v0.5.0

func (x *Extension) GetStarted() int64

func (*Extension) GetState added in v0.5.0

func (x *Extension) GetState() Extension_ExtensionState

func (*Extension) GetStatus added in v0.5.0

func (x *Extension) GetStatus() Extension_ExtensionStatus

func (*Extension) GetUrl added in v0.5.0

func (x *Extension) GetUrl() string

func (*Extension) ProtoMessage added in v0.5.0

func (*Extension) ProtoMessage()

func (*Extension) ProtoReflect added in v0.5.0

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

func (*Extension) Reset added in v0.5.0

func (x *Extension) Reset()

func (*Extension) String added in v0.5.0

func (x *Extension) String() string

type ExtensionExternalEventRequest added in v0.5.0

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

func (*ExtensionExternalEventRequest) Descriptor deprecated added in v0.5.0

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

Deprecated: Use ExtensionExternalEventRequest.ProtoReflect.Descriptor instead.

func (*ExtensionExternalEventRequest) GetPayload added in v0.5.0

func (x *ExtensionExternalEventRequest) GetPayload() []byte

func (*ExtensionExternalEventRequest) ProtoMessage added in v0.5.0

func (*ExtensionExternalEventRequest) ProtoMessage()

func (*ExtensionExternalEventRequest) ProtoReflect added in v0.5.0

func (*ExtensionExternalEventRequest) Reset added in v0.5.0

func (x *ExtensionExternalEventRequest) Reset()

func (*ExtensionExternalEventRequest) String added in v0.5.0

type ExtensionExternalEventResponse added in v0.5.0

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

func (*ExtensionExternalEventResponse) Descriptor deprecated added in v0.5.0

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

Deprecated: Use ExtensionExternalEventResponse.ProtoReflect.Descriptor instead.

func (*ExtensionExternalEventResponse) ProtoMessage added in v0.5.0

func (*ExtensionExternalEventResponse) ProtoMessage()

func (*ExtensionExternalEventResponse) ProtoReflect added in v0.5.0

func (*ExtensionExternalEventResponse) Reset added in v0.5.0

func (x *ExtensionExternalEventResponse) Reset()

func (*ExtensionExternalEventResponse) String added in v0.5.0

type ExtensionInfoRequest added in v0.5.0

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

func (*ExtensionInfoRequest) Descriptor deprecated added in v0.5.0

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

Deprecated: Use ExtensionInfoRequest.ProtoReflect.Descriptor instead.

func (*ExtensionInfoRequest) ProtoMessage added in v0.5.0

func (*ExtensionInfoRequest) ProtoMessage()

func (*ExtensionInfoRequest) ProtoReflect added in v0.5.0

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

func (*ExtensionInfoRequest) Reset added in v0.5.0

func (x *ExtensionInfoRequest) Reset()

func (*ExtensionInfoRequest) String added in v0.5.0

func (x *ExtensionInfoRequest) String() string

type ExtensionInfoResponse added in v0.5.0

type ExtensionInfoResponse struct {

	// kind corresponds a unique extension identifier, this is passed as a envvar
	// via the main process(and as such can be left empty), as the main process
	// container the configuration for which extension "kind" corresponds to which
	// extension container.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Extensions are allowed to provide more extensive documentation on
	// how to use and configure them.
	Documentation string `protobuf:"bytes,2,opt,name=documentation,proto3" json:"documentation,omitempty"`
	// A listing of all registered pipelines in the format: <namespace>/<pipeline>
	Registered []string `protobuf:"bytes,3,rep,name=registered,proto3" json:"registered,omitempty"`
	// contains filtered or unexported fields
}

func (*ExtensionInfoResponse) Descriptor deprecated added in v0.5.0

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

Deprecated: Use ExtensionInfoResponse.ProtoReflect.Descriptor instead.

func (*ExtensionInfoResponse) GetDocumentation added in v0.5.0

func (x *ExtensionInfoResponse) GetDocumentation() string

func (*ExtensionInfoResponse) GetName added in v0.5.0

func (x *ExtensionInfoResponse) GetName() string

func (*ExtensionInfoResponse) GetRegistered added in v0.5.0

func (x *ExtensionInfoResponse) GetRegistered() []string

func (*ExtensionInfoResponse) ProtoMessage added in v0.5.0

func (*ExtensionInfoResponse) ProtoMessage()

func (*ExtensionInfoResponse) ProtoReflect added in v0.5.0

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

func (*ExtensionInfoResponse) Reset added in v0.5.0

func (x *ExtensionInfoResponse) Reset()

func (*ExtensionInfoResponse) String added in v0.5.0

func (x *ExtensionInfoResponse) String() string

type ExtensionInitRequest added in v0.6.0

type ExtensionInitRequest struct {
	Config map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ExtensionInitRequest) Descriptor deprecated added in v0.6.0

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

Deprecated: Use ExtensionInitRequest.ProtoReflect.Descriptor instead.

func (*ExtensionInitRequest) GetConfig added in v0.6.0

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

func (*ExtensionInitRequest) ProtoMessage added in v0.6.0

func (*ExtensionInitRequest) ProtoMessage()

func (*ExtensionInitRequest) ProtoReflect added in v0.6.0

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

func (*ExtensionInitRequest) Reset added in v0.6.0

func (x *ExtensionInitRequest) Reset()

func (*ExtensionInitRequest) String added in v0.6.0

func (x *ExtensionInitRequest) String() string

type ExtensionInitResponse added in v0.6.0

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

func (*ExtensionInitResponse) Descriptor deprecated added in v0.6.0

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

Deprecated: Use ExtensionInitResponse.ProtoReflect.Descriptor instead.

func (*ExtensionInitResponse) ProtoMessage added in v0.6.0

func (*ExtensionInitResponse) ProtoMessage()

func (*ExtensionInitResponse) ProtoReflect added in v0.6.0

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

func (*ExtensionInitResponse) Reset added in v0.6.0

func (x *ExtensionInitResponse) Reset()

func (*ExtensionInitResponse) String added in v0.6.0

func (x *ExtensionInitResponse) String() string

type ExtensionRegistration added in v0.5.0

type ExtensionRegistration struct {
	Name      string                                `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Image     string                                `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	User      string                                `protobuf:"bytes,3,opt,name=user,proto3" json:"user,omitempty"`
	Pass      string                                `protobuf:"bytes,4,opt,name=pass,proto3" json:"pass,omitempty"`
	Variables map[string]string                     `` /* 159-byte string literal not displayed */
	Created   int64                                 `protobuf:"varint,6,opt,name=created,proto3" json:"created,omitempty"`
	Status    ExtensionRegistration_ExtensionStatus `protobuf:"varint,7,opt,name=status,proto3,enum=proto.ExtensionRegistration_ExtensionStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*ExtensionRegistration) Descriptor deprecated added in v0.5.0

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

Deprecated: Use ExtensionRegistration.ProtoReflect.Descriptor instead.

func (*ExtensionRegistration) GetCreated added in v0.5.0

func (x *ExtensionRegistration) GetCreated() int64

func (*ExtensionRegistration) GetImage added in v0.5.0

func (x *ExtensionRegistration) GetImage() string

func (*ExtensionRegistration) GetName added in v0.5.0

func (x *ExtensionRegistration) GetName() string

func (*ExtensionRegistration) GetPass added in v0.5.0

func (x *ExtensionRegistration) GetPass() string

func (*ExtensionRegistration) GetStatus added in v0.5.0

func (*ExtensionRegistration) GetUser added in v0.5.0

func (x *ExtensionRegistration) GetUser() string

func (*ExtensionRegistration) GetVariables added in v0.5.0

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

func (*ExtensionRegistration) ProtoMessage added in v0.5.0

func (*ExtensionRegistration) ProtoMessage()

func (*ExtensionRegistration) ProtoReflect added in v0.5.0

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

func (*ExtensionRegistration) Reset added in v0.5.0

func (x *ExtensionRegistration) Reset()

func (*ExtensionRegistration) String added in v0.5.0

func (x *ExtensionRegistration) String() string

type ExtensionRegistration_ExtensionStatus added in v0.5.0

type ExtensionRegistration_ExtensionStatus int32
const (
	ExtensionRegistration_UNKNOWN_STATUS ExtensionRegistration_ExtensionStatus = 0
	ExtensionRegistration_ENABLED        ExtensionRegistration_ExtensionStatus = 1
	ExtensionRegistration_DISABLED       ExtensionRegistration_ExtensionStatus = 2
)

func (ExtensionRegistration_ExtensionStatus) Descriptor added in v0.5.0

func (ExtensionRegistration_ExtensionStatus) Enum added in v0.5.0

func (ExtensionRegistration_ExtensionStatus) EnumDescriptor deprecated added in v0.5.0

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

Deprecated: Use ExtensionRegistration_ExtensionStatus.Descriptor instead.

func (ExtensionRegistration_ExtensionStatus) Number added in v0.5.0

func (ExtensionRegistration_ExtensionStatus) String added in v0.5.0

func (ExtensionRegistration_ExtensionStatus) Type added in v0.5.0

type ExtensionResult added in v0.5.0

type ExtensionResult struct {
	Status  ExtensionResult_Status `protobuf:"varint,1,opt,name=status,proto3,enum=proto.ExtensionResult_Status" json:"status,omitempty"`
	Details string                 `protobuf:"bytes,2,opt,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

func (*ExtensionResult) Descriptor deprecated added in v0.5.0

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

Deprecated: Use ExtensionResult.ProtoReflect.Descriptor instead.

func (*ExtensionResult) GetDetails added in v0.5.0

func (x *ExtensionResult) GetDetails() string

func (*ExtensionResult) GetStatus added in v0.5.0

func (x *ExtensionResult) GetStatus() ExtensionResult_Status

func (*ExtensionResult) ProtoMessage added in v0.5.0

func (*ExtensionResult) ProtoMessage()

func (*ExtensionResult) ProtoReflect added in v0.5.0

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

func (*ExtensionResult) Reset added in v0.5.0

func (x *ExtensionResult) Reset()

func (*ExtensionResult) String added in v0.5.0

func (x *ExtensionResult) String() string

type ExtensionResult_Status added in v0.5.0

type ExtensionResult_Status int32
const (
	ExtensionResult_UNKNOWN ExtensionResult_Status = 0
	ExtensionResult_FAILURE ExtensionResult_Status = 1
	ExtensionResult_SUCCESS ExtensionResult_Status = 2
	ExtensionResult_SKIPPED ExtensionResult_Status = 3
)

func (ExtensionResult_Status) Descriptor added in v0.5.0

func (ExtensionResult_Status) Enum added in v0.5.0

func (ExtensionResult_Status) EnumDescriptor deprecated added in v0.5.0

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

Deprecated: Use ExtensionResult_Status.Descriptor instead.

func (ExtensionResult_Status) Number added in v0.5.0

func (ExtensionResult_Status) String added in v0.5.0

func (x ExtensionResult_Status) String() string

func (ExtensionResult_Status) Type added in v0.5.0

type ExtensionRunExtensionInstallerClientMessage added in v0.6.0

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

func (*ExtensionRunExtensionInstallerClientMessage) Descriptor deprecated added in v0.6.0

Deprecated: Use ExtensionRunExtensionInstallerClientMessage.ProtoReflect.Descriptor instead.

func (*ExtensionRunExtensionInstallerClientMessage) GetMsg added in v0.6.0

func (*ExtensionRunExtensionInstallerClientMessage) ProtoMessage added in v0.6.0

func (*ExtensionRunExtensionInstallerClientMessage) ProtoReflect added in v0.6.0

func (*ExtensionRunExtensionInstallerClientMessage) Reset added in v0.6.0

func (*ExtensionRunExtensionInstallerClientMessage) String added in v0.6.0

type ExtensionRunExtensionInstallerExtensionMessage added in v0.6.0

type ExtensionRunExtensionInstallerExtensionMessage struct {

	// Types that are assignable to MessageType:
	//
	//	*ExtensionRunExtensionInstallerExtensionMessage_Msg
	//	*ExtensionRunExtensionInstallerExtensionMessage_Query
	//	*ExtensionRunExtensionInstallerExtensionMessage_ConfigSetting_
	MessageType isExtensionRunExtensionInstallerExtensionMessage_MessageType `protobuf_oneof:"message_type"`
	// contains filtered or unexported fields
}

func (*ExtensionRunExtensionInstallerExtensionMessage) Descriptor deprecated added in v0.6.0

Deprecated: Use ExtensionRunExtensionInstallerExtensionMessage.ProtoReflect.Descriptor instead.

func (*ExtensionRunExtensionInstallerExtensionMessage) GetConfigSetting added in v0.6.0

func (*ExtensionRunExtensionInstallerExtensionMessage) GetMessageType added in v0.6.0

func (m *ExtensionRunExtensionInstallerExtensionMessage) GetMessageType() isExtensionRunExtensionInstallerExtensionMessage_MessageType

func (*ExtensionRunExtensionInstallerExtensionMessage) GetMsg added in v0.6.0

func (*ExtensionRunExtensionInstallerExtensionMessage) GetQuery added in v0.6.0

func (*ExtensionRunExtensionInstallerExtensionMessage) ProtoMessage added in v0.6.0

func (*ExtensionRunExtensionInstallerExtensionMessage) ProtoReflect added in v0.6.0

func (*ExtensionRunExtensionInstallerExtensionMessage) Reset added in v0.6.0

func (*ExtensionRunExtensionInstallerExtensionMessage) String added in v0.6.0

type ExtensionRunExtensionInstallerExtensionMessage_ConfigSetting added in v0.6.0

type ExtensionRunExtensionInstallerExtensionMessage_ConfigSetting struct {
	Config string `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	Value  string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*ExtensionRunExtensionInstallerExtensionMessage_ConfigSetting) Descriptor deprecated added in v0.6.0

Deprecated: Use ExtensionRunExtensionInstallerExtensionMessage_ConfigSetting.ProtoReflect.Descriptor instead.

func (*ExtensionRunExtensionInstallerExtensionMessage_ConfigSetting) GetConfig added in v0.6.0

func (*ExtensionRunExtensionInstallerExtensionMessage_ConfigSetting) GetValue added in v0.6.0

func (*ExtensionRunExtensionInstallerExtensionMessage_ConfigSetting) ProtoMessage added in v0.6.0

func (*ExtensionRunExtensionInstallerExtensionMessage_ConfigSetting) ProtoReflect added in v0.6.0

func (*ExtensionRunExtensionInstallerExtensionMessage_ConfigSetting) Reset added in v0.6.0

func (*ExtensionRunExtensionInstallerExtensionMessage_ConfigSetting) String added in v0.6.0

type ExtensionRunExtensionInstallerExtensionMessage_ConfigSetting_ added in v0.6.0

type ExtensionRunExtensionInstallerExtensionMessage_ConfigSetting_ struct {
	// Config setting messages communicate when the extension has suggested a
	// configuration based on the user input.
	ConfigSetting *ExtensionRunExtensionInstallerExtensionMessage_ConfigSetting `protobuf:"bytes,3,opt,name=config_setting,json=configSetting,proto3,oneof"`
}

type ExtensionRunExtensionInstallerExtensionMessage_Msg added in v0.6.0

type ExtensionRunExtensionInstallerExtensionMessage_Msg struct {
	// Normal extension messages that should be passed back to the user.
	Msg string `protobuf:"bytes,1,opt,name=msg,proto3,oneof"`
}

type ExtensionRunExtensionInstallerExtensionMessage_Query added in v0.6.0

type ExtensionRunExtensionInstallerExtensionMessage_Query struct {
	// A question from the extension that needs an answer. The extension will
	// wait for an answer after this request. This specific message type
	// allows the cli to know when to prompt the user for an answer.
	Query string `protobuf:"bytes,2,opt,name=query,proto3,oneof"`
}

type ExtensionRunPipelineConfiguratorClientMessage added in v0.6.0

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

func (*ExtensionRunPipelineConfiguratorClientMessage) Descriptor deprecated added in v0.6.0

Deprecated: Use ExtensionRunPipelineConfiguratorClientMessage.ProtoReflect.Descriptor instead.

func (*ExtensionRunPipelineConfiguratorClientMessage) GetMsg added in v0.6.0

func (*ExtensionRunPipelineConfiguratorClientMessage) ProtoMessage added in v0.6.0

func (*ExtensionRunPipelineConfiguratorClientMessage) ProtoReflect added in v0.6.0

func (*ExtensionRunPipelineConfiguratorClientMessage) Reset added in v0.6.0

func (*ExtensionRunPipelineConfiguratorClientMessage) String added in v0.6.0

type ExtensionRunPipelineConfiguratorExtensionMessage added in v0.6.0

type ExtensionRunPipelineConfiguratorExtensionMessage struct {

	// Types that are assignable to MessageType:
	//
	//	*ExtensionRunPipelineConfiguratorExtensionMessage_Msg
	//	*ExtensionRunPipelineConfiguratorExtensionMessage_Query
	//	*ExtensionRunPipelineConfiguratorExtensionMessage_ParamSetting_
	MessageType isExtensionRunPipelineConfiguratorExtensionMessage_MessageType `protobuf_oneof:"message_type"`
	// contains filtered or unexported fields
}

func (*ExtensionRunPipelineConfiguratorExtensionMessage) Descriptor deprecated added in v0.6.0

Deprecated: Use ExtensionRunPipelineConfiguratorExtensionMessage.ProtoReflect.Descriptor instead.

func (*ExtensionRunPipelineConfiguratorExtensionMessage) GetMessageType added in v0.6.0

func (m *ExtensionRunPipelineConfiguratorExtensionMessage) GetMessageType() isExtensionRunPipelineConfiguratorExtensionMessage_MessageType

func (*ExtensionRunPipelineConfiguratorExtensionMessage) GetMsg added in v0.6.0

func (*ExtensionRunPipelineConfiguratorExtensionMessage) GetParamSetting added in v0.6.0

func (*ExtensionRunPipelineConfiguratorExtensionMessage) GetQuery added in v0.6.0

func (*ExtensionRunPipelineConfiguratorExtensionMessage) ProtoMessage added in v0.6.0

func (*ExtensionRunPipelineConfiguratorExtensionMessage) ProtoReflect added in v0.6.0

func (*ExtensionRunPipelineConfiguratorExtensionMessage) Reset added in v0.6.0

func (*ExtensionRunPipelineConfiguratorExtensionMessage) String added in v0.6.0

type ExtensionRunPipelineConfiguratorExtensionMessage_Msg added in v0.6.0

type ExtensionRunPipelineConfiguratorExtensionMessage_Msg struct {
	// Normal extension messages that should be passed back to the user.
	Msg string `protobuf:"bytes,1,opt,name=msg,proto3,oneof"`
}

type ExtensionRunPipelineConfiguratorExtensionMessage_ParamSetting added in v0.6.0

type ExtensionRunPipelineConfiguratorExtensionMessage_ParamSetting struct {
	Param string `protobuf:"bytes,1,opt,name=param,proto3" json:"param,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*ExtensionRunPipelineConfiguratorExtensionMessage_ParamSetting) Descriptor deprecated added in v0.6.0

Deprecated: Use ExtensionRunPipelineConfiguratorExtensionMessage_ParamSetting.ProtoReflect.Descriptor instead.

func (*ExtensionRunPipelineConfiguratorExtensionMessage_ParamSetting) GetParam added in v0.6.0

func (*ExtensionRunPipelineConfiguratorExtensionMessage_ParamSetting) GetValue added in v0.6.0

func (*ExtensionRunPipelineConfiguratorExtensionMessage_ParamSetting) ProtoMessage added in v0.6.0

func (*ExtensionRunPipelineConfiguratorExtensionMessage_ParamSetting) ProtoReflect added in v0.6.0

func (*ExtensionRunPipelineConfiguratorExtensionMessage_ParamSetting) Reset added in v0.6.0

func (*ExtensionRunPipelineConfiguratorExtensionMessage_ParamSetting) String added in v0.6.0

type ExtensionRunPipelineConfiguratorExtensionMessage_ParamSetting_ added in v0.6.0

type ExtensionRunPipelineConfiguratorExtensionMessage_ParamSetting_ struct {
	// Param setting messages communicate when the extension has suggested a
	// configuration based on the user input.
	ParamSetting *ExtensionRunPipelineConfiguratorExtensionMessage_ParamSetting `protobuf:"bytes,3,opt,name=param_setting,json=paramSetting,proto3,oneof"`
}

type ExtensionRunPipelineConfiguratorExtensionMessage_Query added in v0.6.0

type ExtensionRunPipelineConfiguratorExtensionMessage_Query struct {
	// A question from the extension that needs an answer. The extension will
	// wait for an answer after this request. This specific message type
	// allows the cli to know when to prompt the user for an answer.
	Query string `protobuf:"bytes,2,opt,name=query,proto3,oneof"`
}

type ExtensionServiceClient added in v0.5.0

type ExtensionServiceClient interface {
	// Init returns when an extension is ready to serve requests.
	Init(ctx context.Context, in *ExtensionInitRequest, opts ...grpc.CallOption) (*ExtensionInitResponse, error)
	// Info returns information on the specific plugin.
	Info(ctx context.Context, in *ExtensionInfoRequest, opts ...grpc.CallOption) (*ExtensionInfoResponse, error)
	// Subscribe allows a extension to keep track of all pipelines currently
	// dependant on that extension so that we can extension them at appropriate
	// times.
	Subscribe(ctx context.Context, in *ExtensionSubscribeRequest, opts ...grpc.CallOption) (*ExtensionSubscribeResponse, error)
	// Unsubscribe allows pipelines to remove their extension subscriptions. This
	// is useful if the pipeline no longer needs to be notified about a specific
	// extension automation.
	Unsubscribe(ctx context.Context, in *ExtensionUnsubscribeRequest, opts ...grpc.CallOption) (*ExtensionUnsubscribeResponse, error)
	// Shutdown tells the extension to cleanup and gracefully shutdown. If a
	// extension does not shutdown in a time defined by the gofer API the
	// extension will instead be Force shutdown(SIGKILL). This is to say that all
	// extensions should lean toward quick cleanups and shutdowns.
	Shutdown(ctx context.Context, in *ExtensionShutdownRequest, opts ...grpc.CallOption) (*ExtensionShutdownResponse, error)
	// ExternalEvent are json blobs of gofer's /events endpoint. Normally
	// webhooks.
	ExternalEvent(ctx context.Context, in *ExtensionExternalEventRequest, opts ...grpc.CallOption) (*ExtensionExternalEventResponse, error)
	// Run the installer that helps admin user install the extension.
	RunExtensionInstaller(ctx context.Context, opts ...grpc.CallOption) (ExtensionService_RunExtensionInstallerClient, error)
	// Run the installer that helps pipeline users with their pipeline extension
	// configuration.
	RunPipelineConfigurator(ctx context.Context, opts ...grpc.CallOption) (ExtensionService_RunPipelineConfiguratorClient, error)
}

ExtensionServiceClient is the client API for ExtensionService service.

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

func NewExtensionServiceClient added in v0.5.0

func NewExtensionServiceClient(cc grpc.ClientConnInterface) ExtensionServiceClient

type ExtensionServiceServer added in v0.5.0

type ExtensionServiceServer interface {
	// Init returns when an extension is ready to serve requests.
	Init(context.Context, *ExtensionInitRequest) (*ExtensionInitResponse, error)
	// Info returns information on the specific plugin.
	Info(context.Context, *ExtensionInfoRequest) (*ExtensionInfoResponse, error)
	// Subscribe allows a extension to keep track of all pipelines currently
	// dependant on that extension so that we can extension them at appropriate
	// times.
	Subscribe(context.Context, *ExtensionSubscribeRequest) (*ExtensionSubscribeResponse, error)
	// Unsubscribe allows pipelines to remove their extension subscriptions. This
	// is useful if the pipeline no longer needs to be notified about a specific
	// extension automation.
	Unsubscribe(context.Context, *ExtensionUnsubscribeRequest) (*ExtensionUnsubscribeResponse, error)
	// Shutdown tells the extension to cleanup and gracefully shutdown. If a
	// extension does not shutdown in a time defined by the gofer API the
	// extension will instead be Force shutdown(SIGKILL). This is to say that all
	// extensions should lean toward quick cleanups and shutdowns.
	Shutdown(context.Context, *ExtensionShutdownRequest) (*ExtensionShutdownResponse, error)
	// ExternalEvent are json blobs of gofer's /events endpoint. Normally
	// webhooks.
	ExternalEvent(context.Context, *ExtensionExternalEventRequest) (*ExtensionExternalEventResponse, error)
	// Run the installer that helps admin user install the extension.
	RunExtensionInstaller(ExtensionService_RunExtensionInstallerServer) error
	// Run the installer that helps pipeline users with their pipeline extension
	// configuration.
	RunPipelineConfigurator(ExtensionService_RunPipelineConfiguratorServer) error
	// contains filtered or unexported methods
}

ExtensionServiceServer is the server API for ExtensionService service. All implementations must embed UnimplementedExtensionServiceServer for forward compatibility

type ExtensionService_RunExtensionInstallerClient added in v0.6.0

type ExtensionService_RunExtensionInstallerClient interface {
	Send(*ExtensionRunExtensionInstallerClientMessage) error
	Recv() (*ExtensionRunExtensionInstallerExtensionMessage, error)
	grpc.ClientStream
}

type ExtensionService_RunExtensionInstallerServer added in v0.6.0

type ExtensionService_RunExtensionInstallerServer interface {
	Send(*ExtensionRunExtensionInstallerExtensionMessage) error
	Recv() (*ExtensionRunExtensionInstallerClientMessage, error)
	grpc.ServerStream
}

type ExtensionService_RunPipelineConfiguratorClient added in v0.6.0

type ExtensionService_RunPipelineConfiguratorClient interface {
	Send(*ExtensionRunPipelineConfiguratorClientMessage) error
	Recv() (*ExtensionRunPipelineConfiguratorExtensionMessage, error)
	grpc.ClientStream
}

type ExtensionService_RunPipelineConfiguratorServer added in v0.6.0

type ExtensionService_RunPipelineConfiguratorServer interface {
	Send(*ExtensionRunPipelineConfiguratorExtensionMessage) error
	Recv() (*ExtensionRunPipelineConfiguratorClientMessage, error)
	grpc.ServerStream
}

type ExtensionShutdownRequest added in v0.5.0

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

func (*ExtensionShutdownRequest) Descriptor deprecated added in v0.5.0

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

Deprecated: Use ExtensionShutdownRequest.ProtoReflect.Descriptor instead.

func (*ExtensionShutdownRequest) ProtoMessage added in v0.5.0

func (*ExtensionShutdownRequest) ProtoMessage()

func (*ExtensionShutdownRequest) ProtoReflect added in v0.5.0

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

func (*ExtensionShutdownRequest) Reset added in v0.5.0

func (x *ExtensionShutdownRequest) Reset()

func (*ExtensionShutdownRequest) String added in v0.5.0

func (x *ExtensionShutdownRequest) String() string

type ExtensionShutdownResponse added in v0.5.0

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

func (*ExtensionShutdownResponse) Descriptor deprecated added in v0.5.0

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

Deprecated: Use ExtensionShutdownResponse.ProtoReflect.Descriptor instead.

func (*ExtensionShutdownResponse) ProtoMessage added in v0.5.0

func (*ExtensionShutdownResponse) ProtoMessage()

func (*ExtensionShutdownResponse) ProtoReflect added in v0.5.0

func (*ExtensionShutdownResponse) Reset added in v0.5.0

func (x *ExtensionShutdownResponse) Reset()

func (*ExtensionShutdownResponse) String added in v0.5.0

func (x *ExtensionShutdownResponse) String() string

type ExtensionSubscribeRequest added in v0.5.0

type ExtensionSubscribeRequest struct {
	NamespaceId            string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` // unique identifier for associated namespace.
	PipelineId             string `protobuf:"bytes,2,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`    // unique identifier for associated pipeline.
	PipelineExtensionLabel string ``                                                                                               // pipeline specific subscription id
	/* 129-byte string literal not displayed */
	// Pipelines are allowed to pass a configuration to extensions denoting what
	// specific settings they might like for a specific extension. The acceptable
	// values of this config map is defined by the extensions and should be
	// mentioned in documentation.
	//
	// Additionally, the extension should verify config settings and pass back an
	// error when it does not meet requirements.
	//
	// Note: The keys in this map are forced to be uppercase. This is important
	// when checking for their existance when writing a extension.
	Config map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ExtensionSubscribeRequest) Descriptor deprecated added in v0.5.0

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

Deprecated: Use ExtensionSubscribeRequest.ProtoReflect.Descriptor instead.

func (*ExtensionSubscribeRequest) GetConfig added in v0.5.0

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

func (*ExtensionSubscribeRequest) GetNamespaceId added in v0.5.0

func (x *ExtensionSubscribeRequest) GetNamespaceId() string

func (*ExtensionSubscribeRequest) GetPipelineExtensionLabel added in v0.5.0

func (x *ExtensionSubscribeRequest) GetPipelineExtensionLabel() string

func (*ExtensionSubscribeRequest) GetPipelineId added in v0.5.0

func (x *ExtensionSubscribeRequest) GetPipelineId() string

func (*ExtensionSubscribeRequest) ProtoMessage added in v0.5.0

func (*ExtensionSubscribeRequest) ProtoMessage()

func (*ExtensionSubscribeRequest) ProtoReflect added in v0.5.0

func (*ExtensionSubscribeRequest) Reset added in v0.5.0

func (x *ExtensionSubscribeRequest) Reset()

func (*ExtensionSubscribeRequest) String added in v0.5.0

func (x *ExtensionSubscribeRequest) String() string

type ExtensionSubscribeResponse added in v0.5.0

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

func (*ExtensionSubscribeResponse) Descriptor deprecated added in v0.5.0

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

Deprecated: Use ExtensionSubscribeResponse.ProtoReflect.Descriptor instead.

func (*ExtensionSubscribeResponse) ProtoMessage added in v0.5.0

func (*ExtensionSubscribeResponse) ProtoMessage()

func (*ExtensionSubscribeResponse) ProtoReflect added in v0.5.0

func (*ExtensionSubscribeResponse) Reset added in v0.5.0

func (x *ExtensionSubscribeResponse) Reset()

func (*ExtensionSubscribeResponse) String added in v0.5.0

func (x *ExtensionSubscribeResponse) String() string

type ExtensionUnsubscribeRequest added in v0.5.0

type ExtensionUnsubscribeRequest struct {
	NamespaceId            string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` // unique identifier for associated namespace
	PipelineId             string `protobuf:"bytes,2,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`    // unique identifier for associated pipeline
	PipelineExtensionLabel string ``                                                                                               // pipeline specific subscription id
	/* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ExtensionUnsubscribeRequest) Descriptor deprecated added in v0.5.0

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

Deprecated: Use ExtensionUnsubscribeRequest.ProtoReflect.Descriptor instead.

func (*ExtensionUnsubscribeRequest) GetNamespaceId added in v0.5.0

func (x *ExtensionUnsubscribeRequest) GetNamespaceId() string

func (*ExtensionUnsubscribeRequest) GetPipelineExtensionLabel added in v0.5.0

func (x *ExtensionUnsubscribeRequest) GetPipelineExtensionLabel() string

func (*ExtensionUnsubscribeRequest) GetPipelineId added in v0.5.0

func (x *ExtensionUnsubscribeRequest) GetPipelineId() string

func (*ExtensionUnsubscribeRequest) ProtoMessage added in v0.5.0

func (*ExtensionUnsubscribeRequest) ProtoMessage()

func (*ExtensionUnsubscribeRequest) ProtoReflect added in v0.5.0

func (*ExtensionUnsubscribeRequest) Reset added in v0.5.0

func (x *ExtensionUnsubscribeRequest) Reset()

func (*ExtensionUnsubscribeRequest) String added in v0.5.0

func (x *ExtensionUnsubscribeRequest) String() string

type ExtensionUnsubscribeResponse added in v0.5.0

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

func (*ExtensionUnsubscribeResponse) Descriptor deprecated added in v0.5.0

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

Deprecated: Use ExtensionUnsubscribeResponse.ProtoReflect.Descriptor instead.

func (*ExtensionUnsubscribeResponse) ProtoMessage added in v0.5.0

func (*ExtensionUnsubscribeResponse) ProtoMessage()

func (*ExtensionUnsubscribeResponse) ProtoReflect added in v0.5.0

func (*ExtensionUnsubscribeResponse) Reset added in v0.5.0

func (x *ExtensionUnsubscribeResponse) Reset()

func (*ExtensionUnsubscribeResponse) String added in v0.5.0

type Extension_ExtensionState added in v0.5.0

type Extension_ExtensionState int32
const (
	Extension_UNKNOWN_STATE Extension_ExtensionState = 0
	Extension_PROCESSING    Extension_ExtensionState = 1
	Extension_RUNNING       Extension_ExtensionState = 2
	Extension_EXITED        Extension_ExtensionState = 3
)

func (Extension_ExtensionState) Descriptor added in v0.5.0

func (Extension_ExtensionState) Enum added in v0.5.0

func (Extension_ExtensionState) EnumDescriptor deprecated added in v0.5.0

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

Deprecated: Use Extension_ExtensionState.Descriptor instead.

func (Extension_ExtensionState) Number added in v0.5.0

func (Extension_ExtensionState) String added in v0.5.0

func (x Extension_ExtensionState) String() string

func (Extension_ExtensionState) Type added in v0.5.0

type Extension_ExtensionStatus added in v0.5.0

type Extension_ExtensionStatus int32
const (
	Extension_UNKNOWN_STATUS Extension_ExtensionStatus = 0
	Extension_ENABLED        Extension_ExtensionStatus = 1
	Extension_DISABLED       Extension_ExtensionStatus = 2
)

func (Extension_ExtensionStatus) Descriptor added in v0.5.0

func (Extension_ExtensionStatus) Enum added in v0.5.0

func (Extension_ExtensionStatus) EnumDescriptor deprecated added in v0.5.0

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

Deprecated: Use Extension_ExtensionStatus.Descriptor instead.

func (Extension_ExtensionStatus) Number added in v0.5.0

func (Extension_ExtensionStatus) String added in v0.5.0

func (x Extension_ExtensionStatus) String() string

func (Extension_ExtensionStatus) Type added in v0.5.0

type GetDeploymentRequest added in v0.5.0

type GetDeploymentRequest 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"` // Unique deployment identifier.
	// contains filtered or unexported fields
}

func (*GetDeploymentRequest) Descriptor deprecated added in v0.5.0

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

Deprecated: Use GetDeploymentRequest.ProtoReflect.Descriptor instead.

func (*GetDeploymentRequest) GetId added in v0.5.0

func (x *GetDeploymentRequest) GetId() int64

func (*GetDeploymentRequest) GetNamespaceId added in v0.5.0

func (x *GetDeploymentRequest) GetNamespaceId() string

func (*GetDeploymentRequest) GetPipelineId added in v0.5.0

func (x *GetDeploymentRequest) GetPipelineId() string

func (*GetDeploymentRequest) ProtoMessage added in v0.5.0

func (*GetDeploymentRequest) ProtoMessage()

func (*GetDeploymentRequest) ProtoReflect added in v0.5.0

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

func (*GetDeploymentRequest) Reset added in v0.5.0

func (x *GetDeploymentRequest) Reset()

func (*GetDeploymentRequest) String added in v0.5.0

func (x *GetDeploymentRequest) String() string

type GetDeploymentResponse added in v0.5.0

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

func (*GetDeploymentResponse) Descriptor deprecated added in v0.5.0

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

Deprecated: Use GetDeploymentResponse.ProtoReflect.Descriptor instead.

func (*GetDeploymentResponse) GetDeployment added in v0.5.0

func (x *GetDeploymentResponse) GetDeployment() *Deployment

func (*GetDeploymentResponse) ProtoMessage added in v0.5.0

func (*GetDeploymentResponse) ProtoMessage()

func (*GetDeploymentResponse) ProtoReflect added in v0.5.0

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

func (*GetDeploymentResponse) Reset added in v0.5.0

func (x *GetDeploymentResponse) Reset()

func (*GetDeploymentResponse) String added in v0.5.0

func (x *GetDeploymentResponse) String() string

type GetEventRequest

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

func (*GetEventRequest) Descriptor deprecated

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

Deprecated: Use GetEventRequest.ProtoReflect.Descriptor instead.

func (*GetEventRequest) GetId

func (x *GetEventRequest) GetId() int64

func (*GetEventRequest) ProtoMessage

func (*GetEventRequest) ProtoMessage()

func (*GetEventRequest) ProtoReflect

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

func (*GetEventRequest) Reset

func (x *GetEventRequest) Reset()

func (*GetEventRequest) String

func (x *GetEventRequest) String() string

type GetEventResponse

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

func (*GetEventResponse) Descriptor deprecated

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

Deprecated: Use GetEventResponse.ProtoReflect.Descriptor instead.

func (*GetEventResponse) GetEvent

func (x *GetEventResponse) GetEvent() *Event

func (*GetEventResponse) ProtoMessage

func (*GetEventResponse) ProtoMessage()

func (*GetEventResponse) ProtoReflect

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

func (*GetEventResponse) Reset

func (x *GetEventResponse) Reset()

func (*GetEventResponse) String

func (x *GetEventResponse) String() string

type GetExtensionRequest added in v0.5.0

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

func (*GetExtensionRequest) Descriptor deprecated added in v0.5.0

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

Deprecated: Use GetExtensionRequest.ProtoReflect.Descriptor instead.

func (*GetExtensionRequest) GetName added in v0.5.0

func (x *GetExtensionRequest) GetName() string

func (*GetExtensionRequest) ProtoMessage added in v0.5.0

func (*GetExtensionRequest) ProtoMessage()

func (*GetExtensionRequest) ProtoReflect added in v0.5.0

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

func (*GetExtensionRequest) Reset added in v0.5.0

func (x *GetExtensionRequest) Reset()

func (*GetExtensionRequest) String added in v0.5.0

func (x *GetExtensionRequest) String() string

type GetExtensionResponse added in v0.5.0

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

func (*GetExtensionResponse) Descriptor deprecated added in v0.5.0

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

Deprecated: Use GetExtensionResponse.ProtoReflect.Descriptor instead.

func (*GetExtensionResponse) GetExtension added in v0.5.0

func (x *GetExtensionResponse) GetExtension() *Extension

func (*GetExtensionResponse) ProtoMessage added in v0.5.0

func (*GetExtensionResponse) ProtoMessage()

func (*GetExtensionResponse) ProtoReflect added in v0.5.0

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

func (*GetExtensionResponse) Reset added in v0.5.0

func (x *GetExtensionResponse) Reset()

func (*GetExtensionResponse) String added in v0.5.0

func (x *GetExtensionResponse) String() string

type GetGlobalSecretRequest

type GetGlobalSecretRequest struct {
	Key           string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	IncludeSecret bool   `protobuf:"varint,2,opt,name=include_secret,json=includeSecret,proto3" json:"include_secret,omitempty"` // Whether to include plaintext secret
	// contains filtered or unexported fields
}

func (*GetGlobalSecretRequest) Descriptor deprecated

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

Deprecated: Use GetGlobalSecretRequest.ProtoReflect.Descriptor instead.

func (*GetGlobalSecretRequest) GetIncludeSecret

func (x *GetGlobalSecretRequest) GetIncludeSecret() bool

func (*GetGlobalSecretRequest) GetKey

func (x *GetGlobalSecretRequest) GetKey() string

func (*GetGlobalSecretRequest) ProtoMessage

func (*GetGlobalSecretRequest) ProtoMessage()

func (*GetGlobalSecretRequest) ProtoReflect

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

func (*GetGlobalSecretRequest) Reset

func (x *GetGlobalSecretRequest) Reset()

func (*GetGlobalSecretRequest) String

func (x *GetGlobalSecretRequest) String() string

type GetGlobalSecretResponse

type GetGlobalSecretResponse struct {
	Metadata *SecretStoreKey `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Secret   string          `protobuf:"bytes,2,opt,name=secret,proto3" json:"secret,omitempty"`
	// contains filtered or unexported fields
}

func (*GetGlobalSecretResponse) Descriptor deprecated

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

Deprecated: Use GetGlobalSecretResponse.ProtoReflect.Descriptor instead.

func (*GetGlobalSecretResponse) GetMetadata

func (x *GetGlobalSecretResponse) GetMetadata() *SecretStoreKey

func (*GetGlobalSecretResponse) GetSecret

func (x *GetGlobalSecretResponse) GetSecret() string

func (*GetGlobalSecretResponse) ProtoMessage

func (*GetGlobalSecretResponse) ProtoMessage()

func (*GetGlobalSecretResponse) ProtoReflect

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

func (*GetGlobalSecretResponse) Reset

func (x *GetGlobalSecretResponse) Reset()

func (*GetGlobalSecretResponse) String

func (x *GetGlobalSecretResponse) String() string

type GetNamespaceRequest

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

func (*GetNamespaceRequest) Descriptor deprecated

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

Deprecated: Use GetNamespaceRequest.ProtoReflect.Descriptor instead.

func (*GetNamespaceRequest) GetId

func (x *GetNamespaceRequest) GetId() string

func (*GetNamespaceRequest) ProtoMessage

func (*GetNamespaceRequest) ProtoMessage()

func (*GetNamespaceRequest) ProtoReflect

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

func (*GetNamespaceRequest) Reset

func (x *GetNamespaceRequest) Reset()

func (*GetNamespaceRequest) String

func (x *GetNamespaceRequest) String() string

type GetNamespaceResponse

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

func (*GetNamespaceResponse) Descriptor deprecated

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

Deprecated: Use GetNamespaceResponse.ProtoReflect.Descriptor instead.

func (*GetNamespaceResponse) GetNamespace

func (x *GetNamespaceResponse) GetNamespace() *Namespace

func (*GetNamespaceResponse) ProtoMessage

func (*GetNamespaceResponse) ProtoMessage()

func (*GetNamespaceResponse) ProtoReflect

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

func (*GetNamespaceResponse) Reset

func (x *GetNamespaceResponse) Reset()

func (*GetNamespaceResponse) String

func (x *GetNamespaceResponse) String() string

type GetPipelineConfigRequest added in v0.5.0

type GetPipelineConfigRequest 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"`    // Unique pipeline identifier
	// Pipeline version to retrieve. 0 Returns the currently active version.
	Version int64 `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPipelineConfigRequest) Descriptor deprecated added in v0.5.0

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

Deprecated: Use GetPipelineConfigRequest.ProtoReflect.Descriptor instead.

func (*GetPipelineConfigRequest) GetNamespaceId added in v0.5.0

func (x *GetPipelineConfigRequest) GetNamespaceId() string

func (*GetPipelineConfigRequest) GetPipelineId added in v0.5.0

func (x *GetPipelineConfigRequest) GetPipelineId() string

func (*GetPipelineConfigRequest) GetVersion added in v0.5.0

func (x *GetPipelineConfigRequest) GetVersion() int64

func (*GetPipelineConfigRequest) ProtoMessage added in v0.5.0

func (*GetPipelineConfigRequest) ProtoMessage()

func (*GetPipelineConfigRequest) ProtoReflect added in v0.5.0

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

func (*GetPipelineConfigRequest) Reset added in v0.5.0

func (x *GetPipelineConfigRequest) Reset()

func (*GetPipelineConfigRequest) String added in v0.5.0

func (x *GetPipelineConfigRequest) String() string

type GetPipelineConfigResponse added in v0.5.0

type GetPipelineConfigResponse struct {
	Config *PipelineConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPipelineConfigResponse) Descriptor deprecated added in v0.5.0

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

Deprecated: Use GetPipelineConfigResponse.ProtoReflect.Descriptor instead.

func (*GetPipelineConfigResponse) GetConfig added in v0.5.0

func (x *GetPipelineConfigResponse) GetConfig() *PipelineConfig

func (*GetPipelineConfigResponse) ProtoMessage added in v0.5.0

func (*GetPipelineConfigResponse) ProtoMessage()

func (*GetPipelineConfigResponse) ProtoReflect added in v0.5.0

func (*GetPipelineConfigResponse) Reset added in v0.5.0

func (x *GetPipelineConfigResponse) Reset()

func (*GetPipelineConfigResponse) String added in v0.5.0

func (x *GetPipelineConfigResponse) String() string

type GetPipelineExtensionSubscriptionRequest added in v0.5.0

type GetPipelineExtensionSubscriptionRequest 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"`    // Unique pipeline identifier
	ExtensionName  string `protobuf:"bytes,3,opt,name=extension_name,json=extensionName,proto3" json:"extension_name,omitempty"`
	ExtensionLabel string `protobuf:"bytes,4,opt,name=extension_label,json=extensionLabel,proto3" json:"extension_label,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPipelineExtensionSubscriptionRequest) Descriptor deprecated added in v0.5.0

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

Deprecated: Use GetPipelineExtensionSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*GetPipelineExtensionSubscriptionRequest) GetExtensionLabel added in v0.5.0

func (x *GetPipelineExtensionSubscriptionRequest) GetExtensionLabel() string

func (*GetPipelineExtensionSubscriptionRequest) GetExtensionName added in v0.5.0

func (x *GetPipelineExtensionSubscriptionRequest) GetExtensionName() string

func (*GetPipelineExtensionSubscriptionRequest) GetNamespaceId added in v0.5.0

func (x *GetPipelineExtensionSubscriptionRequest) GetNamespaceId() string

func (*GetPipelineExtensionSubscriptionRequest) GetPipelineId added in v0.5.0

func (*GetPipelineExtensionSubscriptionRequest) ProtoMessage added in v0.5.0

func (*GetPipelineExtensionSubscriptionRequest) ProtoReflect added in v0.5.0

func (*GetPipelineExtensionSubscriptionRequest) Reset added in v0.5.0

func (*GetPipelineExtensionSubscriptionRequest) String added in v0.5.0

type GetPipelineExtensionSubscriptionResponse added in v0.5.0

type GetPipelineExtensionSubscriptionResponse struct {
	Subscription *PipelineExtensionSubscription `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPipelineExtensionSubscriptionResponse) Descriptor deprecated added in v0.5.0

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

Deprecated: Use GetPipelineExtensionSubscriptionResponse.ProtoReflect.Descriptor instead.

func (*GetPipelineExtensionSubscriptionResponse) GetSubscription added in v0.5.0

func (*GetPipelineExtensionSubscriptionResponse) ProtoMessage added in v0.5.0

func (*GetPipelineExtensionSubscriptionResponse) ProtoReflect added in v0.5.0

func (*GetPipelineExtensionSubscriptionResponse) Reset added in v0.5.0

func (*GetPipelineExtensionSubscriptionResponse) String added in v0.5.0

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 (*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
	// Pipeline version to retrieve. 0 Returns the currently active version.
	Version int64 `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	// 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) GetVersion added in v0.5.0

func (x *GetPipelineRequest) GetVersion() int64

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 GetPipelineSecretRequest

type GetPipelineSecretRequest 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"`
	IncludeSecret bool   `protobuf:"varint,4,opt,name=include_secret,json=includeSecret,proto3" json:"include_secret,omitempty"` // Whether to include plaintext secret
	// contains filtered or unexported fields
}

func (*GetPipelineSecretRequest) Descriptor deprecated

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

Deprecated: Use GetPipelineSecretRequest.ProtoReflect.Descriptor instead.

func (*GetPipelineSecretRequest) GetIncludeSecret

func (x *GetPipelineSecretRequest) GetIncludeSecret() bool

func (*GetPipelineSecretRequest) GetKey

func (x *GetPipelineSecretRequest) GetKey() string

func (*GetPipelineSecretRequest) GetNamespaceId

func (x *GetPipelineSecretRequest) GetNamespaceId() string

func (*GetPipelineSecretRequest) GetPipelineId

func (x *GetPipelineSecretRequest) GetPipelineId() string

func (*GetPipelineSecretRequest) ProtoMessage

func (*GetPipelineSecretRequest) ProtoMessage()

func (*GetPipelineSecretRequest) ProtoReflect

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

func (*GetPipelineSecretRequest) Reset

func (x *GetPipelineSecretRequest) Reset()

func (*GetPipelineSecretRequest) String

func (x *GetPipelineSecretRequest) String() string

type GetPipelineSecretResponse

type GetPipelineSecretResponse struct {
	Metadata *SecretStoreKey `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Secret   string          `protobuf:"bytes,2,opt,name=secret,proto3" json:"secret,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPipelineSecretResponse) Descriptor deprecated

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

Deprecated: Use GetPipelineSecretResponse.ProtoReflect.Descriptor instead.

func (*GetPipelineSecretResponse) GetMetadata

func (x *GetPipelineSecretResponse) GetMetadata() *SecretStoreKey

func (*GetPipelineSecretResponse) GetSecret

func (x *GetPipelineSecretResponse) GetSecret() string

func (*GetPipelineSecretResponse) ProtoMessage

func (*GetPipelineSecretResponse) ProtoMessage()

func (*GetPipelineSecretResponse) ProtoReflect

func (*GetPipelineSecretResponse) Reset

func (x *GetPipelineSecretResponse) Reset()

func (*GetPipelineSecretResponse) String

func (x *GetPipelineSecretResponse) String() string

type GetRunObjectRequest

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

func (*GetRunObjectRequest) Descriptor deprecated

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

Deprecated: Use GetRunObjectRequest.ProtoReflect.Descriptor instead.

func (*GetRunObjectRequest) GetKey

func (x *GetRunObjectRequest) GetKey() string

func (*GetRunObjectRequest) GetNamespaceId

func (x *GetRunObjectRequest) GetNamespaceId() string

func (*GetRunObjectRequest) GetPipelineId

func (x *GetRunObjectRequest) GetPipelineId() string

func (*GetRunObjectRequest) GetRunId

func (x *GetRunObjectRequest) GetRunId() int64

func (*GetRunObjectRequest) ProtoMessage

func (*GetRunObjectRequest) ProtoMessage()

func (*GetRunObjectRequest) ProtoReflect

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

func (*GetRunObjectRequest) Reset

func (x *GetRunObjectRequest) Reset()

func (*GetRunObjectRequest) String

func (x *GetRunObjectRequest) String() string

type GetRunObjectResponse

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

func (*GetRunObjectResponse) Descriptor deprecated

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

Deprecated: Use GetRunObjectResponse.ProtoReflect.Descriptor instead.

func (*GetRunObjectResponse) GetContent

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

func (*GetRunObjectResponse) ProtoMessage

func (*GetRunObjectResponse) ProtoMessage()

func (*GetRunObjectResponse) ProtoReflect

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

func (*GetRunObjectResponse) Reset

func (x *GetRunObjectResponse) Reset()

func (*GetRunObjectResponse) String

func (x *GetRunObjectResponse) String() string

type GetRunRequest

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

func (*GetRunRequest) Descriptor deprecated

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

Deprecated: Use GetRunRequest.ProtoReflect.Descriptor instead.

func (*GetRunRequest) GetId

func (x *GetRunRequest) GetId() int64

func (*GetRunRequest) GetNamespaceId

func (x *GetRunRequest) GetNamespaceId() string

func (*GetRunRequest) GetPipelineId

func (x *GetRunRequest) GetPipelineId() string

func (*GetRunRequest) ProtoMessage

func (*GetRunRequest) ProtoMessage()

func (*GetRunRequest) ProtoReflect

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

func (*GetRunRequest) Reset

func (x *GetRunRequest) Reset()

func (*GetRunRequest) String

func (x *GetRunRequest) String() string

type GetRunResponse

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

func (*GetRunResponse) Descriptor deprecated

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

Deprecated: Use GetRunResponse.ProtoReflect.Descriptor instead.

func (*GetRunResponse) GetRun

func (x *GetRunResponse) GetRun() *Run

func (*GetRunResponse) ProtoMessage

func (*GetRunResponse) ProtoMessage()

func (*GetRunResponse) ProtoReflect

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

func (*GetRunResponse) Reset

func (x *GetRunResponse) Reset()

func (*GetRunResponse) String

func (x *GetRunResponse) String() string

type GetSystemInfoRequest

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

func (*GetSystemInfoRequest) Descriptor deprecated

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

Deprecated: Use GetSystemInfoRequest.ProtoReflect.Descriptor instead.

func (*GetSystemInfoRequest) ProtoMessage

func (*GetSystemInfoRequest) ProtoMessage()

func (*GetSystemInfoRequest) ProtoReflect

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

func (*GetSystemInfoRequest) Reset

func (x *GetSystemInfoRequest) Reset()

func (*GetSystemInfoRequest) String

func (x *GetSystemInfoRequest) String() string

type GetSystemInfoResponse

type GetSystemInfoResponse struct {
	Commit string `protobuf:"bytes,1,opt,name=commit,proto3" json:"commit,omitempty"`
	Semver string `protobuf:"bytes,2,opt,name=semver,proto3" json:"semver,omitempty"`
	// 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) GetSemver

func (x *GetSystemInfoResponse) GetSemver() 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 GoferClient

type GoferClient interface {
	// //////////// System RPCs //////////////
	//
	// Service RPCs exist to help with management of the Gofer service. They
	// usually perform admin type interactions with the service as a whole and
	// provide ways for admins to quickly repair Gofer broken states without
	// having to stop the entire service.
	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)
	// ListTokens returns information about all tokens for a particular namespace;
	ListTokens(ctx context.Context, in *ListTokensRequest, opts ...grpc.CallOption) (*ListTokensResponse, error)
	// GetToken returns information about a particular token;
	GetToken(ctx context.Context, in *GetTokenRequest, opts ...grpc.CallOption) (*GetTokenResponse, error)
	// EnableToken makes a token usable.
	EnableToken(ctx context.Context, in *EnableTokenRequest, opts ...grpc.CallOption) (*EnableTokenResponse, error)
	// DisableToken makes a token unusable.
	DisableToken(ctx context.Context, in *DisableTokenRequest, opts ...grpc.CallOption) (*DisableTokenResponse, error)
	// DeleteToken removes a token.
	DeleteToken(ctx context.Context, in *DeleteTokenRequest, opts ...grpc.CallOption) (*DeleteTokenResponse, error)
	// 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
	// extension 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 extension
	// events that would normally cause the pipeline to be run are instead
	// discarded.
	DisablePipeline(ctx context.Context, in *DisablePipelineRequest, opts ...grpc.CallOption) (*DisablePipelineResponse, error)
	// DeployPipeline attempts to deploy a version of a pipeline.
	DeployPipeline(ctx context.Context, in *DeployPipelineRequest, opts ...grpc.CallOption) (*DeployPipelineResponse, error)
	// DeletePipeline deletes a pipeline permenantly. It is not recoverable.
	DeletePipeline(ctx context.Context, in *DeletePipelineRequest, opts ...grpc.CallOption) (*DeletePipelineResponse, error)
	// RegisterPipelineConfig registers a new version of a pipeline's
	// configuration. If the pipeline does not exist it will be created.
	RegisterPipelineConfig(ctx context.Context, in *RegisterPipelineConfigRequest, opts ...grpc.CallOption) (*RegisterPipelineConfigResponse, error)
	// ListPipelineConfigs returns all registered pipeline configs.
	ListPipelineConfigs(ctx context.Context, in *ListPipelineConfigsRequest, opts ...grpc.CallOption) (*ListPipelineConfigsResponse, error)
	// GetPipelineConfig returns a single pipelineconfig by id.
	GetPipelineConfig(ctx context.Context, in *GetPipelineConfigRequest, opts ...grpc.CallOption) (*GetPipelineConfigResponse, error)
	// DeletePipelineConfig removes a pipelineconfig by id.
	DeletePipelineConfig(ctx context.Context, in *DeletePipelineConfigRequest, opts ...grpc.CallOption) (*DeletePipelineConfigResponse, error)
	// //////////// Pipeline Extension Subscription RPCs //////////////
	//
	// Pipelines can subscribe to extensions in order to extend their
	// functionality.
	//
	// Subscribe a pipeline to a extension.
	CreatePipelineExtensionSubscription(ctx context.Context, in *CreatePipelineExtensionSubscriptionRequest, opts ...grpc.CallOption) (*CreatePipelineExtensionSubscriptionResponse, error)
	// ListPipelineExtensionSubscriptions returns all extension subscriptions for
	// a particular pipeline.
	ListPipelineExtensionSubscriptions(ctx context.Context, in *ListPipelineExtensionSubscriptionsRequest, opts ...grpc.CallOption) (*ListPipelineExtensionSubscriptionsResponse, error)
	// GetPipelineExtensionSubscription returns a single pipeline extension
	// subscription.
	GetPipelineExtensionSubscription(ctx context.Context, in *GetPipelineExtensionSubscriptionRequest, opts ...grpc.CallOption) (*GetPipelineExtensionSubscriptionResponse, error)
	// EnablePipelineExtensionSubscription removes a pipeline extension
	// subscription.
	EnablePipelineExtensionSubscription(ctx context.Context, in *EnablePipelineExtensionSubscriptionRequest, opts ...grpc.CallOption) (*EnablePipelineExtensionSubscriptionResponse, error)
	// DisablePipelineExtensionSubscription removes a pipeline extension
	// subscription.
	DisablePipelineExtensionSubscription(ctx context.Context, in *DisablePipelineExtensionSubscriptionRequest, opts ...grpc.CallOption) (*DisablePipelineExtensionSubscriptionResponse, error)
	// DeletePipelineExtensionSubscription removes a pipeline extension
	// subscription.
	DeletePipelineExtensionSubscription(ctx context.Context, in *DeletePipelineExtensionSubscriptionRequest, opts ...grpc.CallOption) (*DeletePipelineExtensionSubscriptionResponse, error)
	// ListDeployments
	ListDeployments(ctx context.Context, in *ListDeploymentsRequest, opts ...grpc.CallOption) (*ListDeploymentsResponse, error)
	// GetDeployment
	GetDeployment(ctx context.Context, in *GetDeploymentRequest, opts ...grpc.CallOption) (*GetDeploymentResponse, error)
	// GetRun returns the details of a single run.
	GetRun(ctx context.Context, in *GetRunRequest, opts ...grpc.CallOption) (*GetRunResponse, 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 executes a single run of a particular pipeline.
	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)
	// Attach to a running task run container. Useful for debugging.
	AttachToTaskRun(ctx context.Context, opts ...grpc.CallOption) (Gofer_AttachToTaskRunClient, 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)
	// GetExtension returns details about a specific extension.
	GetExtension(ctx context.Context, in *GetExtensionRequest, opts ...grpc.CallOption) (*GetExtensionResponse, error)
	// ListExtensions lists all extensions currently registered within gofer.
	ListExtensions(ctx context.Context, in *ListExtensionsRequest, opts ...grpc.CallOption) (*ListExtensionsResponse, error)
	// Run the installer that helps admin user install the extension.
	RunExtensionInstaller(ctx context.Context, opts ...grpc.CallOption) (Gofer_RunExtensionInstallerClient, error)
	// Run the installer that helps pipeline users with their pipeline extension
	// configuration.
	RunPipelineConfigurator(ctx context.Context, opts ...grpc.CallOption) (Gofer_RunPipelineConfiguratorClient, error)
	// InstallExtension attempts to install a new extension.
	InstallExtension(ctx context.Context, in *InstallExtensionRequest, opts ...grpc.CallOption) (*InstallExtensionResponse, error)
	// UninstallExtension attempts to uninstall a extension.
	UninstallExtension(ctx context.Context, in *UninstallExtensionRequest, opts ...grpc.CallOption) (*UninstallExtensionResponse, error)
	// EnableExtension attempts to enable a new extension.
	EnableExtension(ctx context.Context, in *EnableExtensionRequest, opts ...grpc.CallOption) (*EnableExtensionResponse, error)
	// DisableExtension attempts to disable a new extension.
	DisableExtension(ctx context.Context, in *DisableExtensionRequest, opts ...grpc.CallOption) (*DisableExtensionResponse, error)
	// ListPipelineObjects returns a list of all pipeline object keys.
	ListPipelineObjects(ctx context.Context, in *ListPipelineObjectsRequest, opts ...grpc.CallOption) (*ListPipelineObjectsResponse, 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)
	// ListRunObjects returns a list of all run object keys.
	ListRunObjects(ctx context.Context, in *ListRunObjectsRequest, opts ...grpc.CallOption) (*ListRunObjectsResponse, 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)
	// GetPipelineSecret returns a single secret by pipeline ID and key.
	GetPipelineSecret(ctx context.Context, in *GetPipelineSecretRequest, opts ...grpc.CallOption) (*GetPipelineSecretResponse, error)
	// ListPipelineSecrets returns a single secret by pipeline ID and key.
	ListPipelineSecrets(ctx context.Context, in *ListPipelineSecretsRequest, opts ...grpc.CallOption) (*ListPipelineSecretsResponse, error)
	// PutPipelineSecret uploads a single secret by pipeline ID and key.
	PutPipelineSecret(ctx context.Context, in *PutPipelineSecretRequest, opts ...grpc.CallOption) (*PutPipelineSecretResponse, error)
	// DeletePipelineSecret removes a single secret by pipeline ID and
	// key.
	DeletePipelineSecret(ctx context.Context, in *DeletePipelineSecretRequest, opts ...grpc.CallOption) (*DeletePipelineSecretResponse, error)
	// GetGlobalSecret returns a single secret by  key.
	GetGlobalSecret(ctx context.Context, in *GetGlobalSecretRequest, opts ...grpc.CallOption) (*GetGlobalSecretResponse, error)
	// ListGlobalSecrets returns a single secret by global ID and key.
	ListGlobalSecrets(ctx context.Context, in *ListGlobalSecretsRequest, opts ...grpc.CallOption) (*ListGlobalSecretsResponse, error)
	// PutGlobalSecret uploads a single secret by key.
	PutGlobalSecret(ctx context.Context, in *PutGlobalSecretRequest, opts ...grpc.CallOption) (*PutGlobalSecretResponse, error)
	// DeleteGlobalSecret removes a single secret by key.
	DeleteGlobalSecret(ctx context.Context, in *DeleteGlobalSecretRequest, opts ...grpc.CallOption) (*DeleteGlobalSecretResponse, 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)
}

GoferClient is the client API for Gofer service.

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

func NewGoferClient

func NewGoferClient(cc grpc.ClientConnInterface) GoferClient

type GoferServer

type GoferServer interface {
	// //////////// System RPCs //////////////
	//
	// Service RPCs exist to help with management of the Gofer service. They
	// usually perform admin type interactions with the service as a whole and
	// provide ways for admins to quickly repair Gofer broken states without
	// having to stop the entire service.
	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)
	// ListTokens returns information about all tokens for a particular namespace;
	ListTokens(context.Context, *ListTokensRequest) (*ListTokensResponse, error)
	// GetToken returns information about a particular token;
	GetToken(context.Context, *GetTokenRequest) (*GetTokenResponse, error)
	// EnableToken makes a token usable.
	EnableToken(context.Context, *EnableTokenRequest) (*EnableTokenResponse, error)
	// DisableToken makes a token unusable.
	DisableToken(context.Context, *DisableTokenRequest) (*DisableTokenResponse, error)
	// DeleteToken removes a token.
	DeleteToken(context.Context, *DeleteTokenRequest) (*DeleteTokenResponse, error)
	// 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
	// extension 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 extension
	// events that would normally cause the pipeline to be run are instead
	// discarded.
	DisablePipeline(context.Context, *DisablePipelineRequest) (*DisablePipelineResponse, error)
	// DeployPipeline attempts to deploy a version of a pipeline.
	DeployPipeline(context.Context, *DeployPipelineRequest) (*DeployPipelineResponse, error)
	// DeletePipeline deletes a pipeline permenantly. It is not recoverable.
	DeletePipeline(context.Context, *DeletePipelineRequest) (*DeletePipelineResponse, error)
	// RegisterPipelineConfig registers a new version of a pipeline's
	// configuration. If the pipeline does not exist it will be created.
	RegisterPipelineConfig(context.Context, *RegisterPipelineConfigRequest) (*RegisterPipelineConfigResponse, error)
	// ListPipelineConfigs returns all registered pipeline configs.
	ListPipelineConfigs(context.Context, *ListPipelineConfigsRequest) (*ListPipelineConfigsResponse, error)
	// GetPipelineConfig returns a single pipelineconfig by id.
	GetPipelineConfig(context.Context, *GetPipelineConfigRequest) (*GetPipelineConfigResponse, error)
	// DeletePipelineConfig removes a pipelineconfig by id.
	DeletePipelineConfig(context.Context, *DeletePipelineConfigRequest) (*DeletePipelineConfigResponse, error)
	// //////////// Pipeline Extension Subscription RPCs //////////////
	//
	// Pipelines can subscribe to extensions in order to extend their
	// functionality.
	//
	// Subscribe a pipeline to a extension.
	CreatePipelineExtensionSubscription(context.Context, *CreatePipelineExtensionSubscriptionRequest) (*CreatePipelineExtensionSubscriptionResponse, error)
	// ListPipelineExtensionSubscriptions returns all extension subscriptions for
	// a particular pipeline.
	ListPipelineExtensionSubscriptions(context.Context, *ListPipelineExtensionSubscriptionsRequest) (*ListPipelineExtensionSubscriptionsResponse, error)
	// GetPipelineExtensionSubscription returns a single pipeline extension
	// subscription.
	GetPipelineExtensionSubscription(context.Context, *GetPipelineExtensionSubscriptionRequest) (*GetPipelineExtensionSubscriptionResponse, error)
	// EnablePipelineExtensionSubscription removes a pipeline extension
	// subscription.
	EnablePipelineExtensionSubscription(context.Context, *EnablePipelineExtensionSubscriptionRequest) (*EnablePipelineExtensionSubscriptionResponse, error)
	// DisablePipelineExtensionSubscription removes a pipeline extension
	// subscription.
	DisablePipelineExtensionSubscription(context.Context, *DisablePipelineExtensionSubscriptionRequest) (*DisablePipelineExtensionSubscriptionResponse, error)
	// DeletePipelineExtensionSubscription removes a pipeline extension
	// subscription.
	DeletePipelineExtensionSubscription(context.Context, *DeletePipelineExtensionSubscriptionRequest) (*DeletePipelineExtensionSubscriptionResponse, error)
	// ListDeployments
	ListDeployments(context.Context, *ListDeploymentsRequest) (*ListDeploymentsResponse, error)
	// GetDeployment
	GetDeployment(context.Context, *GetDeploymentRequest) (*GetDeploymentResponse, error)
	// GetRun returns the details of a single run.
	GetRun(context.Context, *GetRunRequest) (*GetRunResponse, 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 executes a single run of a particular pipeline.
	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)
	// Attach to a running task run container. Useful for debugging.
	AttachToTaskRun(Gofer_AttachToTaskRunServer) 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)
	// GetExtension returns details about a specific extension.
	GetExtension(context.Context, *GetExtensionRequest) (*GetExtensionResponse, error)
	// ListExtensions lists all extensions currently registered within gofer.
	ListExtensions(context.Context, *ListExtensionsRequest) (*ListExtensionsResponse, error)
	// Run the installer that helps admin user install the extension.
	RunExtensionInstaller(Gofer_RunExtensionInstallerServer) error
	// Run the installer that helps pipeline users with their pipeline extension
	// configuration.
	RunPipelineConfigurator(Gofer_RunPipelineConfiguratorServer) error
	// InstallExtension attempts to install a new extension.
	InstallExtension(context.Context, *InstallExtensionRequest) (*InstallExtensionResponse, error)
	// UninstallExtension attempts to uninstall a extension.
	UninstallExtension(context.Context, *UninstallExtensionRequest) (*UninstallExtensionResponse, error)
	// EnableExtension attempts to enable a new extension.
	EnableExtension(context.Context, *EnableExtensionRequest) (*EnableExtensionResponse, error)
	// DisableExtension attempts to disable a new extension.
	DisableExtension(context.Context, *DisableExtensionRequest) (*DisableExtensionResponse, error)
	// ListPipelineObjects returns a list of all pipeline object keys.
	ListPipelineObjects(context.Context, *ListPipelineObjectsRequest) (*ListPipelineObjectsResponse, 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)
	// ListRunObjects returns a list of all run object keys.
	ListRunObjects(context.Context, *ListRunObjectsRequest) (*ListRunObjectsResponse, 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)
	// GetPipelineSecret returns a single secret by pipeline ID and key.
	GetPipelineSecret(context.Context, *GetPipelineSecretRequest) (*GetPipelineSecretResponse, error)
	// ListPipelineSecrets returns a single secret by pipeline ID and key.
	ListPipelineSecrets(context.Context, *ListPipelineSecretsRequest) (*ListPipelineSecretsResponse, error)
	// PutPipelineSecret uploads a single secret by pipeline ID and key.
	PutPipelineSecret(context.Context, *PutPipelineSecretRequest) (*PutPipelineSecretResponse, error)
	// DeletePipelineSecret removes a single secret by pipeline ID and
	// key.
	DeletePipelineSecret(context.Context, *DeletePipelineSecretRequest) (*DeletePipelineSecretResponse, error)
	// GetGlobalSecret returns a single secret by  key.
	GetGlobalSecret(context.Context, *GetGlobalSecretRequest) (*GetGlobalSecretResponse, error)
	// ListGlobalSecrets returns a single secret by global ID and key.
	ListGlobalSecrets(context.Context, *ListGlobalSecretsRequest) (*ListGlobalSecretsResponse, error)
	// PutGlobalSecret uploads a single secret by key.
	PutGlobalSecret(context.Context, *PutGlobalSecretRequest) (*PutGlobalSecretResponse, error)
	// DeleteGlobalSecret removes a single secret by key.
	DeleteGlobalSecret(context.Context, *DeleteGlobalSecretRequest) (*DeleteGlobalSecretResponse, 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
	// contains filtered or unexported methods
}

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

type Gofer_AttachToTaskRunClient added in v0.6.0

type Gofer_AttachToTaskRunClient interface {
	Send(*AttachToTaskRunRequest) error
	Recv() (*AttachToTaskRunOutput, error)
	grpc.ClientStream
}

type Gofer_AttachToTaskRunServer added in v0.6.0

type Gofer_AttachToTaskRunServer interface {
	Send(*AttachToTaskRunOutput) error
	Recv() (*AttachToTaskRunRequest, error)
	grpc.ServerStream
}

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

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

type Gofer_ListEventsServer

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

type Gofer_RunExtensionInstallerClient added in v0.6.0

type Gofer_RunExtensionInstallerClient interface {
	Send(*RunExtensionInstallerClientMessage) error
	Recv() (*RunExtensionInstallerExtensionMessage, error)
	grpc.ClientStream
}

type Gofer_RunExtensionInstallerServer added in v0.6.0

type Gofer_RunExtensionInstallerServer interface {
	Send(*RunExtensionInstallerExtensionMessage) error
	Recv() (*RunExtensionInstallerClientMessage, error)
	grpc.ServerStream
}

type Gofer_RunPipelineConfiguratorClient added in v0.6.0

type Gofer_RunPipelineConfiguratorClient interface {
	Send(*RunPipelineConfiguratorClientMessage) error
	Recv() (*RunPipelineConfiguratorExtensionMessage, error)
	grpc.ClientStream
}

type Gofer_RunPipelineConfiguratorServer added in v0.6.0

type Gofer_RunPipelineConfiguratorServer interface {
	Send(*RunPipelineConfiguratorExtensionMessage) error
	Recv() (*RunPipelineConfiguratorClientMessage, error)
	grpc.ServerStream
}

type Initiator added in v0.5.0

type Initiator struct {
	Type   Initiator_Type `protobuf:"varint,1,opt,name=type,proto3,enum=proto.Initiator_Type" json:"type,omitempty"`
	Name   string         `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Reason string         `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*Initiator) Descriptor deprecated added in v0.5.0

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

Deprecated: Use Initiator.ProtoReflect.Descriptor instead.

func (*Initiator) GetName added in v0.5.0

func (x *Initiator) GetName() string

func (*Initiator) GetReason added in v0.5.0

func (x *Initiator) GetReason() string

func (*Initiator) GetType added in v0.5.0

func (x *Initiator) GetType() Initiator_Type

func (*Initiator) ProtoMessage added in v0.5.0

func (*Initiator) ProtoMessage()

func (*Initiator) ProtoReflect added in v0.5.0

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

func (*Initiator) Reset added in v0.5.0

func (x *Initiator) Reset()

func (*Initiator) String added in v0.5.0

func (x *Initiator) String() string

type Initiator_Type added in v0.5.0

type Initiator_Type int32
const (
	Initiator_UNKNOWN   Initiator_Type = 0
	Initiator_BOT       Initiator_Type = 1
	Initiator_HUMAN     Initiator_Type = 2
	Initiator_EXTENSION Initiator_Type = 3
)

func (Initiator_Type) Descriptor added in v0.5.0

func (Initiator_Type) Enum added in v0.5.0

func (x Initiator_Type) Enum() *Initiator_Type

func (Initiator_Type) EnumDescriptor deprecated added in v0.5.0

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

Deprecated: Use Initiator_Type.Descriptor instead.

func (Initiator_Type) Number added in v0.5.0

func (Initiator_Type) String added in v0.5.0

func (x Initiator_Type) String() string

func (Initiator_Type) Type added in v0.5.0

type InstallExtensionRequest added in v0.5.0

type InstallExtensionRequest struct {
	Name      string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Image     string            `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	User      string            `protobuf:"bytes,3,opt,name=user,proto3" json:"user,omitempty"`
	Pass      string            `protobuf:"bytes,4,opt,name=pass,proto3" json:"pass,omitempty"`
	Variables map[string]string `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*InstallExtensionRequest) Descriptor deprecated added in v0.5.0

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

Deprecated: Use InstallExtensionRequest.ProtoReflect.Descriptor instead.

func (*InstallExtensionRequest) GetImage added in v0.5.0

func (x *InstallExtensionRequest) GetImage() string

func (*InstallExtensionRequest) GetName added in v0.5.0

func (x *InstallExtensionRequest) GetName() string

func (*InstallExtensionRequest) GetPass added in v0.5.0

func (x *InstallExtensionRequest) GetPass() string

func (*InstallExtensionRequest) GetUser added in v0.5.0

func (x *InstallExtensionRequest) GetUser() string

func (*InstallExtensionRequest) GetVariables added in v0.5.0

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

func (*InstallExtensionRequest) ProtoMessage added in v0.5.0

func (*InstallExtensionRequest) ProtoMessage()

func (*InstallExtensionRequest) ProtoReflect added in v0.5.0

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

func (*InstallExtensionRequest) Reset added in v0.5.0

func (x *InstallExtensionRequest) Reset()

func (*InstallExtensionRequest) String added in v0.5.0

func (x *InstallExtensionRequest) String() string

type InstallExtensionResponse added in v0.5.0

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

func (*InstallExtensionResponse) Descriptor deprecated added in v0.5.0

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

Deprecated: Use InstallExtensionResponse.ProtoReflect.Descriptor instead.

func (*InstallExtensionResponse) ProtoMessage added in v0.5.0

func (*InstallExtensionResponse) ProtoMessage()

func (*InstallExtensionResponse) ProtoReflect added in v0.5.0

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

func (*InstallExtensionResponse) Reset added in v0.5.0

func (x *InstallExtensionResponse) Reset()

func (*InstallExtensionResponse) String added in v0.5.0

func (x *InstallExtensionResponse) String() string

type ListDeploymentsRequest added in v0.5.0

type ListDeploymentsRequest struct {

	// offset is a pagination parameter that defines where to start when counting
	// the list of Deployments to return.
	Offset int64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	// limit is a pagination parameter that defines how many Deployments 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
}

//////////// Deployment Transport Models //////////////

func (*ListDeploymentsRequest) Descriptor deprecated added in v0.5.0

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

Deprecated: Use ListDeploymentsRequest.ProtoReflect.Descriptor instead.

func (*ListDeploymentsRequest) GetLimit added in v0.5.0

func (x *ListDeploymentsRequest) GetLimit() int64

func (*ListDeploymentsRequest) GetNamespaceId added in v0.5.0

func (x *ListDeploymentsRequest) GetNamespaceId() string

func (*ListDeploymentsRequest) GetOffset added in v0.5.0

func (x *ListDeploymentsRequest) GetOffset() int64

func (*ListDeploymentsRequest) GetPipelineId added in v0.5.0

func (x *ListDeploymentsRequest) GetPipelineId() string

func (*ListDeploymentsRequest) ProtoMessage added in v0.5.0

func (*ListDeploymentsRequest) ProtoMessage()

func (*ListDeploymentsRequest) ProtoReflect added in v0.5.0

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

func (*ListDeploymentsRequest) Reset added in v0.5.0

func (x *ListDeploymentsRequest) Reset()

func (*ListDeploymentsRequest) String added in v0.5.0

func (x *ListDeploymentsRequest) String() string

type ListDeploymentsResponse added in v0.5.0

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

func (*ListDeploymentsResponse) Descriptor deprecated added in v0.5.0

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

Deprecated: Use ListDeploymentsResponse.ProtoReflect.Descriptor instead.

func (*ListDeploymentsResponse) GetDeployments added in v0.5.0

func (x *ListDeploymentsResponse) GetDeployments() []*Deployment

func (*ListDeploymentsResponse) ProtoMessage added in v0.5.0

func (*ListDeploymentsResponse) ProtoMessage()

func (*ListDeploymentsResponse) ProtoReflect added in v0.5.0

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

func (*ListDeploymentsResponse) Reset added in v0.5.0

func (x *ListDeploymentsResponse) Reset()

func (*ListDeploymentsResponse) String added in v0.5.0

func (x *ListDeploymentsResponse) String() string

type ListEventsRequest

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

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

Deprecated: Use ListEventsRequest.ProtoReflect.Descriptor instead.

func (*ListEventsRequest) GetFollow

func (x *ListEventsRequest) GetFollow() bool

func (*ListEventsRequest) GetReverse

func (x *ListEventsRequest) GetReverse() bool

func (*ListEventsRequest) ProtoMessage

func (*ListEventsRequest) ProtoMessage()

func (*ListEventsRequest) ProtoReflect

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

func (*ListEventsRequest) Reset

func (x *ListEventsRequest) Reset()

func (*ListEventsRequest) String

func (x *ListEventsRequest) String() string

type ListEventsResponse

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

func (*ListEventsResponse) Descriptor deprecated

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

Deprecated: Use ListEventsResponse.ProtoReflect.Descriptor instead.

func (*ListEventsResponse) GetEvent

func (x *ListEventsResponse) GetEvent() *Event

func (*ListEventsResponse) ProtoMessage

func (*ListEventsResponse) ProtoMessage()

func (*ListEventsResponse) ProtoReflect

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

func (*ListEventsResponse) Reset

func (x *ListEventsResponse) Reset()

func (*ListEventsResponse) String

func (x *ListEventsResponse) String() string

type ListExtensionsRequest added in v0.5.0

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

func (*ListExtensionsRequest) Descriptor deprecated added in v0.5.0

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

Deprecated: Use ListExtensionsRequest.ProtoReflect.Descriptor instead.

func (*ListExtensionsRequest) ProtoMessage added in v0.5.0

func (*ListExtensionsRequest) ProtoMessage()

func (*ListExtensionsRequest) ProtoReflect added in v0.5.0

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

func (*ListExtensionsRequest) Reset added in v0.5.0

func (x *ListExtensionsRequest) Reset()

func (*ListExtensionsRequest) String added in v0.5.0

func (x *ListExtensionsRequest) String() string

type ListExtensionsResponse added in v0.5.0

type ListExtensionsResponse struct {
	Extensions []*Extension `protobuf:"bytes,1,rep,name=extensions,proto3" json:"extensions,omitempty"`
	// contains filtered or unexported fields
}

func (*ListExtensionsResponse) Descriptor deprecated added in v0.5.0

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

Deprecated: Use ListExtensionsResponse.ProtoReflect.Descriptor instead.

func (*ListExtensionsResponse) GetExtensions added in v0.5.0

func (x *ListExtensionsResponse) GetExtensions() []*Extension

func (*ListExtensionsResponse) ProtoMessage added in v0.5.0

func (*ListExtensionsResponse) ProtoMessage()

func (*ListExtensionsResponse) ProtoReflect added in v0.5.0

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

func (*ListExtensionsResponse) Reset added in v0.5.0

func (x *ListExtensionsResponse) Reset()

func (*ListExtensionsResponse) String added in v0.5.0

func (x *ListExtensionsResponse) String() string

type ListGlobalSecretsRequest

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

func (*ListGlobalSecretsRequest) Descriptor deprecated

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

Deprecated: Use ListGlobalSecretsRequest.ProtoReflect.Descriptor instead.

func (*ListGlobalSecretsRequest) ProtoMessage

func (*ListGlobalSecretsRequest) ProtoMessage()

func (*ListGlobalSecretsRequest) ProtoReflect

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

func (*ListGlobalSecretsRequest) Reset

func (x *ListGlobalSecretsRequest) Reset()

func (*ListGlobalSecretsRequest) String

func (x *ListGlobalSecretsRequest) String() string

type ListGlobalSecretsResponse

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

func (*ListGlobalSecretsResponse) Descriptor deprecated

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

Deprecated: Use ListGlobalSecretsResponse.ProtoReflect.Descriptor instead.

func (*ListGlobalSecretsResponse) GetKeys

func (x *ListGlobalSecretsResponse) GetKeys() []*SecretStoreKey

func (*ListGlobalSecretsResponse) ProtoMessage

func (*ListGlobalSecretsResponse) ProtoMessage()

func (*ListGlobalSecretsResponse) ProtoReflect

func (*ListGlobalSecretsResponse) Reset

func (x *ListGlobalSecretsResponse) Reset()

func (*ListGlobalSecretsResponse) String

func (x *ListGlobalSecretsResponse) String() string

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"`
	// 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) 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 ListPipelineConfigsRequest added in v0.5.0

type ListPipelineConfigsRequest 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"`
	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"`    // Unique pipeline identifier
	// contains filtered or unexported fields
}

func (*ListPipelineConfigsRequest) Descriptor deprecated added in v0.5.0

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

Deprecated: Use ListPipelineConfigsRequest.ProtoReflect.Descriptor instead.

func (*ListPipelineConfigsRequest) GetLimit added in v0.5.0

func (x *ListPipelineConfigsRequest) GetLimit() int64

func (*ListPipelineConfigsRequest) GetNamespaceId added in v0.5.0

func (x *ListPipelineConfigsRequest) GetNamespaceId() string

func (*ListPipelineConfigsRequest) GetOffset added in v0.5.0

func (x *ListPipelineConfigsRequest) GetOffset() int64

func (*ListPipelineConfigsRequest) GetPipelineId added in v0.5.0

func (x *ListPipelineConfigsRequest) GetPipelineId() string

func (*ListPipelineConfigsRequest) ProtoMessage added in v0.5.0

func (*ListPipelineConfigsRequest) ProtoMessage()

func (*ListPipelineConfigsRequest) ProtoReflect added in v0.5.0

func (*ListPipelineConfigsRequest) Reset added in v0.5.0

func (x *ListPipelineConfigsRequest) Reset()

func (*ListPipelineConfigsRequest) String added in v0.5.0

func (x *ListPipelineConfigsRequest) String() string

type ListPipelineConfigsResponse added in v0.5.0

type ListPipelineConfigsResponse struct {
	Configs []*PipelineConfig `protobuf:"bytes,1,rep,name=configs,proto3" json:"configs,omitempty"`
	// contains filtered or unexported fields
}

func (*ListPipelineConfigsResponse) Descriptor deprecated added in v0.5.0

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

Deprecated: Use ListPipelineConfigsResponse.ProtoReflect.Descriptor instead.

func (*ListPipelineConfigsResponse) GetConfigs added in v0.5.0

func (x *ListPipelineConfigsResponse) GetConfigs() []*PipelineConfig

func (*ListPipelineConfigsResponse) ProtoMessage added in v0.5.0

func (*ListPipelineConfigsResponse) ProtoMessage()

func (*ListPipelineConfigsResponse) ProtoReflect added in v0.5.0

func (*ListPipelineConfigsResponse) Reset added in v0.5.0

func (x *ListPipelineConfigsResponse) Reset()

func (*ListPipelineConfigsResponse) String added in v0.5.0

func (x *ListPipelineConfigsResponse) String() string

type ListPipelineExtensionSubscriptionsRequest added in v0.5.0

type ListPipelineExtensionSubscriptionsRequest 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"`    // Unique pipeline identifier
	// contains filtered or unexported fields
}

func (*ListPipelineExtensionSubscriptionsRequest) Descriptor deprecated added in v0.5.0

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

Deprecated: Use ListPipelineExtensionSubscriptionsRequest.ProtoReflect.Descriptor instead.

func (*ListPipelineExtensionSubscriptionsRequest) GetNamespaceId added in v0.5.0

func (*ListPipelineExtensionSubscriptionsRequest) GetPipelineId added in v0.5.0

func (*ListPipelineExtensionSubscriptionsRequest) ProtoMessage added in v0.5.0

func (*ListPipelineExtensionSubscriptionsRequest) ProtoReflect added in v0.5.0

func (*ListPipelineExtensionSubscriptionsRequest) Reset added in v0.5.0

func (*ListPipelineExtensionSubscriptionsRequest) String added in v0.5.0

type ListPipelineExtensionSubscriptionsResponse added in v0.5.0

type ListPipelineExtensionSubscriptionsResponse struct {
	Subscriptions []*PipelineExtensionSubscription `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	// contains filtered or unexported fields
}

func (*ListPipelineExtensionSubscriptionsResponse) Descriptor deprecated added in v0.5.0

Deprecated: Use ListPipelineExtensionSubscriptionsResponse.ProtoReflect.Descriptor instead.

func (*ListPipelineExtensionSubscriptionsResponse) GetSubscriptions added in v0.5.0

func (*ListPipelineExtensionSubscriptionsResponse) ProtoMessage added in v0.5.0

func (*ListPipelineExtensionSubscriptionsResponse) ProtoReflect added in v0.5.0

func (*ListPipelineExtensionSubscriptionsResponse) Reset added in v0.5.0

func (*ListPipelineExtensionSubscriptionsResponse) String added in v0.5.0

type ListPipelineObjectsRequest

type ListPipelineObjectsRequest 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 (*ListPipelineObjectsRequest) Descriptor deprecated

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

Deprecated: Use ListPipelineObjectsRequest.ProtoReflect.Descriptor instead.

func (*ListPipelineObjectsRequest) GetNamespaceId

func (x *ListPipelineObjectsRequest) GetNamespaceId() string

func (*ListPipelineObjectsRequest) GetPipelineId

func (x *ListPipelineObjectsRequest) GetPipelineId() string

func (*ListPipelineObjectsRequest) ProtoMessage

func (*ListPipelineObjectsRequest) ProtoMessage()

func (*ListPipelineObjectsRequest) ProtoReflect

func (*ListPipelineObjectsRequest) Reset

func (x *ListPipelineObjectsRequest) Reset()

func (*ListPipelineObjectsRequest) String

func (x *ListPipelineObjectsRequest) String() string

type ListPipelineObjectsResponse

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

func (*ListPipelineObjectsResponse) Descriptor deprecated

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

Deprecated: Use ListPipelineObjectsResponse.ProtoReflect.Descriptor instead.

func (*ListPipelineObjectsResponse) GetKeys

func (*ListPipelineObjectsResponse) ProtoMessage

func (*ListPipelineObjectsResponse) ProtoMessage()

func (*ListPipelineObjectsResponse) ProtoReflect

func (*ListPipelineObjectsResponse) Reset

func (x *ListPipelineObjectsResponse) Reset()

func (*ListPipelineObjectsResponse) String

func (x *ListPipelineObjectsResponse) String() string

type ListPipelineSecretsRequest

type ListPipelineSecretsRequest 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 (*ListPipelineSecretsRequest) Descriptor deprecated

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

Deprecated: Use ListPipelineSecretsRequest.ProtoReflect.Descriptor instead.

func (*ListPipelineSecretsRequest) GetNamespaceId

func (x *ListPipelineSecretsRequest) GetNamespaceId() string

func (*ListPipelineSecretsRequest) GetPipelineId

func (x *ListPipelineSecretsRequest) GetPipelineId() string

func (*ListPipelineSecretsRequest) ProtoMessage

func (*ListPipelineSecretsRequest) ProtoMessage()

func (*ListPipelineSecretsRequest) ProtoReflect

func (*ListPipelineSecretsRequest) Reset

func (x *ListPipelineSecretsRequest) Reset()

func (*ListPipelineSecretsRequest) String

func (x *ListPipelineSecretsRequest) String() string

type ListPipelineSecretsResponse

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

func (*ListPipelineSecretsResponse) Descriptor deprecated

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

Deprecated: Use ListPipelineSecretsResponse.ProtoReflect.Descriptor instead.

func (*ListPipelineSecretsResponse) GetKeys

func (*ListPipelineSecretsResponse) ProtoMessage

func (*ListPipelineSecretsResponse) ProtoMessage()

func (*ListPipelineSecretsResponse) ProtoReflect

func (*ListPipelineSecretsResponse) Reset

func (x *ListPipelineSecretsResponse) Reset()

func (*ListPipelineSecretsResponse) String

func (x *ListPipelineSecretsResponse) 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 []*PipelineMetadata `protobuf:"bytes,1,rep,name=pipelines,proto3" json:"pipelines,omitempty"`
	// contains filtered or unexported fields
}

func (*ListPipelinesResponse) Descriptor deprecated

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

Deprecated: Use ListPipelinesResponse.ProtoReflect.Descriptor instead.

func (*ListPipelinesResponse) GetPipelines

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

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 ListRunObjectsRequest

type ListRunObjectsRequest 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 (*ListRunObjectsRequest) Descriptor deprecated

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

Deprecated: Use ListRunObjectsRequest.ProtoReflect.Descriptor instead.

func (*ListRunObjectsRequest) GetNamespaceId

func (x *ListRunObjectsRequest) GetNamespaceId() string

func (*ListRunObjectsRequest) GetPipelineId

func (x *ListRunObjectsRequest) GetPipelineId() string

func (*ListRunObjectsRequest) GetRunId

func (x *ListRunObjectsRequest) GetRunId() int64

func (*ListRunObjectsRequest) ProtoMessage

func (*ListRunObjectsRequest) ProtoMessage()

func (*ListRunObjectsRequest) ProtoReflect

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

func (*ListRunObjectsRequest) Reset

func (x *ListRunObjectsRequest) Reset()

func (*ListRunObjectsRequest) String

func (x *ListRunObjectsRequest) String() string

type ListRunObjectsResponse

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

func (*ListRunObjectsResponse) Descriptor deprecated

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

Deprecated: Use ListRunObjectsResponse.ProtoReflect.Descriptor instead.

func (*ListRunObjectsResponse) GetKeys

func (x *ListRunObjectsResponse) GetKeys() []*ObjectStoreKey

func (*ListRunObjectsResponse) ProtoMessage

func (*ListRunObjectsResponse) ProtoMessage()

func (*ListRunObjectsResponse) ProtoReflect

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

func (*ListRunObjectsResponse) Reset

func (x *ListRunObjectsResponse) Reset()

func (*ListRunObjectsResponse) String

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

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

func (*ListTokensRequest) Descriptor deprecated

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

Deprecated: Use ListTokensRequest.ProtoReflect.Descriptor instead.

func (*ListTokensRequest) GetNamespace

func (x *ListTokensRequest) GetNamespace() string

func (*ListTokensRequest) ProtoMessage

func (*ListTokensRequest) ProtoMessage()

func (*ListTokensRequest) ProtoReflect

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

func (*ListTokensRequest) Reset

func (x *ListTokensRequest) Reset()

func (*ListTokensRequest) String

func (x *ListTokensRequest) String() string

type ListTokensResponse

type ListTokensResponse struct {
	Tokens []*Token `protobuf:"bytes,1,rep,name=tokens,proto3" json:"tokens,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTokensResponse) Descriptor deprecated

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

Deprecated: Use ListTokensResponse.ProtoReflect.Descriptor instead.

func (*ListTokensResponse) GetTokens

func (x *ListTokensResponse) GetTokens() []*Token

func (*ListTokensResponse) ProtoMessage

func (*ListTokensResponse) ProtoMessage()

func (*ListTokensResponse) ProtoReflect

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

func (*ListTokensResponse) Reset

func (x *ListTokensResponse) Reset()

func (*ListTokensResponse) String

func (x *ListTokensResponse) 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"`
	Modified    int64  `protobuf:"varint,5,opt,name=modified,proto3" json:"modified,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) GetDescription

func (x *Namespace) GetDescription() string

func (*Namespace) GetId

func (x *Namespace) GetId() string

func (*Namespace) GetModified

func (x *Namespace) GetModified() int64

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 ObjectStoreKey

type ObjectStoreKey struct {
	Key     string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Created int64  `protobuf:"varint,2,opt,name=created,proto3" json:"created,omitempty"`
	// contains filtered or unexported fields
}

func (*ObjectStoreKey) Descriptor deprecated

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

Deprecated: Use ObjectStoreKey.ProtoReflect.Descriptor instead.

func (*ObjectStoreKey) GetCreated

func (x *ObjectStoreKey) GetCreated() int64

func (*ObjectStoreKey) GetKey

func (x *ObjectStoreKey) GetKey() string

func (*ObjectStoreKey) ProtoMessage

func (*ObjectStoreKey) ProtoMessage()

func (*ObjectStoreKey) ProtoReflect

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

func (*ObjectStoreKey) Reset

func (x *ObjectStoreKey) Reset()

func (*ObjectStoreKey) String

func (x *ObjectStoreKey) String() string

type Pipeline

type Pipeline struct {
	Metadata *PipelineMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Config   *PipelineConfig   `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*Pipeline) Descriptor deprecated

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

Deprecated: Use Pipeline.ProtoReflect.Descriptor instead.

func (*Pipeline) GetConfig added in v0.5.0

func (x *Pipeline) GetConfig() *PipelineConfig

func (*Pipeline) GetMetadata added in v0.5.0

func (x *Pipeline) GetMetadata() *PipelineMetadata

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 PipelineConfig

type PipelineConfig struct {
	Namespace   string                             `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Pipeline    string                             `protobuf:"bytes,2,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	Version     int64                              `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	Parallelism int64                              `protobuf:"varint,4,opt,name=parallelism,proto3" json:"parallelism,omitempty"`
	Name        string                             `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"`
	Description string                             `protobuf:"bytes,6,opt,name=description,proto3" json:"description,omitempty"`
	Tasks       map[string]*Task                   `` /* 151-byte string literal not displayed */
	State       PipelineConfig_PipelineConfigState `protobuf:"varint,9,opt,name=state,proto3,enum=proto.PipelineConfig_PipelineConfigState" json:"state,omitempty"`
	Registered  int64                              `protobuf:"varint,10,opt,name=registered,proto3" json:"registered,omitempty"`
	Deprecated  int64                              `protobuf:"varint,11,opt,name=deprecated,proto3" json:"deprecated,omitempty"`
	// contains filtered or unexported fields
}

func (*PipelineConfig) Descriptor deprecated

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

Deprecated: Use PipelineConfig.ProtoReflect.Descriptor instead.

func (*PipelineConfig) GetDeprecated added in v0.5.0

func (x *PipelineConfig) GetDeprecated() int64

func (*PipelineConfig) GetDescription

func (x *PipelineConfig) GetDescription() string

func (*PipelineConfig) GetName

func (x *PipelineConfig) GetName() string

func (*PipelineConfig) GetNamespace added in v0.5.0

func (x *PipelineConfig) GetNamespace() string

func (*PipelineConfig) GetParallelism

func (x *PipelineConfig) GetParallelism() int64

func (*PipelineConfig) GetPipeline added in v0.5.0

func (x *PipelineConfig) GetPipeline() string

func (*PipelineConfig) GetRegistered added in v0.5.0

func (x *PipelineConfig) GetRegistered() int64

func (*PipelineConfig) GetState added in v0.5.0

func (*PipelineConfig) GetTasks

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

func (*PipelineConfig) GetVersion added in v0.5.0

func (x *PipelineConfig) GetVersion() int64

func (*PipelineConfig) ProtoMessage

func (*PipelineConfig) ProtoMessage()

func (*PipelineConfig) ProtoReflect

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

func (*PipelineConfig) Reset

func (x *PipelineConfig) Reset()

func (*PipelineConfig) String

func (x *PipelineConfig) String() string

type PipelineConfig_PipelineConfigState added in v0.5.0

type PipelineConfig_PipelineConfigState int32
const (
	PipelineConfig_PIPELINE_CONFIG_STATE_UNKNOWN PipelineConfig_PipelineConfigState = 0
	PipelineConfig_UNRELEASED                    PipelineConfig_PipelineConfigState = 1
	PipelineConfig_LIVE                          PipelineConfig_PipelineConfigState = 2
	PipelineConfig_DEPRECATED                    PipelineConfig_PipelineConfigState = 3
)

func (PipelineConfig_PipelineConfigState) Descriptor added in v0.5.0

func (PipelineConfig_PipelineConfigState) Enum added in v0.5.0

func (PipelineConfig_PipelineConfigState) EnumDescriptor deprecated added in v0.5.0

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

Deprecated: Use PipelineConfig_PipelineConfigState.Descriptor instead.

func (PipelineConfig_PipelineConfigState) Number added in v0.5.0

func (PipelineConfig_PipelineConfigState) String added in v0.5.0

func (PipelineConfig_PipelineConfigState) Type added in v0.5.0

type PipelineExtensionSettings added in v0.5.0

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

func (*PipelineExtensionSettings) Descriptor deprecated added in v0.5.0

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

Deprecated: Use PipelineExtensionSettings.ProtoReflect.Descriptor instead.

func (*PipelineExtensionSettings) GetLabel added in v0.5.0

func (x *PipelineExtensionSettings) GetLabel() string

func (*PipelineExtensionSettings) GetName added in v0.5.0

func (x *PipelineExtensionSettings) GetName() string

func (*PipelineExtensionSettings) GetSettings added in v0.5.0

func (x *PipelineExtensionSettings) GetSettings() map[string]string

func (*PipelineExtensionSettings) ProtoMessage added in v0.5.0

func (*PipelineExtensionSettings) ProtoMessage()

func (*PipelineExtensionSettings) ProtoReflect added in v0.5.0

func (*PipelineExtensionSettings) Reset added in v0.5.0

func (x *PipelineExtensionSettings) Reset()

func (*PipelineExtensionSettings) String added in v0.5.0

func (x *PipelineExtensionSettings) String() string

type PipelineExtensionSubscription added in v0.5.0

type PipelineExtensionSubscription struct {
	Namespace    string                                     `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Pipeline     string                                     `protobuf:"bytes,2,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	Name         string                                     `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Label        string                                     `protobuf:"bytes,4,opt,name=label,proto3" json:"label,omitempty"`
	Settings     map[string]string                          `` /* 157-byte string literal not displayed */
	Status       PipelineExtensionSubscription_Status       `protobuf:"varint,6,opt,name=status,proto3,enum=proto.PipelineExtensionSubscription_Status" json:"status,omitempty"`
	StatusReason *PipelineExtensionSubscriptionStatusReason `protobuf:"bytes,7,opt,name=status_reason,json=statusReason,proto3" json:"status_reason,omitempty"`
	// contains filtered or unexported fields
}

func (*PipelineExtensionSubscription) Descriptor deprecated added in v0.5.0

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

Deprecated: Use PipelineExtensionSubscription.ProtoReflect.Descriptor instead.

func (*PipelineExtensionSubscription) GetLabel added in v0.5.0

func (x *PipelineExtensionSubscription) GetLabel() string

func (*PipelineExtensionSubscription) GetName added in v0.5.0

func (*PipelineExtensionSubscription) GetNamespace added in v0.5.0

func (x *PipelineExtensionSubscription) GetNamespace() string

func (*PipelineExtensionSubscription) GetPipeline added in v0.5.0

func (x *PipelineExtensionSubscription) GetPipeline() string

func (*PipelineExtensionSubscription) GetSettings added in v0.5.0

func (x *PipelineExtensionSubscription) GetSettings() map[string]string

func (*PipelineExtensionSubscription) GetStatus added in v0.5.0

func (*PipelineExtensionSubscription) GetStatusReason added in v0.5.0

func (*PipelineExtensionSubscription) ProtoMessage added in v0.5.0

func (*PipelineExtensionSubscription) ProtoMessage()

func (*PipelineExtensionSubscription) ProtoReflect added in v0.5.0

func (*PipelineExtensionSubscription) Reset added in v0.5.0

func (x *PipelineExtensionSubscription) Reset()

func (*PipelineExtensionSubscription) String added in v0.5.0

type PipelineExtensionSubscriptionStatusReason added in v0.5.0

type PipelineExtensionSubscriptionStatusReason struct {
	Reason      PipelineExtensionSubscriptionStatusReason_PipelineExtensionSubscriptionStatusReasonKind `` /* 165-byte string literal not displayed */
	Description string                                                                                  `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*PipelineExtensionSubscriptionStatusReason) Descriptor deprecated added in v0.5.0

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

Deprecated: Use PipelineExtensionSubscriptionStatusReason.ProtoReflect.Descriptor instead.

func (*PipelineExtensionSubscriptionStatusReason) GetDescription added in v0.5.0

func (*PipelineExtensionSubscriptionStatusReason) GetReason added in v0.5.0

func (*PipelineExtensionSubscriptionStatusReason) ProtoMessage added in v0.5.0

func (*PipelineExtensionSubscriptionStatusReason) ProtoReflect added in v0.5.0

func (*PipelineExtensionSubscriptionStatusReason) Reset added in v0.5.0

func (*PipelineExtensionSubscriptionStatusReason) String added in v0.5.0

type PipelineExtensionSubscriptionStatusReason_PipelineExtensionSubscriptionStatusReasonKind added in v0.5.0

type PipelineExtensionSubscriptionStatusReason_PipelineExtensionSubscriptionStatusReasonKind int32
const (
	PipelineExtensionSubscriptionStatusReason_PIPELINE_EXTENSION_STATUS_REASON_UNKNOWN PipelineExtensionSubscriptionStatusReason_PipelineExtensionSubscriptionStatusReasonKind = 0
	PipelineExtensionSubscriptionStatusReason_ACTIVE                                   PipelineExtensionSubscriptionStatusReason_PipelineExtensionSubscriptionStatusReasonKind = 1
	PipelineExtensionSubscriptionStatusReason_ERROR                                    PipelineExtensionSubscriptionStatusReason_PipelineExtensionSubscriptionStatusReasonKind = 2
	PipelineExtensionSubscriptionStatusReason_DISABLED                                 PipelineExtensionSubscriptionStatusReason_PipelineExtensionSubscriptionStatusReasonKind = 3
)

func (PipelineExtensionSubscriptionStatusReason_PipelineExtensionSubscriptionStatusReasonKind) Descriptor added in v0.5.0

func (PipelineExtensionSubscriptionStatusReason_PipelineExtensionSubscriptionStatusReasonKind) Enum added in v0.5.0

func (PipelineExtensionSubscriptionStatusReason_PipelineExtensionSubscriptionStatusReasonKind) EnumDescriptor deprecated added in v0.5.0

Deprecated: Use PipelineExtensionSubscriptionStatusReason_PipelineExtensionSubscriptionStatusReasonKind.Descriptor instead.

func (PipelineExtensionSubscriptionStatusReason_PipelineExtensionSubscriptionStatusReasonKind) Number added in v0.5.0

func (PipelineExtensionSubscriptionStatusReason_PipelineExtensionSubscriptionStatusReasonKind) String added in v0.5.0

func (PipelineExtensionSubscriptionStatusReason_PipelineExtensionSubscriptionStatusReasonKind) Type added in v0.5.0

type PipelineExtensionSubscription_Status added in v0.5.0

type PipelineExtensionSubscription_Status int32
const (
	PipelineExtensionSubscription_STATUS_UNKNOWN PipelineExtensionSubscription_Status = 0
	PipelineExtensionSubscription_ACTIVE         PipelineExtensionSubscription_Status = 1
	PipelineExtensionSubscription_ERROR          PipelineExtensionSubscription_Status = 2
	PipelineExtensionSubscription_DISABLED       PipelineExtensionSubscription_Status = 3
)

func (PipelineExtensionSubscription_Status) Descriptor added in v0.5.0

func (PipelineExtensionSubscription_Status) Enum added in v0.5.0

func (PipelineExtensionSubscription_Status) EnumDescriptor deprecated added in v0.5.0

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

Deprecated: Use PipelineExtensionSubscription_Status.Descriptor instead.

func (PipelineExtensionSubscription_Status) Number added in v0.5.0

func (PipelineExtensionSubscription_Status) String added in v0.5.0

func (PipelineExtensionSubscription_Status) Type added in v0.5.0

type PipelineMetadata added in v0.5.0

type PipelineMetadata struct {
	Namespace string                         `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Id        string                         `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Created   int64                          `protobuf:"varint,3,opt,name=created,proto3" json:"created,omitempty"`
	Modified  int64                          `protobuf:"varint,4,opt,name=modified,proto3" json:"modified,omitempty"`
	State     PipelineMetadata_PipelineState `protobuf:"varint,5,opt,name=state,proto3,enum=proto.PipelineMetadata_PipelineState" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*PipelineMetadata) Descriptor deprecated added in v0.5.0

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

Deprecated: Use PipelineMetadata.ProtoReflect.Descriptor instead.

func (*PipelineMetadata) GetCreated added in v0.5.0

func (x *PipelineMetadata) GetCreated() int64

func (*PipelineMetadata) GetId added in v0.5.0

func (x *PipelineMetadata) GetId() string

func (*PipelineMetadata) GetModified added in v0.5.0

func (x *PipelineMetadata) GetModified() int64

func (*PipelineMetadata) GetNamespace added in v0.5.0

func (x *PipelineMetadata) GetNamespace() string

func (*PipelineMetadata) GetState added in v0.5.0

func (*PipelineMetadata) ProtoMessage added in v0.5.0

func (*PipelineMetadata) ProtoMessage()

func (*PipelineMetadata) ProtoReflect added in v0.5.0

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

func (*PipelineMetadata) Reset added in v0.5.0

func (x *PipelineMetadata) Reset()

func (*PipelineMetadata) String added in v0.5.0

func (x *PipelineMetadata) String() string

type PipelineMetadata_PipelineState added in v0.5.0

type PipelineMetadata_PipelineState int32
const (
	PipelineMetadata_PIPELINE_STATE_UNKNOWN PipelineMetadata_PipelineState = 0
	PipelineMetadata_ACTIVE                 PipelineMetadata_PipelineState = 1
	PipelineMetadata_DISABLED               PipelineMetadata_PipelineState = 2
)

func (PipelineMetadata_PipelineState) Descriptor added in v0.5.0

func (PipelineMetadata_PipelineState) Enum added in v0.5.0

func (PipelineMetadata_PipelineState) EnumDescriptor deprecated added in v0.5.0

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

Deprecated: Use PipelineMetadata_PipelineState.Descriptor instead.

func (PipelineMetadata_PipelineState) Number added in v0.5.0

func (PipelineMetadata_PipelineState) String added in v0.5.0

func (PipelineMetadata_PipelineState) Type added in v0.5.0

type PutGlobalSecretRequest

type PutGlobalSecretRequest struct {
	Key        string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Content    string   `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	Namespaces []string `protobuf:"bytes,3,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	Force      bool     `protobuf:"varint,4,opt,name=force,proto3" json:"force,omitempty"` // Overwrites already existing values.
	// contains filtered or unexported fields
}

func (*PutGlobalSecretRequest) Descriptor deprecated

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

Deprecated: Use PutGlobalSecretRequest.ProtoReflect.Descriptor instead.

func (*PutGlobalSecretRequest) GetContent

func (x *PutGlobalSecretRequest) GetContent() string

func (*PutGlobalSecretRequest) GetForce

func (x *PutGlobalSecretRequest) GetForce() bool

func (*PutGlobalSecretRequest) GetKey

func (x *PutGlobalSecretRequest) GetKey() string

func (*PutGlobalSecretRequest) GetNamespaces added in v0.5.0

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

func (*PutGlobalSecretRequest) ProtoMessage

func (*PutGlobalSecretRequest) ProtoMessage()

func (*PutGlobalSecretRequest) ProtoReflect

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

func (*PutGlobalSecretRequest) Reset

func (x *PutGlobalSecretRequest) Reset()

func (*PutGlobalSecretRequest) String

func (x *PutGlobalSecretRequest) String() string

type PutGlobalSecretResponse

type PutGlobalSecretResponse struct {

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

func (*PutGlobalSecretResponse) Descriptor deprecated

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

Deprecated: Use PutGlobalSecretResponse.ProtoReflect.Descriptor instead.

func (*PutGlobalSecretResponse) GetBytes

func (x *PutGlobalSecretResponse) GetBytes() int64

func (*PutGlobalSecretResponse) ProtoMessage

func (*PutGlobalSecretResponse) ProtoMessage()

func (*PutGlobalSecretResponse) ProtoReflect

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

func (*PutGlobalSecretResponse) Reset

func (x *PutGlobalSecretResponse) Reset()

func (*PutGlobalSecretResponse) String

func (x *PutGlobalSecretResponse) String() string

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 (*PutPipelineObjectResponse) Reset

func (x *PutPipelineObjectResponse) Reset()

func (*PutPipelineObjectResponse) String

func (x *PutPipelineObjectResponse) String() string

type PutPipelineSecretRequest

type PutPipelineSecretRequest 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 (*PutPipelineSecretRequest) Descriptor deprecated

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

Deprecated: Use PutPipelineSecretRequest.ProtoReflect.Descriptor instead.

func (*PutPipelineSecretRequest) GetContent

func (x *PutPipelineSecretRequest) GetContent() string

func (*PutPipelineSecretRequest) GetForce

func (x *PutPipelineSecretRequest) GetForce() bool

func (*PutPipelineSecretRequest) GetKey

func (x *PutPipelineSecretRequest) GetKey() string

func (*PutPipelineSecretRequest) GetNamespaceId

func (x *PutPipelineSecretRequest) GetNamespaceId() string

func (*PutPipelineSecretRequest) GetPipelineId

func (x *PutPipelineSecretRequest) GetPipelineId() string

func (*PutPipelineSecretRequest) ProtoMessage

func (*PutPipelineSecretRequest) ProtoMessage()

func (*PutPipelineSecretRequest) ProtoReflect

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

func (*PutPipelineSecretRequest) Reset

func (x *PutPipelineSecretRequest) Reset()

func (*PutPipelineSecretRequest) String

func (x *PutPipelineSecretRequest) String() string

type PutPipelineSecretResponse

type PutPipelineSecretResponse struct {

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

func (*PutPipelineSecretResponse) Descriptor deprecated

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

Deprecated: Use PutPipelineSecretResponse.ProtoReflect.Descriptor instead.

func (*PutPipelineSecretResponse) GetBytes

func (x *PutPipelineSecretResponse) GetBytes() int64

func (*PutPipelineSecretResponse) ProtoMessage

func (*PutPipelineSecretResponse) ProtoMessage()

func (*PutPipelineSecretResponse) ProtoReflect

func (*PutPipelineSecretResponse) Reset

func (x *PutPipelineSecretResponse) Reset()

func (*PutPipelineSecretResponse) String

func (x *PutPipelineSecretResponse) 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 RegisterPipelineConfigRequest added in v0.5.0

type RegisterPipelineConfigRequest struct {
	NamespaceId    string              `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"` // Unique namespace identifier
	PipelineConfig *UserPipelineConfig `protobuf:"bytes,2,opt,name=pipeline_config,json=pipelineConfig,proto3" json:"pipeline_config,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterPipelineConfigRequest) Descriptor deprecated added in v0.5.0

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

Deprecated: Use RegisterPipelineConfigRequest.ProtoReflect.Descriptor instead.

func (*RegisterPipelineConfigRequest) GetNamespaceId added in v0.5.0

func (x *RegisterPipelineConfigRequest) GetNamespaceId() string

func (*RegisterPipelineConfigRequest) GetPipelineConfig added in v0.5.0

func (x *RegisterPipelineConfigRequest) GetPipelineConfig() *UserPipelineConfig

func (*RegisterPipelineConfigRequest) ProtoMessage added in v0.5.0

func (*RegisterPipelineConfigRequest) ProtoMessage()

func (*RegisterPipelineConfigRequest) ProtoReflect added in v0.5.0

func (*RegisterPipelineConfigRequest) Reset added in v0.5.0

func (x *RegisterPipelineConfigRequest) Reset()

func (*RegisterPipelineConfigRequest) String added in v0.5.0

type RegisterPipelineConfigResponse added in v0.5.0

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

func (*RegisterPipelineConfigResponse) Descriptor deprecated added in v0.5.0

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

Deprecated: Use RegisterPipelineConfigResponse.ProtoReflect.Descriptor instead.

func (*RegisterPipelineConfigResponse) GetPipeline added in v0.5.0

func (x *RegisterPipelineConfigResponse) GetPipeline() *Pipeline

func (*RegisterPipelineConfigResponse) ProtoMessage added in v0.5.0

func (*RegisterPipelineConfigResponse) ProtoMessage()

func (*RegisterPipelineConfigResponse) ProtoReflect added in v0.5.0

func (*RegisterPipelineConfigResponse) Reset added in v0.5.0

func (x *RegisterPipelineConfigResponse) Reset()

func (*RegisterPipelineConfigResponse) String added in v0.5.0

type RegistryAuth

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

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

Deprecated: Use RegistryAuth.ProtoReflect.Descriptor instead.

func (*RegistryAuth) GetPass

func (x *RegistryAuth) GetPass() string

func (*RegistryAuth) GetUser

func (x *RegistryAuth) GetUser() string

func (*RegistryAuth) ProtoMessage

func (*RegistryAuth) ProtoMessage()

func (*RegistryAuth) ProtoReflect

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

func (*RegistryAuth) Reset

func (x *RegistryAuth) Reset()

func (*RegistryAuth) String

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"`
	RunId       int64      `protobuf:"varint,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"` // Run ID
	Initiator   *Initiator `protobuf:"bytes,4,opt,name=initiator,proto3" json:"initiator,omitempty"`       // Who started the run and for what purpose?
	// contains filtered or unexported fields
}

func (*RetryRunRequest) Descriptor deprecated

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

Deprecated: Use RetryRunRequest.ProtoReflect.Descriptor instead.

func (*RetryRunRequest) GetInitiator added in v0.5.0

func (x *RetryRunRequest) GetInitiator() *Initiator

func (*RetryRunRequest) GetNamespaceId

func (x *RetryRunRequest) GetNamespaceId() string

func (*RetryRunRequest) GetPipelineId

func (x *RetryRunRequest) GetPipelineId() string

func (*RetryRunRequest) GetRunId

func (x *RetryRunRequest) GetRunId() int64

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 {
	Namespace           string           `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Pipeline            string           `protobuf:"bytes,2,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	Version             int64            `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	Id                  int64            `protobuf:"varint,4,opt,name=id,proto3" json:"id,omitempty"`
	Started             int64            `protobuf:"varint,5,opt,name=started,proto3" json:"started,omitempty"`
	Ended               int64            `protobuf:"varint,6,opt,name=ended,proto3" json:"ended,omitempty"`
	State               Run_RunState     `protobuf:"varint,7,opt,name=state,proto3,enum=proto.Run_RunState" json:"state,omitempty"`
	Status              Run_RunStatus    `protobuf:"varint,8,opt,name=status,proto3,enum=proto.Run_RunStatus" json:"status,omitempty"`
	StatusReason        *RunStatusReason `protobuf:"bytes,9,opt,name=status_reason,json=statusReason,proto3" json:"status_reason,omitempty"`
	Initiator           *Initiator       `protobuf:"bytes,10,opt,name=initiator,proto3" json:"initiator,omitempty"`
	Variables           []*Variable      `protobuf:"bytes,11,rep,name=variables,proto3" json:"variables,omitempty"`
	StoreObjectsExpired bool             `protobuf:"varint,12,opt,name=store_objects_expired,json=storeObjectsExpired,proto3" json:"store_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) GetId

func (x *Run) GetId() int64

func (*Run) GetInitiator added in v0.5.0

func (x *Run) GetInitiator() *Initiator

func (*Run) GetNamespace

func (x *Run) GetNamespace() string

func (*Run) GetPipeline

func (x *Run) GetPipeline() string

func (*Run) GetStarted

func (x *Run) GetStarted() int64

func (*Run) GetState

func (x *Run) GetState() Run_RunState

func (*Run) GetStatus

func (x *Run) GetStatus() Run_RunStatus

func (*Run) GetStatusReason

func (x *Run) GetStatusReason() *RunStatusReason

func (*Run) GetStoreObjectsExpired

func (x *Run) GetStoreObjectsExpired() bool

func (*Run) GetVariables

func (x *Run) GetVariables() []*Variable

func (*Run) GetVersion added in v0.5.0

func (x *Run) GetVersion() int64

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 RunExtensionInstallerClientMessage added in v0.6.0

type RunExtensionInstallerClientMessage struct {

	// Types that are assignable to MessageType:
	//
	//	*RunExtensionInstallerClientMessage_Init_
	//	*RunExtensionInstallerClientMessage_Msg
	MessageType isRunExtensionInstallerClientMessage_MessageType `protobuf_oneof:"message_type"`
	// contains filtered or unexported fields
}

func (*RunExtensionInstallerClientMessage) Descriptor deprecated added in v0.6.0

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

Deprecated: Use RunExtensionInstallerClientMessage.ProtoReflect.Descriptor instead.

func (*RunExtensionInstallerClientMessage) GetInit added in v0.6.0

func (*RunExtensionInstallerClientMessage) GetMessageType added in v0.6.0

func (m *RunExtensionInstallerClientMessage) GetMessageType() isRunExtensionInstallerClientMessage_MessageType

func (*RunExtensionInstallerClientMessage) GetMsg added in v0.6.0

func (*RunExtensionInstallerClientMessage) ProtoMessage added in v0.6.0

func (*RunExtensionInstallerClientMessage) ProtoMessage()

func (*RunExtensionInstallerClientMessage) ProtoReflect added in v0.6.0

func (*RunExtensionInstallerClientMessage) Reset added in v0.6.0

func (*RunExtensionInstallerClientMessage) String added in v0.6.0

type RunExtensionInstallerClientMessage_Init added in v0.6.0

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

func (*RunExtensionInstallerClientMessage_Init) Descriptor deprecated added in v0.6.0

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

Deprecated: Use RunExtensionInstallerClientMessage_Init.ProtoReflect.Descriptor instead.

func (*RunExtensionInstallerClientMessage_Init) GetImage added in v0.6.0

func (*RunExtensionInstallerClientMessage_Init) GetPass added in v0.6.0

func (*RunExtensionInstallerClientMessage_Init) GetUser added in v0.6.0

func (*RunExtensionInstallerClientMessage_Init) ProtoMessage added in v0.6.0

func (*RunExtensionInstallerClientMessage_Init) ProtoReflect added in v0.6.0

func (*RunExtensionInstallerClientMessage_Init) Reset added in v0.6.0

func (*RunExtensionInstallerClientMessage_Init) String added in v0.6.0

type RunExtensionInstallerClientMessage_Init_ added in v0.6.0

type RunExtensionInstallerClientMessage_Init_ struct {
	Init *RunExtensionInstallerClientMessage_Init `protobuf:"bytes,1,opt,name=init,proto3,oneof"`
}

type RunExtensionInstallerClientMessage_Msg added in v0.6.0

type RunExtensionInstallerClientMessage_Msg struct {
	Msg string `protobuf:"bytes,2,opt,name=msg,proto3,oneof"`
}

type RunExtensionInstallerExtensionMessage added in v0.6.0

type RunExtensionInstallerExtensionMessage struct {

	// Types that are assignable to MessageType:
	//
	//	*RunExtensionInstallerExtensionMessage_Msg
	//	*RunExtensionInstallerExtensionMessage_Query
	//	*RunExtensionInstallerExtensionMessage_ConfigSetting_
	MessageType isRunExtensionInstallerExtensionMessage_MessageType `protobuf_oneof:"message_type"`
	// contains filtered or unexported fields
}

func (*RunExtensionInstallerExtensionMessage) Descriptor deprecated added in v0.6.0

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

Deprecated: Use RunExtensionInstallerExtensionMessage.ProtoReflect.Descriptor instead.

func (*RunExtensionInstallerExtensionMessage) GetConfigSetting added in v0.6.0

func (*RunExtensionInstallerExtensionMessage) GetMessageType added in v0.6.0

func (m *RunExtensionInstallerExtensionMessage) GetMessageType() isRunExtensionInstallerExtensionMessage_MessageType

func (*RunExtensionInstallerExtensionMessage) GetMsg added in v0.6.0

func (*RunExtensionInstallerExtensionMessage) GetQuery added in v0.6.0

func (*RunExtensionInstallerExtensionMessage) ProtoMessage added in v0.6.0

func (*RunExtensionInstallerExtensionMessage) ProtoMessage()

func (*RunExtensionInstallerExtensionMessage) ProtoReflect added in v0.6.0

func (*RunExtensionInstallerExtensionMessage) Reset added in v0.6.0

func (*RunExtensionInstallerExtensionMessage) String added in v0.6.0

type RunExtensionInstallerExtensionMessage_ConfigSetting added in v0.6.0

type RunExtensionInstallerExtensionMessage_ConfigSetting struct {
	Config string `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	Value  string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*RunExtensionInstallerExtensionMessage_ConfigSetting) Descriptor deprecated added in v0.6.0

Deprecated: Use RunExtensionInstallerExtensionMessage_ConfigSetting.ProtoReflect.Descriptor instead.

func (*RunExtensionInstallerExtensionMessage_ConfigSetting) GetConfig added in v0.6.0

func (*RunExtensionInstallerExtensionMessage_ConfigSetting) GetValue added in v0.6.0

func (*RunExtensionInstallerExtensionMessage_ConfigSetting) ProtoMessage added in v0.6.0

func (*RunExtensionInstallerExtensionMessage_ConfigSetting) ProtoReflect added in v0.6.0

func (*RunExtensionInstallerExtensionMessage_ConfigSetting) Reset added in v0.6.0

func (*RunExtensionInstallerExtensionMessage_ConfigSetting) String added in v0.6.0

type RunExtensionInstallerExtensionMessage_ConfigSetting_ added in v0.6.0

type RunExtensionInstallerExtensionMessage_ConfigSetting_ struct {
	// Config setting messages communicate when the extension has suggested a
	// configuration based on the user input.
	ConfigSetting *RunExtensionInstallerExtensionMessage_ConfigSetting `protobuf:"bytes,3,opt,name=config_setting,json=configSetting,proto3,oneof"`
}

type RunExtensionInstallerExtensionMessage_Msg added in v0.6.0

type RunExtensionInstallerExtensionMessage_Msg struct {
	// Normal extension messages that should be passed back to the user.
	Msg string `protobuf:"bytes,1,opt,name=msg,proto3,oneof"`
}

type RunExtensionInstallerExtensionMessage_Query added in v0.6.0

type RunExtensionInstallerExtensionMessage_Query struct {
	// A question from the extension that needs an answer. The extension will
	// wait for an answer after this request. This specific message type
	// allows the cli to know when to prompt the user for an answer.
	Query string `protobuf:"bytes,2,opt,name=query,proto3,oneof"`
}

type RunPipelineConfiguratorClientMessage added in v0.6.0

type RunPipelineConfiguratorClientMessage struct {

	// Types that are assignable to MessageType:
	//
	//	*RunPipelineConfiguratorClientMessage_Init_
	//	*RunPipelineConfiguratorClientMessage_Msg
	MessageType isRunPipelineConfiguratorClientMessage_MessageType `protobuf_oneof:"message_type"`
	// contains filtered or unexported fields
}

func (*RunPipelineConfiguratorClientMessage) Descriptor deprecated added in v0.6.0

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

Deprecated: Use RunPipelineConfiguratorClientMessage.ProtoReflect.Descriptor instead.

func (*RunPipelineConfiguratorClientMessage) GetInit added in v0.6.0

func (*RunPipelineConfiguratorClientMessage) GetMessageType added in v0.6.0

func (m *RunPipelineConfiguratorClientMessage) GetMessageType() isRunPipelineConfiguratorClientMessage_MessageType

func (*RunPipelineConfiguratorClientMessage) GetMsg added in v0.6.0

func (*RunPipelineConfiguratorClientMessage) ProtoMessage added in v0.6.0

func (*RunPipelineConfiguratorClientMessage) ProtoMessage()

func (*RunPipelineConfiguratorClientMessage) ProtoReflect added in v0.6.0

func (*RunPipelineConfiguratorClientMessage) Reset added in v0.6.0

func (*RunPipelineConfiguratorClientMessage) String added in v0.6.0

type RunPipelineConfiguratorClientMessage_Init added in v0.6.0

type RunPipelineConfiguratorClientMessage_Init struct {

	// name of the extension you want to run the pipeline
	// configurator for
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*RunPipelineConfiguratorClientMessage_Init) Descriptor deprecated added in v0.6.0

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

Deprecated: Use RunPipelineConfiguratorClientMessage_Init.ProtoReflect.Descriptor instead.

func (*RunPipelineConfiguratorClientMessage_Init) GetName added in v0.6.0

func (*RunPipelineConfiguratorClientMessage_Init) ProtoMessage added in v0.6.0

func (*RunPipelineConfiguratorClientMessage_Init) ProtoReflect added in v0.6.0

func (*RunPipelineConfiguratorClientMessage_Init) Reset added in v0.6.0

func (*RunPipelineConfiguratorClientMessage_Init) String added in v0.6.0

type RunPipelineConfiguratorClientMessage_Init_ added in v0.6.0

type RunPipelineConfiguratorClientMessage_Init_ struct {
	Init *RunPipelineConfiguratorClientMessage_Init `protobuf:"bytes,1,opt,name=init,proto3,oneof"`
}

type RunPipelineConfiguratorClientMessage_Msg added in v0.6.0

type RunPipelineConfiguratorClientMessage_Msg struct {
	Msg string `protobuf:"bytes,2,opt,name=msg,proto3,oneof"`
}

type RunPipelineConfiguratorExtensionMessage added in v0.6.0

type RunPipelineConfiguratorExtensionMessage struct {

	// Types that are assignable to MessageType:
	//
	//	*RunPipelineConfiguratorExtensionMessage_Msg
	//	*RunPipelineConfiguratorExtensionMessage_Query
	//	*RunPipelineConfiguratorExtensionMessage_ParamSetting_
	MessageType isRunPipelineConfiguratorExtensionMessage_MessageType `protobuf_oneof:"message_type"`
	// contains filtered or unexported fields
}

func (*RunPipelineConfiguratorExtensionMessage) Descriptor deprecated added in v0.6.0

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

Deprecated: Use RunPipelineConfiguratorExtensionMessage.ProtoReflect.Descriptor instead.

func (*RunPipelineConfiguratorExtensionMessage) GetMessageType added in v0.6.0

func (m *RunPipelineConfiguratorExtensionMessage) GetMessageType() isRunPipelineConfiguratorExtensionMessage_MessageType

func (*RunPipelineConfiguratorExtensionMessage) GetMsg added in v0.6.0

func (*RunPipelineConfiguratorExtensionMessage) GetParamSetting added in v0.6.0

func (*RunPipelineConfiguratorExtensionMessage) GetQuery added in v0.6.0

func (*RunPipelineConfiguratorExtensionMessage) ProtoMessage added in v0.6.0

func (*RunPipelineConfiguratorExtensionMessage) ProtoReflect added in v0.6.0

func (*RunPipelineConfiguratorExtensionMessage) Reset added in v0.6.0

func (*RunPipelineConfiguratorExtensionMessage) String added in v0.6.0

type RunPipelineConfiguratorExtensionMessage_Msg added in v0.6.0

type RunPipelineConfiguratorExtensionMessage_Msg struct {
	// Normal extension messages that should be passed back to the user.
	Msg string `protobuf:"bytes,1,opt,name=msg,proto3,oneof"`
}

type RunPipelineConfiguratorExtensionMessage_ParamSetting added in v0.6.0

type RunPipelineConfiguratorExtensionMessage_ParamSetting struct {
	Param string `protobuf:"bytes,1,opt,name=param,proto3" json:"param,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*RunPipelineConfiguratorExtensionMessage_ParamSetting) Descriptor deprecated added in v0.6.0

Deprecated: Use RunPipelineConfiguratorExtensionMessage_ParamSetting.ProtoReflect.Descriptor instead.

func (*RunPipelineConfiguratorExtensionMessage_ParamSetting) GetParam added in v0.6.0

func (*RunPipelineConfiguratorExtensionMessage_ParamSetting) GetValue added in v0.6.0

func (*RunPipelineConfiguratorExtensionMessage_ParamSetting) ProtoMessage added in v0.6.0

func (*RunPipelineConfiguratorExtensionMessage_ParamSetting) ProtoReflect added in v0.6.0

func (*RunPipelineConfiguratorExtensionMessage_ParamSetting) Reset added in v0.6.0

func (*RunPipelineConfiguratorExtensionMessage_ParamSetting) String added in v0.6.0

type RunPipelineConfiguratorExtensionMessage_ParamSetting_ added in v0.6.0

type RunPipelineConfiguratorExtensionMessage_ParamSetting_ struct {
	// Param setting messages communicate when the extension has suggested a
	// configuration based on the user input.
	ParamSetting *RunPipelineConfiguratorExtensionMessage_ParamSetting `protobuf:"bytes,3,opt,name=param_setting,json=paramSetting,proto3,oneof"`
}

type RunPipelineConfiguratorExtensionMessage_Query added in v0.6.0

type RunPipelineConfiguratorExtensionMessage_Query struct {
	// A question from the extension that needs an answer. The extension will
	// wait for an answer after this request. This specific message type
	// allows the cli to know when to prompt the user for an answer.
	Query string `protobuf:"bytes,2,opt,name=query,proto3,oneof"`
}

type RunStatusReason

type RunStatusReason struct {
	Reason      RunStatusReason_RunStatusReasonKind `protobuf:"varint,1,opt,name=reason,proto3,enum=proto.RunStatusReason_RunStatusReasonKind" json:"reason,omitempty"`
	Description string                              `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*RunStatusReason) Descriptor deprecated

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

Deprecated: Use RunStatusReason.ProtoReflect.Descriptor instead.

func (*RunStatusReason) GetDescription

func (x *RunStatusReason) GetDescription() string

func (*RunStatusReason) GetReason

func (*RunStatusReason) ProtoMessage

func (*RunStatusReason) ProtoMessage()

func (*RunStatusReason) ProtoReflect

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

func (*RunStatusReason) Reset

func (x *RunStatusReason) Reset()

func (*RunStatusReason) String

func (x *RunStatusReason) String() string

type RunStatusReason_RunStatusReasonKind

type RunStatusReason_RunStatusReasonKind int32
const (
	RunStatusReason_RUN_STATUS_REASON_UNKNOWN RunStatusReason_RunStatusReasonKind = 0
	RunStatusReason_ABNORMAL_EXIT             RunStatusReason_RunStatusReasonKind = 1
	RunStatusReason_SCHEDULER_ERROR           RunStatusReason_RunStatusReasonKind = 2
	RunStatusReason_FAILED_PRECONDITION       RunStatusReason_RunStatusReasonKind = 3
	RunStatusReason_USER_CANCELLED            RunStatusReason_RunStatusReasonKind = 4
	RunStatusReason_ADMIN_CANCELLED           RunStatusReason_RunStatusReasonKind = 5
)

func (RunStatusReason_RunStatusReasonKind) Descriptor

func (RunStatusReason_RunStatusReasonKind) Enum

func (RunStatusReason_RunStatusReasonKind) EnumDescriptor deprecated

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

Deprecated: Use RunStatusReason_RunStatusReasonKind.Descriptor instead.

func (RunStatusReason_RunStatusReasonKind) Number

func (RunStatusReason_RunStatusReasonKind) String

func (RunStatusReason_RunStatusReasonKind) Type

type Run_RunState

type Run_RunState int32
const (
	Run_RUN_STATE_UNKNOWN Run_RunState = 0
	Run_PENDING           Run_RunState = 1
	Run_RUNNING           Run_RunState = 2
	Run_COMPLETE          Run_RunState = 3
)

func (Run_RunState) Descriptor

func (Run_RunState) Enum

func (x Run_RunState) Enum() *Run_RunState

func (Run_RunState) EnumDescriptor deprecated

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

Deprecated: Use Run_RunState.Descriptor instead.

func (Run_RunState) Number

func (Run_RunState) String

func (x Run_RunState) String() string

func (Run_RunState) Type

type Run_RunStatus

type Run_RunStatus int32
const (
	Run_RUN_STATUS_UNKNOWN Run_RunStatus = 0
	Run_SUCCESSFUL         Run_RunStatus = 1
	Run_FAILED             Run_RunStatus = 2
	Run_CANCELLED          Run_RunStatus = 3
)

func (Run_RunStatus) Descriptor

func (Run_RunStatus) Enum

func (x Run_RunStatus) Enum() *Run_RunStatus

func (Run_RunStatus) EnumDescriptor deprecated

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

Deprecated: Use Run_RunStatus.Descriptor instead.

func (Run_RunStatus) Number

func (Run_RunStatus) String

func (x Run_RunStatus) String() string

func (Run_RunStatus) Type

type SecretStoreKey

type SecretStoreKey struct {
	Key        string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Namespaces []string `protobuf:"bytes,2,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	Created    int64    `protobuf:"varint,3,opt,name=created,proto3" json:"created,omitempty"`
	// contains filtered or unexported fields
}

func (*SecretStoreKey) Descriptor deprecated

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

Deprecated: Use SecretStoreKey.ProtoReflect.Descriptor instead.

func (*SecretStoreKey) GetCreated

func (x *SecretStoreKey) GetCreated() int64

func (*SecretStoreKey) GetKey

func (x *SecretStoreKey) GetKey() string

func (*SecretStoreKey) GetNamespaces added in v0.5.0

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

func (*SecretStoreKey) ProtoMessage

func (*SecretStoreKey) ProtoMessage()

func (*SecretStoreKey) ProtoReflect

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

func (*SecretStoreKey) Reset

func (x *SecretStoreKey) Reset()

func (*SecretStoreKey) String

func (x *SecretStoreKey) String() string

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"`
	// 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 */
	Initiator *Initiator        `protobuf:"bytes,4,opt,name=initiator,proto3" json:"initiator,omitempty"` // Who started the run and for what purpose?
	// contains filtered or unexported fields
}

func (*StartRunRequest) Descriptor deprecated

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

Deprecated: Use StartRunRequest.ProtoReflect.Descriptor instead.

func (*StartRunRequest) GetInitiator added in v0.5.0

func (x *StartRunRequest) GetInitiator() *Initiator

func (*StartRunRequest) GetNamespaceId

func (x *StartRunRequest) GetNamespaceId() 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 added in v0.5.0

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"`
	RegistryAuth   *RegistryAuth                        `protobuf:"bytes,4,opt,name=registry_auth,json=registryAuth,proto3" json:"registry_auth,omitempty"`
	DependsOn      map[string]Task_RequiredParentStatus `` /* 214-byte string literal not displayed */
	Variables      []*Variable                          `protobuf:"bytes,6,rep,name=variables,proto3" json:"variables,omitempty"`
	Entrypoint     []string                             `protobuf:"bytes,7,rep,name=entrypoint,proto3" json:"entrypoint,omitempty"`
	Command        []string                             `protobuf:"bytes,8,rep,name=command,proto3" json:"command,omitempty"`
	InjectApiToken bool                                 `protobuf:"varint,9,opt,name=inject_api_token,json=injectApiToken,proto3" json:"inject_api_token,omitempty"`
	// contains filtered or unexported fields
}

func (*Task) Descriptor deprecated added in v0.5.0

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetCommand added in v0.5.0

func (x *Task) GetCommand() []string

func (*Task) GetDependsOn added in v0.5.0

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

func (*Task) GetDescription added in v0.5.0

func (x *Task) GetDescription() string

func (*Task) GetEntrypoint added in v0.5.0

func (x *Task) GetEntrypoint() []string

func (*Task) GetId added in v0.5.0

func (x *Task) GetId() string

func (*Task) GetImage added in v0.5.0

func (x *Task) GetImage() string

func (*Task) GetInjectApiToken added in v0.5.0

func (x *Task) GetInjectApiToken() bool

func (*Task) GetRegistryAuth added in v0.5.0

func (x *Task) GetRegistryAuth() *RegistryAuth

func (*Task) GetVariables added in v0.5.0

func (x *Task) GetVariables() []*Variable

func (*Task) ProtoMessage added in v0.5.0

func (*Task) ProtoMessage()

func (*Task) ProtoReflect added in v0.5.0

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

func (*Task) Reset added in v0.5.0

func (x *Task) Reset()

func (*Task) String added in v0.5.0

func (x *Task) String() string

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"`
	StatusReason *TaskRunStatusReason  `protobuf:"bytes,4,opt,name=status_reason,json=statusReason,proto3" json:"status_reason,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"`
	Namespace    string                `protobuf:"bytes,8,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Pipeline     string                `protobuf:"bytes,9,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	Version      int64                 `protobuf:"varint,10,opt,name=version,proto3" json:"version,omitempty"`
	Run          int64                 `protobuf:"varint,11,opt,name=run,proto3" json:"run,omitempty"`
	Started      int64                 `protobuf:"varint,12,opt,name=started,proto3" json:"started,omitempty"`
	State        TaskRun_TaskRunState  `protobuf:"varint,13,opt,name=state,proto3,enum=proto.TaskRun_TaskRunState" json:"state,omitempty"`
	Status       TaskRun_TaskRunStatus `protobuf:"varint,14,opt,name=status,proto3,enum=proto.TaskRun_TaskRunStatus" json:"status,omitempty"`
	Task         *Task                 `protobuf:"bytes,15,opt,name=task,proto3" json:"task,omitempty"`
	Variables    []*Variable           `protobuf:"bytes,16,rep,name=variables,proto3" json:"variables,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) GetId

func (x *TaskRun) GetId() string

func (*TaskRun) GetLogsExpired

func (x *TaskRun) GetLogsExpired() bool

func (*TaskRun) GetLogsRemoved

func (x *TaskRun) GetLogsRemoved() bool

func (*TaskRun) GetNamespace

func (x *TaskRun) GetNamespace() string

func (*TaskRun) GetPipeline

func (x *TaskRun) GetPipeline() string

func (*TaskRun) GetRun

func (x *TaskRun) GetRun() int64

func (*TaskRun) GetStarted

func (x *TaskRun) GetStarted() int64

func (*TaskRun) GetState

func (x *TaskRun) GetState() TaskRun_TaskRunState

func (*TaskRun) GetStatus

func (x *TaskRun) GetStatus() TaskRun_TaskRunStatus

func (*TaskRun) GetStatusReason

func (x *TaskRun) GetStatusReason() *TaskRunStatusReason

func (*TaskRun) GetTask

func (x *TaskRun) GetTask() *Task

func (*TaskRun) GetVariables

func (x *TaskRun) GetVariables() []*Variable

func (*TaskRun) GetVersion added in v0.5.0

func (x *TaskRun) GetVersion() int64

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 TaskRunStatusReason

type TaskRunStatusReason struct {
	Reason      TaskRunStatusReason_Reason `protobuf:"varint,1,opt,name=reason,proto3,enum=proto.TaskRunStatusReason_Reason" json:"reason,omitempty"`
	Description string                     `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskRunStatusReason) Descriptor deprecated

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

Deprecated: Use TaskRunStatusReason.ProtoReflect.Descriptor instead.

func (*TaskRunStatusReason) GetDescription

func (x *TaskRunStatusReason) GetDescription() string

func (*TaskRunStatusReason) GetReason

func (*TaskRunStatusReason) ProtoMessage

func (*TaskRunStatusReason) ProtoMessage()

func (*TaskRunStatusReason) ProtoReflect

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

func (*TaskRunStatusReason) Reset

func (x *TaskRunStatusReason) Reset()

func (*TaskRunStatusReason) String

func (x *TaskRunStatusReason) String() string

type TaskRunStatusReason_Reason

type TaskRunStatusReason_Reason int32
const (
	TaskRunStatusReason_UNKNOWN             TaskRunStatusReason_Reason = 0
	TaskRunStatusReason_ABNORMAL_EXIT       TaskRunStatusReason_Reason = 1
	TaskRunStatusReason_SCHEDULER_ERROR     TaskRunStatusReason_Reason = 2
	TaskRunStatusReason_FAILED_PRECONDITION TaskRunStatusReason_Reason = 3
	TaskRunStatusReason_CANCELLED           TaskRunStatusReason_Reason = 4
	TaskRunStatusReason_ORPHANED            TaskRunStatusReason_Reason = 5
)

func (TaskRunStatusReason_Reason) Descriptor

func (TaskRunStatusReason_Reason) Enum

func (TaskRunStatusReason_Reason) EnumDescriptor deprecated

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

Deprecated: Use TaskRunStatusReason_Reason.Descriptor instead.

func (TaskRunStatusReason_Reason) Number

func (TaskRunStatusReason_Reason) String

func (TaskRunStatusReason_Reason) Type

type TaskRun_TaskRunState

type TaskRun_TaskRunState int32
const (
	TaskRun_UNKNOWN_STATE TaskRun_TaskRunState = 0
	TaskRun_PROCESSING    TaskRun_TaskRunState = 1
	TaskRun_WAITING       TaskRun_TaskRunState = 2
	TaskRun_RUNNING       TaskRun_TaskRunState = 3
	TaskRun_COMPLETE      TaskRun_TaskRunState = 4
)

func (TaskRun_TaskRunState) Descriptor

func (TaskRun_TaskRunState) Enum

func (TaskRun_TaskRunState) EnumDescriptor deprecated

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

Deprecated: Use TaskRun_TaskRunState.Descriptor instead.

func (TaskRun_TaskRunState) Number

func (TaskRun_TaskRunState) String

func (x TaskRun_TaskRunState) String() string

func (TaskRun_TaskRunState) Type

type TaskRun_TaskRunStatus

type TaskRun_TaskRunStatus int32
const (
	TaskRun_UNKNOWN_STATUS TaskRun_TaskRunStatus = 0
	TaskRun_SUCCESSFUL     TaskRun_TaskRunStatus = 1
	TaskRun_FAILED         TaskRun_TaskRunStatus = 2
	TaskRun_CANCELLED      TaskRun_TaskRunStatus = 3
	TaskRun_SKIPPED        TaskRun_TaskRunStatus = 4
)

func (TaskRun_TaskRunStatus) Descriptor

func (TaskRun_TaskRunStatus) Enum

func (TaskRun_TaskRunStatus) EnumDescriptor deprecated

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

Deprecated: Use TaskRun_TaskRunStatus.Descriptor instead.

func (TaskRun_TaskRunStatus) Number

func (TaskRun_TaskRunStatus) String

func (x TaskRun_TaskRunStatus) String() string

func (TaskRun_TaskRunStatus) Type

type Task_RequiredParentStatus added in v0.5.0

type Task_RequiredParentStatus int32
const (
	Task_REQUIRED_PARENT_STATUS_UNKNOWN Task_RequiredParentStatus = 0
	Task_ANY                            Task_RequiredParentStatus = 1
	Task_SUCCESS                        Task_RequiredParentStatus = 2
	Task_FAILURE                        Task_RequiredParentStatus = 3
)

func (Task_RequiredParentStatus) Descriptor added in v0.5.0

func (Task_RequiredParentStatus) Enum added in v0.5.0

func (Task_RequiredParentStatus) EnumDescriptor deprecated added in v0.5.0

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

Deprecated: Use Task_RequiredParentStatus.Descriptor instead.

func (Task_RequiredParentStatus) Number added in v0.5.0

func (Task_RequiredParentStatus) String added in v0.5.0

func (x Task_RequiredParentStatus) String() string

func (Task_RequiredParentStatus) Type added in v0.5.0

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 (*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 (*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"`
	// Accepts either direct namespace list or regex
	Namespaces []string          `protobuf:"bytes,3,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	Metadata   map[string]string `` /* 157-byte string literal not displayed */
	Expires    int64             `protobuf:"varint,5,opt,name=expires,proto3" json:"expires,omitempty"`
	Disabled   bool              `protobuf:"varint,6,opt,name=disabled,proto3" json:"disabled,omitempty"`
	// 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) GetDisabled

func (x *Token) GetDisabled() bool

func (*Token) GetExpires

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

type UnimplementedExtensionServiceServer added in v0.5.0

type UnimplementedExtensionServiceServer struct {
}

UnimplementedExtensionServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedExtensionServiceServer) ExternalEvent added in v0.5.0

func (UnimplementedExtensionServiceServer) Info added in v0.5.0

func (UnimplementedExtensionServiceServer) Init added in v0.6.0

func (UnimplementedExtensionServiceServer) RunExtensionInstaller added in v0.6.0

func (UnimplementedExtensionServiceServer) RunPipelineConfigurator added in v0.6.0

func (UnimplementedExtensionServiceServer) Shutdown added in v0.5.0

func (UnimplementedExtensionServiceServer) Subscribe added in v0.5.0

func (UnimplementedExtensionServiceServer) Unsubscribe added in v0.5.0

type UnimplementedGoferServer

type UnimplementedGoferServer struct {
}

UnimplementedGoferServer must be embedded to have forward compatible implementations.

func (UnimplementedGoferServer) AttachToTaskRun added in v0.6.0

func (UnimplementedGoferServer) BootstrapToken

func (UnimplementedGoferServer) CancelAllRuns

func (UnimplementedGoferServer) CancelRun

func (UnimplementedGoferServer) CancelTaskRun

func (UnimplementedGoferServer) CreateNamespace

func (UnimplementedGoferServer) CreateToken

func (UnimplementedGoferServer) DeleteNamespace

func (UnimplementedGoferServer) DeletePipeline

func (UnimplementedGoferServer) DeletePipelineConfig added in v0.5.0

func (UnimplementedGoferServer) DeleteRunObject

func (UnimplementedGoferServer) DeleteToken

func (UnimplementedGoferServer) DeployPipeline added in v0.5.0

func (UnimplementedGoferServer) DisableExtension added in v0.5.0

func (UnimplementedGoferServer) DisablePipeline

func (UnimplementedGoferServer) DisableToken

func (UnimplementedGoferServer) EnableExtension added in v0.5.0

func (UnimplementedGoferServer) EnablePipeline

func (UnimplementedGoferServer) EnableToken

func (UnimplementedGoferServer) GetDeployment added in v0.5.0

func (UnimplementedGoferServer) GetEvent

func (UnimplementedGoferServer) GetExtension added in v0.5.0

func (UnimplementedGoferServer) GetGlobalSecret

func (UnimplementedGoferServer) GetNamespace

func (UnimplementedGoferServer) GetPipeline

func (UnimplementedGoferServer) GetPipelineConfig added in v0.5.0

func (UnimplementedGoferServer) GetPipelineExtensionSubscription added in v0.5.0

func (UnimplementedGoferServer) GetRun

func (UnimplementedGoferServer) GetRunObject

func (UnimplementedGoferServer) GetSystemInfo

func (UnimplementedGoferServer) GetTaskRun

func (UnimplementedGoferServer) GetTaskRunLogs

func (UnimplementedGoferServer) GetToken

func (UnimplementedGoferServer) InstallExtension added in v0.5.0

func (UnimplementedGoferServer) ListDeployments added in v0.5.0

func (UnimplementedGoferServer) ListEvents

func (UnimplementedGoferServer) ListExtensions added in v0.5.0

func (UnimplementedGoferServer) ListNamespaces

func (UnimplementedGoferServer) ListPipelineConfigs added in v0.5.0

func (UnimplementedGoferServer) ListPipelines

func (UnimplementedGoferServer) ListRunObjects

func (UnimplementedGoferServer) ListRuns

func (UnimplementedGoferServer) ListTaskRuns

func (UnimplementedGoferServer) ListTokens

func (UnimplementedGoferServer) PutGlobalSecret

func (UnimplementedGoferServer) PutRunObject

func (UnimplementedGoferServer) RegisterPipelineConfig added in v0.5.0

func (UnimplementedGoferServer) RepairOrphan

func (UnimplementedGoferServer) RetryRun

func (UnimplementedGoferServer) RunExtensionInstaller added in v0.6.0

func (UnimplementedGoferServer) RunPipelineConfigurator added in v0.6.0

func (UnimplementedGoferServer) StartRun

func (UnimplementedGoferServer) UninstallExtension added in v0.5.0

func (UnimplementedGoferServer) UpdateNamespace

type UninstallExtensionRequest added in v0.5.0

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

func (*UninstallExtensionRequest) Descriptor deprecated added in v0.5.0

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

Deprecated: Use UninstallExtensionRequest.ProtoReflect.Descriptor instead.

func (*UninstallExtensionRequest) GetName added in v0.5.0

func (x *UninstallExtensionRequest) GetName() string

func (*UninstallExtensionRequest) ProtoMessage added in v0.5.0

func (*UninstallExtensionRequest) ProtoMessage()

func (*UninstallExtensionRequest) ProtoReflect added in v0.5.0

func (*UninstallExtensionRequest) Reset added in v0.5.0

func (x *UninstallExtensionRequest) Reset()

func (*UninstallExtensionRequest) String added in v0.5.0

func (x *UninstallExtensionRequest) String() string

type UninstallExtensionResponse added in v0.5.0

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

func (*UninstallExtensionResponse) Descriptor deprecated added in v0.5.0

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

Deprecated: Use UninstallExtensionResponse.ProtoReflect.Descriptor instead.

func (*UninstallExtensionResponse) ProtoMessage added in v0.5.0

func (*UninstallExtensionResponse) ProtoMessage()

func (*UninstallExtensionResponse) ProtoReflect added in v0.5.0

func (*UninstallExtensionResponse) Reset added in v0.5.0

func (x *UninstallExtensionResponse) Reset()

func (*UninstallExtensionResponse) String added in v0.5.0

func (x *UninstallExtensionResponse) String() string

type UnsafeExtensionServiceServer added in v0.5.0

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

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

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 {
	// contains filtered or unexported fields
}

func (*UpdateNamespaceResponse) Descriptor deprecated

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

Deprecated: Use UpdateNamespaceResponse.ProtoReflect.Descriptor instead.

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 UserPipelineConfig added in v0.5.0

type UserPipelineConfig 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"`
	Parallelism int64                     `protobuf:"varint,4,opt,name=parallelism,proto3" json:"parallelism,omitempty"`
	Tasks       []*UserPipelineTaskConfig `protobuf:"bytes,5,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*UserPipelineConfig) Descriptor deprecated added in v0.5.0

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

Deprecated: Use UserPipelineConfig.ProtoReflect.Descriptor instead.

func (*UserPipelineConfig) GetDescription added in v0.5.0

func (x *UserPipelineConfig) GetDescription() string

func (*UserPipelineConfig) GetId added in v0.5.0

func (x *UserPipelineConfig) GetId() string

func (*UserPipelineConfig) GetName added in v0.5.0

func (x *UserPipelineConfig) GetName() string

func (*UserPipelineConfig) GetParallelism added in v0.5.0

func (x *UserPipelineConfig) GetParallelism() int64

func (*UserPipelineConfig) GetTasks added in v0.5.0

func (x *UserPipelineConfig) GetTasks() []*UserPipelineTaskConfig

func (*UserPipelineConfig) ProtoMessage added in v0.5.0

func (*UserPipelineConfig) ProtoMessage()

func (*UserPipelineConfig) ProtoReflect added in v0.5.0

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

func (*UserPipelineConfig) Reset added in v0.5.0

func (x *UserPipelineConfig) Reset()

func (*UserPipelineConfig) String added in v0.5.0

func (x *UserPipelineConfig) String() string

type UserPipelineTaskConfig added in v0.5.0

type UserPipelineTaskConfig 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"`
	RegistryAuth   *RegistryAuth                                          `protobuf:"bytes,4,opt,name=registry_auth,json=registryAuth,proto3" json:"registry_auth,omitempty"`
	DependsOn      map[string]UserPipelineTaskConfig_RequiredParentStatus `` /* 232-byte string literal not displayed */
	Variables      map[string]string                                      `` /* 159-byte string literal not displayed */
	Entrypoint     []string                                               `protobuf:"bytes,7,rep,name=entrypoint,proto3" json:"entrypoint,omitempty"`
	Command        []string                                               `protobuf:"bytes,8,rep,name=command,proto3" json:"command,omitempty"`
	InjectApiToken bool                                                   `protobuf:"varint,9,opt,name=inject_api_token,json=injectApiToken,proto3" json:"inject_api_token,omitempty"`
	// contains filtered or unexported fields
}

func (*UserPipelineTaskConfig) Descriptor deprecated added in v0.5.0

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

Deprecated: Use UserPipelineTaskConfig.ProtoReflect.Descriptor instead.

func (*UserPipelineTaskConfig) GetCommand added in v0.5.0

func (x *UserPipelineTaskConfig) GetCommand() []string

func (*UserPipelineTaskConfig) GetDependsOn added in v0.5.0

func (*UserPipelineTaskConfig) GetDescription added in v0.5.0

func (x *UserPipelineTaskConfig) GetDescription() string

func (*UserPipelineTaskConfig) GetEntrypoint added in v0.5.0

func (x *UserPipelineTaskConfig) GetEntrypoint() []string

func (*UserPipelineTaskConfig) GetId added in v0.5.0

func (x *UserPipelineTaskConfig) GetId() string

func (*UserPipelineTaskConfig) GetImage added in v0.5.0

func (x *UserPipelineTaskConfig) GetImage() string

func (*UserPipelineTaskConfig) GetInjectApiToken added in v0.5.0

func (x *UserPipelineTaskConfig) GetInjectApiToken() bool

func (*UserPipelineTaskConfig) GetRegistryAuth added in v0.5.0

func (x *UserPipelineTaskConfig) GetRegistryAuth() *RegistryAuth

func (*UserPipelineTaskConfig) GetVariables added in v0.5.0

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

func (*UserPipelineTaskConfig) ProtoMessage added in v0.5.0

func (*UserPipelineTaskConfig) ProtoMessage()

func (*UserPipelineTaskConfig) ProtoReflect added in v0.5.0

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

func (*UserPipelineTaskConfig) Reset added in v0.5.0

func (x *UserPipelineTaskConfig) Reset()

func (*UserPipelineTaskConfig) String added in v0.5.0

func (x *UserPipelineTaskConfig) String() string

type UserPipelineTaskConfig_RequiredParentStatus added in v0.5.0

type UserPipelineTaskConfig_RequiredParentStatus int32
const (
	UserPipelineTaskConfig_REQUIRED_PARENT_STATUS_UNKNOWN UserPipelineTaskConfig_RequiredParentStatus = 0
	UserPipelineTaskConfig_ANY                            UserPipelineTaskConfig_RequiredParentStatus = 1
	UserPipelineTaskConfig_SUCCESS                        UserPipelineTaskConfig_RequiredParentStatus = 2
	UserPipelineTaskConfig_FAILURE                        UserPipelineTaskConfig_RequiredParentStatus = 3
)

func (UserPipelineTaskConfig_RequiredParentStatus) Descriptor added in v0.5.0

func (UserPipelineTaskConfig_RequiredParentStatus) Enum added in v0.5.0

func (UserPipelineTaskConfig_RequiredParentStatus) EnumDescriptor deprecated added in v0.5.0

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

Deprecated: Use UserPipelineTaskConfig_RequiredParentStatus.Descriptor instead.

func (UserPipelineTaskConfig_RequiredParentStatus) Number added in v0.5.0

func (UserPipelineTaskConfig_RequiredParentStatus) String added in v0.5.0

func (UserPipelineTaskConfig_RequiredParentStatus) Type added in v0.5.0

type Variable

type Variable struct {
	Key    string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value  string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Source string `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"`
	// contains filtered or unexported fields
}

func (*Variable) Descriptor deprecated

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

Deprecated: Use Variable.ProtoReflect.Descriptor instead.

func (*Variable) GetKey

func (x *Variable) GetKey() string

func (*Variable) GetSource

func (x *Variable) GetSource() string

func (*Variable) GetValue

func (x *Variable) GetValue() string

func (*Variable) ProtoMessage

func (*Variable) ProtoMessage()

func (*Variable) ProtoReflect

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

func (*Variable) Reset

func (x *Variable) Reset()

func (*Variable) String

func (x *Variable) String() string

Jump to

Keyboard shortcuts

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