pipelinev1beta

package
v0.3.3-alpha.0...-a97b5aa Latest Latest
Warning

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

Go to latest
Published: May 10, 2024 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Overview

Package pipelinev1beta is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package pipelinev1beta is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source
const (
	PipelinePrivateService_ListPipelinesAdmin_FullMethodName        = "/vdp.pipeline.v1beta.PipelinePrivateService/ListPipelinesAdmin"
	PipelinePrivateService_LookUpPipelineAdmin_FullMethodName       = "/vdp.pipeline.v1beta.PipelinePrivateService/LookUpPipelineAdmin"
	PipelinePrivateService_ListPipelineReleasesAdmin_FullMethodName = "/vdp.pipeline.v1beta.PipelinePrivateService/ListPipelineReleasesAdmin"
)
View Source
const (
	PipelinePublicService_Liveness_FullMethodName                                = "/vdp.pipeline.v1beta.PipelinePublicService/Liveness"
	PipelinePublicService_Readiness_FullMethodName                               = "/vdp.pipeline.v1beta.PipelinePublicService/Readiness"
	PipelinePublicService_ListPipelines_FullMethodName                           = "/vdp.pipeline.v1beta.PipelinePublicService/ListPipelines"
	PipelinePublicService_LookUpPipeline_FullMethodName                          = "/vdp.pipeline.v1beta.PipelinePublicService/LookUpPipeline"
	PipelinePublicService_CreateUserPipeline_FullMethodName                      = "/vdp.pipeline.v1beta.PipelinePublicService/CreateUserPipeline"
	PipelinePublicService_ListUserPipelines_FullMethodName                       = "/vdp.pipeline.v1beta.PipelinePublicService/ListUserPipelines"
	PipelinePublicService_GetUserPipeline_FullMethodName                         = "/vdp.pipeline.v1beta.PipelinePublicService/GetUserPipeline"
	PipelinePublicService_UpdateUserPipeline_FullMethodName                      = "/vdp.pipeline.v1beta.PipelinePublicService/UpdateUserPipeline"
	PipelinePublicService_DeleteUserPipeline_FullMethodName                      = "/vdp.pipeline.v1beta.PipelinePublicService/DeleteUserPipeline"
	PipelinePublicService_ValidateUserPipeline_FullMethodName                    = "/vdp.pipeline.v1beta.PipelinePublicService/ValidateUserPipeline"
	PipelinePublicService_RenameUserPipeline_FullMethodName                      = "/vdp.pipeline.v1beta.PipelinePublicService/RenameUserPipeline"
	PipelinePublicService_CloneUserPipeline_FullMethodName                       = "/vdp.pipeline.v1beta.PipelinePublicService/CloneUserPipeline"
	PipelinePublicService_TriggerUserPipeline_FullMethodName                     = "/vdp.pipeline.v1beta.PipelinePublicService/TriggerUserPipeline"
	PipelinePublicService_TriggerAsyncUserPipeline_FullMethodName                = "/vdp.pipeline.v1beta.PipelinePublicService/TriggerAsyncUserPipeline"
	PipelinePublicService_CreateUserPipelineRelease_FullMethodName               = "/vdp.pipeline.v1beta.PipelinePublicService/CreateUserPipelineRelease"
	PipelinePublicService_ListUserPipelineReleases_FullMethodName                = "/vdp.pipeline.v1beta.PipelinePublicService/ListUserPipelineReleases"
	PipelinePublicService_GetUserPipelineRelease_FullMethodName                  = "/vdp.pipeline.v1beta.PipelinePublicService/GetUserPipelineRelease"
	PipelinePublicService_UpdateUserPipelineRelease_FullMethodName               = "/vdp.pipeline.v1beta.PipelinePublicService/UpdateUserPipelineRelease"
	PipelinePublicService_DeleteUserPipelineRelease_FullMethodName               = "/vdp.pipeline.v1beta.PipelinePublicService/DeleteUserPipelineRelease"
	PipelinePublicService_RestoreUserPipelineRelease_FullMethodName              = "/vdp.pipeline.v1beta.PipelinePublicService/RestoreUserPipelineRelease"
	PipelinePublicService_RenameUserPipelineRelease_FullMethodName               = "/vdp.pipeline.v1beta.PipelinePublicService/RenameUserPipelineRelease"
	PipelinePublicService_TriggerUserPipelineRelease_FullMethodName              = "/vdp.pipeline.v1beta.PipelinePublicService/TriggerUserPipelineRelease"
	PipelinePublicService_TriggerAsyncUserPipelineRelease_FullMethodName         = "/vdp.pipeline.v1beta.PipelinePublicService/TriggerAsyncUserPipelineRelease"
	PipelinePublicService_CreateOrganizationPipeline_FullMethodName              = "/vdp.pipeline.v1beta.PipelinePublicService/CreateOrganizationPipeline"
	PipelinePublicService_ListOrganizationPipelines_FullMethodName               = "/vdp.pipeline.v1beta.PipelinePublicService/ListOrganizationPipelines"
	PipelinePublicService_GetOrganizationPipeline_FullMethodName                 = "/vdp.pipeline.v1beta.PipelinePublicService/GetOrganizationPipeline"
	PipelinePublicService_UpdateOrganizationPipeline_FullMethodName              = "/vdp.pipeline.v1beta.PipelinePublicService/UpdateOrganizationPipeline"
	PipelinePublicService_DeleteOrganizationPipeline_FullMethodName              = "/vdp.pipeline.v1beta.PipelinePublicService/DeleteOrganizationPipeline"
	PipelinePublicService_ValidateOrganizationPipeline_FullMethodName            = "/vdp.pipeline.v1beta.PipelinePublicService/ValidateOrganizationPipeline"
	PipelinePublicService_RenameOrganizationPipeline_FullMethodName              = "/vdp.pipeline.v1beta.PipelinePublicService/RenameOrganizationPipeline"
	PipelinePublicService_CloneOrganizationPipeline_FullMethodName               = "/vdp.pipeline.v1beta.PipelinePublicService/CloneOrganizationPipeline"
	PipelinePublicService_TriggerOrganizationPipeline_FullMethodName             = "/vdp.pipeline.v1beta.PipelinePublicService/TriggerOrganizationPipeline"
	PipelinePublicService_TriggerAsyncOrganizationPipeline_FullMethodName        = "/vdp.pipeline.v1beta.PipelinePublicService/TriggerAsyncOrganizationPipeline"
	PipelinePublicService_CreateOrganizationPipelineRelease_FullMethodName       = "/vdp.pipeline.v1beta.PipelinePublicService/CreateOrganizationPipelineRelease"
	PipelinePublicService_ListOrganizationPipelineReleases_FullMethodName        = "/vdp.pipeline.v1beta.PipelinePublicService/ListOrganizationPipelineReleases"
	PipelinePublicService_GetOrganizationPipelineRelease_FullMethodName          = "/vdp.pipeline.v1beta.PipelinePublicService/GetOrganizationPipelineRelease"
	PipelinePublicService_UpdateOrganizationPipelineRelease_FullMethodName       = "/vdp.pipeline.v1beta.PipelinePublicService/UpdateOrganizationPipelineRelease"
	PipelinePublicService_DeleteOrganizationPipelineRelease_FullMethodName       = "/vdp.pipeline.v1beta.PipelinePublicService/DeleteOrganizationPipelineRelease"
	PipelinePublicService_RestoreOrganizationPipelineRelease_FullMethodName      = "/vdp.pipeline.v1beta.PipelinePublicService/RestoreOrganizationPipelineRelease"
	PipelinePublicService_RenameOrganizationPipelineRelease_FullMethodName       = "/vdp.pipeline.v1beta.PipelinePublicService/RenameOrganizationPipelineRelease"
	PipelinePublicService_TriggerOrganizationPipelineRelease_FullMethodName      = "/vdp.pipeline.v1beta.PipelinePublicService/TriggerOrganizationPipelineRelease"
	PipelinePublicService_TriggerAsyncOrganizationPipelineRelease_FullMethodName = "/vdp.pipeline.v1beta.PipelinePublicService/TriggerAsyncOrganizationPipelineRelease"
	PipelinePublicService_GetOperation_FullMethodName                            = "/vdp.pipeline.v1beta.PipelinePublicService/GetOperation"
	PipelinePublicService_ListConnectorDefinitions_FullMethodName                = "/vdp.pipeline.v1beta.PipelinePublicService/ListConnectorDefinitions"
	PipelinePublicService_GetConnectorDefinition_FullMethodName                  = "/vdp.pipeline.v1beta.PipelinePublicService/GetConnectorDefinition"
	PipelinePublicService_ListOperatorDefinitions_FullMethodName                 = "/vdp.pipeline.v1beta.PipelinePublicService/ListOperatorDefinitions"
	PipelinePublicService_ListComponentDefinitions_FullMethodName                = "/vdp.pipeline.v1beta.PipelinePublicService/ListComponentDefinitions"
	PipelinePublicService_GetOperatorDefinition_FullMethodName                   = "/vdp.pipeline.v1beta.PipelinePublicService/GetOperatorDefinition"
	PipelinePublicService_CheckName_FullMethodName                               = "/vdp.pipeline.v1beta.PipelinePublicService/CheckName"
	PipelinePublicService_CreateUserSecret_FullMethodName                        = "/vdp.pipeline.v1beta.PipelinePublicService/CreateUserSecret"
	PipelinePublicService_ListUserSecrets_FullMethodName                         = "/vdp.pipeline.v1beta.PipelinePublicService/ListUserSecrets"
	PipelinePublicService_GetUserSecret_FullMethodName                           = "/vdp.pipeline.v1beta.PipelinePublicService/GetUserSecret"
	PipelinePublicService_UpdateUserSecret_FullMethodName                        = "/vdp.pipeline.v1beta.PipelinePublicService/UpdateUserSecret"
	PipelinePublicService_DeleteUserSecret_FullMethodName                        = "/vdp.pipeline.v1beta.PipelinePublicService/DeleteUserSecret"
	PipelinePublicService_CreateOrganizationSecret_FullMethodName                = "/vdp.pipeline.v1beta.PipelinePublicService/CreateOrganizationSecret"
	PipelinePublicService_ListOrganizationSecrets_FullMethodName                 = "/vdp.pipeline.v1beta.PipelinePublicService/ListOrganizationSecrets"
	PipelinePublicService_GetOrganizationSecret_FullMethodName                   = "/vdp.pipeline.v1beta.PipelinePublicService/GetOrganizationSecret"
	PipelinePublicService_UpdateOrganizationSecret_FullMethodName                = "/vdp.pipeline.v1beta.PipelinePublicService/UpdateOrganizationSecret"
	PipelinePublicService_DeleteOrganizationSecret_FullMethodName                = "/vdp.pipeline.v1beta.PipelinePublicService/DeleteOrganizationSecret"
)

Variables

View Source
var (
	Role_name = map[int32]string{
		0: "ROLE_UNSPECIFIED",
		1: "ROLE_VIEWER",
		2: "ROLE_EXECUTOR",
	}
	Role_value = map[string]int32{
		"ROLE_UNSPECIFIED": 0,
		"ROLE_VIEWER":      1,
		"ROLE_EXECUTOR":    2,
	}
)

Enum value maps for Role.

View Source
var (
	ComponentType_name = map[int32]string{
		0: "COMPONENT_TYPE_UNSPECIFIED",
		1: "COMPONENT_TYPE_CONNECTOR_AI",
		2: "COMPONENT_TYPE_CONNECTOR_DATA",
		4: "COMPONENT_TYPE_OPERATOR",
		5: "COMPONENT_TYPE_CONNECTOR_APPLICATION",
	}
	ComponentType_value = map[string]int32{
		"COMPONENT_TYPE_UNSPECIFIED":           0,
		"COMPONENT_TYPE_CONNECTOR_AI":          1,
		"COMPONENT_TYPE_CONNECTOR_DATA":        2,
		"COMPONENT_TYPE_OPERATOR":              4,
		"COMPONENT_TYPE_CONNECTOR_APPLICATION": 5,
	}
)

Enum value maps for ComponentType.

View Source
var (
	CheckNameResponse_Name_name = map[int32]string{
		0: "NAME_UNSPECIFIED",
		1: "NAME_AVAILABLE",
		2: "NAME_UNAVAILABLE",
	}
	CheckNameResponse_Name_value = map[string]int32{
		"NAME_UNSPECIFIED": 0,
		"NAME_AVAILABLE":   1,
		"NAME_UNAVAILABLE": 2,
	}
)

Enum value maps for CheckNameResponse_Name.

View Source
var (
	ConnectorType_name = map[int32]string{
		0: "CONNECTOR_TYPE_UNSPECIFIED",
		3: "CONNECTOR_TYPE_AI",
		5: "CONNECTOR_TYPE_DATA",
		6: "CONNECTOR_TYPE_OPERATOR",
		7: "CONNECTOR_TYPE_APPLICATION",
	}
	ConnectorType_value = map[string]int32{
		"CONNECTOR_TYPE_UNSPECIFIED": 0,
		"CONNECTOR_TYPE_AI":          3,
		"CONNECTOR_TYPE_DATA":        5,
		"CONNECTOR_TYPE_OPERATOR":    6,
		"CONNECTOR_TYPE_APPLICATION": 7,
	}
)

Enum value maps for ConnectorType.

View Source
var (
	ComponentDefinition_View_name = map[int32]string{
		0: "VIEW_UNSPECIFIED",
		1: "VIEW_BASIC",
		2: "VIEW_FULL",
	}
	ComponentDefinition_View_value = map[string]int32{
		"VIEW_UNSPECIFIED": 0,
		"VIEW_BASIC":       1,
		"VIEW_FULL":        2,
	}
)

Enum value maps for ComponentDefinition_View.

View Source
var (
	ComponentDefinition_ReleaseStage_name = map[int32]string{
		0: "RELEASE_STAGE_UNSPECIFIED",
		1: "RELEASE_STAGE_OPEN_FOR_CONTRIBUTION",
		2: "RELEASE_STAGE_COMING_SOON",
		3: "RELEASE_STAGE_ALPHA",
		4: "RELEASE_STAGE_BETA",
		5: "RELEASE_STAGE_GA",
	}
	ComponentDefinition_ReleaseStage_value = map[string]int32{
		"RELEASE_STAGE_UNSPECIFIED":           0,
		"RELEASE_STAGE_OPEN_FOR_CONTRIBUTION": 1,
		"RELEASE_STAGE_COMING_SOON":           2,
		"RELEASE_STAGE_ALPHA":                 3,
		"RELEASE_STAGE_BETA":                  4,
		"RELEASE_STAGE_GA":                    5,
	}
)

Enum value maps for ComponentDefinition_ReleaseStage.

View Source
var (
	State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "STATE_INACTIVE",
		2: "STATE_ACTIVE",
		3: "STATE_ERROR",
	}
	State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"STATE_INACTIVE":    1,
		"STATE_ACTIVE":      2,
		"STATE_ERROR":       3,
	}
)

Enum value maps for State.

View Source
var (
	Pipeline_View_name = map[int32]string{
		0: "VIEW_UNSPECIFIED",
		1: "VIEW_BASIC",
		2: "VIEW_FULL",
		3: "VIEW_RECIPE",
	}
	Pipeline_View_value = map[string]int32{
		"VIEW_UNSPECIFIED": 0,
		"VIEW_BASIC":       1,
		"VIEW_FULL":        2,
		"VIEW_RECIPE":      3,
	}
)

Enum value maps for Pipeline_View.

View Source
var (
	Pipeline_Visibility_name = map[int32]string{
		0: "VISIBILITY_UNSPECIFIED",
		1: "VISIBILITY_PRIVATE",
		2: "VISIBILITY_PUBLIC",
	}
	Pipeline_Visibility_value = map[string]int32{
		"VISIBILITY_UNSPECIFIED": 0,
		"VISIBILITY_PRIVATE":     1,
		"VISIBILITY_PUBLIC":      2,
	}
)

Enum value maps for Pipeline_Visibility.

View Source
var (
	Trace_Status_name = map[int32]string{
		0: "STATUS_UNSPECIFIED",
		1: "STATUS_COMPLETED",
		2: "STATUS_SKIPPED",
		3: "STATUS_ERROR",
	}
	Trace_Status_value = map[string]int32{
		"STATUS_UNSPECIFIED": 0,
		"STATUS_COMPLETED":   1,
		"STATUS_SKIPPED":     2,
		"STATUS_ERROR":       3,
	}
)

Enum value maps for Trace_Status.

View Source
var File_vdp_pipeline_v1beta_common_proto protoreflect.FileDescriptor
View Source
var File_vdp_pipeline_v1beta_component_definition_proto protoreflect.FileDescriptor
View Source
var File_vdp_pipeline_v1beta_pipeline_private_service_proto protoreflect.FileDescriptor
View Source
var File_vdp_pipeline_v1beta_pipeline_proto protoreflect.FileDescriptor
View Source
var File_vdp_pipeline_v1beta_pipeline_public_service_proto protoreflect.FileDescriptor
View Source
var File_vdp_pipeline_v1beta_secret_proto protoreflect.FileDescriptor
View Source
var PipelinePrivateService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "vdp.pipeline.v1beta.PipelinePrivateService",
	HandlerType: (*PipelinePrivateServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListPipelinesAdmin",
			Handler:    _PipelinePrivateService_ListPipelinesAdmin_Handler,
		},
		{
			MethodName: "LookUpPipelineAdmin",
			Handler:    _PipelinePrivateService_LookUpPipelineAdmin_Handler,
		},
		{
			MethodName: "ListPipelineReleasesAdmin",
			Handler:    _PipelinePrivateService_ListPipelineReleasesAdmin_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "vdp/pipeline/v1beta/pipeline_private_service.proto",
}

PipelinePrivateService_ServiceDesc is the grpc.ServiceDesc for PipelinePrivateService 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 PipelinePublicService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "vdp.pipeline.v1beta.PipelinePublicService",
	HandlerType: (*PipelinePublicServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Liveness",
			Handler:    _PipelinePublicService_Liveness_Handler,
		},
		{
			MethodName: "Readiness",
			Handler:    _PipelinePublicService_Readiness_Handler,
		},
		{
			MethodName: "ListPipelines",
			Handler:    _PipelinePublicService_ListPipelines_Handler,
		},
		{
			MethodName: "LookUpPipeline",
			Handler:    _PipelinePublicService_LookUpPipeline_Handler,
		},
		{
			MethodName: "CreateUserPipeline",
			Handler:    _PipelinePublicService_CreateUserPipeline_Handler,
		},
		{
			MethodName: "ListUserPipelines",
			Handler:    _PipelinePublicService_ListUserPipelines_Handler,
		},
		{
			MethodName: "GetUserPipeline",
			Handler:    _PipelinePublicService_GetUserPipeline_Handler,
		},
		{
			MethodName: "UpdateUserPipeline",
			Handler:    _PipelinePublicService_UpdateUserPipeline_Handler,
		},
		{
			MethodName: "DeleteUserPipeline",
			Handler:    _PipelinePublicService_DeleteUserPipeline_Handler,
		},
		{
			MethodName: "ValidateUserPipeline",
			Handler:    _PipelinePublicService_ValidateUserPipeline_Handler,
		},
		{
			MethodName: "RenameUserPipeline",
			Handler:    _PipelinePublicService_RenameUserPipeline_Handler,
		},
		{
			MethodName: "CloneUserPipeline",
			Handler:    _PipelinePublicService_CloneUserPipeline_Handler,
		},
		{
			MethodName: "TriggerUserPipeline",
			Handler:    _PipelinePublicService_TriggerUserPipeline_Handler,
		},
		{
			MethodName: "TriggerAsyncUserPipeline",
			Handler:    _PipelinePublicService_TriggerAsyncUserPipeline_Handler,
		},
		{
			MethodName: "CreateUserPipelineRelease",
			Handler:    _PipelinePublicService_CreateUserPipelineRelease_Handler,
		},
		{
			MethodName: "ListUserPipelineReleases",
			Handler:    _PipelinePublicService_ListUserPipelineReleases_Handler,
		},
		{
			MethodName: "GetUserPipelineRelease",
			Handler:    _PipelinePublicService_GetUserPipelineRelease_Handler,
		},
		{
			MethodName: "UpdateUserPipelineRelease",
			Handler:    _PipelinePublicService_UpdateUserPipelineRelease_Handler,
		},
		{
			MethodName: "DeleteUserPipelineRelease",
			Handler:    _PipelinePublicService_DeleteUserPipelineRelease_Handler,
		},
		{
			MethodName: "RestoreUserPipelineRelease",
			Handler:    _PipelinePublicService_RestoreUserPipelineRelease_Handler,
		},
		{
			MethodName: "RenameUserPipelineRelease",
			Handler:    _PipelinePublicService_RenameUserPipelineRelease_Handler,
		},
		{
			MethodName: "TriggerUserPipelineRelease",
			Handler:    _PipelinePublicService_TriggerUserPipelineRelease_Handler,
		},
		{
			MethodName: "TriggerAsyncUserPipelineRelease",
			Handler:    _PipelinePublicService_TriggerAsyncUserPipelineRelease_Handler,
		},
		{
			MethodName: "CreateOrganizationPipeline",
			Handler:    _PipelinePublicService_CreateOrganizationPipeline_Handler,
		},
		{
			MethodName: "ListOrganizationPipelines",
			Handler:    _PipelinePublicService_ListOrganizationPipelines_Handler,
		},
		{
			MethodName: "GetOrganizationPipeline",
			Handler:    _PipelinePublicService_GetOrganizationPipeline_Handler,
		},
		{
			MethodName: "UpdateOrganizationPipeline",
			Handler:    _PipelinePublicService_UpdateOrganizationPipeline_Handler,
		},
		{
			MethodName: "DeleteOrganizationPipeline",
			Handler:    _PipelinePublicService_DeleteOrganizationPipeline_Handler,
		},
		{
			MethodName: "ValidateOrganizationPipeline",
			Handler:    _PipelinePublicService_ValidateOrganizationPipeline_Handler,
		},
		{
			MethodName: "RenameOrganizationPipeline",
			Handler:    _PipelinePublicService_RenameOrganizationPipeline_Handler,
		},
		{
			MethodName: "CloneOrganizationPipeline",
			Handler:    _PipelinePublicService_CloneOrganizationPipeline_Handler,
		},
		{
			MethodName: "TriggerOrganizationPipeline",
			Handler:    _PipelinePublicService_TriggerOrganizationPipeline_Handler,
		},
		{
			MethodName: "TriggerAsyncOrganizationPipeline",
			Handler:    _PipelinePublicService_TriggerAsyncOrganizationPipeline_Handler,
		},
		{
			MethodName: "CreateOrganizationPipelineRelease",
			Handler:    _PipelinePublicService_CreateOrganizationPipelineRelease_Handler,
		},
		{
			MethodName: "ListOrganizationPipelineReleases",
			Handler:    _PipelinePublicService_ListOrganizationPipelineReleases_Handler,
		},
		{
			MethodName: "GetOrganizationPipelineRelease",
			Handler:    _PipelinePublicService_GetOrganizationPipelineRelease_Handler,
		},
		{
			MethodName: "UpdateOrganizationPipelineRelease",
			Handler:    _PipelinePublicService_UpdateOrganizationPipelineRelease_Handler,
		},
		{
			MethodName: "DeleteOrganizationPipelineRelease",
			Handler:    _PipelinePublicService_DeleteOrganizationPipelineRelease_Handler,
		},
		{
			MethodName: "RestoreOrganizationPipelineRelease",
			Handler:    _PipelinePublicService_RestoreOrganizationPipelineRelease_Handler,
		},
		{
			MethodName: "RenameOrganizationPipelineRelease",
			Handler:    _PipelinePublicService_RenameOrganizationPipelineRelease_Handler,
		},
		{
			MethodName: "TriggerOrganizationPipelineRelease",
			Handler:    _PipelinePublicService_TriggerOrganizationPipelineRelease_Handler,
		},
		{
			MethodName: "TriggerAsyncOrganizationPipelineRelease",
			Handler:    _PipelinePublicService_TriggerAsyncOrganizationPipelineRelease_Handler,
		},
		{
			MethodName: "GetOperation",
			Handler:    _PipelinePublicService_GetOperation_Handler,
		},
		{
			MethodName: "ListConnectorDefinitions",
			Handler:    _PipelinePublicService_ListConnectorDefinitions_Handler,
		},
		{
			MethodName: "GetConnectorDefinition",
			Handler:    _PipelinePublicService_GetConnectorDefinition_Handler,
		},
		{
			MethodName: "ListOperatorDefinitions",
			Handler:    _PipelinePublicService_ListOperatorDefinitions_Handler,
		},
		{
			MethodName: "ListComponentDefinitions",
			Handler:    _PipelinePublicService_ListComponentDefinitions_Handler,
		},
		{
			MethodName: "GetOperatorDefinition",
			Handler:    _PipelinePublicService_GetOperatorDefinition_Handler,
		},
		{
			MethodName: "CheckName",
			Handler:    _PipelinePublicService_CheckName_Handler,
		},
		{
			MethodName: "CreateUserSecret",
			Handler:    _PipelinePublicService_CreateUserSecret_Handler,
		},
		{
			MethodName: "ListUserSecrets",
			Handler:    _PipelinePublicService_ListUserSecrets_Handler,
		},
		{
			MethodName: "GetUserSecret",
			Handler:    _PipelinePublicService_GetUserSecret_Handler,
		},
		{
			MethodName: "UpdateUserSecret",
			Handler:    _PipelinePublicService_UpdateUserSecret_Handler,
		},
		{
			MethodName: "DeleteUserSecret",
			Handler:    _PipelinePublicService_DeleteUserSecret_Handler,
		},
		{
			MethodName: "CreateOrganizationSecret",
			Handler:    _PipelinePublicService_CreateOrganizationSecret_Handler,
		},
		{
			MethodName: "ListOrganizationSecrets",
			Handler:    _PipelinePublicService_ListOrganizationSecrets_Handler,
		},
		{
			MethodName: "GetOrganizationSecret",
			Handler:    _PipelinePublicService_GetOrganizationSecret_Handler,
		},
		{
			MethodName: "UpdateOrganizationSecret",
			Handler:    _PipelinePublicService_UpdateOrganizationSecret_Handler,
		},
		{
			MethodName: "DeleteOrganizationSecret",
			Handler:    _PipelinePublicService_DeleteOrganizationSecret_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "vdp/pipeline/v1beta/pipeline_public_service.proto",
}

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

Functions

func RegisterPipelinePrivateServiceHandler

func RegisterPipelinePrivateServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterPipelinePrivateServiceHandler registers the http handlers for service PipelinePrivateService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterPipelinePrivateServiceHandlerClient

func RegisterPipelinePrivateServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client PipelinePrivateServiceClient) error

RegisterPipelinePrivateServiceHandlerClient registers the http handlers for service PipelinePrivateService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "PipelinePrivateServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "PipelinePrivateServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "PipelinePrivateServiceClient" to call the correct interceptors.

func RegisterPipelinePrivateServiceHandlerFromEndpoint

func RegisterPipelinePrivateServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterPipelinePrivateServiceHandlerFromEndpoint is same as RegisterPipelinePrivateServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterPipelinePrivateServiceHandlerServer

func RegisterPipelinePrivateServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server PipelinePrivateServiceServer) error

RegisterPipelinePrivateServiceHandlerServer registers the http handlers for service PipelinePrivateService to "mux". UnaryRPC :call PipelinePrivateServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterPipelinePrivateServiceHandlerFromEndpoint instead.

func RegisterPipelinePrivateServiceServer

func RegisterPipelinePrivateServiceServer(s grpc.ServiceRegistrar, srv PipelinePrivateServiceServer)

func RegisterPipelinePublicServiceHandler

func RegisterPipelinePublicServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterPipelinePublicServiceHandler registers the http handlers for service PipelinePublicService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterPipelinePublicServiceHandlerClient

func RegisterPipelinePublicServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client PipelinePublicServiceClient) error

RegisterPipelinePublicServiceHandlerClient registers the http handlers for service PipelinePublicService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "PipelinePublicServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "PipelinePublicServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "PipelinePublicServiceClient" to call the correct interceptors.

func RegisterPipelinePublicServiceHandlerFromEndpoint

func RegisterPipelinePublicServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterPipelinePublicServiceHandlerFromEndpoint is same as RegisterPipelinePublicServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterPipelinePublicServiceHandlerServer

func RegisterPipelinePublicServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server PipelinePublicServiceServer) error

RegisterPipelinePublicServiceHandlerServer registers the http handlers for service PipelinePublicService to "mux". UnaryRPC :call PipelinePublicServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterPipelinePublicServiceHandlerFromEndpoint instead.

func RegisterPipelinePublicServiceServer

func RegisterPipelinePublicServiceServer(s grpc.ServiceRegistrar, srv PipelinePublicServiceServer)

Types

type CheckNameRequest

type CheckNameRequest struct {

	// The name of the resource to be checked. For the moment, only pipeline and
	// connector names can be checked. The following formats are accepted:
	// - `users/{user.id}/pipelines/{pipeline.id}`
	// - `users/{user.id}/connectors/{connector.id}`
	// - `organizations/{organization.id}/pipelines/{pipeline.id}`
	// - `organizations/{organization.id}/connectors/{connector.id}`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

CheckNameRequest represents a request to verify if a name is available.

func (*CheckNameRequest) Descriptor deprecated

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

Deprecated: Use CheckNameRequest.ProtoReflect.Descriptor instead.

func (*CheckNameRequest) GetName

func (x *CheckNameRequest) GetName() string

func (*CheckNameRequest) ProtoMessage

func (*CheckNameRequest) ProtoMessage()

func (*CheckNameRequest) ProtoReflect

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

func (*CheckNameRequest) Reset

func (x *CheckNameRequest) Reset()

func (*CheckNameRequest) String

func (x *CheckNameRequest) String() string

type CheckNameResponse

type CheckNameResponse struct {

	// The availability of the requested name.
	Availability CheckNameResponse_Name `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

CheckNameResponse contains the availability of a resource name.

func (*CheckNameResponse) Descriptor deprecated

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

Deprecated: Use CheckNameResponse.ProtoReflect.Descriptor instead.

func (*CheckNameResponse) GetAvailability

func (x *CheckNameResponse) GetAvailability() CheckNameResponse_Name

func (*CheckNameResponse) ProtoMessage

func (*CheckNameResponse) ProtoMessage()

func (*CheckNameResponse) ProtoReflect

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

func (*CheckNameResponse) Reset

func (x *CheckNameResponse) Reset()

func (*CheckNameResponse) String

func (x *CheckNameResponse) String() string

type CheckNameResponse_Name

type CheckNameResponse_Name int32

Name defines the availability of a resource name.

const (
	// Unspecified.
	CheckNameResponse_NAME_UNSPECIFIED CheckNameResponse_Name = 0
	// Available.
	CheckNameResponse_NAME_AVAILABLE CheckNameResponse_Name = 1
	// Unavailable.
	CheckNameResponse_NAME_UNAVAILABLE CheckNameResponse_Name = 2
)

func (CheckNameResponse_Name) Descriptor

func (CheckNameResponse_Name) Enum

func (CheckNameResponse_Name) EnumDescriptor deprecated

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

Deprecated: Use CheckNameResponse_Name.Descriptor instead.

func (CheckNameResponse_Name) Number

func (CheckNameResponse_Name) String

func (x CheckNameResponse_Name) String() string

func (CheckNameResponse_Name) Type

type CloneOrganizationPipelineRequest

type CloneOrganizationPipelineRequest struct {

	// The resource name of the pipeline, which allows its access by parent
	// organization and ID.
	// - Format: `organizations/{organization.id}/pipelines/{pipeline.id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The target pipeline name. It can be under a user or an organization
	// namespace, so the following formats are accepted:
	// - `users/{user.id}/pipelines/{pipeline.id}`
	// - `organizations/{organization.id}/pipelines/{pipeline.id}`
	Target string `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	// contains filtered or unexported fields
}

CloneOrganizationPipelineRequest represents a request to clone a pipeline owned by an organization.

func (*CloneOrganizationPipelineRequest) Descriptor deprecated

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

Deprecated: Use CloneOrganizationPipelineRequest.ProtoReflect.Descriptor instead.

func (*CloneOrganizationPipelineRequest) GetName

func (*CloneOrganizationPipelineRequest) GetTarget

func (*CloneOrganizationPipelineRequest) ProtoMessage

func (*CloneOrganizationPipelineRequest) ProtoMessage()

func (*CloneOrganizationPipelineRequest) ProtoReflect

func (*CloneOrganizationPipelineRequest) Reset

func (*CloneOrganizationPipelineRequest) String

type CloneOrganizationPipelineResponse

type CloneOrganizationPipelineResponse struct {

	// The cloned pipeline resource.
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// contains filtered or unexported fields
}

CloneOrganizationPipelineResponse contains a cloned pipeline.

func (*CloneOrganizationPipelineResponse) Descriptor deprecated

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

Deprecated: Use CloneOrganizationPipelineResponse.ProtoReflect.Descriptor instead.

func (*CloneOrganizationPipelineResponse) GetPipeline

func (x *CloneOrganizationPipelineResponse) GetPipeline() *Pipeline

func (*CloneOrganizationPipelineResponse) ProtoMessage

func (*CloneOrganizationPipelineResponse) ProtoMessage()

func (*CloneOrganizationPipelineResponse) ProtoReflect

func (*CloneOrganizationPipelineResponse) Reset

func (*CloneOrganizationPipelineResponse) String

type CloneUserPipelineRequest

type CloneUserPipelineRequest struct {

	// The resource name of the pipeline, which allows its access by parent user
	// and ID.
	// - Format: `users/{user.id}/pipelines/{pipeline.id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The target pipeline name. It can be under a user or an organization
	// namespace, so the following formats are accepted:
	// - `users/{user.id}/pipelines/{pipeline.id}`
	// - `organizations/{organization.id}/pipelines/{pipeline.id}`
	Target string `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	// contains filtered or unexported fields
}

CloneUserPipelineRequest represents a request to clone a pipeline owned by a user.

func (*CloneUserPipelineRequest) Descriptor deprecated

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

Deprecated: Use CloneUserPipelineRequest.ProtoReflect.Descriptor instead.

func (*CloneUserPipelineRequest) GetName

func (x *CloneUserPipelineRequest) GetName() string

func (*CloneUserPipelineRequest) GetTarget

func (x *CloneUserPipelineRequest) GetTarget() string

func (*CloneUserPipelineRequest) ProtoMessage

func (*CloneUserPipelineRequest) ProtoMessage()

func (*CloneUserPipelineRequest) ProtoReflect

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

func (*CloneUserPipelineRequest) Reset

func (x *CloneUserPipelineRequest) Reset()

func (*CloneUserPipelineRequest) String

func (x *CloneUserPipelineRequest) String() string

type CloneUserPipelineResponse

type CloneUserPipelineResponse struct {

	// The cloned pipeline resource.
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// contains filtered or unexported fields
}

CloneUserPipelineResponse contains a cloned pipeline.

func (*CloneUserPipelineResponse) Descriptor deprecated

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

Deprecated: Use CloneUserPipelineResponse.ProtoReflect.Descriptor instead.

func (*CloneUserPipelineResponse) GetPipeline

func (x *CloneUserPipelineResponse) GetPipeline() *Pipeline

func (*CloneUserPipelineResponse) ProtoMessage

func (*CloneUserPipelineResponse) ProtoMessage()

func (*CloneUserPipelineResponse) ProtoReflect

func (*CloneUserPipelineResponse) Reset

func (x *CloneUserPipelineResponse) Reset()

func (*CloneUserPipelineResponse) String

func (x *CloneUserPipelineResponse) String() string

type Component

type Component struct {

	// Component ID, provided by the user on creation.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Metadata of the component.
	Metadata *structpb.Struct `protobuf:"bytes,10,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// The component configuration.
	//
	// Types that are assignable to Component:
	//
	//	*Component_ConnectorComponent
	//	*Component_OperatorComponent
	//	*Component_IteratorComponent
	Component isComponent_Component `protobuf_oneof:"component"`
	// contains filtered or unexported fields
}

Component Fundamental building block in pipelines.

For more information, see [Pipeline Component](https://www.instill.tech/docs/latest/core/concepts/pipeline#pipeline-component)

func (*Component) Descriptor deprecated

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

Deprecated: Use Component.ProtoReflect.Descriptor instead.

func (*Component) GetComponent

func (m *Component) GetComponent() isComponent_Component

func (*Component) GetConnectorComponent

func (x *Component) GetConnectorComponent() *ConnectorComponent

func (*Component) GetId

func (x *Component) GetId() string

func (*Component) GetIteratorComponent

func (x *Component) GetIteratorComponent() *IteratorComponent

func (*Component) GetMetadata

func (x *Component) GetMetadata() *structpb.Struct

func (*Component) GetOperatorComponent

func (x *Component) GetOperatorComponent() *OperatorComponent

func (*Component) ProtoMessage

func (*Component) ProtoMessage()

func (*Component) ProtoReflect

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

func (*Component) Reset

func (x *Component) Reset()

func (*Component) String

func (x *Component) String() string

type ComponentDefinition

type ComponentDefinition struct {

	// Defines the type of task the component will perform.
	Type ComponentType `protobuf:"varint,1,opt,name=type,proto3,enum=vdp.pipeline.v1beta.ComponentType" json:"type,omitempty"`
	// The component definition details.
	//
	// Types that are assignable to Definition:
	//
	//	*ComponentDefinition_OperatorDefinition
	//	*ComponentDefinition_ConnectorDefinition
	Definition isComponentDefinition_Definition `protobuf_oneof:"definition"`
	// contains filtered or unexported fields
}

ComponentDefinition describes a certain type of Component.

func (*ComponentDefinition) Descriptor deprecated

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

Deprecated: Use ComponentDefinition.ProtoReflect.Descriptor instead.

func (*ComponentDefinition) GetConnectorDefinition

func (x *ComponentDefinition) GetConnectorDefinition() *ConnectorDefinition

func (*ComponentDefinition) GetDefinition

func (m *ComponentDefinition) GetDefinition() isComponentDefinition_Definition

func (*ComponentDefinition) GetOperatorDefinition

func (x *ComponentDefinition) GetOperatorDefinition() *OperatorDefinition

func (*ComponentDefinition) GetType

func (x *ComponentDefinition) GetType() ComponentType

func (*ComponentDefinition) ProtoMessage

func (*ComponentDefinition) ProtoMessage()

func (*ComponentDefinition) ProtoReflect

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

func (*ComponentDefinition) Reset

func (x *ComponentDefinition) Reset()

func (*ComponentDefinition) String

func (x *ComponentDefinition) String() string

type ComponentDefinition_ConnectorDefinition

type ComponentDefinition_ConnectorDefinition struct {
	// connector definition detail
	ConnectorDefinition *ConnectorDefinition `protobuf:"bytes,3,opt,name=connector_definition,json=connectorDefinition,proto3,oneof"`
}

type ComponentDefinition_OperatorDefinition

type ComponentDefinition_OperatorDefinition struct {
	// operator definition detail
	OperatorDefinition *OperatorDefinition `protobuf:"bytes,2,opt,name=operator_definition,json=operatorDefinition,proto3,oneof"`
}

type ComponentDefinition_ReleaseStage

type ComponentDefinition_ReleaseStage int32

ReleaseStage defines the release stage of a component. This is used to group components with the same pre-relase groups (e.g. `0.1.0-beta`, `0.1.0-beta.1` -> `RELEASE_STAGE_BETA`) and to include other "in progress" (i.e. coming soon, open for contributions) stages that may not be relevant within semantic versioning. See the documentation of each value for potential constraints between `version` and `release_stage` fields.`

const (
	// Unspecified.
	ComponentDefinition_RELEASE_STAGE_UNSPECIFIED ComponentDefinition_ReleaseStage = 0
	// This component is unimplemented and community contributions are welcome
	// for this component.
	//
	// It is recommended that the major and minor versions for definitions at
	// this release stage is kept at 0, e.g., `0.0.1`, `0.0.4`, etc.
	ComponentDefinition_RELEASE_STAGE_OPEN_FOR_CONTRIBUTION ComponentDefinition_ReleaseStage = 1
	// The implementation of this component is planned and will be tackled by
	// the Instill AI team.
	//
	// It is recommended that the major and minor versions for definitions at
	// this release stage is kept at 0, e.g., `0.0.1`, `0.0.4`, etc.
	ComponentDefinition_RELEASE_STAGE_COMING_SOON ComponentDefinition_ReleaseStage = 2
	// Initial implementation intended to gather feedback and issues from early
	// adopters. Alpha releases are discouraged for production use cases.
	//
	// The `version` field in the definition must have `alpha` as its first
	// pre-release identifier, e.g., `0.1.0-alpha`, `0.1.3-alpha.1`.
	ComponentDefinition_RELEASE_STAGE_ALPHA ComponentDefinition_ReleaseStage = 3
	// The connector has reached stability and no backwards incompatible
	// changes are expected. Before reaching general availability, it should be
	// validated by a broader group of users. Some fixes might be added during
	// this process.
	//
	// The `version` field in the definition must have `beta` as its first
	// pre-release identifier, e.g., `0.1.0-beta`, `0.1.3-beta.1`.
	ComponentDefinition_RELEASE_STAGE_BETA ComponentDefinition_ReleaseStage = 4
	// Generally available - ready for use in production and fully supported by
	// Instill AI.
	ComponentDefinition_RELEASE_STAGE_GA ComponentDefinition_ReleaseStage = 5
)

func (ComponentDefinition_ReleaseStage) Descriptor

func (ComponentDefinition_ReleaseStage) Enum

func (ComponentDefinition_ReleaseStage) EnumDescriptor deprecated

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

Deprecated: Use ComponentDefinition_ReleaseStage.Descriptor instead.

func (ComponentDefinition_ReleaseStage) Number

func (ComponentDefinition_ReleaseStage) String

func (ComponentDefinition_ReleaseStage) Type

type ComponentDefinition_View

type ComponentDefinition_View int32

View defines how a component definition is presented.

const (
	// Unspecified, equivalent to BASIC.
	ComponentDefinition_VIEW_UNSPECIFIED ComponentDefinition_View = 0
	// Default view, only includes basic information (removes the `spec`
	// field).
	ComponentDefinition_VIEW_BASIC ComponentDefinition_View = 1
	// Full representation.
	ComponentDefinition_VIEW_FULL ComponentDefinition_View = 2
)

func (ComponentDefinition_View) Descriptor

func (ComponentDefinition_View) Enum

func (ComponentDefinition_View) EnumDescriptor deprecated

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

Deprecated: Use ComponentDefinition_View.Descriptor instead.

func (ComponentDefinition_View) Number

func (ComponentDefinition_View) String

func (x ComponentDefinition_View) String() string

func (ComponentDefinition_View) Type

type ComponentTask

type ComponentTask struct {

	// The task name, e.g. `TASK_TEXT_GENERATION`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Title is the task name in a human-friendly format.
	Title string `protobuf:"bytes,2,opt,name=title,proto3" json:"title,omitempty"`
	// Description contains information about the task.
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

ComponentTask contains information about a task that a component can perform.

func (*ComponentTask) Descriptor deprecated

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

Deprecated: Use ComponentTask.ProtoReflect.Descriptor instead.

func (*ComponentTask) GetDescription

func (x *ComponentTask) GetDescription() string

func (*ComponentTask) GetName

func (x *ComponentTask) GetName() string

func (*ComponentTask) GetTitle

func (x *ComponentTask) GetTitle() string

func (*ComponentTask) ProtoMessage

func (*ComponentTask) ProtoMessage()

func (*ComponentTask) ProtoReflect

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

func (*ComponentTask) Reset

func (x *ComponentTask) Reset()

func (*ComponentTask) String

func (x *ComponentTask) String() string

type ComponentType

type ComponentType int32

ComponentType defines the component type based on its task features.

const (
	// Unspecified.
	ComponentType_COMPONENT_TYPE_UNSPECIFIED ComponentType = 0
	// Connect with an AI model.
	ComponentType_COMPONENT_TYPE_CONNECTOR_AI ComponentType = 1
	// Connect with a remote data source.
	ComponentType_COMPONENT_TYPE_CONNECTOR_DATA ComponentType = 2
	// Manipulate data.
	ComponentType_COMPONENT_TYPE_OPERATOR ComponentType = 4
	// Connect with an external application.
	ComponentType_COMPONENT_TYPE_CONNECTOR_APPLICATION ComponentType = 5
)

func (ComponentType) Descriptor

func (ComponentType) Enum

func (x ComponentType) Enum() *ComponentType

func (ComponentType) EnumDescriptor deprecated

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

Deprecated: Use ComponentType.Descriptor instead.

func (ComponentType) Number

func (ComponentType) String

func (x ComponentType) String() string

func (ComponentType) Type

type Component_ConnectorComponent

type Component_ConnectorComponent struct {
	// ConnectorComponent
	ConnectorComponent *ConnectorComponent `protobuf:"bytes,13,opt,name=connector_component,json=connectorComponent,proto3,oneof"`
}

type Component_IteratorComponent

type Component_IteratorComponent struct {
	// IteratorComponent
	IteratorComponent *IteratorComponent `protobuf:"bytes,15,opt,name=iterator_component,json=iteratorComponent,proto3,oneof"`
}

type Component_OperatorComponent

type Component_OperatorComponent struct {
	// OperatorComponent
	OperatorComponent *OperatorComponent `protobuf:"bytes,14,opt,name=operator_component,json=operatorComponent,proto3,oneof"`
}

type ConnectorComponent

type ConnectorComponent struct {

	// Definition name.
	DefinitionName string `protobuf:"bytes,1,opt,name=definition_name,json=definitionName,proto3" json:"definition_name,omitempty"`
	// Connector definition.
	Definition *ConnectorDefinition `protobuf:"bytes,2,opt,name=definition,proto3" json:"definition,omitempty"`
	// Task.
	Task string `protobuf:"bytes,5,opt,name=task,proto3" json:"task,omitempty"`
	// Input configuration of the component. JSON schema described in the connector definition.
	Input *structpb.Struct `protobuf:"bytes,6,opt,name=input,proto3" json:"input,omitempty"`
	// Condition statement determining whether the component is executed or not.
	Condition string `protobuf:"bytes,7,opt,name=condition,proto3" json:"condition,omitempty"`
	// Connection configuration of the component. JSON schema described in the connector definition.
	Connection *structpb.Struct `protobuf:"bytes,8,opt,name=connection,proto3" json:"connection,omitempty"`
	// contains filtered or unexported fields
}

ConnectorComponent Configures a connector component. Requires the creation of a connector resource first.

func (*ConnectorComponent) Descriptor deprecated

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

Deprecated: Use ConnectorComponent.ProtoReflect.Descriptor instead.

func (*ConnectorComponent) GetCondition

func (x *ConnectorComponent) GetCondition() string

func (*ConnectorComponent) GetConnection

func (x *ConnectorComponent) GetConnection() *structpb.Struct

func (*ConnectorComponent) GetDefinition

func (x *ConnectorComponent) GetDefinition() *ConnectorDefinition

func (*ConnectorComponent) GetDefinitionName

func (x *ConnectorComponent) GetDefinitionName() string

func (*ConnectorComponent) GetInput

func (x *ConnectorComponent) GetInput() *structpb.Struct

func (*ConnectorComponent) GetTask

func (x *ConnectorComponent) GetTask() string

func (*ConnectorComponent) ProtoMessage

func (*ConnectorComponent) ProtoMessage()

func (*ConnectorComponent) ProtoReflect

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

func (*ConnectorComponent) Reset

func (x *ConnectorComponent) Reset()

func (*ConnectorComponent) String

func (x *ConnectorComponent) String() string

type ConnectorDefinition

type ConnectorDefinition struct {

	// The name of the connector definition, defined by its ID.
	// - Format: `connector-definitions/{id}
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Connector definition UUID.
	Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
	// Connector definition resource ID (used in `name` as the last segment). This
	// conforms to RFC-1034, which restricts to letters, numbers, and hyphen,
	// with the first character a letter, the last a letter or a number, and a 63
	// character maximum.
	Id string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	// Connector definition title.
	Title string `protobuf:"bytes,4,opt,name=title,proto3" json:"title,omitempty"`
	// Connector definition documentation URL.
	DocumentationUrl string `protobuf:"bytes,5,opt,name=documentation_url,json=documentationUrl,proto3" json:"documentation_url,omitempty"`
	// Connector definition icon. This is a path that's relative to the root of
	// the connector implementation (see `source_url`) and that allows clients
	// frontend applications to pull and locate the icons.
	Icon string `protobuf:"bytes,6,opt,name=icon,proto3" json:"icon,omitempty"`
	// Connector definition specification.
	Spec *ConnectorSpec `protobuf:"bytes,7,opt,name=spec,proto3" json:"spec,omitempty"`
	// Connector definition type.
	Type ConnectorType `protobuf:"varint,8,opt,name=type,proto3,enum=vdp.pipeline.v1beta.ConnectorType" json:"type,omitempty"`
	// Connector definition tombstone. If true, this configuration is permanently
	// off. Otherwise, the configuration is active.
	Tombstone bool `protobuf:"varint,9,opt,name=tombstone,proto3" json:"tombstone,omitempty"`
	// The public flag determines whether this connector definition is available
	// to all workspaces.
	Public bool `protobuf:"varint,10,opt,name=public,proto3" json:"public,omitempty"`
	// Connector definition custom flag, i.e., whether this is a custom
	// connector definition.
	Custom bool `protobuf:"varint,11,opt,name=custom,proto3" json:"custom,omitempty"`
	// Connector definition vendor name.
	Vendor string `protobuf:"bytes,13,opt,name=vendor,proto3" json:"vendor,omitempty"`
	// Vendor-specific attributes.
	VendorAttributes *structpb.Struct `protobuf:"bytes,14,opt,name=vendor_attributes,json=vendorAttributes,proto3" json:"vendor_attributes,omitempty"`
	// Source code URL. This points to the source code where the connector is
	// implemented.
	SourceUrl string `protobuf:"bytes,15,opt,name=source_url,json=sourceUrl,proto3" json:"source_url,omitempty"`
	// Connector definition version. This is a string that fulfills the SemVer
	// specification (e.g. `1.0.0-beta`).
	Version string `protobuf:"bytes,16,opt,name=version,proto3" json:"version,omitempty"`
	// List of tasks that can be executed by the connector.
	Tasks []*ComponentTask `protobuf:"bytes,17,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// Short description of the connector.
	Description string `protobuf:"bytes,18,opt,name=description,proto3" json:"description,omitempty"`
	// Release stage.
	ReleaseStage ComponentDefinition_ReleaseStage `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

A Connector is a type of pipeline component that queries, processes or sends the ingested unstructured data to a service or app. Users need to configure their connectors (e.g. by providing an API token to a remote service). A ConnectorDefinition describes a certain type of Connector.

For more information, see Component(https://www.instill.tech/docs/latest/core/concepts/pipeline#pipeline-component) in the official documentation.

func (*ConnectorDefinition) Descriptor deprecated

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

Deprecated: Use ConnectorDefinition.ProtoReflect.Descriptor instead.

func (*ConnectorDefinition) GetCustom

func (x *ConnectorDefinition) GetCustom() bool

func (*ConnectorDefinition) GetDescription

func (x *ConnectorDefinition) GetDescription() string

func (*ConnectorDefinition) GetDocumentationUrl

func (x *ConnectorDefinition) GetDocumentationUrl() string

func (*ConnectorDefinition) GetIcon

func (x *ConnectorDefinition) GetIcon() string

func (*ConnectorDefinition) GetId

func (x *ConnectorDefinition) GetId() string

func (*ConnectorDefinition) GetName

func (x *ConnectorDefinition) GetName() string

func (*ConnectorDefinition) GetPublic

func (x *ConnectorDefinition) GetPublic() bool

func (*ConnectorDefinition) GetReleaseStage

func (*ConnectorDefinition) GetSourceUrl

func (x *ConnectorDefinition) GetSourceUrl() string

func (*ConnectorDefinition) GetSpec

func (x *ConnectorDefinition) GetSpec() *ConnectorSpec

func (*ConnectorDefinition) GetTasks

func (x *ConnectorDefinition) GetTasks() []*ComponentTask

func (*ConnectorDefinition) GetTitle

func (x *ConnectorDefinition) GetTitle() string

func (*ConnectorDefinition) GetTombstone

func (x *ConnectorDefinition) GetTombstone() bool

func (*ConnectorDefinition) GetType

func (x *ConnectorDefinition) GetType() ConnectorType

func (*ConnectorDefinition) GetUid

func (x *ConnectorDefinition) GetUid() string

func (*ConnectorDefinition) GetVendor

func (x *ConnectorDefinition) GetVendor() string

func (*ConnectorDefinition) GetVendorAttributes

func (x *ConnectorDefinition) GetVendorAttributes() *structpb.Struct

func (*ConnectorDefinition) GetVersion

func (x *ConnectorDefinition) GetVersion() string

func (*ConnectorDefinition) ProtoMessage

func (*ConnectorDefinition) ProtoMessage()

func (*ConnectorDefinition) ProtoReflect

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

func (*ConnectorDefinition) Reset

func (x *ConnectorDefinition) Reset()

func (*ConnectorDefinition) String

func (x *ConnectorDefinition) String() string

type ConnectorSpec

type ConnectorSpec struct {

	// Component specification.
	ComponentSpecification *structpb.Struct `` /* 127-byte string literal not displayed */
	// Data specifications.
	// The key represents the task, and the value is the corresponding data_specification.
	DataSpecifications map[string]*DataSpecification `` /* 203-byte string literal not displayed */
	// contains filtered or unexported fields
}

ConnectorSpec represents a specification data model.

func (*ConnectorSpec) Descriptor deprecated

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

Deprecated: Use ConnectorSpec.ProtoReflect.Descriptor instead.

func (*ConnectorSpec) GetComponentSpecification

func (x *ConnectorSpec) GetComponentSpecification() *structpb.Struct

func (*ConnectorSpec) GetDataSpecifications

func (x *ConnectorSpec) GetDataSpecifications() map[string]*DataSpecification

func (*ConnectorSpec) ProtoMessage

func (*ConnectorSpec) ProtoMessage()

func (*ConnectorSpec) ProtoReflect

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

func (*ConnectorSpec) Reset

func (x *ConnectorSpec) Reset()

func (*ConnectorSpec) String

func (x *ConnectorSpec) String() string

type ConnectorType

type ConnectorType int32

ConnectorType defines the connector type based on its task features.

const (
	// Unspecified.
	ConnectorType_CONNECTOR_TYPE_UNSPECIFIED ConnectorType = 0
	// AI connector.
	ConnectorType_CONNECTOR_TYPE_AI ConnectorType = 3
	// Data connector.
	ConnectorType_CONNECTOR_TYPE_DATA ConnectorType = 5
	// Operator connector.
	ConnectorType_CONNECTOR_TYPE_OPERATOR ConnectorType = 6
	// Application connector.
	ConnectorType_CONNECTOR_TYPE_APPLICATION ConnectorType = 7
)

func (ConnectorType) Descriptor

func (ConnectorType) Enum

func (x ConnectorType) Enum() *ConnectorType

func (ConnectorType) EnumDescriptor deprecated

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

Deprecated: Use ConnectorType.Descriptor instead.

func (ConnectorType) Number

func (ConnectorType) String

func (x ConnectorType) String() string

func (ConnectorType) Type

type CreateOrganizationPipelineReleaseRequest

type CreateOrganizationPipelineReleaseRequest struct {

	// The release information.
	Release *PipelineRelease `protobuf:"bytes,1,opt,name=release,proto3" json:"release,omitempty"`
	// Name of the pipeline for which the release will be created.
	// Format: `organizations/{organization.id}/pipelines/{pipeline.id}`
	Parent string `protobuf:"bytes,2,opt,name=parent,proto3" json:"parent,omitempty"`
	// contains filtered or unexported fields
}

CreateOrganizationPipelineReleaseRequest represents a request to release a version in an organization-owned pipeline.

func (*CreateOrganizationPipelineReleaseRequest) Descriptor deprecated

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

Deprecated: Use CreateOrganizationPipelineReleaseRequest.ProtoReflect.Descriptor instead.

func (*CreateOrganizationPipelineReleaseRequest) GetParent

func (*CreateOrganizationPipelineReleaseRequest) GetRelease

func (*CreateOrganizationPipelineReleaseRequest) ProtoMessage

func (*CreateOrganizationPipelineReleaseRequest) ProtoReflect

func (*CreateOrganizationPipelineReleaseRequest) Reset

func (*CreateOrganizationPipelineReleaseRequest) String

type CreateOrganizationPipelineReleaseResponse

type CreateOrganizationPipelineReleaseResponse struct {

	// The created pipeline release object.
	Release *PipelineRelease `protobuf:"bytes,1,opt,name=release,proto3" json:"release,omitempty"`
	// contains filtered or unexported fields
}

CreateOrganizationPipelineReleaseResponse contains the created release.

func (*CreateOrganizationPipelineReleaseResponse) Descriptor deprecated

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

Deprecated: Use CreateOrganizationPipelineReleaseResponse.ProtoReflect.Descriptor instead.

func (*CreateOrganizationPipelineReleaseResponse) GetRelease

func (*CreateOrganizationPipelineReleaseResponse) ProtoMessage

func (*CreateOrganizationPipelineReleaseResponse) ProtoReflect

func (*CreateOrganizationPipelineReleaseResponse) Reset

func (*CreateOrganizationPipelineReleaseResponse) String

type CreateOrganizationPipelineRequest

type CreateOrganizationPipelineRequest struct {

	// The properties of the pipeline to be created.
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// The parent resource, i.e., the organization that creates the pipeline.
	// - Format: `organizations/{organization.id}`.
	Parent string `protobuf:"bytes,2,opt,name=parent,proto3" json:"parent,omitempty"`
	// contains filtered or unexported fields
}

CreateOrganizationPipelineRequest represents a request from an organization to create a pipeline.

func (*CreateOrganizationPipelineRequest) Descriptor deprecated

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

Deprecated: Use CreateOrganizationPipelineRequest.ProtoReflect.Descriptor instead.

func (*CreateOrganizationPipelineRequest) GetParent

func (*CreateOrganizationPipelineRequest) GetPipeline

func (x *CreateOrganizationPipelineRequest) GetPipeline() *Pipeline

func (*CreateOrganizationPipelineRequest) ProtoMessage

func (*CreateOrganizationPipelineRequest) ProtoMessage()

func (*CreateOrganizationPipelineRequest) ProtoReflect

func (*CreateOrganizationPipelineRequest) Reset

func (*CreateOrganizationPipelineRequest) String

type CreateOrganizationPipelineResponse

type CreateOrganizationPipelineResponse struct {

	// The created pipeline resource.
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// contains filtered or unexported fields
}

CreateOrganizationPipelineResponse contains the created pipeline.

func (*CreateOrganizationPipelineResponse) Descriptor deprecated

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

Deprecated: Use CreateOrganizationPipelineResponse.ProtoReflect.Descriptor instead.

func (*CreateOrganizationPipelineResponse) GetPipeline

func (x *CreateOrganizationPipelineResponse) GetPipeline() *Pipeline

func (*CreateOrganizationPipelineResponse) ProtoMessage

func (*CreateOrganizationPipelineResponse) ProtoMessage()

func (*CreateOrganizationPipelineResponse) ProtoReflect

func (*CreateOrganizationPipelineResponse) Reset

func (*CreateOrganizationPipelineResponse) String

type CreateOrganizationSecretRequest

type CreateOrganizationSecretRequest struct {

	// The properties of the secret to be created.
	Secret *Secret `protobuf:"bytes,1,opt,name=secret,proto3" json:"secret,omitempty"`
	// The parent resource, i.e., the organization that creates the secret.
	// - Format: `organizations/{organization.id}`.
	Parent string `protobuf:"bytes,2,opt,name=parent,proto3" json:"parent,omitempty"`
	// contains filtered or unexported fields
}

CreateOrganizationSecretRequest represents a request to create a secret.

func (*CreateOrganizationSecretRequest) Descriptor deprecated

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

Deprecated: Use CreateOrganizationSecretRequest.ProtoReflect.Descriptor instead.

func (*CreateOrganizationSecretRequest) GetParent

func (x *CreateOrganizationSecretRequest) GetParent() string

func (*CreateOrganizationSecretRequest) GetSecret

func (x *CreateOrganizationSecretRequest) GetSecret() *Secret

func (*CreateOrganizationSecretRequest) ProtoMessage

func (*CreateOrganizationSecretRequest) ProtoMessage()

func (*CreateOrganizationSecretRequest) ProtoReflect

func (*CreateOrganizationSecretRequest) Reset

func (*CreateOrganizationSecretRequest) String

type CreateOrganizationSecretResponse

type CreateOrganizationSecretResponse struct {

	// The created secret resource.
	Secret *Secret `protobuf:"bytes,1,opt,name=secret,proto3" json:"secret,omitempty"`
	// contains filtered or unexported fields
}

CreateOrganizationSecretResponse contains the created secret.

func (*CreateOrganizationSecretResponse) Descriptor deprecated

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

Deprecated: Use CreateOrganizationSecretResponse.ProtoReflect.Descriptor instead.

func (*CreateOrganizationSecretResponse) GetSecret

func (x *CreateOrganizationSecretResponse) GetSecret() *Secret

func (*CreateOrganizationSecretResponse) ProtoMessage

func (*CreateOrganizationSecretResponse) ProtoMessage()

func (*CreateOrganizationSecretResponse) ProtoReflect

func (*CreateOrganizationSecretResponse) Reset

func (*CreateOrganizationSecretResponse) String

type CreateUserPipelineReleaseRequest

type CreateUserPipelineReleaseRequest struct {

	// The release information.
	Release *PipelineRelease `protobuf:"bytes,1,opt,name=release,proto3" json:"release,omitempty"`
	// Name of the pipeline for which the release will be created.
	// Format: `users/{user.id}/pipelines/{pipeline.id}`
	Parent string `protobuf:"bytes,2,opt,name=parent,proto3" json:"parent,omitempty"`
	// contains filtered or unexported fields
}

CreateUserPipelineReleaseRequest represents a request to release a version in a user-owned pipeline.

func (*CreateUserPipelineReleaseRequest) Descriptor deprecated

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

Deprecated: Use CreateUserPipelineReleaseRequest.ProtoReflect.Descriptor instead.

func (*CreateUserPipelineReleaseRequest) GetParent

func (*CreateUserPipelineReleaseRequest) GetRelease

func (*CreateUserPipelineReleaseRequest) ProtoMessage

func (*CreateUserPipelineReleaseRequest) ProtoMessage()

func (*CreateUserPipelineReleaseRequest) ProtoReflect

func (*CreateUserPipelineReleaseRequest) Reset

func (*CreateUserPipelineReleaseRequest) String

type CreateUserPipelineReleaseResponse

type CreateUserPipelineReleaseResponse struct {

	// The created pipeline release object.
	Release *PipelineRelease `protobuf:"bytes,1,opt,name=release,proto3" json:"release,omitempty"`
	// contains filtered or unexported fields
}

CreateUserPipelineReleaseResponse contains the created release.

func (*CreateUserPipelineReleaseResponse) Descriptor deprecated

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

Deprecated: Use CreateUserPipelineReleaseResponse.ProtoReflect.Descriptor instead.

func (*CreateUserPipelineReleaseResponse) GetRelease

func (*CreateUserPipelineReleaseResponse) ProtoMessage

func (*CreateUserPipelineReleaseResponse) ProtoMessage()

func (*CreateUserPipelineReleaseResponse) ProtoReflect

func (*CreateUserPipelineReleaseResponse) Reset

func (*CreateUserPipelineReleaseResponse) String

type CreateUserPipelineRequest

type CreateUserPipelineRequest struct {

	// The properties of the pipeline to be created.
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// The parent resource, i.e., the user that creates the pipeline.
	// - Format: `users/{user.id}`.
	Parent string `protobuf:"bytes,2,opt,name=parent,proto3" json:"parent,omitempty"`
	// contains filtered or unexported fields
}

CreateUserPipelineRequest represents a request from a user to create a pipeline.

func (*CreateUserPipelineRequest) Descriptor deprecated

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

Deprecated: Use CreateUserPipelineRequest.ProtoReflect.Descriptor instead.

func (*CreateUserPipelineRequest) GetParent

func (x *CreateUserPipelineRequest) GetParent() string

func (*CreateUserPipelineRequest) GetPipeline

func (x *CreateUserPipelineRequest) GetPipeline() *Pipeline

func (*CreateUserPipelineRequest) ProtoMessage

func (*CreateUserPipelineRequest) ProtoMessage()

func (*CreateUserPipelineRequest) ProtoReflect

func (*CreateUserPipelineRequest) Reset

func (x *CreateUserPipelineRequest) Reset()

func (*CreateUserPipelineRequest) String

func (x *CreateUserPipelineRequest) String() string

type CreateUserPipelineResponse

type CreateUserPipelineResponse struct {

	// The created pipeline resource.
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// contains filtered or unexported fields
}

CreateUserPipelineResponse contains the created pipeline.

func (*CreateUserPipelineResponse) Descriptor deprecated

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

Deprecated: Use CreateUserPipelineResponse.ProtoReflect.Descriptor instead.

func (*CreateUserPipelineResponse) GetPipeline

func (x *CreateUserPipelineResponse) GetPipeline() *Pipeline

func (*CreateUserPipelineResponse) ProtoMessage

func (*CreateUserPipelineResponse) ProtoMessage()

func (*CreateUserPipelineResponse) ProtoReflect

func (*CreateUserPipelineResponse) Reset

func (x *CreateUserPipelineResponse) Reset()

func (*CreateUserPipelineResponse) String

func (x *CreateUserPipelineResponse) String() string

type CreateUserSecretRequest

type CreateUserSecretRequest struct {

	// The properties of the secret to be created.
	Secret *Secret `protobuf:"bytes,1,opt,name=secret,proto3" json:"secret,omitempty"`
	// The parent resource, i.e., the user that creates the secret.
	// - Format: `users/{user.id}`.
	Parent string `protobuf:"bytes,2,opt,name=parent,proto3" json:"parent,omitempty"`
	// contains filtered or unexported fields
}

CreateUserSecretRequest represents a request to create a secret.

func (*CreateUserSecretRequest) Descriptor deprecated

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

Deprecated: Use CreateUserSecretRequest.ProtoReflect.Descriptor instead.

func (*CreateUserSecretRequest) GetParent

func (x *CreateUserSecretRequest) GetParent() string

func (*CreateUserSecretRequest) GetSecret

func (x *CreateUserSecretRequest) GetSecret() *Secret

func (*CreateUserSecretRequest) ProtoMessage

func (*CreateUserSecretRequest) ProtoMessage()

func (*CreateUserSecretRequest) ProtoReflect

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

func (*CreateUserSecretRequest) Reset

func (x *CreateUserSecretRequest) Reset()

func (*CreateUserSecretRequest) String

func (x *CreateUserSecretRequest) String() string

type CreateUserSecretResponse

type CreateUserSecretResponse struct {

	// The created secret resource.
	Secret *Secret `protobuf:"bytes,1,opt,name=secret,proto3" json:"secret,omitempty"`
	// contains filtered or unexported fields
}

CreateUserSecretResponse contains the created secret.

func (*CreateUserSecretResponse) Descriptor deprecated

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

Deprecated: Use CreateUserSecretResponse.ProtoReflect.Descriptor instead.

func (*CreateUserSecretResponse) GetSecret

func (x *CreateUserSecretResponse) GetSecret() *Secret

func (*CreateUserSecretResponse) ProtoMessage

func (*CreateUserSecretResponse) ProtoMessage()

func (*CreateUserSecretResponse) ProtoReflect

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

func (*CreateUserSecretResponse) Reset

func (x *CreateUserSecretResponse) Reset()

func (*CreateUserSecretResponse) String

func (x *CreateUserSecretResponse) String() string

type DataSpecification

type DataSpecification struct {

	// JSON schema describing the component input data.
	Input *structpb.Struct `protobuf:"bytes,1,opt,name=input,proto3" json:"input,omitempty"`
	// JSON schema describing the component output data.
	Output *structpb.Struct `protobuf:"bytes,2,opt,name=output,proto3" json:"output,omitempty"`
	// contains filtered or unexported fields
}

DataSpecification describes the JSON schema of component input and output.

func (*DataSpecification) Descriptor deprecated

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

Deprecated: Use DataSpecification.ProtoReflect.Descriptor instead.

func (*DataSpecification) GetInput

func (x *DataSpecification) GetInput() *structpb.Struct

func (*DataSpecification) GetOutput

func (x *DataSpecification) GetOutput() *structpb.Struct

func (*DataSpecification) ProtoMessage

func (*DataSpecification) ProtoMessage()

func (*DataSpecification) ProtoReflect

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

func (*DataSpecification) Reset

func (x *DataSpecification) Reset()

func (*DataSpecification) String

func (x *DataSpecification) String() string

type DeleteOrganizationPipelineReleaseRequest

type DeleteOrganizationPipelineReleaseRequest struct {

	// The resource name of the pipeline release, which allows its access by
	// parent pipeline and ID.
	// - Format:
	// `organizations/{organization.id}/pipelines/{pipeline.id}/releases/{release.id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

DeleteOrganizationPipelineReleaseRequest represents a request to delete a release in an organization-owned pipeline.

func (*DeleteOrganizationPipelineReleaseRequest) Descriptor deprecated

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

Deprecated: Use DeleteOrganizationPipelineReleaseRequest.ProtoReflect.Descriptor instead.

func (*DeleteOrganizationPipelineReleaseRequest) GetName

func (*DeleteOrganizationPipelineReleaseRequest) ProtoMessage

func (*DeleteOrganizationPipelineReleaseRequest) ProtoReflect

func (*DeleteOrganizationPipelineReleaseRequest) Reset

func (*DeleteOrganizationPipelineReleaseRequest) String

type DeleteOrganizationPipelineReleaseResponse

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

DeleteOrganizationPipelineReleaseResponse is an empty response.

func (*DeleteOrganizationPipelineReleaseResponse) Descriptor deprecated

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

Deprecated: Use DeleteOrganizationPipelineReleaseResponse.ProtoReflect.Descriptor instead.

func (*DeleteOrganizationPipelineReleaseResponse) ProtoMessage

func (*DeleteOrganizationPipelineReleaseResponse) ProtoReflect

func (*DeleteOrganizationPipelineReleaseResponse) Reset

func (*DeleteOrganizationPipelineReleaseResponse) String

type DeleteOrganizationPipelineRequest

type DeleteOrganizationPipelineRequest struct {

	// The resource name of the pipeline, which allows its access by parent
	// organization and ID.
	// - Format: `organizations/{organization.id}/pipelines/{pipeline.id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

DeleteOrganizationPipelineRequest represents a request to delete a pipeline owned by an organization.

func (*DeleteOrganizationPipelineRequest) Descriptor deprecated

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

Deprecated: Use DeleteOrganizationPipelineRequest.ProtoReflect.Descriptor instead.

func (*DeleteOrganizationPipelineRequest) GetName

func (*DeleteOrganizationPipelineRequest) ProtoMessage

func (*DeleteOrganizationPipelineRequest) ProtoMessage()

func (*DeleteOrganizationPipelineRequest) ProtoReflect

func (*DeleteOrganizationPipelineRequest) Reset

func (*DeleteOrganizationPipelineRequest) String

type DeleteOrganizationPipelineResponse

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

DeleteOrganizationPipelineResponse is an empty response.

func (*DeleteOrganizationPipelineResponse) Descriptor deprecated

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

Deprecated: Use DeleteOrganizationPipelineResponse.ProtoReflect.Descriptor instead.

func (*DeleteOrganizationPipelineResponse) ProtoMessage

func (*DeleteOrganizationPipelineResponse) ProtoMessage()

func (*DeleteOrganizationPipelineResponse) ProtoReflect

func (*DeleteOrganizationPipelineResponse) Reset

func (*DeleteOrganizationPipelineResponse) String

type DeleteOrganizationSecretRequest

type DeleteOrganizationSecretRequest struct {

	// The resource name of the secret, which allows its access by ID.
	// - Format: `organizations/{organization.id}/secrets/{secret.id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

DeleteOrganizationSecretRequest represents a request to delete a secret resource.

func (*DeleteOrganizationSecretRequest) Descriptor deprecated

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

Deprecated: Use DeleteOrganizationSecretRequest.ProtoReflect.Descriptor instead.

func (*DeleteOrganizationSecretRequest) GetName

func (*DeleteOrganizationSecretRequest) ProtoMessage

func (*DeleteOrganizationSecretRequest) ProtoMessage()

func (*DeleteOrganizationSecretRequest) ProtoReflect

func (*DeleteOrganizationSecretRequest) Reset

func (*DeleteOrganizationSecretRequest) String

type DeleteOrganizationSecretResponse

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

DeleteOrganizationSecretResponse is an empty response.

func (*DeleteOrganizationSecretResponse) Descriptor deprecated

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

Deprecated: Use DeleteOrganizationSecretResponse.ProtoReflect.Descriptor instead.

func (*DeleteOrganizationSecretResponse) ProtoMessage

func (*DeleteOrganizationSecretResponse) ProtoMessage()

func (*DeleteOrganizationSecretResponse) ProtoReflect

func (*DeleteOrganizationSecretResponse) Reset

func (*DeleteOrganizationSecretResponse) String

type DeleteUserPipelineReleaseRequest

type DeleteUserPipelineReleaseRequest struct {

	// The resource name of the pipeline release, which allows its access by
	// parent pipeline and ID.
	// - Format: `users/{user.id}/pipelines/{pipeline.id}/releases/{release.id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

DeleteUserPipelineReleaseRequest represents a request to delete a release in a user-owned pipeline.

func (*DeleteUserPipelineReleaseRequest) Descriptor deprecated

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

Deprecated: Use DeleteUserPipelineReleaseRequest.ProtoReflect.Descriptor instead.

func (*DeleteUserPipelineReleaseRequest) GetName

func (*DeleteUserPipelineReleaseRequest) ProtoMessage

func (*DeleteUserPipelineReleaseRequest) ProtoMessage()

func (*DeleteUserPipelineReleaseRequest) ProtoReflect

func (*DeleteUserPipelineReleaseRequest) Reset

func (*DeleteUserPipelineReleaseRequest) String

type DeleteUserPipelineReleaseResponse

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

DeleteUserPipelineReleaseResponse is an empty response.

func (*DeleteUserPipelineReleaseResponse) Descriptor deprecated

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

Deprecated: Use DeleteUserPipelineReleaseResponse.ProtoReflect.Descriptor instead.

func (*DeleteUserPipelineReleaseResponse) ProtoMessage

func (*DeleteUserPipelineReleaseResponse) ProtoMessage()

func (*DeleteUserPipelineReleaseResponse) ProtoReflect

func (*DeleteUserPipelineReleaseResponse) Reset

func (*DeleteUserPipelineReleaseResponse) String

type DeleteUserPipelineRequest

type DeleteUserPipelineRequest struct {

	// The resource name of the pipeline, which allows its access by parent user
	// and ID.
	// - Format: `users/{user.id}/pipelines/{pipeline.id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

DeleteUserPipelineRequest represents a request to delete a pipeline owned by a user.

func (*DeleteUserPipelineRequest) Descriptor deprecated

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

Deprecated: Use DeleteUserPipelineRequest.ProtoReflect.Descriptor instead.

func (*DeleteUserPipelineRequest) GetName

func (x *DeleteUserPipelineRequest) GetName() string

func (*DeleteUserPipelineRequest) ProtoMessage

func (*DeleteUserPipelineRequest) ProtoMessage()

func (*DeleteUserPipelineRequest) ProtoReflect

func (*DeleteUserPipelineRequest) Reset

func (x *DeleteUserPipelineRequest) Reset()

func (*DeleteUserPipelineRequest) String

func (x *DeleteUserPipelineRequest) String() string

type DeleteUserPipelineResponse

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

DeleteUserPipelineResponse is an empty response.

func (*DeleteUserPipelineResponse) Descriptor deprecated

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

Deprecated: Use DeleteUserPipelineResponse.ProtoReflect.Descriptor instead.

func (*DeleteUserPipelineResponse) ProtoMessage

func (*DeleteUserPipelineResponse) ProtoMessage()

func (*DeleteUserPipelineResponse) ProtoReflect

func (*DeleteUserPipelineResponse) Reset

func (x *DeleteUserPipelineResponse) Reset()

func (*DeleteUserPipelineResponse) String

func (x *DeleteUserPipelineResponse) String() string

type DeleteUserSecretRequest

type DeleteUserSecretRequest struct {

	// The resource name of the secret, which allows its access by ID.
	// - Format: `users/{user.id}/secrets/{secret.id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

DeleteUserSecretRequest represents a request to delete a secret resource.

func (*DeleteUserSecretRequest) Descriptor deprecated

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

Deprecated: Use DeleteUserSecretRequest.ProtoReflect.Descriptor instead.

func (*DeleteUserSecretRequest) GetName

func (x *DeleteUserSecretRequest) GetName() string

func (*DeleteUserSecretRequest) ProtoMessage

func (*DeleteUserSecretRequest) ProtoMessage()

func (*DeleteUserSecretRequest) ProtoReflect

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

func (*DeleteUserSecretRequest) Reset

func (x *DeleteUserSecretRequest) Reset()

func (*DeleteUserSecretRequest) String

func (x *DeleteUserSecretRequest) String() string

type DeleteUserSecretResponse

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

DeleteUserSecretResponse is an empty response.

func (*DeleteUserSecretResponse) Descriptor deprecated

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

Deprecated: Use DeleteUserSecretResponse.ProtoReflect.Descriptor instead.

func (*DeleteUserSecretResponse) ProtoMessage

func (*DeleteUserSecretResponse) ProtoMessage()

func (*DeleteUserSecretResponse) ProtoReflect

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

func (*DeleteUserSecretResponse) Reset

func (x *DeleteUserSecretResponse) Reset()

func (*DeleteUserSecretResponse) String

func (x *DeleteUserSecretResponse) String() string

type GetConnectorDefinitionRequest

type GetConnectorDefinitionRequest struct {

	// The resource name of the connector definition, which allows its access by ID.
	// - Format: `connector-definitions/{id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// View allows clients to specify the desired resource view in the response.
	View *ComponentDefinition_View `protobuf:"varint,3,opt,name=view,proto3,enum=vdp.pipeline.v1beta.ComponentDefinition_View,oneof" json:"view,omitempty"`
	// contains filtered or unexported fields
}

GetConnectorDefinitionRequest represents a request to fetch the details of a connector definition.

func (*GetConnectorDefinitionRequest) Descriptor deprecated

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

Deprecated: Use GetConnectorDefinitionRequest.ProtoReflect.Descriptor instead.

func (*GetConnectorDefinitionRequest) GetName

func (*GetConnectorDefinitionRequest) GetView

func (*GetConnectorDefinitionRequest) ProtoMessage

func (*GetConnectorDefinitionRequest) ProtoMessage()

func (*GetConnectorDefinitionRequest) ProtoReflect

func (*GetConnectorDefinitionRequest) Reset

func (x *GetConnectorDefinitionRequest) Reset()

func (*GetConnectorDefinitionRequest) String

type GetConnectorDefinitionResponse

type GetConnectorDefinitionResponse struct {

	// The connector definition resource.
	ConnectorDefinition *ConnectorDefinition `protobuf:"bytes,1,opt,name=connector_definition,json=connectorDefinition,proto3" json:"connector_definition,omitempty"`
	// contains filtered or unexported fields
}

GetConnectorDefinitionResponse contains the requested connector definition.

func (*GetConnectorDefinitionResponse) Descriptor deprecated

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

Deprecated: Use GetConnectorDefinitionResponse.ProtoReflect.Descriptor instead.

func (*GetConnectorDefinitionResponse) GetConnectorDefinition

func (x *GetConnectorDefinitionResponse) GetConnectorDefinition() *ConnectorDefinition

func (*GetConnectorDefinitionResponse) ProtoMessage

func (*GetConnectorDefinitionResponse) ProtoMessage()

func (*GetConnectorDefinitionResponse) ProtoReflect

func (*GetConnectorDefinitionResponse) Reset

func (x *GetConnectorDefinitionResponse) Reset()

func (*GetConnectorDefinitionResponse) String

type GetOperationRequest

type GetOperationRequest struct {

	// The name of the operation resource. Asynchronous methods will contain this
	// information in their response.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

GetOperationRequest represents a request to query a long-running operation.

func (*GetOperationRequest) Descriptor deprecated

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

Deprecated: Use GetOperationRequest.ProtoReflect.Descriptor instead.

func (*GetOperationRequest) GetName

func (x *GetOperationRequest) GetName() string

func (*GetOperationRequest) ProtoMessage

func (*GetOperationRequest) ProtoMessage()

func (*GetOperationRequest) ProtoReflect

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

func (*GetOperationRequest) Reset

func (x *GetOperationRequest) Reset()

func (*GetOperationRequest) String

func (x *GetOperationRequest) String() string

type GetOperationResponse

type GetOperationResponse struct {

	// The long-running operation.
	Operation *longrunningpb.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

GetOperationResponse contains the long-running operation details.

func (*GetOperationResponse) Descriptor deprecated

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

Deprecated: Use GetOperationResponse.ProtoReflect.Descriptor instead.

func (*GetOperationResponse) GetOperation

func (x *GetOperationResponse) GetOperation() *longrunningpb.Operation

func (*GetOperationResponse) ProtoMessage

func (*GetOperationResponse) ProtoMessage()

func (*GetOperationResponse) ProtoReflect

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

func (*GetOperationResponse) Reset

func (x *GetOperationResponse) Reset()

func (*GetOperationResponse) String

func (x *GetOperationResponse) String() string

type GetOperatorDefinitionRequest

type GetOperatorDefinitionRequest struct {

	// The resource name of the operator definition, which allows its access by ID.
	// - Format: `operator-definitions/{id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// View allows clients to specify the desired resource view in the response.
	View *ComponentDefinition_View `protobuf:"varint,3,opt,name=view,proto3,enum=vdp.pipeline.v1beta.ComponentDefinition_View,oneof" json:"view,omitempty"`
	// contains filtered or unexported fields
}

GetOperatorDefinitionRequest represents a request to fetch the details of a operator definition.

func (*GetOperatorDefinitionRequest) Descriptor deprecated

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

Deprecated: Use GetOperatorDefinitionRequest.ProtoReflect.Descriptor instead.

func (*GetOperatorDefinitionRequest) GetName

func (x *GetOperatorDefinitionRequest) GetName() string

func (*GetOperatorDefinitionRequest) GetView

func (*GetOperatorDefinitionRequest) ProtoMessage

func (*GetOperatorDefinitionRequest) ProtoMessage()

func (*GetOperatorDefinitionRequest) ProtoReflect

func (*GetOperatorDefinitionRequest) Reset

func (x *GetOperatorDefinitionRequest) Reset()

func (*GetOperatorDefinitionRequest) String

type GetOperatorDefinitionResponse

type GetOperatorDefinitionResponse struct {

	// The operator definition resource.
	OperatorDefinition *OperatorDefinition `protobuf:"bytes,1,opt,name=operator_definition,json=operatorDefinition,proto3" json:"operator_definition,omitempty"`
	// contains filtered or unexported fields
}

GetOperatorDefinitionResponse contains the requested operator definition.

func (*GetOperatorDefinitionResponse) Descriptor deprecated

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

Deprecated: Use GetOperatorDefinitionResponse.ProtoReflect.Descriptor instead.

func (*GetOperatorDefinitionResponse) GetOperatorDefinition

func (x *GetOperatorDefinitionResponse) GetOperatorDefinition() *OperatorDefinition

func (*GetOperatorDefinitionResponse) ProtoMessage

func (*GetOperatorDefinitionResponse) ProtoMessage()

func (*GetOperatorDefinitionResponse) ProtoReflect

func (*GetOperatorDefinitionResponse) Reset

func (x *GetOperatorDefinitionResponse) Reset()

func (*GetOperatorDefinitionResponse) String

type GetOrganizationPipelineReleaseRequest

type GetOrganizationPipelineReleaseRequest struct {

	// The resource name of the pipeline release, which allows its access by
	// parent pipeline and ID.
	// - Format:
	// `organizations/{organization.id}/pipelines/{pipeline.id}/releases/{release.id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// View allows clients to specify the desired pipeline view in the response.
	View *Pipeline_View `protobuf:"varint,2,opt,name=view,proto3,enum=vdp.pipeline.v1beta.Pipeline_View,oneof" json:"view,omitempty"`
	// contains filtered or unexported fields
}

GetOrganizationPipelineReleaseRequest represents a request to fetchthe details of a release in an organization-owned pipeline.

func (*GetOrganizationPipelineReleaseRequest) Descriptor deprecated

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

Deprecated: Use GetOrganizationPipelineReleaseRequest.ProtoReflect.Descriptor instead.

func (*GetOrganizationPipelineReleaseRequest) GetName

func (*GetOrganizationPipelineReleaseRequest) GetView

func (*GetOrganizationPipelineReleaseRequest) ProtoMessage

func (*GetOrganizationPipelineReleaseRequest) ProtoMessage()

func (*GetOrganizationPipelineReleaseRequest) ProtoReflect

func (*GetOrganizationPipelineReleaseRequest) Reset

func (*GetOrganizationPipelineReleaseRequest) String

type GetOrganizationPipelineReleaseResponse

type GetOrganizationPipelineReleaseResponse struct {

	// The pipeline release resource.
	Release *PipelineRelease `protobuf:"bytes,1,opt,name=release,proto3" json:"release,omitempty"`
	// contains filtered or unexported fields
}

GetOrganizationPipelineReleaseResponse contains the requested pipeline release.

func (*GetOrganizationPipelineReleaseResponse) Descriptor deprecated

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

Deprecated: Use GetOrganizationPipelineReleaseResponse.ProtoReflect.Descriptor instead.

func (*GetOrganizationPipelineReleaseResponse) GetRelease

func (*GetOrganizationPipelineReleaseResponse) ProtoMessage

func (*GetOrganizationPipelineReleaseResponse) ProtoReflect

func (*GetOrganizationPipelineReleaseResponse) Reset

func (*GetOrganizationPipelineReleaseResponse) String

type GetOrganizationPipelineRequest

type GetOrganizationPipelineRequest struct {

	// The resource name of the pipeline, which allows its access by parent
	// organization and ID.
	// - Format: `organizations/{organization.id}/pipelines/{pipeline.id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// View allows clients to specify the desired pipeline view in the response.
	View *Pipeline_View `protobuf:"varint,2,opt,name=view,proto3,enum=vdp.pipeline.v1beta.Pipeline_View,oneof" json:"view,omitempty"`
	// contains filtered or unexported fields
}

GetOrganizationPipelineRequest represents a request to fetch the details of a pipeline owned by an organization.

func (*GetOrganizationPipelineRequest) Descriptor deprecated

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

Deprecated: Use GetOrganizationPipelineRequest.ProtoReflect.Descriptor instead.

func (*GetOrganizationPipelineRequest) GetName

func (*GetOrganizationPipelineRequest) GetView

func (*GetOrganizationPipelineRequest) ProtoMessage

func (*GetOrganizationPipelineRequest) ProtoMessage()

func (*GetOrganizationPipelineRequest) ProtoReflect

func (*GetOrganizationPipelineRequest) Reset

func (x *GetOrganizationPipelineRequest) Reset()

func (*GetOrganizationPipelineRequest) String

type GetOrganizationPipelineResponse

type GetOrganizationPipelineResponse struct {

	// The pipeline resource.
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// contains filtered or unexported fields
}

GetOrganizationPipelineResponse contains the requested pipeline.

func (*GetOrganizationPipelineResponse) Descriptor deprecated

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

Deprecated: Use GetOrganizationPipelineResponse.ProtoReflect.Descriptor instead.

func (*GetOrganizationPipelineResponse) GetPipeline

func (x *GetOrganizationPipelineResponse) GetPipeline() *Pipeline

func (*GetOrganizationPipelineResponse) ProtoMessage

func (*GetOrganizationPipelineResponse) ProtoMessage()

func (*GetOrganizationPipelineResponse) ProtoReflect

func (*GetOrganizationPipelineResponse) Reset

func (*GetOrganizationPipelineResponse) String

type GetOrganizationSecretRequest

type GetOrganizationSecretRequest struct {

	// The resource name of the secret, which allows its access by ID.
	// - Format: `organizations/{organization.id}/secrets/{secret.id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

GetOrganizationSecretRequest represents a request to fetch the details of a secret

func (*GetOrganizationSecretRequest) Descriptor deprecated

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

Deprecated: Use GetOrganizationSecretRequest.ProtoReflect.Descriptor instead.

func (*GetOrganizationSecretRequest) GetName

func (x *GetOrganizationSecretRequest) GetName() string

func (*GetOrganizationSecretRequest) ProtoMessage

func (*GetOrganizationSecretRequest) ProtoMessage()

func (*GetOrganizationSecretRequest) ProtoReflect

func (*GetOrganizationSecretRequest) Reset

func (x *GetOrganizationSecretRequest) Reset()

func (*GetOrganizationSecretRequest) String

type GetOrganizationSecretResponse

type GetOrganizationSecretResponse struct {

	// The secret resource.
	Secret *Secret `protobuf:"bytes,1,opt,name=secret,proto3" json:"secret,omitempty"`
	// contains filtered or unexported fields
}

GetOrganizationSecretResponse contains the requested secret.

func (*GetOrganizationSecretResponse) Descriptor deprecated

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

Deprecated: Use GetOrganizationSecretResponse.ProtoReflect.Descriptor instead.

func (*GetOrganizationSecretResponse) GetSecret

func (x *GetOrganizationSecretResponse) GetSecret() *Secret

func (*GetOrganizationSecretResponse) ProtoMessage

func (*GetOrganizationSecretResponse) ProtoMessage()

func (*GetOrganizationSecretResponse) ProtoReflect

func (*GetOrganizationSecretResponse) Reset

func (x *GetOrganizationSecretResponse) Reset()

func (*GetOrganizationSecretResponse) String

type GetUserPipelineReleaseRequest

type GetUserPipelineReleaseRequest struct {

	// The resource name of the pipeline release, which allows its access by
	// parent pipeline and ID.
	// - Format: `users/{user.id}/pipelines/{pipeline.id}/releases/{release.id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// View allows clients to specify the desired pipeline view in the response.
	View *Pipeline_View `protobuf:"varint,2,opt,name=view,proto3,enum=vdp.pipeline.v1beta.Pipeline_View,oneof" json:"view,omitempty"`
	// contains filtered or unexported fields
}

GetUserPipelineReleaseRequest represents a request to fetchthe details of a release in a user-owned pipeline.

func (*GetUserPipelineReleaseRequest) Descriptor deprecated

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

Deprecated: Use GetUserPipelineReleaseRequest.ProtoReflect.Descriptor instead.

func (*GetUserPipelineReleaseRequest) GetName

func (*GetUserPipelineReleaseRequest) GetView

func (*GetUserPipelineReleaseRequest) ProtoMessage

func (*GetUserPipelineReleaseRequest) ProtoMessage()

func (*GetUserPipelineReleaseRequest) ProtoReflect

func (*GetUserPipelineReleaseRequest) Reset

func (x *GetUserPipelineReleaseRequest) Reset()

func (*GetUserPipelineReleaseRequest) String

type GetUserPipelineReleaseResponse

type GetUserPipelineReleaseResponse struct {

	// The pipeline release resource.
	Release *PipelineRelease `protobuf:"bytes,1,opt,name=release,proto3" json:"release,omitempty"`
	// contains filtered or unexported fields
}

GetUserPipelineReleaseResponse contains the requested pipeline release.

func (*GetUserPipelineReleaseResponse) Descriptor deprecated

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

Deprecated: Use GetUserPipelineReleaseResponse.ProtoReflect.Descriptor instead.

func (*GetUserPipelineReleaseResponse) GetRelease

func (*GetUserPipelineReleaseResponse) ProtoMessage

func (*GetUserPipelineReleaseResponse) ProtoMessage()

func (*GetUserPipelineReleaseResponse) ProtoReflect

func (*GetUserPipelineReleaseResponse) Reset

func (x *GetUserPipelineReleaseResponse) Reset()

func (*GetUserPipelineReleaseResponse) String

type GetUserPipelineRequest

type GetUserPipelineRequest struct {

	// The resource name of the pipeline, which allows its access by parent user
	// and ID.
	// - Format: `users/{user.id}/pipelines/{pipeline.id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// View allows clients to specify the desired pipeline view in the response.
	View *Pipeline_View `protobuf:"varint,2,opt,name=view,proto3,enum=vdp.pipeline.v1beta.Pipeline_View,oneof" json:"view,omitempty"`
	// contains filtered or unexported fields
}

GetUserPipelineRequest represents a request to fetch the details of a pipeline owned by a user.

func (*GetUserPipelineRequest) Descriptor deprecated

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

Deprecated: Use GetUserPipelineRequest.ProtoReflect.Descriptor instead.

func (*GetUserPipelineRequest) GetName

func (x *GetUserPipelineRequest) GetName() string

func (*GetUserPipelineRequest) GetView

func (*GetUserPipelineRequest) ProtoMessage

func (*GetUserPipelineRequest) ProtoMessage()

func (*GetUserPipelineRequest) ProtoReflect

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

func (*GetUserPipelineRequest) Reset

func (x *GetUserPipelineRequest) Reset()

func (*GetUserPipelineRequest) String

func (x *GetUserPipelineRequest) String() string

type GetUserPipelineResponse

type GetUserPipelineResponse struct {

	// The pipeline resource.
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// contains filtered or unexported fields
}

GetUserPipelineResponse contains the requested pipeline.

func (*GetUserPipelineResponse) Descriptor deprecated

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

Deprecated: Use GetUserPipelineResponse.ProtoReflect.Descriptor instead.

func (*GetUserPipelineResponse) GetPipeline

func (x *GetUserPipelineResponse) GetPipeline() *Pipeline

func (*GetUserPipelineResponse) ProtoMessage

func (*GetUserPipelineResponse) ProtoMessage()

func (*GetUserPipelineResponse) ProtoReflect

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

func (*GetUserPipelineResponse) Reset

func (x *GetUserPipelineResponse) Reset()

func (*GetUserPipelineResponse) String

func (x *GetUserPipelineResponse) String() string

type GetUserSecretRequest

type GetUserSecretRequest struct {

	// The resource name of the secret, which allows its access by ID.
	// - Format: `users/{user.id}/secrets/{secret.id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

GetUserSecretRequest represents a request to fetch the details of a secret

func (*GetUserSecretRequest) Descriptor deprecated

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

Deprecated: Use GetUserSecretRequest.ProtoReflect.Descriptor instead.

func (*GetUserSecretRequest) GetName

func (x *GetUserSecretRequest) GetName() string

func (*GetUserSecretRequest) ProtoMessage

func (*GetUserSecretRequest) ProtoMessage()

func (*GetUserSecretRequest) ProtoReflect

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

func (*GetUserSecretRequest) Reset

func (x *GetUserSecretRequest) Reset()

func (*GetUserSecretRequest) String

func (x *GetUserSecretRequest) String() string

type GetUserSecretResponse

type GetUserSecretResponse struct {

	// The secret resource.
	Secret *Secret `protobuf:"bytes,1,opt,name=secret,proto3" json:"secret,omitempty"`
	// contains filtered or unexported fields
}

GetUserSecretResponse contains the requested secret.

func (*GetUserSecretResponse) Descriptor deprecated

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

Deprecated: Use GetUserSecretResponse.ProtoReflect.Descriptor instead.

func (*GetUserSecretResponse) GetSecret

func (x *GetUserSecretResponse) GetSecret() *Secret

func (*GetUserSecretResponse) ProtoMessage

func (*GetUserSecretResponse) ProtoMessage()

func (*GetUserSecretResponse) ProtoReflect

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

func (*GetUserSecretResponse) Reset

func (x *GetUserSecretResponse) Reset()

func (*GetUserSecretResponse) String

func (x *GetUserSecretResponse) String() string

type IteratorComponent

type IteratorComponent struct {

	// Input: The iterator will iterate over the elements of the input (must be an array).
	Input string `protobuf:"bytes,1,opt,name=input,proto3" json:"input,omitempty"`
	// Output elements: Configure the output arrays of the iterator.
	// The key is the output element variable name, and the value is the data reference of the template.
	// Example:
	//
	//	output_elements: {
	//	  "key1": "${element.output.a}",
	//	  "key2": "${element.output.b}",
	//	}
	//
	// This will create the results:
	//
	//	output: {
	//	  "key1": [ ${element1.output.a},  ${element2.output.a} ... ],
	//	  "key2": [ ${element1.output.b},  ${element2.output.b} ... ],
	//	}
	OutputElements map[string]string `` /* 191-byte string literal not displayed */
	// Components: These components will be executed for each input element.
	Components []*NestedComponent `protobuf:"bytes,3,rep,name=components,proto3" json:"components,omitempty"`
	// Condition statement determining whether the component is executed or not.
	Condition string `protobuf:"bytes,4,opt,name=condition,proto3" json:"condition,omitempty"`
	// DataSpecification returns the JSON schema for the iterator input and output.
	DataSpecification *DataSpecification `protobuf:"bytes,5,opt,name=data_specification,json=dataSpecification,proto3" json:"data_specification,omitempty"`
	// contains filtered or unexported fields
}

IteratorComponent Configures an iterator component. An iterator takes an array and executes an operation (defined by a set of nested components) on each of its elements. It can be regarded as triggering a sub-pipeline using the elements of an array as input.

func (*IteratorComponent) Descriptor deprecated

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

Deprecated: Use IteratorComponent.ProtoReflect.Descriptor instead.

func (*IteratorComponent) GetComponents

func (x *IteratorComponent) GetComponents() []*NestedComponent

func (*IteratorComponent) GetCondition

func (x *IteratorComponent) GetCondition() string

func (*IteratorComponent) GetDataSpecification

func (x *IteratorComponent) GetDataSpecification() *DataSpecification

func (*IteratorComponent) GetInput

func (x *IteratorComponent) GetInput() string

func (*IteratorComponent) GetOutputElements

func (x *IteratorComponent) GetOutputElements() map[string]string

func (*IteratorComponent) ProtoMessage

func (*IteratorComponent) ProtoMessage()

func (*IteratorComponent) ProtoReflect

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

func (*IteratorComponent) Reset

func (x *IteratorComponent) Reset()

func (*IteratorComponent) String

func (x *IteratorComponent) String() string

type ListComponentDefinitionsRequest

type ListComponentDefinitionsRequest struct {

	// The maximum number of component definitions to return. If this parameter
	// is unspecified, at most 10 definitions will be returned. The cap value for
	// this parameter is 100 (i.e. any value above that will be coerced to 100).
	PageSize *int32 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3,oneof" json:"page_size,omitempty"`
	// View allows clients to specify the desired resource view in the response.
	View *ComponentDefinition_View `protobuf:"varint,3,opt,name=view,proto3,enum=vdp.pipeline.v1beta.ComponentDefinition_View,oneof" json:"view,omitempty"`
	// Filter can hold an [AIP-160](https://google.aip.dev/160)-compliant filter
	// expression.
	// - Example: `component_type="COMPONENT_TYPE_CONNECTOR_AI"`.
	// - Example: `tasks:"TASK_TEXT_GENERATION"`.
	Filter *string `protobuf:"bytes,4,opt,name=filter,proto3,oneof" json:"filter,omitempty"`
	// Page number.
	Page *int32 `protobuf:"varint,5,opt,name=page,proto3,oneof" json:"page,omitempty"`
	// contains filtered or unexported fields
}

ListComponentDefinitionsRequest represents a request to list component definitions.

func (*ListComponentDefinitionsRequest) Descriptor deprecated

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

Deprecated: Use ListComponentDefinitionsRequest.ProtoReflect.Descriptor instead.

func (*ListComponentDefinitionsRequest) GetFilter

func (x *ListComponentDefinitionsRequest) GetFilter() string

func (*ListComponentDefinitionsRequest) GetPage

func (*ListComponentDefinitionsRequest) GetPageSize

func (x *ListComponentDefinitionsRequest) GetPageSize() int32

func (*ListComponentDefinitionsRequest) GetView

func (*ListComponentDefinitionsRequest) ProtoMessage

func (*ListComponentDefinitionsRequest) ProtoMessage()

func (*ListComponentDefinitionsRequest) ProtoReflect

func (*ListComponentDefinitionsRequest) Reset

func (*ListComponentDefinitionsRequest) String

type ListComponentDefinitionsResponse

type ListComponentDefinitionsResponse struct {

	// A list of component definition resources.
	ComponentDefinitions []*ComponentDefinition `protobuf:"bytes,1,rep,name=component_definitions,json=componentDefinitions,proto3" json:"component_definitions,omitempty"`
	// Total number of connector definitions.
	TotalSize int32 `protobuf:"varint,3,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	// The requested page size.
	PageSize int32 `protobuf:"varint,4,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// The requested page offset.
	Page int32 `protobuf:"varint,5,opt,name=page,proto3" json:"page,omitempty"`
	// contains filtered or unexported fields
}

ListComponentDefinitionsResponse contains a list of component definitions.

func (*ListComponentDefinitionsResponse) Descriptor deprecated

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

Deprecated: Use ListComponentDefinitionsResponse.ProtoReflect.Descriptor instead.

func (*ListComponentDefinitionsResponse) GetComponentDefinitions

func (x *ListComponentDefinitionsResponse) GetComponentDefinitions() []*ComponentDefinition

func (*ListComponentDefinitionsResponse) GetPage

func (*ListComponentDefinitionsResponse) GetPageSize

func (x *ListComponentDefinitionsResponse) GetPageSize() int32

func (*ListComponentDefinitionsResponse) GetTotalSize

func (x *ListComponentDefinitionsResponse) GetTotalSize() int32

func (*ListComponentDefinitionsResponse) ProtoMessage

func (*ListComponentDefinitionsResponse) ProtoMessage()

func (*ListComponentDefinitionsResponse) ProtoReflect

func (*ListComponentDefinitionsResponse) Reset

func (*ListComponentDefinitionsResponse) String

type ListConnectorDefinitionsRequest

type ListConnectorDefinitionsRequest struct {

	// The maximum number of connector definitions to return. If this parameter
	// is unspecified, at most 10 definitions will be returned. The cap value for
	// this parameter is 100 (i.e. any value above that will be coerced to 100).
	PageSize *int32 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3,oneof" json:"page_size,omitempty"`
	// Page token.
	PageToken *string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3,oneof" json:"page_token,omitempty"`
	// Filter can hold an [AIP-160](https://google.aip.dev/160)-compliant filter
	// expression.
	// - Example: `create_time>timestamp("2000-06-19T23:31:08.657Z")`.
	Filter *string `protobuf:"bytes,4,opt,name=filter,proto3,oneof" json:"filter,omitempty"`
	// View allows clients to specify the desired resource view in the response.
	View *ComponentDefinition_View `protobuf:"varint,5,opt,name=view,proto3,enum=vdp.pipeline.v1beta.ComponentDefinition_View,oneof" json:"view,omitempty"`
	// contains filtered or unexported fields
}

ListConnectorDefinitionsRequest represents a request to list connector definitions.

func (*ListConnectorDefinitionsRequest) Descriptor deprecated

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

Deprecated: Use ListConnectorDefinitionsRequest.ProtoReflect.Descriptor instead.

func (*ListConnectorDefinitionsRequest) GetFilter

func (x *ListConnectorDefinitionsRequest) GetFilter() string

func (*ListConnectorDefinitionsRequest) GetPageSize

func (x *ListConnectorDefinitionsRequest) GetPageSize() int32

func (*ListConnectorDefinitionsRequest) GetPageToken

func (x *ListConnectorDefinitionsRequest) GetPageToken() string

func (*ListConnectorDefinitionsRequest) GetView

func (*ListConnectorDefinitionsRequest) ProtoMessage

func (*ListConnectorDefinitionsRequest) ProtoMessage()

func (*ListConnectorDefinitionsRequest) ProtoReflect

func (*ListConnectorDefinitionsRequest) Reset

func (*ListConnectorDefinitionsRequest) String

type ListConnectorDefinitionsResponse

type ListConnectorDefinitionsResponse struct {

	// A list of connector definition resources.
	ConnectorDefinitions []*ConnectorDefinition `protobuf:"bytes,1,rep,name=connector_definitions,json=connectorDefinitions,proto3" json:"connector_definitions,omitempty"`
	// Next page token.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// Total number of connector definitions.
	TotalSize int32 `protobuf:"varint,3,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	// contains filtered or unexported fields
}

ListConnectorDefinitionsResponse contains a list of connector definitions.

func (*ListConnectorDefinitionsResponse) Descriptor deprecated

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

Deprecated: Use ListConnectorDefinitionsResponse.ProtoReflect.Descriptor instead.

func (*ListConnectorDefinitionsResponse) GetConnectorDefinitions

func (x *ListConnectorDefinitionsResponse) GetConnectorDefinitions() []*ConnectorDefinition

func (*ListConnectorDefinitionsResponse) GetNextPageToken

func (x *ListConnectorDefinitionsResponse) GetNextPageToken() string

func (*ListConnectorDefinitionsResponse) GetTotalSize

func (x *ListConnectorDefinitionsResponse) GetTotalSize() int32

func (*ListConnectorDefinitionsResponse) ProtoMessage

func (*ListConnectorDefinitionsResponse) ProtoMessage()

func (*ListConnectorDefinitionsResponse) ProtoReflect

func (*ListConnectorDefinitionsResponse) Reset

func (*ListConnectorDefinitionsResponse) String

type ListOperatorDefinitionsRequest

type ListOperatorDefinitionsRequest struct {

	// The maximum number of OperatorDefinitions to return. The
	// service may return fewer than this value. If unspecified, at most 10
	// OperatorDefinitions will be returned. The maximum value is 100;
	// values above 100 will be coerced to 100.
	PageSize *int32 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3,oneof" json:"page_size,omitempty"`
	// Page token.
	PageToken *string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3,oneof" json:"page_token,omitempty"`
	// Filter can hold an [AIP-160](https://google.aip.dev/160)-compliant filter
	// expression.
	// - Example: `create_time>timestamp("2000-06-19T23:31:08.657Z")`.
	Filter *string `protobuf:"bytes,4,opt,name=filter,proto3,oneof" json:"filter,omitempty"`
	// View allows clients to specify the desired resource view in the response.
	View *ComponentDefinition_View `protobuf:"varint,5,opt,name=view,proto3,enum=vdp.pipeline.v1beta.ComponentDefinition_View,oneof" json:"view,omitempty"`
	// contains filtered or unexported fields
}

ListOperatorDefinitionsRequest represents a request to list operator definitions.

func (*ListOperatorDefinitionsRequest) Descriptor deprecated

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

Deprecated: Use ListOperatorDefinitionsRequest.ProtoReflect.Descriptor instead.

func (*ListOperatorDefinitionsRequest) GetFilter

func (x *ListOperatorDefinitionsRequest) GetFilter() string

func (*ListOperatorDefinitionsRequest) GetPageSize

func (x *ListOperatorDefinitionsRequest) GetPageSize() int32

func (*ListOperatorDefinitionsRequest) GetPageToken

func (x *ListOperatorDefinitionsRequest) GetPageToken() string

func (*ListOperatorDefinitionsRequest) GetView

func (*ListOperatorDefinitionsRequest) ProtoMessage

func (*ListOperatorDefinitionsRequest) ProtoMessage()

func (*ListOperatorDefinitionsRequest) ProtoReflect

func (*ListOperatorDefinitionsRequest) Reset

func (x *ListOperatorDefinitionsRequest) Reset()

func (*ListOperatorDefinitionsRequest) String

type ListOperatorDefinitionsResponse

type ListOperatorDefinitionsResponse struct {

	// A list of operator definition resources.
	OperatorDefinitions []*OperatorDefinition `protobuf:"bytes,1,rep,name=operator_definitions,json=operatorDefinitions,proto3" json:"operator_definitions,omitempty"`
	// Next page token.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// Total number of operator definitions.
	TotalSize int32 `protobuf:"varint,3,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	// contains filtered or unexported fields
}

ListOperatorDefinitionsResponse contains a list of operator definitions.

func (*ListOperatorDefinitionsResponse) Descriptor deprecated

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

Deprecated: Use ListOperatorDefinitionsResponse.ProtoReflect.Descriptor instead.

func (*ListOperatorDefinitionsResponse) GetNextPageToken

func (x *ListOperatorDefinitionsResponse) GetNextPageToken() string

func (*ListOperatorDefinitionsResponse) GetOperatorDefinitions

func (x *ListOperatorDefinitionsResponse) GetOperatorDefinitions() []*OperatorDefinition

func (*ListOperatorDefinitionsResponse) GetTotalSize

func (x *ListOperatorDefinitionsResponse) GetTotalSize() int32

func (*ListOperatorDefinitionsResponse) ProtoMessage

func (*ListOperatorDefinitionsResponse) ProtoMessage()

func (*ListOperatorDefinitionsResponse) ProtoReflect

func (*ListOperatorDefinitionsResponse) Reset

func (*ListOperatorDefinitionsResponse) String

type ListOrganizationPipelineReleasesRequest

type ListOrganizationPipelineReleasesRequest struct {

	// The maximum number of releases to return. If this parameter is
	// unspecified, at most 10 pipelines will be returned. The cap value for this
	// parameter is 100 (i.e. any value above that will be coerced to 100).
	PageSize *int32 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3,oneof" json:"page_size,omitempty"`
	// Page token.
	PageToken *string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3,oneof" json:"page_token,omitempty"`
	// View allows clients to specify the desired pipeline view in the response.
	View *Pipeline_View `protobuf:"varint,3,opt,name=view,proto3,enum=vdp.pipeline.v1beta.Pipeline_View,oneof" json:"view,omitempty"`
	// Filter can hold an [AIP-160](https://google.aip.dev/160)-compliant filter
	// expression.
	// - Example: `create_time>timestamp("2000-06-19T23:31:08.657Z")`.
	Filter *string `protobuf:"bytes,4,opt,name=filter,proto3,oneof" json:"filter,omitempty"`
	// The parent resource where this pipeline release will be created.
	// Format: `organizations/{organization.id}/pipelines/{pipeline.id}`
	Parent string `protobuf:"bytes,5,opt,name=parent,proto3" json:"parent,omitempty"`
	// Include soft-deleted pipelines in the result.
	ShowDeleted *bool `protobuf:"varint,6,opt,name=show_deleted,json=showDeleted,proto3,oneof" json:"show_deleted,omitempty"`
	// contains filtered or unexported fields
}

ListOrganizationPipelineReleasesRequest represents a request to list the releases in an organization-owned pipeline.

func (*ListOrganizationPipelineReleasesRequest) Descriptor deprecated

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

Deprecated: Use ListOrganizationPipelineReleasesRequest.ProtoReflect.Descriptor instead.

func (*ListOrganizationPipelineReleasesRequest) GetFilter

func (*ListOrganizationPipelineReleasesRequest) GetPageSize

func (*ListOrganizationPipelineReleasesRequest) GetPageToken

func (*ListOrganizationPipelineReleasesRequest) GetParent

func (*ListOrganizationPipelineReleasesRequest) GetShowDeleted

func (x *ListOrganizationPipelineReleasesRequest) GetShowDeleted() bool

func (*ListOrganizationPipelineReleasesRequest) GetView

func (*ListOrganizationPipelineReleasesRequest) ProtoMessage

func (*ListOrganizationPipelineReleasesRequest) ProtoReflect

func (*ListOrganizationPipelineReleasesRequest) Reset

func (*ListOrganizationPipelineReleasesRequest) String

type ListOrganizationPipelineReleasesResponse

type ListOrganizationPipelineReleasesResponse struct {

	// A list of pipeline release resources.
	Releases []*PipelineRelease `protobuf:"bytes,1,rep,name=releases,proto3" json:"releases,omitempty"`
	// Next page token.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// Total number of pipeline releases.
	TotalSize int32 `protobuf:"varint,3,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	// contains filtered or unexported fields
}

ListOrganizationPipelineReleasesResponse contains a list of pipeline releases.

func (*ListOrganizationPipelineReleasesResponse) Descriptor deprecated

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

Deprecated: Use ListOrganizationPipelineReleasesResponse.ProtoReflect.Descriptor instead.

func (*ListOrganizationPipelineReleasesResponse) GetNextPageToken

func (x *ListOrganizationPipelineReleasesResponse) GetNextPageToken() string

func (*ListOrganizationPipelineReleasesResponse) GetReleases

func (*ListOrganizationPipelineReleasesResponse) GetTotalSize

func (*ListOrganizationPipelineReleasesResponse) ProtoMessage

func (*ListOrganizationPipelineReleasesResponse) ProtoReflect

func (*ListOrganizationPipelineReleasesResponse) Reset

func (*ListOrganizationPipelineReleasesResponse) String

type ListOrganizationPipelinesRequest

type ListOrganizationPipelinesRequest struct {

	// The maximum number of pipelines to return. If this parameter is
	// unspecified, at most 10 pipelines will be returned. The cap value for this
	// parameter is 100 (i.e. any value above that will be coerced to 100).
	PageSize *int32 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3,oneof" json:"page_size,omitempty"`
	// Page token.
	PageToken *string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3,oneof" json:"page_token,omitempty"`
	// View allows clients to specify the desired pipeline view in the response.
	View *Pipeline_View `protobuf:"varint,3,opt,name=view,proto3,enum=vdp.pipeline.v1beta.Pipeline_View,oneof" json:"view,omitempty"`
	// Filter can hold an [AIP-160](https://google.aip.dev/160)-compliant filter
	// expression.
	// - Example: `create_time>timestamp("2000-06-19T23:31:08.657Z")`.
	// - Example:
	// `recipe.components.definition_name:"operator-definitions/2ac8be70-0f7a-4b61-a33d-098b8acfa6f3"`.
	Filter *string `protobuf:"bytes,4,opt,name=filter,proto3,oneof" json:"filter,omitempty"`
	// The parent resource, i.e., the organization that created the pipelines.
	// - Format: `organizations/{organization.id}`.
	Parent string `protobuf:"bytes,5,opt,name=parent,proto3" json:"parent,omitempty"`
	// Include soft-deleted pipelines in the result.
	ShowDeleted *bool `protobuf:"varint,6,opt,name=show_deleted,json=showDeleted,proto3,oneof" json:"show_deleted,omitempty"`
	// Limit results to pipelines with the specified visibility.
	Visibility *Pipeline_Visibility `protobuf:"varint,7,opt,name=visibility,proto3,enum=vdp.pipeline.v1beta.Pipeline_Visibility,oneof" json:"visibility,omitempty"`
	// contains filtered or unexported fields
}

ListOrganizationPipelinesRequest represents a request to list the pipelines of an organization.

func (*ListOrganizationPipelinesRequest) Descriptor deprecated

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

Deprecated: Use ListOrganizationPipelinesRequest.ProtoReflect.Descriptor instead.

func (*ListOrganizationPipelinesRequest) GetFilter

func (*ListOrganizationPipelinesRequest) GetPageSize

func (x *ListOrganizationPipelinesRequest) GetPageSize() int32

func (*ListOrganizationPipelinesRequest) GetPageToken

func (x *ListOrganizationPipelinesRequest) GetPageToken() string

func (*ListOrganizationPipelinesRequest) GetParent

func (*ListOrganizationPipelinesRequest) GetShowDeleted

func (x *ListOrganizationPipelinesRequest) GetShowDeleted() bool

func (*ListOrganizationPipelinesRequest) GetView

func (*ListOrganizationPipelinesRequest) GetVisibility

func (*ListOrganizationPipelinesRequest) ProtoMessage

func (*ListOrganizationPipelinesRequest) ProtoMessage()

func (*ListOrganizationPipelinesRequest) ProtoReflect

func (*ListOrganizationPipelinesRequest) Reset

func (*ListOrganizationPipelinesRequest) String

type ListOrganizationPipelinesResponse

type ListOrganizationPipelinesResponse struct {

	// A list of pipeline resources.
	Pipelines []*Pipeline `protobuf:"bytes,1,rep,name=pipelines,proto3" json:"pipelines,omitempty"`
	// Next page token.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// Total number of pipelines.
	TotalSize int32 `protobuf:"varint,3,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	// contains filtered or unexported fields
}

ListOrganizationPipelinesResponse contains a list of pipelines.

func (*ListOrganizationPipelinesResponse) Descriptor deprecated

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

Deprecated: Use ListOrganizationPipelinesResponse.ProtoReflect.Descriptor instead.

func (*ListOrganizationPipelinesResponse) GetNextPageToken

func (x *ListOrganizationPipelinesResponse) GetNextPageToken() string

func (*ListOrganizationPipelinesResponse) GetPipelines

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

func (*ListOrganizationPipelinesResponse) GetTotalSize

func (x *ListOrganizationPipelinesResponse) GetTotalSize() int32

func (*ListOrganizationPipelinesResponse) ProtoMessage

func (*ListOrganizationPipelinesResponse) ProtoMessage()

func (*ListOrganizationPipelinesResponse) ProtoReflect

func (*ListOrganizationPipelinesResponse) Reset

func (*ListOrganizationPipelinesResponse) String

type ListOrganizationSecretsRequest

type ListOrganizationSecretsRequest struct {

	// The maximum number of secrets to return. If this parameter is unspecified,
	// at most 10 pipelines will be returned. The cap value for this parameter is
	// 100 (i.e. any value above that will be coerced to 100).
	PageSize *int32 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3,oneof" json:"page_size,omitempty"`
	// Page secret.
	PageToken *string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3,oneof" json:"page_token,omitempty"`
	// The parent resource, i.e., the organization that creates the secret.
	// - Format: `organizations/{organization.id}`.
	Parent string `protobuf:"bytes,3,opt,name=parent,proto3" json:"parent,omitempty"`
	// contains filtered or unexported fields
}

ListOrganizationSecretsRequest represents a request to list the secrets of a user.

func (*ListOrganizationSecretsRequest) Descriptor deprecated

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

Deprecated: Use ListOrganizationSecretsRequest.ProtoReflect.Descriptor instead.

func (*ListOrganizationSecretsRequest) GetPageSize

func (x *ListOrganizationSecretsRequest) GetPageSize() int32

func (*ListOrganizationSecretsRequest) GetPageToken

func (x *ListOrganizationSecretsRequest) GetPageToken() string

func (*ListOrganizationSecretsRequest) GetParent

func (x *ListOrganizationSecretsRequest) GetParent() string

func (*ListOrganizationSecretsRequest) ProtoMessage

func (*ListOrganizationSecretsRequest) ProtoMessage()

func (*ListOrganizationSecretsRequest) ProtoReflect

func (*ListOrganizationSecretsRequest) Reset

func (x *ListOrganizationSecretsRequest) Reset()

func (*ListOrganizationSecretsRequest) String

type ListOrganizationSecretsResponse

type ListOrganizationSecretsResponse struct {

	// A list of secret resources.
	Secrets []*Secret `protobuf:"bytes,1,rep,name=secrets,proto3" json:"secrets,omitempty"`
	// Next page secret.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// Total number of secret resources.
	TotalSize int32 `protobuf:"varint,3,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	// contains filtered or unexported fields
}

ListOrganizationSecretsResponse contains a list of secrets.

func (*ListOrganizationSecretsResponse) Descriptor deprecated

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

Deprecated: Use ListOrganizationSecretsResponse.ProtoReflect.Descriptor instead.

func (*ListOrganizationSecretsResponse) GetNextPageToken

func (x *ListOrganizationSecretsResponse) GetNextPageToken() string

func (*ListOrganizationSecretsResponse) GetSecrets

func (x *ListOrganizationSecretsResponse) GetSecrets() []*Secret

func (*ListOrganizationSecretsResponse) GetTotalSize

func (x *ListOrganizationSecretsResponse) GetTotalSize() int32

func (*ListOrganizationSecretsResponse) ProtoMessage

func (*ListOrganizationSecretsResponse) ProtoMessage()

func (*ListOrganizationSecretsResponse) ProtoReflect

func (*ListOrganizationSecretsResponse) Reset

func (*ListOrganizationSecretsResponse) String

type ListPipelineReleasesAdminRequest

type ListPipelineReleasesAdminRequest struct {

	// The maximum number of releases to return. If this parameter is
	// unspecified, at most 10 releases will be returned. The cap value for this
	// parameter is 100 (i.e. any value above that will be coerced to 100).
	PageSize *int32 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3,oneof" json:"page_size,omitempty"`
	// Page token.
	PageToken *string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3,oneof" json:"page_token,omitempty"`
	// View allows clients to specify the desired pipeline view in the response.
	View *Pipeline_View `protobuf:"varint,3,opt,name=view,proto3,enum=vdp.pipeline.v1beta.Pipeline_View,oneof" json:"view,omitempty"`
	// Filter can hold an [AIP-160](https://google.aip.dev/160)-compliant filter
	// expression.
	// - Example: `create_time>timestamp("2000-06-19T23:31:08.657Z")`.
	Filter *string `protobuf:"bytes,4,opt,name=filter,proto3,oneof" json:"filter,omitempty"`
	// Include soft-deleted pipelines in the result.
	ShowDeleted *bool `protobuf:"varint,5,opt,name=show_deleted,json=showDeleted,proto3,oneof" json:"show_deleted,omitempty"`
	// contains filtered or unexported fields
}

ListPipelinesReleaseAdminRequest represents a request by an admin to list all pipeline releases. Admin users have access to pipelines from any user.

func (*ListPipelineReleasesAdminRequest) Descriptor deprecated

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

Deprecated: Use ListPipelineReleasesAdminRequest.ProtoReflect.Descriptor instead.

func (*ListPipelineReleasesAdminRequest) GetFilter

func (*ListPipelineReleasesAdminRequest) GetPageSize

func (x *ListPipelineReleasesAdminRequest) GetPageSize() int32

func (*ListPipelineReleasesAdminRequest) GetPageToken

func (x *ListPipelineReleasesAdminRequest) GetPageToken() string

func (*ListPipelineReleasesAdminRequest) GetShowDeleted

func (x *ListPipelineReleasesAdminRequest) GetShowDeleted() bool

func (*ListPipelineReleasesAdminRequest) GetView

func (*ListPipelineReleasesAdminRequest) ProtoMessage

func (*ListPipelineReleasesAdminRequest) ProtoMessage()

func (*ListPipelineReleasesAdminRequest) ProtoReflect

func (*ListPipelineReleasesAdminRequest) Reset

func (*ListPipelineReleasesAdminRequest) String

type ListPipelineReleasesAdminResponse

type ListPipelineReleasesAdminResponse struct {

	// A list of pipeline releases.
	Releases []*PipelineRelease `protobuf:"bytes,1,rep,name=releases,proto3" json:"releases,omitempty"`
	// Next page token.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// Total number of pipeline releases.
	TotalSize int32 `protobuf:"varint,3,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	// contains filtered or unexported fields
}

ListPipelineReleasesAdminResponse contains a list of pipeline releases requested by an admin user. For the moment, the pipeline recipes will be UID-based (permalink) instead of name-based. This is a temporary solution.

func (*ListPipelineReleasesAdminResponse) Descriptor deprecated

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

Deprecated: Use ListPipelineReleasesAdminResponse.ProtoReflect.Descriptor instead.

func (*ListPipelineReleasesAdminResponse) GetNextPageToken

func (x *ListPipelineReleasesAdminResponse) GetNextPageToken() string

func (*ListPipelineReleasesAdminResponse) GetReleases

func (*ListPipelineReleasesAdminResponse) GetTotalSize

func (x *ListPipelineReleasesAdminResponse) GetTotalSize() int32

func (*ListPipelineReleasesAdminResponse) ProtoMessage

func (*ListPipelineReleasesAdminResponse) ProtoMessage()

func (*ListPipelineReleasesAdminResponse) ProtoReflect

func (*ListPipelineReleasesAdminResponse) Reset

func (*ListPipelineReleasesAdminResponse) String

type ListPipelinesAdminRequest

type ListPipelinesAdminRequest struct {

	// The maximum number of pipelines to return. If this parameter is
	// unspecified, at most 10 pipelines will be returned. The cap value for this
	// parameter is 100 (i.e. any value above that will be coerced to 100).
	PageSize *int32 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3,oneof" json:"page_size,omitempty"`
	// Page token.
	PageToken *string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3,oneof" json:"page_token,omitempty"`
	// View allows clients to specify the desired pipeline view in the response.
	View *Pipeline_View `protobuf:"varint,3,opt,name=view,proto3,enum=vdp.pipeline.v1beta.Pipeline_View,oneof" json:"view,omitempty"`
	// Filter can hold an [AIP-160](https://google.aip.dev/160)-compliant filter
	// expression.
	// - Example: `create_time>timestamp("2000-06-19T23:31:08.657Z")`.
	// - Example:
	// `recipe.components.definition_name:"operator-definitions/2ac8be70-0f7a-4b61-a33d-098b8acfa6f3"`.
	Filter *string `protobuf:"bytes,4,opt,name=filter,proto3,oneof" json:"filter,omitempty"`
	// Include soft-deleted pipelines in the result.
	ShowDeleted *bool `protobuf:"varint,5,opt,name=show_deleted,json=showDeleted,proto3,oneof" json:"show_deleted,omitempty"`
	// contains filtered or unexported fields
}

ListPipelinesAdminRequest represents a request by an admin to list all the pipelines. Admin users have access to pipelines from any user.

func (*ListPipelinesAdminRequest) Descriptor deprecated

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

Deprecated: Use ListPipelinesAdminRequest.ProtoReflect.Descriptor instead.

func (*ListPipelinesAdminRequest) GetFilter

func (x *ListPipelinesAdminRequest) GetFilter() string

func (*ListPipelinesAdminRequest) GetPageSize

func (x *ListPipelinesAdminRequest) GetPageSize() int32

func (*ListPipelinesAdminRequest) GetPageToken

func (x *ListPipelinesAdminRequest) GetPageToken() string

func (*ListPipelinesAdminRequest) GetShowDeleted

func (x *ListPipelinesAdminRequest) GetShowDeleted() bool

func (*ListPipelinesAdminRequest) GetView

func (*ListPipelinesAdminRequest) ProtoMessage

func (*ListPipelinesAdminRequest) ProtoMessage()

func (*ListPipelinesAdminRequest) ProtoReflect

func (*ListPipelinesAdminRequest) Reset

func (x *ListPipelinesAdminRequest) Reset()

func (*ListPipelinesAdminRequest) String

func (x *ListPipelinesAdminRequest) String() string

type ListPipelinesAdminResponse

type ListPipelinesAdminResponse struct {

	// A list of pipeline resources.
	Pipelines []*Pipeline `protobuf:"bytes,1,rep,name=pipelines,proto3" json:"pipelines,omitempty"`
	// Next page token.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// Total number of pipelines.
	TotalSize int32 `protobuf:"varint,3,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	// contains filtered or unexported fields
}

ListPipelinesAdminResponse contains a list of pipelines requested by an admin user. For the moment, the pipeline recipes will be UID-based (permalink) instead of name-based. This is a temporary solution.

func (*ListPipelinesAdminResponse) Descriptor deprecated

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

Deprecated: Use ListPipelinesAdminResponse.ProtoReflect.Descriptor instead.

func (*ListPipelinesAdminResponse) GetNextPageToken

func (x *ListPipelinesAdminResponse) GetNextPageToken() string

func (*ListPipelinesAdminResponse) GetPipelines

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

func (*ListPipelinesAdminResponse) GetTotalSize

func (x *ListPipelinesAdminResponse) GetTotalSize() int32

func (*ListPipelinesAdminResponse) ProtoMessage

func (*ListPipelinesAdminResponse) ProtoMessage()

func (*ListPipelinesAdminResponse) ProtoReflect

func (*ListPipelinesAdminResponse) Reset

func (x *ListPipelinesAdminResponse) Reset()

func (*ListPipelinesAdminResponse) String

func (x *ListPipelinesAdminResponse) String() string

type ListPipelinesRequest

type ListPipelinesRequest struct {

	// The maximum number of pipelines to return. If this parameter is
	// unspecified, at most 10 pipelines will be returned. The cap value for this
	// parameter is 100 (i.e. any value above that will be coerced to 100).
	PageSize *int32 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3,oneof" json:"page_size,omitempty"`
	// Page token.
	PageToken *string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3,oneof" json:"page_token,omitempty"`
	// View allows clients to specify the desired pipeline view in the response.
	View *Pipeline_View `protobuf:"varint,3,opt,name=view,proto3,enum=vdp.pipeline.v1beta.Pipeline_View,oneof" json:"view,omitempty"`
	// Filter can hold an [AIP-160](https://google.aip.dev/160)-compliant filter
	// expression.
	// - Example: `create_time>timestamp("2000-06-19T23:31:08.657Z")`.
	// - Example:
	// `recipe.components.definition_name:"operator-definitions/2ac8be70-0f7a-4b61-a33d-098b8acfa6f3"`.
	Filter *string `protobuf:"bytes,4,opt,name=filter,proto3,oneof" json:"filter,omitempty"`
	// Include soft-deleted pipelines in the result.
	ShowDeleted *bool `protobuf:"varint,5,opt,name=show_deleted,json=showDeleted,proto3,oneof" json:"show_deleted,omitempty"`
	// Limit results to pipelines with the specified visibility.
	Visibility *Pipeline_Visibility `protobuf:"varint,6,opt,name=visibility,proto3,enum=vdp.pipeline.v1beta.Pipeline_Visibility,oneof" json:"visibility,omitempty"`
	// contains filtered or unexported fields
}

ListPipelinesRequest represents a request to list pipelines.

func (*ListPipelinesRequest) Descriptor deprecated

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

Deprecated: Use ListPipelinesRequest.ProtoReflect.Descriptor instead.

func (*ListPipelinesRequest) GetFilter

func (x *ListPipelinesRequest) GetFilter() string

func (*ListPipelinesRequest) GetPageSize

func (x *ListPipelinesRequest) GetPageSize() int32

func (*ListPipelinesRequest) GetPageToken

func (x *ListPipelinesRequest) GetPageToken() string

func (*ListPipelinesRequest) GetShowDeleted

func (x *ListPipelinesRequest) GetShowDeleted() bool

func (*ListPipelinesRequest) GetView

func (x *ListPipelinesRequest) GetView() Pipeline_View

func (*ListPipelinesRequest) GetVisibility

func (x *ListPipelinesRequest) GetVisibility() Pipeline_Visibility

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 {

	// A list of pipeline resources.
	Pipelines []*Pipeline `protobuf:"bytes,1,rep,name=pipelines,proto3" json:"pipelines,omitempty"`
	// Next page token.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// Total number of pipelines.
	TotalSize int32 `protobuf:"varint,3,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	// contains filtered or unexported fields
}

ListPipelinesResponse contains a list of pipelines.

func (*ListPipelinesResponse) Descriptor deprecated

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

Deprecated: Use ListPipelinesResponse.ProtoReflect.Descriptor instead.

func (*ListPipelinesResponse) GetNextPageToken

func (x *ListPipelinesResponse) GetNextPageToken() string

func (*ListPipelinesResponse) GetPipelines

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

func (*ListPipelinesResponse) GetTotalSize

func (x *ListPipelinesResponse) GetTotalSize() int32

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 ListUserPipelineReleasesRequest

type ListUserPipelineReleasesRequest struct {

	// The maximum number of releases to return. If this parameter is
	// unspecified, at most 10 pipelines will be returned. The cap value for this
	// parameter is 100 (i.e. any value above that will be coerced to 100).
	PageSize *int32 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3,oneof" json:"page_size,omitempty"`
	// Page token.
	PageToken *string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3,oneof" json:"page_token,omitempty"`
	// View allows clients to specify the desired pipeline view in the response.
	View *Pipeline_View `protobuf:"varint,3,opt,name=view,proto3,enum=vdp.pipeline.v1beta.Pipeline_View,oneof" json:"view,omitempty"`
	// Filter can hold an [AIP-160](https://google.aip.dev/160)-compliant filter
	// expression.
	// - Example: `create_time>timestamp("2000-06-19T23:31:08.657Z")`.
	Filter *string `protobuf:"bytes,4,opt,name=filter,proto3,oneof" json:"filter,omitempty"`
	// The parent resource where this pipeline release will be created.
	// Format: `users/{user.id}/pipelines/{pipeline.id}`.
	Parent string `protobuf:"bytes,5,opt,name=parent,proto3" json:"parent,omitempty"`
	// Include soft-deleted pipelines in the result.
	ShowDeleted *bool `protobuf:"varint,6,opt,name=show_deleted,json=showDeleted,proto3,oneof" json:"show_deleted,omitempty"`
	// contains filtered or unexported fields
}

ListUserPipelineReleasesRequest represents a request to list the releases in a user-owned pipeline.

func (*ListUserPipelineReleasesRequest) Descriptor deprecated

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

Deprecated: Use ListUserPipelineReleasesRequest.ProtoReflect.Descriptor instead.

func (*ListUserPipelineReleasesRequest) GetFilter

func (x *ListUserPipelineReleasesRequest) GetFilter() string

func (*ListUserPipelineReleasesRequest) GetPageSize

func (x *ListUserPipelineReleasesRequest) GetPageSize() int32

func (*ListUserPipelineReleasesRequest) GetPageToken

func (x *ListUserPipelineReleasesRequest) GetPageToken() string

func (*ListUserPipelineReleasesRequest) GetParent

func (x *ListUserPipelineReleasesRequest) GetParent() string

func (*ListUserPipelineReleasesRequest) GetShowDeleted

func (x *ListUserPipelineReleasesRequest) GetShowDeleted() bool

func (*ListUserPipelineReleasesRequest) GetView

func (*ListUserPipelineReleasesRequest) ProtoMessage

func (*ListUserPipelineReleasesRequest) ProtoMessage()

func (*ListUserPipelineReleasesRequest) ProtoReflect

func (*ListUserPipelineReleasesRequest) Reset

func (*ListUserPipelineReleasesRequest) String

type ListUserPipelineReleasesResponse

type ListUserPipelineReleasesResponse struct {

	// A list of pipeline release resources.
	Releases []*PipelineRelease `protobuf:"bytes,1,rep,name=releases,proto3" json:"releases,omitempty"`
	// Next page token.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// Total number of pipeline releases.
	TotalSize int32 `protobuf:"varint,3,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	// contains filtered or unexported fields
}

ListUserPipelineReleasesResponse contains a list of pipeline releases.

func (*ListUserPipelineReleasesResponse) Descriptor deprecated

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

Deprecated: Use ListUserPipelineReleasesResponse.ProtoReflect.Descriptor instead.

func (*ListUserPipelineReleasesResponse) GetNextPageToken

func (x *ListUserPipelineReleasesResponse) GetNextPageToken() string

func (*ListUserPipelineReleasesResponse) GetReleases

func (*ListUserPipelineReleasesResponse) GetTotalSize

func (x *ListUserPipelineReleasesResponse) GetTotalSize() int32

func (*ListUserPipelineReleasesResponse) ProtoMessage

func (*ListUserPipelineReleasesResponse) ProtoMessage()

func (*ListUserPipelineReleasesResponse) ProtoReflect

func (*ListUserPipelineReleasesResponse) Reset

func (*ListUserPipelineReleasesResponse) String

type ListUserPipelinesRequest

type ListUserPipelinesRequest struct {

	// The maximum number of pipelines to return. If this parameter is
	// unspecified, at most 10 pipelines will be returned. The cap value for this
	// parameter is 100 (i.e. any value above that will be coerced to 100).
	PageSize *int32 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3,oneof" json:"page_size,omitempty"`
	// Page token.
	PageToken *string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3,oneof" json:"page_token,omitempty"`
	// View allows clients to specify the desired pipeline view in the response.
	View *Pipeline_View `protobuf:"varint,3,opt,name=view,proto3,enum=vdp.pipeline.v1beta.Pipeline_View,oneof" json:"view,omitempty"`
	// Filter can hold an [AIP-160](https://google.aip.dev/160)-compliant filter
	// expression.
	// - Example: `create_time>timestamp("2000-06-19T23:31:08.657Z")`.
	// - Example:
	// `recipe.components.definition_name:"operator-definitions/2ac8be70-0f7a-4b61-a33d-098b8acfa6f3"`.
	Filter *string `protobuf:"bytes,4,opt,name=filter,proto3,oneof" json:"filter,omitempty"`
	// The parent resource, i.e., the user that created the pipelines.
	// - Format: `users/{user.id}`.
	Parent string `protobuf:"bytes,5,opt,name=parent,proto3" json:"parent,omitempty"`
	// Include soft-deleted pipelines in the result.
	ShowDeleted *bool `protobuf:"varint,6,opt,name=show_deleted,json=showDeleted,proto3,oneof" json:"show_deleted,omitempty"`
	// Limit results to pipelines with the specified visibility.
	Visibility *Pipeline_Visibility `protobuf:"varint,7,opt,name=visibility,proto3,enum=vdp.pipeline.v1beta.Pipeline_Visibility,oneof" json:"visibility,omitempty"`
	// contains filtered or unexported fields
}

ListUserPipelinesRequest represents a request to list the pipelines of a user.

func (*ListUserPipelinesRequest) Descriptor deprecated

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

Deprecated: Use ListUserPipelinesRequest.ProtoReflect.Descriptor instead.

func (*ListUserPipelinesRequest) GetFilter

func (x *ListUserPipelinesRequest) GetFilter() string

func (*ListUserPipelinesRequest) GetPageSize

func (x *ListUserPipelinesRequest) GetPageSize() int32

func (*ListUserPipelinesRequest) GetPageToken

func (x *ListUserPipelinesRequest) GetPageToken() string

func (*ListUserPipelinesRequest) GetParent

func (x *ListUserPipelinesRequest) GetParent() string

func (*ListUserPipelinesRequest) GetShowDeleted

func (x *ListUserPipelinesRequest) GetShowDeleted() bool

func (*ListUserPipelinesRequest) GetView

func (*ListUserPipelinesRequest) GetVisibility

func (x *ListUserPipelinesRequest) GetVisibility() Pipeline_Visibility

func (*ListUserPipelinesRequest) ProtoMessage

func (*ListUserPipelinesRequest) ProtoMessage()

func (*ListUserPipelinesRequest) ProtoReflect

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

func (*ListUserPipelinesRequest) Reset

func (x *ListUserPipelinesRequest) Reset()

func (*ListUserPipelinesRequest) String

func (x *ListUserPipelinesRequest) String() string

type ListUserPipelinesResponse

type ListUserPipelinesResponse struct {

	// A list of pipeline resources.
	Pipelines []*Pipeline `protobuf:"bytes,1,rep,name=pipelines,proto3" json:"pipelines,omitempty"`
	// Next page token.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// Total number of pipelines.
	TotalSize int32 `protobuf:"varint,3,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	// contains filtered or unexported fields
}

ListUserPipelinesResponse contains a list of pipelines.

func (*ListUserPipelinesResponse) Descriptor deprecated

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

Deprecated: Use ListUserPipelinesResponse.ProtoReflect.Descriptor instead.

func (*ListUserPipelinesResponse) GetNextPageToken

func (x *ListUserPipelinesResponse) GetNextPageToken() string

func (*ListUserPipelinesResponse) GetPipelines

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

func (*ListUserPipelinesResponse) GetTotalSize

func (x *ListUserPipelinesResponse) GetTotalSize() int32

func (*ListUserPipelinesResponse) ProtoMessage

func (*ListUserPipelinesResponse) ProtoMessage()

func (*ListUserPipelinesResponse) ProtoReflect

func (*ListUserPipelinesResponse) Reset

func (x *ListUserPipelinesResponse) Reset()

func (*ListUserPipelinesResponse) String

func (x *ListUserPipelinesResponse) String() string

type ListUserSecretsRequest

type ListUserSecretsRequest struct {

	// The maximum number of secrets to return. If this parameter is unspecified,
	// at most 10 pipelines will be returned. The cap value for this parameter is
	// 100 (i.e. any value above that will be coerced to 100).
	PageSize *int32 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3,oneof" json:"page_size,omitempty"`
	// Page secret.
	PageToken *string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3,oneof" json:"page_token,omitempty"`
	// The parent resource, i.e., the user that creates the secret.
	// - Format: `users/{user.id}`.
	Parent string `protobuf:"bytes,3,opt,name=parent,proto3" json:"parent,omitempty"`
	// contains filtered or unexported fields
}

ListUserSecretsRequest represents a request to list the secrets of a user.

func (*ListUserSecretsRequest) Descriptor deprecated

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

Deprecated: Use ListUserSecretsRequest.ProtoReflect.Descriptor instead.

func (*ListUserSecretsRequest) GetPageSize

func (x *ListUserSecretsRequest) GetPageSize() int32

func (*ListUserSecretsRequest) GetPageToken

func (x *ListUserSecretsRequest) GetPageToken() string

func (*ListUserSecretsRequest) GetParent

func (x *ListUserSecretsRequest) GetParent() string

func (*ListUserSecretsRequest) ProtoMessage

func (*ListUserSecretsRequest) ProtoMessage()

func (*ListUserSecretsRequest) ProtoReflect

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

func (*ListUserSecretsRequest) Reset

func (x *ListUserSecretsRequest) Reset()

func (*ListUserSecretsRequest) String

func (x *ListUserSecretsRequest) String() string

type ListUserSecretsResponse

type ListUserSecretsResponse struct {

	// A list of secret resources.
	Secrets []*Secret `protobuf:"bytes,1,rep,name=secrets,proto3" json:"secrets,omitempty"`
	// Next page secret.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// Total number of secret resources.
	TotalSize int32 `protobuf:"varint,3,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	// contains filtered or unexported fields
}

ListUserSecretsResponse contains a list of secrets.

func (*ListUserSecretsResponse) Descriptor deprecated

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

Deprecated: Use ListUserSecretsResponse.ProtoReflect.Descriptor instead.

func (*ListUserSecretsResponse) GetNextPageToken

func (x *ListUserSecretsResponse) GetNextPageToken() string

func (*ListUserSecretsResponse) GetSecrets

func (x *ListUserSecretsResponse) GetSecrets() []*Secret

func (*ListUserSecretsResponse) GetTotalSize

func (x *ListUserSecretsResponse) GetTotalSize() int32

func (*ListUserSecretsResponse) ProtoMessage

func (*ListUserSecretsResponse) ProtoMessage()

func (*ListUserSecretsResponse) ProtoReflect

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

func (*ListUserSecretsResponse) Reset

func (x *ListUserSecretsResponse) Reset()

func (*ListUserSecretsResponse) String

func (x *ListUserSecretsResponse) String() string

type LivenessRequest

type LivenessRequest struct {

	// HealthCheckRequest message
	HealthCheckRequest *v1beta.HealthCheckRequest `protobuf:"bytes,1,opt,name=health_check_request,json=healthCheckRequest,proto3,oneof" json:"health_check_request,omitempty"`
	// contains filtered or unexported fields
}

LivenessRequest represents a request to check a service liveness status

func (*LivenessRequest) Descriptor deprecated

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

Deprecated: Use LivenessRequest.ProtoReflect.Descriptor instead.

func (*LivenessRequest) GetHealthCheckRequest

func (x *LivenessRequest) GetHealthCheckRequest() *v1beta.HealthCheckRequest

func (*LivenessRequest) ProtoMessage

func (*LivenessRequest) ProtoMessage()

func (*LivenessRequest) ProtoReflect

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

func (*LivenessRequest) Reset

func (x *LivenessRequest) Reset()

func (*LivenessRequest) String

func (x *LivenessRequest) String() string

type LivenessResponse

type LivenessResponse struct {

	// HealthCheckResponse message
	HealthCheckResponse *v1beta.HealthCheckResponse `protobuf:"bytes,1,opt,name=health_check_response,json=healthCheckResponse,proto3" json:"health_check_response,omitempty"`
	// contains filtered or unexported fields
}

LivenessResponse represents a response for a service liveness status

func (*LivenessResponse) Descriptor deprecated

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

Deprecated: Use LivenessResponse.ProtoReflect.Descriptor instead.

func (*LivenessResponse) GetHealthCheckResponse

func (x *LivenessResponse) GetHealthCheckResponse() *v1beta.HealthCheckResponse

func (*LivenessResponse) ProtoMessage

func (*LivenessResponse) ProtoMessage()

func (*LivenessResponse) ProtoReflect

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

func (*LivenessResponse) Reset

func (x *LivenessResponse) Reset()

func (*LivenessResponse) String

func (x *LivenessResponse) String() string

type LookUpPipelineAdminRequest

type LookUpPipelineAdminRequest struct {

	// The permalink of the pipeline, which allows its access by UID.
	// - Format: `pipelines/{pipeline.uid}`.
	Permalink string `protobuf:"bytes,1,opt,name=permalink,proto3" json:"permalink,omitempty"`
	// View allows clients to specify the desired pipeline view in the response.
	View *Pipeline_View `protobuf:"varint,2,opt,name=view,proto3,enum=vdp.pipeline.v1beta.Pipeline_View,oneof" json:"view,omitempty"`
	// contains filtered or unexported fields
}

LookUpPipelineAdminRequest represents a request by an admin to query a pipeline by its UID.

func (*LookUpPipelineAdminRequest) Descriptor deprecated

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

Deprecated: Use LookUpPipelineAdminRequest.ProtoReflect.Descriptor instead.

func (x *LookUpPipelineAdminRequest) GetPermalink() string

func (*LookUpPipelineAdminRequest) GetView

func (*LookUpPipelineAdminRequest) ProtoMessage

func (*LookUpPipelineAdminRequest) ProtoMessage()

func (*LookUpPipelineAdminRequest) ProtoReflect

func (*LookUpPipelineAdminRequest) Reset

func (x *LookUpPipelineAdminRequest) Reset()

func (*LookUpPipelineAdminRequest) String

func (x *LookUpPipelineAdminRequest) String() string

type LookUpPipelineAdminResponse

type LookUpPipelineAdminResponse struct {

	// The requested pipeline.
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// contains filtered or unexported fields
}

LookUpPipelineAdminResponse contains the requested pipeline.

func (*LookUpPipelineAdminResponse) Descriptor deprecated

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

Deprecated: Use LookUpPipelineAdminResponse.ProtoReflect.Descriptor instead.

func (*LookUpPipelineAdminResponse) GetPipeline

func (x *LookUpPipelineAdminResponse) GetPipeline() *Pipeline

func (*LookUpPipelineAdminResponse) ProtoMessage

func (*LookUpPipelineAdminResponse) ProtoMessage()

func (*LookUpPipelineAdminResponse) ProtoReflect

func (*LookUpPipelineAdminResponse) Reset

func (x *LookUpPipelineAdminResponse) Reset()

func (*LookUpPipelineAdminResponse) String

func (x *LookUpPipelineAdminResponse) String() string

type LookUpPipelineRequest

type LookUpPipelineRequest struct {

	// The permalink of the pipeline, which allows its access by UID.
	// - Format: `pipelines/{pipeline.uid}`.
	Permalink string `protobuf:"bytes,1,opt,name=permalink,proto3" json:"permalink,omitempty"`
	// View allows clients to specify the desired pipeline view in the response.
	View *Pipeline_View `protobuf:"varint,2,opt,name=view,proto3,enum=vdp.pipeline.v1beta.Pipeline_View,oneof" json:"view,omitempty"`
	// contains filtered or unexported fields
}

LookUpPipelineRequest represents a request to query a pipeline by its UID.

func (*LookUpPipelineRequest) Descriptor deprecated

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

Deprecated: Use LookUpPipelineRequest.ProtoReflect.Descriptor instead.

func (x *LookUpPipelineRequest) GetPermalink() string

func (*LookUpPipelineRequest) GetView

func (x *LookUpPipelineRequest) GetView() Pipeline_View

func (*LookUpPipelineRequest) ProtoMessage

func (*LookUpPipelineRequest) ProtoMessage()

func (*LookUpPipelineRequest) ProtoReflect

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

func (*LookUpPipelineRequest) Reset

func (x *LookUpPipelineRequest) Reset()

func (*LookUpPipelineRequest) String

func (x *LookUpPipelineRequest) String() string

type LookUpPipelineResponse

type LookUpPipelineResponse struct {

	// The requested pipeline.
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// contains filtered or unexported fields
}

LookUpPipelineResponse contains the requested pipeline.

func (*LookUpPipelineResponse) Descriptor deprecated

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

Deprecated: Use LookUpPipelineResponse.ProtoReflect.Descriptor instead.

func (*LookUpPipelineResponse) GetPipeline

func (x *LookUpPipelineResponse) GetPipeline() *Pipeline

func (*LookUpPipelineResponse) ProtoMessage

func (*LookUpPipelineResponse) ProtoMessage()

func (*LookUpPipelineResponse) ProtoReflect

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

func (*LookUpPipelineResponse) Reset

func (x *LookUpPipelineResponse) Reset()

func (*LookUpPipelineResponse) String

func (x *LookUpPipelineResponse) String() string

type NestedComponent

type NestedComponent struct {

	// Component ID, provided by the user on creation.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Metadata of the component.
	Metadata *structpb.Struct `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// The component configuration.
	//
	// Types that are assignable to Component:
	//
	//	*NestedComponent_ConnectorComponent
	//	*NestedComponent_OperatorComponent
	Component isNestedComponent_Component `protobuf_oneof:"component"`
	// contains filtered or unexported fields
}

NestedComponent Fundamental building block in iterator component.

func (*NestedComponent) Descriptor deprecated

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

Deprecated: Use NestedComponent.ProtoReflect.Descriptor instead.

func (*NestedComponent) GetComponent

func (m *NestedComponent) GetComponent() isNestedComponent_Component

func (*NestedComponent) GetConnectorComponent

func (x *NestedComponent) GetConnectorComponent() *ConnectorComponent

func (*NestedComponent) GetId

func (x *NestedComponent) GetId() string

func (*NestedComponent) GetMetadata

func (x *NestedComponent) GetMetadata() *structpb.Struct

func (*NestedComponent) GetOperatorComponent

func (x *NestedComponent) GetOperatorComponent() *OperatorComponent

func (*NestedComponent) ProtoMessage

func (*NestedComponent) ProtoMessage()

func (*NestedComponent) ProtoReflect

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

func (*NestedComponent) Reset

func (x *NestedComponent) Reset()

func (*NestedComponent) String

func (x *NestedComponent) String() string

type NestedComponent_ConnectorComponent

type NestedComponent_ConnectorComponent struct {
	// ConnectorConfiguration
	ConnectorComponent *ConnectorComponent `protobuf:"bytes,3,opt,name=connector_component,json=connectorComponent,proto3,oneof"`
}

type NestedComponent_OperatorComponent

type NestedComponent_OperatorComponent struct {
	// OperatorConfiguration
	OperatorComponent *OperatorComponent `protobuf:"bytes,4,opt,name=operator_component,json=operatorComponent,proto3,oneof"`
}

type OperatorComponent

type OperatorComponent struct {

	// Definition name.
	DefinitionName string `protobuf:"bytes,1,opt,name=definition_name,json=definitionName,proto3" json:"definition_name,omitempty"`
	// Operator definition.
	Definition *OperatorDefinition `protobuf:"bytes,2,opt,name=definition,proto3" json:"definition,omitempty"`
	// Task.
	Task string `protobuf:"bytes,3,opt,name=task,proto3" json:"task,omitempty"`
	// Input configuration of the component. JSON schema described in the operator definition.
	Input *structpb.Struct `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
	// Condition statement determining whether the component is executed or not.
	Condition string `protobuf:"bytes,5,opt,name=condition,proto3" json:"condition,omitempty"`
	// contains filtered or unexported fields
}

OperatorComponent Configures an operator component.

func (*OperatorComponent) Descriptor deprecated

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

Deprecated: Use OperatorComponent.ProtoReflect.Descriptor instead.

func (*OperatorComponent) GetCondition

func (x *OperatorComponent) GetCondition() string

func (*OperatorComponent) GetDefinition

func (x *OperatorComponent) GetDefinition() *OperatorDefinition

func (*OperatorComponent) GetDefinitionName

func (x *OperatorComponent) GetDefinitionName() string

func (*OperatorComponent) GetInput

func (x *OperatorComponent) GetInput() *structpb.Struct

func (*OperatorComponent) GetTask

func (x *OperatorComponent) GetTask() string

func (*OperatorComponent) ProtoMessage

func (*OperatorComponent) ProtoMessage()

func (*OperatorComponent) ProtoReflect

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

func (*OperatorComponent) Reset

func (x *OperatorComponent) Reset()

func (*OperatorComponent) String

func (x *OperatorComponent) String() string

type OperatorDefinition

type OperatorDefinition struct {

	// The name of the operator definition.
	// - Format: `operator-definitions/*`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Operator definition UUID.
	Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
	// Operator definition resource ID (used in `name` as the last segment).
	// This conforms to RFC-1034, which restricts to letters, numbers, and
	// hyphen, with the first character a letter, the last a letter or a number,
	// and a 63 character maximum.
	Id string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	// Operator definition title.
	Title string `protobuf:"bytes,4,opt,name=title,proto3" json:"title,omitempty"`
	// Operator definition documentation URL.
	DocumentationUrl string `protobuf:"bytes,5,opt,name=documentation_url,json=documentationUrl,proto3" json:"documentation_url,omitempty"`
	// Operator definition icon. This is a path that's relative to the root of
	// the operator implementation (see `source_url`) and that allows clients
	// frontend applications to pull and locate the icons.
	Icon string `protobuf:"bytes,6,opt,name=icon,proto3" json:"icon,omitempty"`
	// Operator definition specification.
	Spec *OperatorSpec `protobuf:"bytes,7,opt,name=spec,proto3" json:"spec,omitempty"`
	// Operator definition tombstone. If true, this configuration is permanently
	// off. Otherwise, the configuration is active.
	Tombstone bool `protobuf:"varint,8,opt,name=tombstone,proto3" json:"tombstone,omitempty"`
	// The public flag determines whether this operator definition is available
	// to all workspaces.
	Public bool `protobuf:"varint,9,opt,name=public,proto3" json:"public,omitempty"`
	// The custom flag determines whether this is a custom operator definition.
	Custom bool `protobuf:"varint,10,opt,name=custom,proto3" json:"custom,omitempty"`
	// Source code URL. This points to the source code where the operator is
	// implemented.
	SourceUrl string `protobuf:"bytes,15,opt,name=source_url,json=sourceUrl,proto3" json:"source_url,omitempty"`
	// Operator definition version. This is a string that fulfills the SemVer
	// specification (e.g. `1.0.0-beta`).
	Version string `protobuf:"bytes,16,opt,name=version,proto3" json:"version,omitempty"`
	// List of tasks that can be executed by the operator.
	Tasks []*ComponentTask `protobuf:"bytes,17,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// Short description of the operator.
	Description string `protobuf:"bytes,18,opt,name=description,proto3" json:"description,omitempty"`
	// Release stage.
	ReleaseStage ComponentDefinition_ReleaseStage `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

An Operator is a type of pipeline component that performs data injection and manipulation. OperatorDefinition describes a certain type of operator.

For more information, see Component(https://www.instill.tech/docs/latest/core/concepts/pipeline#pipeline-component) in the official documentation.

func (*OperatorDefinition) Descriptor deprecated

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

Deprecated: Use OperatorDefinition.ProtoReflect.Descriptor instead.

func (*OperatorDefinition) GetCustom

func (x *OperatorDefinition) GetCustom() bool

func (*OperatorDefinition) GetDescription

func (x *OperatorDefinition) GetDescription() string

func (*OperatorDefinition) GetDocumentationUrl

func (x *OperatorDefinition) GetDocumentationUrl() string

func (*OperatorDefinition) GetIcon

func (x *OperatorDefinition) GetIcon() string

func (*OperatorDefinition) GetId

func (x *OperatorDefinition) GetId() string

func (*OperatorDefinition) GetName

func (x *OperatorDefinition) GetName() string

func (*OperatorDefinition) GetPublic

func (x *OperatorDefinition) GetPublic() bool

func (*OperatorDefinition) GetReleaseStage

func (*OperatorDefinition) GetSourceUrl

func (x *OperatorDefinition) GetSourceUrl() string

func (*OperatorDefinition) GetSpec

func (x *OperatorDefinition) GetSpec() *OperatorSpec

func (*OperatorDefinition) GetTasks

func (x *OperatorDefinition) GetTasks() []*ComponentTask

func (*OperatorDefinition) GetTitle

func (x *OperatorDefinition) GetTitle() string

func (*OperatorDefinition) GetTombstone

func (x *OperatorDefinition) GetTombstone() bool

func (*OperatorDefinition) GetUid

func (x *OperatorDefinition) GetUid() string

func (*OperatorDefinition) GetVersion

func (x *OperatorDefinition) GetVersion() string

func (*OperatorDefinition) ProtoMessage

func (*OperatorDefinition) ProtoMessage()

func (*OperatorDefinition) ProtoReflect

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

func (*OperatorDefinition) Reset

func (x *OperatorDefinition) Reset()

func (*OperatorDefinition) String

func (x *OperatorDefinition) String() string

type OperatorSpec

type OperatorSpec struct {

	// Component specification.
	ComponentSpecification *structpb.Struct `` /* 127-byte string literal not displayed */
	// Data specifications.
	// The key represents the task, and the value is the corresponding data_specification.
	DataSpecifications map[string]*DataSpecification `` /* 203-byte string literal not displayed */
	// contains filtered or unexported fields
}

OperatorSpec represents a specification data model.

func (*OperatorSpec) Descriptor deprecated

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

Deprecated: Use OperatorSpec.ProtoReflect.Descriptor instead.

func (*OperatorSpec) GetComponentSpecification

func (x *OperatorSpec) GetComponentSpecification() *structpb.Struct

func (*OperatorSpec) GetDataSpecifications

func (x *OperatorSpec) GetDataSpecifications() map[string]*DataSpecification

func (*OperatorSpec) ProtoMessage

func (*OperatorSpec) ProtoMessage()

func (*OperatorSpec) ProtoReflect

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

func (*OperatorSpec) Reset

func (x *OperatorSpec) Reset()

func (*OperatorSpec) String

func (x *OperatorSpec) String() string

type Permission

type Permission struct {

	// Defines whether the resource can be modified.
	CanEdit bool `protobuf:"varint,1,opt,name=can_edit,json=canEdit,proto3" json:"can_edit,omitempty"`
	// Defines whether the resource can be executed.
	CanTrigger bool `protobuf:"varint,2,opt,name=can_trigger,json=canTrigger,proto3" json:"can_trigger,omitempty"`
	// contains filtered or unexported fields
}

Permission defines how a resource can be used.

func (*Permission) Descriptor deprecated

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

Deprecated: Use Permission.ProtoReflect.Descriptor instead.

func (*Permission) GetCanEdit

func (x *Permission) GetCanEdit() bool

func (*Permission) GetCanTrigger

func (x *Permission) GetCanTrigger() bool

func (*Permission) ProtoMessage

func (*Permission) ProtoMessage()

func (*Permission) ProtoReflect

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

func (*Permission) Reset

func (x *Permission) Reset()

func (*Permission) String

func (x *Permission) String() string

type Pipeline

type Pipeline struct {

	// The name of the pipeline, defined by its parent and ID.
	// - Format: `{parent_type}/{parent.id}/pipelines/{pipeline.id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Pipeline UUID.
	Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
	// Pipeline resource ID (used in `name` as the last segment). This conforms
	// to RFC-1034, which restricts to letters, numbers, and hyphen, with the
	// first character a letter, the last a letter or a number, and a 63
	// character maximum.
	Id string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	// Pipeline description.
	Description *string `protobuf:"bytes,4,opt,name=description,proto3,oneof" json:"description,omitempty"`
	// Recipe describes the components of a Pipeline and how they are connected.
	Recipe *Recipe `protobuf:"bytes,5,opt,name=recipe,proto3" json:"recipe,omitempty"`
	// Pipeline creation time.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Pipeline update time.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Pipeline delete time.
	DeleteTime *timestamppb.Timestamp `protobuf:"bytes,14,opt,name=delete_time,json=deleteTime,proto3" json:"delete_time,omitempty"`
	// Pipeline sharing information.
	Sharing *Sharing `protobuf:"bytes,15,opt,name=sharing,proto3" json:"sharing,omitempty"`
	// Metadata holds console-related data such as the pipeline builder layout.
	Metadata *structpb.Struct `protobuf:"bytes,16,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Owner Name.
	OwnerName string `protobuf:"bytes,17,opt,name=owner_name,json=ownerName,proto3" json:"owner_name,omitempty"`
	// Releases holds the history of pipeline versions.
	Releases []*PipelineRelease `protobuf:"bytes,19,rep,name=releases,proto3" json:"releases,omitempty"`
	// README holds the pipeline documentation.
	Readme string `protobuf:"bytes,20,opt,name=readme,proto3" json:"readme,omitempty"`
	// Permission defines how a pipeline can be used.
	Permission *Permission `protobuf:"bytes,21,opt,name=permission,proto3" json:"permission,omitempty"`
	// Pipeline visibility.
	Visibility Pipeline_Visibility `protobuf:"varint,22,opt,name=visibility,proto3,enum=vdp.pipeline.v1beta.Pipeline_Visibility" json:"visibility,omitempty"`
	// Pipeline owner.
	Owner *v1beta1.Owner `protobuf:"bytes,23,opt,name=owner,proto3,oneof" json:"owner,omitempty"`
	// Data specifications.
	DataSpecification *DataSpecification `protobuf:"bytes,24,opt,name=data_specification,json=dataSpecification,proto3" json:"data_specification,omitempty"`
	// contains filtered or unexported fields
}

A Pipeline is an end-to-end workflow that automates a sequence of components to process data.

For more information, see Pipeline(https://www.instill.tech/docs/latest/core/concepts/pipeline) in the official documentation.

func (*Pipeline) Descriptor deprecated

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

Deprecated: Use Pipeline.ProtoReflect.Descriptor instead.

func (*Pipeline) GetCreateTime

func (x *Pipeline) GetCreateTime() *timestamppb.Timestamp

func (*Pipeline) GetDataSpecification

func (x *Pipeline) GetDataSpecification() *DataSpecification

func (*Pipeline) GetDeleteTime

func (x *Pipeline) GetDeleteTime() *timestamppb.Timestamp

func (*Pipeline) GetDescription

func (x *Pipeline) GetDescription() string

func (*Pipeline) GetId

func (x *Pipeline) GetId() string

func (*Pipeline) GetMetadata

func (x *Pipeline) GetMetadata() *structpb.Struct

func (*Pipeline) GetName

func (x *Pipeline) GetName() string

func (*Pipeline) GetOwner

func (x *Pipeline) GetOwner() *v1beta1.Owner

func (*Pipeline) GetOwnerName

func (x *Pipeline) GetOwnerName() string

func (*Pipeline) GetPermission

func (x *Pipeline) GetPermission() *Permission

func (*Pipeline) GetReadme

func (x *Pipeline) GetReadme() string

func (*Pipeline) GetRecipe

func (x *Pipeline) GetRecipe() *Recipe

func (*Pipeline) GetReleases

func (x *Pipeline) GetReleases() []*PipelineRelease

func (*Pipeline) GetSharing

func (x *Pipeline) GetSharing() *Sharing

func (*Pipeline) GetUid

func (x *Pipeline) GetUid() string

func (*Pipeline) GetUpdateTime

func (x *Pipeline) GetUpdateTime() *timestamppb.Timestamp

func (*Pipeline) GetVisibility

func (x *Pipeline) GetVisibility() Pipeline_Visibility

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 PipelinePrivateServiceClient

type PipelinePrivateServiceClient interface {
	// List pipelines (admin only)
	//
	// This is a *private* method that allows admin users and internal clients to
	// list *all* pipeline resources.
	ListPipelinesAdmin(ctx context.Context, in *ListPipelinesAdminRequest, opts ...grpc.CallOption) (*ListPipelinesAdminResponse, error)
	// Get a pipeline by UID (admin only)
	//
	// This is a *private* method that allows admin users to access any pipeline
	// resource by its UID.
	LookUpPipelineAdmin(ctx context.Context, in *LookUpPipelineAdminRequest, opts ...grpc.CallOption) (*LookUpPipelineAdminResponse, error)
	// List pipeline releases (admin only)
	//
	// This is a *private* method that allows admin users to list *all* pipeline
	// releases.
	ListPipelineReleasesAdmin(ctx context.Context, in *ListPipelineReleasesAdminRequest, opts ...grpc.CallOption) (*ListPipelineReleasesAdminResponse, error)
}

PipelinePrivateServiceClient is the client API for PipelinePrivateService service.

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

type PipelinePrivateServiceServer

type PipelinePrivateServiceServer interface {
	// List pipelines (admin only)
	//
	// This is a *private* method that allows admin users and internal clients to
	// list *all* pipeline resources.
	ListPipelinesAdmin(context.Context, *ListPipelinesAdminRequest) (*ListPipelinesAdminResponse, error)
	// Get a pipeline by UID (admin only)
	//
	// This is a *private* method that allows admin users to access any pipeline
	// resource by its UID.
	LookUpPipelineAdmin(context.Context, *LookUpPipelineAdminRequest) (*LookUpPipelineAdminResponse, error)
	// List pipeline releases (admin only)
	//
	// This is a *private* method that allows admin users to list *all* pipeline
	// releases.
	ListPipelineReleasesAdmin(context.Context, *ListPipelineReleasesAdminRequest) (*ListPipelineReleasesAdminResponse, error)
}

PipelinePrivateServiceServer is the server API for PipelinePrivateService service. All implementations should embed UnimplementedPipelinePrivateServiceServer for forward compatibility

type PipelinePublicServiceClient

type PipelinePublicServiceClient interface {
	// Check if the pipeline server is alive
	//
	// See https://github.com/grpc/grpc/blob/master/doc/health-checking.md.
	Liveness(ctx context.Context, in *LivenessRequest, opts ...grpc.CallOption) (*LivenessResponse, error)
	// Check if the pipeline server is ready
	//
	// See https://github.com/grpc/grpc/blob/master/doc/health-checking.md
	Readiness(ctx context.Context, in *ReadinessRequest, opts ...grpc.CallOption) (*ReadinessResponse, error)
	// List accessible pipelines
	//
	// Returns a paginated list of pipelines that are visible to the requester.
	ListPipelines(ctx context.Context, in *ListPipelinesRequest, opts ...grpc.CallOption) (*ListPipelinesResponse, error)
	// Get a pipeline by UID
	//
	// Returns the details of a pipeline by a permalink defined by the resource
	// UID.
	LookUpPipeline(ctx context.Context, in *LookUpPipelineRequest, opts ...grpc.CallOption) (*LookUpPipelineResponse, error)
	// Create a new user pipeline
	//
	// Creates a new pipeline under the parenthood of a user. Users can only
	// create a pipeline as the parent of that resource (i.e. the authenticated
	// user must match the `parent` path parameter).
	CreateUserPipeline(ctx context.Context, in *CreateUserPipelineRequest, opts ...grpc.CallOption) (*CreateUserPipelineResponse, error)
	// List user pipelines
	//
	// Returns a paginated list of pipelines that belong to the specified user.
	// The parent user may be different from the authenticated user, in which
	// case the results will contain the pipelines that are visible to the
	// latter.
	ListUserPipelines(ctx context.Context, in *ListUserPipelinesRequest, opts ...grpc.CallOption) (*ListUserPipelinesResponse, error)
	// Get a pipeline owned by a user
	//
	// Returns the details of a user-owned pipeline by its resource name, which is defined
	// by the parent user and the ID of the pipeline.
	GetUserPipeline(ctx context.Context, in *GetUserPipelineRequest, opts ...grpc.CallOption) (*GetUserPipelineResponse, error)
	// Update a pipeline owned by a user
	//
	// Udpates a pipeline, accessing it by its resource name, which is defined by
	// the parent user and the ID of the pipeline. The authenticated user must be
	// the parent of the pipeline in order to modify it.
	//
	// In REST requests, only the supplied pipeline fields will be taken into
	// account when updating the resource.
	UpdateUserPipeline(ctx context.Context, in *UpdateUserPipelineRequest, opts ...grpc.CallOption) (*UpdateUserPipelineResponse, error)
	// Delete a pipeline owned by a user
	//
	// Deletes a pipeline, accesing it by its resource name, which is defined by
	// the parent user and the ID of the pipeline. The authenticated user must be
	// the parent of the pipeline in order to delete it.
	DeleteUserPipeline(ctx context.Context, in *DeleteUserPipelineRequest, opts ...grpc.CallOption) (*DeleteUserPipelineResponse, error)
	// Validate a pipeline a pipeline owned by a user
	//
	// Validates a pipeline by its resource name, which is defined by the parent
	// user and the ID of the pipeline.
	//
	// Validation checks the recipe of the pipeline and the status of its components.
	ValidateUserPipeline(ctx context.Context, in *ValidateUserPipelineRequest, opts ...grpc.CallOption) (*ValidateUserPipelineResponse, error)
	// Rename a pipeline owned by a user
	//
	// Updates the ID of a pipeline. Since this is an output-only field, a custom
	// method is required to modify it.
	//
	// The pipeline name will be updated accordingly, as it is  composed by the
	// parent user and ID of the pipeline (e.g.
	// `users/luigi/pipelines/pizza-recipe-generator`).
	//
	// The authenticated user must be the parent of the pipeline in order to
	// perform this action.
	RenameUserPipeline(ctx context.Context, in *RenameUserPipelineRequest, opts ...grpc.CallOption) (*RenameUserPipelineResponse, error)
	// Clone a pipeline owned by a user
	//
	// Clones a pipeline owned by a user. The new pipeline may have a different
	// parent, and this can be either a user or an organization.
	CloneUserPipeline(ctx context.Context, in *CloneUserPipelineRequest, opts ...grpc.CallOption) (*CloneUserPipelineResponse, error)
	// Trigger a pipeline owned by a user
	//
	// Triggers the execution of a pipeline synchronously, i.e., the result is
	// sent back to the user right after the data is processed. This method is
	// intended for real-time inference when low latency is of concern.
	//
	// The pipeline is identified by its resource name, formed by the parent user
	// and ID of the pipeline.
	//
	// For more information, see [Trigger
	// Pipeline](https://www.instill.tech/docs/latest/core/concepts/pipeline#trigger-pipeline).
	TriggerUserPipeline(ctx context.Context, in *TriggerUserPipelineRequest, opts ...grpc.CallOption) (*TriggerUserPipelineResponse, error)
	// Trigger a pipeline owned by a user asynchronously
	//
	// Triggers the execution of a pipeline asynchronously, i.e., the result
	// contains the necessary information to access the result and status of the
	// operation. This method is intended for cases that require long-running
	// workloads.
	//
	// The pipeline is identified by its resource name, formed by the parent user
	// and ID of the pipeline.
	//
	// For more information, see [Trigger
	// Pipeline](https://www.instill.tech/docs/latest/core/concepts/pipeline#trigger-pipeline).
	TriggerAsyncUserPipeline(ctx context.Context, in *TriggerAsyncUserPipelineRequest, opts ...grpc.CallOption) (*TriggerAsyncUserPipelineResponse, error)
	// Release a version of a pipeline owned by a user
	//
	// Commits the version of a pipeline, identified by its resource name, which
	// is formed by the parent user and ID of the pipeline.
	//
	// The authenticated user must be the parent of the pipeline in order to
	// perform this action.
	CreateUserPipelineRelease(ctx context.Context, in *CreateUserPipelineReleaseRequest, opts ...grpc.CallOption) (*CreateUserPipelineReleaseResponse, error)
	// List the releases in a pipeline owned by a user
	//
	// Lists the commited versions of a pipeline, identified by its resource
	// name, which is formed by the parent user and ID of the pipeline.
	ListUserPipelineReleases(ctx context.Context, in *ListUserPipelineReleasesRequest, opts ...grpc.CallOption) (*ListUserPipelineReleasesResponse, error)
	// Get a release in a pipeline owned by a user
	//
	// Gets the details of a pipeline release, where the pipeline is identified
	// by its resource name, formed by its parent user and ID.
	GetUserPipelineRelease(ctx context.Context, in *GetUserPipelineReleaseRequest, opts ...grpc.CallOption) (*GetUserPipelineReleaseResponse, error)
	// Update a release in a pipeline owned by a user
	//
	// Updates the details of a pipeline release, where the pipeline is
	// identified by its resource name, formed by its parent user and ID.
	//
	// The authenticated user must be the parent of the pipeline in order to
	// perform this action.
	UpdateUserPipelineRelease(ctx context.Context, in *UpdateUserPipelineReleaseRequest, opts ...grpc.CallOption) (*UpdateUserPipelineReleaseResponse, error)
	// Delete a release in a pipeline owned by a user
	//
	// Deletes a pipeline release, where the pipeline is identified by its
	// resource name, formed by its parent user and ID.
	//
	// The authenticated user must be the parent of the pipeline in order to
	// perform this action.
	DeleteUserPipelineRelease(ctx context.Context, in *DeleteUserPipelineReleaseRequest, opts ...grpc.CallOption) (*DeleteUserPipelineReleaseResponse, error)
	// Set the version of a pipeline owned by a user to a pinned release
	//
	// Sets the pipeline configuration to a pinned version defined by a release.
	//
	// The pipeline is identified by its resource name, formed by its parent user
	// and ID.
	//
	// The authenticated user must be the parent of the pipeline in order to
	// perform this action.
	RestoreUserPipelineRelease(ctx context.Context, in *RestoreUserPipelineReleaseRequest, opts ...grpc.CallOption) (*RestoreUserPipelineReleaseResponse, error)
	// Rename a release in a pipeline owned by a user
	//
	// Updates the ID of a pipeline release, where the pipeline is identified by
	// its resource name, formed by the parent user and ID. Since this is an
	// output-only field, a custom method is required to modify it.
	//
	// The pipeline release name will be updated accordingly, as it is  composed
	// by the pipeline name and the ID of the release (e.g.
	// `users/luigi/pipelines/pizza-recipe-generator/releases/v0.2.1`).
	//
	// The authenticated user must be the parent of the pipeline in order to
	// perform this action.
	RenameUserPipelineRelease(ctx context.Context, in *RenameUserPipelineReleaseRequest, opts ...grpc.CallOption) (*RenameUserPipelineReleaseResponse, error)
	// Trigger a version of a pipeline owned by a user
	//
	// Triggers the synchronous execution of of a pipeline. While the trigger
	// endpoint (where the release version isn't specified) triggers the pipeline
	// at its latest release, this method allows the client to specified any
	// committed release.
	//
	// The pipeline is identified by its resource name, formed by its parent user
	// and ID.
	TriggerUserPipelineRelease(ctx context.Context, in *TriggerUserPipelineReleaseRequest, opts ...grpc.CallOption) (*TriggerUserPipelineReleaseResponse, error)
	// Trigger a version of a pipeline owned by a user asynchronously
	//
	// Triggers the asynchronous execution of of a pipeline. While the trigger
	// endpoint (where the release version isn't specified) triggers the pipeline
	// at its latest release, this method allows the client to specified any
	// committed release.
	//
	// The pipeline is identified by its resource name, formed by its parent user
	// and ID.
	TriggerAsyncUserPipelineRelease(ctx context.Context, in *TriggerAsyncUserPipelineReleaseRequest, opts ...grpc.CallOption) (*TriggerAsyncUserPipelineReleaseResponse, error)
	// Create a new organization pipeline
	//
	// Creates a new pipeline under the parenthood of an organization.
	CreateOrganizationPipeline(ctx context.Context, in *CreateOrganizationPipelineRequest, opts ...grpc.CallOption) (*CreateOrganizationPipelineResponse, error)
	// List organization pipelines
	//
	// Returns a paginated list of pipelines that belong to the specified
	// organization.
	ListOrganizationPipelines(ctx context.Context, in *ListOrganizationPipelinesRequest, opts ...grpc.CallOption) (*ListOrganizationPipelinesResponse, error)
	// Get a pipeline owned by an organization
	//
	// Returns the details of an organization-owned pipeline by its resource name,
	// which is defined by the parent organization and the ID of the pipeline.
	GetOrganizationPipeline(ctx context.Context, in *GetOrganizationPipelineRequest, opts ...grpc.CallOption) (*GetOrganizationPipelineResponse, error)
	// Update a pipeline owned by an organization
	//
	// # Udpates a pipeline, accessing it by its resource name, which is defined by
	//
	// In REST requests, only the supplied pipeline fields will be taken into
	// account when updating the resource.
	UpdateOrganizationPipeline(ctx context.Context, in *UpdateOrganizationPipelineRequest, opts ...grpc.CallOption) (*UpdateOrganizationPipelineResponse, error)
	// Delete a pipeline owned by an organization
	//
	// Deletes a pipeline, accesing it by its resource name, which is defined by
	// the parent organization and the ID of the pipeline.
	DeleteOrganizationPipeline(ctx context.Context, in *DeleteOrganizationPipelineRequest, opts ...grpc.CallOption) (*DeleteOrganizationPipelineResponse, error)
	// Validate a pipeline a pipeline owned by an organization
	//
	// Validates a pipeline by its resource name, which is defined by the parent
	// organization and the ID of the pipeline.
	//
	// Validation checks the recipe of the pipeline and the status of its
	// components.
	ValidateOrganizationPipeline(ctx context.Context, in *ValidateOrganizationPipelineRequest, opts ...grpc.CallOption) (*ValidateOrganizationPipelineResponse, error)
	// Rename a pipeline owned by an organization
	//
	// Updates the ID of a pipeline. Since this is an output-only field, a custom
	// method is required to modify it.
	//
	// The pipeline name will be updated accordingly, as it is  composed by the
	// parent organization and ID of the pipeline (e.g.
	// `organizations/luigi/pipelines/pizza-recipe-generator`).
	RenameOrganizationPipeline(ctx context.Context, in *RenameOrganizationPipelineRequest, opts ...grpc.CallOption) (*RenameOrganizationPipelineResponse, error)
	// Clone a pipeline owned by an organization
	//
	// Clones a pipeline owned by an organization. The new pipeline may have a
	// different parent, and this can be either a user or an organization.
	CloneOrganizationPipeline(ctx context.Context, in *CloneOrganizationPipelineRequest, opts ...grpc.CallOption) (*CloneOrganizationPipelineResponse, error)
	// Trigger a pipeline owned by an organization
	//
	// Triggers the execution of a pipeline synchronously, i.e., the result is sent
	// back to the organization right after the data is processed. This method is
	// intended for real-time inference when low latency is of concern.
	//
	// The pipeline is identified by its resource name, formed by the parent
	// organization and ID of the pipeline.
	//
	// For more information, see [Trigger
	// Pipeline](https://www.instill.tech/docs/latest/core/concepts/pipeline#trigger-pipeline).
	TriggerOrganizationPipeline(ctx context.Context, in *TriggerOrganizationPipelineRequest, opts ...grpc.CallOption) (*TriggerOrganizationPipelineResponse, error)
	// Trigger a pipeline owned by an organization asynchronously
	//
	// Triggers the execution of a pipeline asynchronously, i.e., the result
	// contains the necessary information to access the result and status of the
	// operation. This method is intended for cases that require long-running
	// workloads.
	//
	// The pipeline is identified by its resource name, formed by the parent
	// organization and ID of the pipeline.
	//
	// For more information, see [Trigger
	// Pipeline](https://www.instill.tech/docs/latest/core/concepts/pipeline#trigger-pipeline).
	TriggerAsyncOrganizationPipeline(ctx context.Context, in *TriggerAsyncOrganizationPipelineRequest, opts ...grpc.CallOption) (*TriggerAsyncOrganizationPipelineResponse, error)
	// Release a version of a pipeline owned by an organization
	//
	// Commits the version of a pipeline, identified by its resource name, which is
	// formed by the parent organization and ID of the pipeline.
	CreateOrganizationPipelineRelease(ctx context.Context, in *CreateOrganizationPipelineReleaseRequest, opts ...grpc.CallOption) (*CreateOrganizationPipelineReleaseResponse, error)
	// List the releases in a pipeline owned by an organization
	//
	// Lists the commited versions of a pipeline, identified by its resource name,
	// which is formed by the parent organization and ID of the pipeline.
	ListOrganizationPipelineReleases(ctx context.Context, in *ListOrganizationPipelineReleasesRequest, opts ...grpc.CallOption) (*ListOrganizationPipelineReleasesResponse, error)
	// Get a release in a pipeline owned by an organization
	//
	// Gets the details of a pipeline release, where the pipeline is identified by
	// its resource name, formed by its parent organization and ID.
	GetOrganizationPipelineRelease(ctx context.Context, in *GetOrganizationPipelineReleaseRequest, opts ...grpc.CallOption) (*GetOrganizationPipelineReleaseResponse, error)
	// Update a release in a pipeline owned by an organization
	//
	// Updates the details of a pipeline release, where the pipeline is identified
	// by its resource name, formed by its parent organization and ID.
	UpdateOrganizationPipelineRelease(ctx context.Context, in *UpdateOrganizationPipelineReleaseRequest, opts ...grpc.CallOption) (*UpdateOrganizationPipelineReleaseResponse, error)
	// Delete a release in a pipeline owned by an organization
	//
	// Deletes a pipeline release, where the pipeline is identified by its resource
	// name, formed by its parent organization and ID.
	DeleteOrganizationPipelineRelease(ctx context.Context, in *DeleteOrganizationPipelineReleaseRequest, opts ...grpc.CallOption) (*DeleteOrganizationPipelineReleaseResponse, error)
	// Set the version of a pipeline owned by an organization to a pinned release
	//
	// Sets the pipeline configuration to a pinned version defined by a release.
	//
	// The pipeline is identified by its resource name, formed by its parent
	// organization and ID.
	RestoreOrganizationPipelineRelease(ctx context.Context, in *RestoreOrganizationPipelineReleaseRequest, opts ...grpc.CallOption) (*RestoreOrganizationPipelineReleaseResponse, error)
	// Rename a release in a pipeline owned by an organization
	//
	// Updates the ID of a pipeline release, where the pipeline is identified by
	// its resource name, formed by the parent organization and ID. Since this is
	// an output-only field, a custom method is required to modify it.
	//
	// The pipeline release name will be updated accordingly, as it is  composed by
	// the pipeline name and the ID of the release (e.g.
	// `organizations/luigi/pipelines/pizza-recipe-generator/releases/v0.2.1`).
	RenameOrganizationPipelineRelease(ctx context.Context, in *RenameOrganizationPipelineReleaseRequest, opts ...grpc.CallOption) (*RenameOrganizationPipelineReleaseResponse, error)
	// Trigger a version of a pipeline owned by an organization
	//
	// Triggers the synchronous execution of of a pipeline. While the trigger
	// endpoint (where the release version isn't specified) triggers the pipeline
	// at its latest release, this method allows the client to specified any
	// committed release.
	//
	// The pipeline is identified by its resource name, formed by its parent
	// organization and ID.
	TriggerOrganizationPipelineRelease(ctx context.Context, in *TriggerOrganizationPipelineReleaseRequest, opts ...grpc.CallOption) (*TriggerOrganizationPipelineReleaseResponse, error)
	// Trigger a version of a pipeline owned by an organization asynchronously
	//
	// Triggers the asynchronous execution of of a pipeline. While the trigger
	// endpoint (where the release version isn't specified) triggers the pipeline
	// at its latest release, this method allows the client to specified any
	// committed release.
	//
	// The pipeline is identified by its resource name, formed by its parent
	// organization and ID.
	TriggerAsyncOrganizationPipelineRelease(ctx context.Context, in *TriggerAsyncOrganizationPipelineReleaseRequest, opts ...grpc.CallOption) (*TriggerAsyncOrganizationPipelineReleaseResponse, error)
	// Get the details of a long-running operation
	//
	// This method allows requesters to request the status and outcome of
	// long-running operations such as asynchronous pipeline triggers.
	GetOperation(ctx context.Context, in *GetOperationRequest, opts ...grpc.CallOption) (*GetOperationResponse, error)
	// List connector definitions
	//
	// Returns a paginated list of connector definitions.
	ListConnectorDefinitions(ctx context.Context, in *ListConnectorDefinitionsRequest, opts ...grpc.CallOption) (*ListConnectorDefinitionsResponse, error)
	// Get connector definition
	//
	// Returns the details of a connector definition.
	GetConnectorDefinition(ctx context.Context, in *GetConnectorDefinitionRequest, opts ...grpc.CallOption) (*GetConnectorDefinitionResponse, error)
	// List operator definitions
	//
	// Returns a paginated list of operator definitions.
	ListOperatorDefinitions(ctx context.Context, in *ListOperatorDefinitionsRequest, opts ...grpc.CallOption) (*ListOperatorDefinitionsResponse, error)
	// List component definitions
	//
	// Returns a paginated list of component definitions, regardless their type.
	// This offers a single source of truth, with pagination and filter
	// capabilities, for the components that might be used in a VDP pipeline.
	ListComponentDefinitions(ctx context.Context, in *ListComponentDefinitionsRequest, opts ...grpc.CallOption) (*ListComponentDefinitionsResponse, error)
	// Get operator definition
	//
	// Returns the details of an operator definition.
	GetOperatorDefinition(ctx context.Context, in *GetOperatorDefinitionRequest, opts ...grpc.CallOption) (*GetOperatorDefinitionResponse, error)
	// Check the availibity of a resource name
	//
	// Check whether a resource name is already in use. Currently this endpoint
	// only supports pipeline and connector resource names.
	CheckName(ctx context.Context, in *CheckNameRequest, opts ...grpc.CallOption) (*CheckNameResponse, error)
	// Create a new user secret
	//
	// Creates a new secret under the parenthood of an user.
	CreateUserSecret(ctx context.Context, in *CreateUserSecretRequest, opts ...grpc.CallOption) (*CreateUserSecretResponse, error)
	// List user secrets
	//
	// Returns a paginated list of secrets that belong to the specified
	// user.
	ListUserSecrets(ctx context.Context, in *ListUserSecretsRequest, opts ...grpc.CallOption) (*ListUserSecretsResponse, error)
	// Get a secret owned by an user
	//
	// Returns the details of an user-owned secret by its resource name,
	// which is defined by the parent user and the ID of the secret.
	GetUserSecret(ctx context.Context, in *GetUserSecretRequest, opts ...grpc.CallOption) (*GetUserSecretResponse, error)
	// Update a secret owned by an user
	//
	// # Udpates a secret, accessing it by its resource name, which is defined by
	//
	// In REST requests, only the supplied secret fields will be taken into
	// account when updating the resource.
	UpdateUserSecret(ctx context.Context, in *UpdateUserSecretRequest, opts ...grpc.CallOption) (*UpdateUserSecretResponse, error)
	// Delete a secret owned by an user
	//
	// Deletes a secret, accesing it by its resource name, which is defined by
	// the parent user and the ID of the secret.
	DeleteUserSecret(ctx context.Context, in *DeleteUserSecretRequest, opts ...grpc.CallOption) (*DeleteUserSecretResponse, error)
	// Create a new organization secret
	//
	// Creates a new secret under the parenthood of an organization.
	CreateOrganizationSecret(ctx context.Context, in *CreateOrganizationSecretRequest, opts ...grpc.CallOption) (*CreateOrganizationSecretResponse, error)
	// List organization secrets
	//
	// Returns a paginated list of secrets that belong to the specified
	// organization.
	ListOrganizationSecrets(ctx context.Context, in *ListOrganizationSecretsRequest, opts ...grpc.CallOption) (*ListOrganizationSecretsResponse, error)
	// Get a secret owned by an organization
	//
	// Returns the details of an organization-owned secret by its resource name,
	// which is defined by the parent organization and the ID of the secret.
	GetOrganizationSecret(ctx context.Context, in *GetOrganizationSecretRequest, opts ...grpc.CallOption) (*GetOrganizationSecretResponse, error)
	// Update a secret owned by an organization
	//
	// # Udpates a secret, accessing it by its resource name, which is defined by
	//
	// In REST requests, only the supplied secret fields will be taken into
	// account when updating the resource.
	UpdateOrganizationSecret(ctx context.Context, in *UpdateOrganizationSecretRequest, opts ...grpc.CallOption) (*UpdateOrganizationSecretResponse, error)
	// Delete a secret owned by an organization
	//
	// Deletes a secret, accesing it by its resource name, which is defined by
	// the parent organization and the ID of the secret.
	DeleteOrganizationSecret(ctx context.Context, in *DeleteOrganizationSecretRequest, opts ...grpc.CallOption) (*DeleteOrganizationSecretResponse, error)
}

PipelinePublicServiceClient is the client API for PipelinePublicService service.

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

type PipelinePublicServiceServer

type PipelinePublicServiceServer interface {
	// Check if the pipeline server is alive
	//
	// See https://github.com/grpc/grpc/blob/master/doc/health-checking.md.
	Liveness(context.Context, *LivenessRequest) (*LivenessResponse, error)
	// Check if the pipeline server is ready
	//
	// See https://github.com/grpc/grpc/blob/master/doc/health-checking.md
	Readiness(context.Context, *ReadinessRequest) (*ReadinessResponse, error)
	// List accessible pipelines
	//
	// Returns a paginated list of pipelines that are visible to the requester.
	ListPipelines(context.Context, *ListPipelinesRequest) (*ListPipelinesResponse, error)
	// Get a pipeline by UID
	//
	// Returns the details of a pipeline by a permalink defined by the resource
	// UID.
	LookUpPipeline(context.Context, *LookUpPipelineRequest) (*LookUpPipelineResponse, error)
	// Create a new user pipeline
	//
	// Creates a new pipeline under the parenthood of a user. Users can only
	// create a pipeline as the parent of that resource (i.e. the authenticated
	// user must match the `parent` path parameter).
	CreateUserPipeline(context.Context, *CreateUserPipelineRequest) (*CreateUserPipelineResponse, error)
	// List user pipelines
	//
	// Returns a paginated list of pipelines that belong to the specified user.
	// The parent user may be different from the authenticated user, in which
	// case the results will contain the pipelines that are visible to the
	// latter.
	ListUserPipelines(context.Context, *ListUserPipelinesRequest) (*ListUserPipelinesResponse, error)
	// Get a pipeline owned by a user
	//
	// Returns the details of a user-owned pipeline by its resource name, which is defined
	// by the parent user and the ID of the pipeline.
	GetUserPipeline(context.Context, *GetUserPipelineRequest) (*GetUserPipelineResponse, error)
	// Update a pipeline owned by a user
	//
	// Udpates a pipeline, accessing it by its resource name, which is defined by
	// the parent user and the ID of the pipeline. The authenticated user must be
	// the parent of the pipeline in order to modify it.
	//
	// In REST requests, only the supplied pipeline fields will be taken into
	// account when updating the resource.
	UpdateUserPipeline(context.Context, *UpdateUserPipelineRequest) (*UpdateUserPipelineResponse, error)
	// Delete a pipeline owned by a user
	//
	// Deletes a pipeline, accesing it by its resource name, which is defined by
	// the parent user and the ID of the pipeline. The authenticated user must be
	// the parent of the pipeline in order to delete it.
	DeleteUserPipeline(context.Context, *DeleteUserPipelineRequest) (*DeleteUserPipelineResponse, error)
	// Validate a pipeline a pipeline owned by a user
	//
	// Validates a pipeline by its resource name, which is defined by the parent
	// user and the ID of the pipeline.
	//
	// Validation checks the recipe of the pipeline and the status of its components.
	ValidateUserPipeline(context.Context, *ValidateUserPipelineRequest) (*ValidateUserPipelineResponse, error)
	// Rename a pipeline owned by a user
	//
	// Updates the ID of a pipeline. Since this is an output-only field, a custom
	// method is required to modify it.
	//
	// The pipeline name will be updated accordingly, as it is  composed by the
	// parent user and ID of the pipeline (e.g.
	// `users/luigi/pipelines/pizza-recipe-generator`).
	//
	// The authenticated user must be the parent of the pipeline in order to
	// perform this action.
	RenameUserPipeline(context.Context, *RenameUserPipelineRequest) (*RenameUserPipelineResponse, error)
	// Clone a pipeline owned by a user
	//
	// Clones a pipeline owned by a user. The new pipeline may have a different
	// parent, and this can be either a user or an organization.
	CloneUserPipeline(context.Context, *CloneUserPipelineRequest) (*CloneUserPipelineResponse, error)
	// Trigger a pipeline owned by a user
	//
	// Triggers the execution of a pipeline synchronously, i.e., the result is
	// sent back to the user right after the data is processed. This method is
	// intended for real-time inference when low latency is of concern.
	//
	// The pipeline is identified by its resource name, formed by the parent user
	// and ID of the pipeline.
	//
	// For more information, see [Trigger
	// Pipeline](https://www.instill.tech/docs/latest/core/concepts/pipeline#trigger-pipeline).
	TriggerUserPipeline(context.Context, *TriggerUserPipelineRequest) (*TriggerUserPipelineResponse, error)
	// Trigger a pipeline owned by a user asynchronously
	//
	// Triggers the execution of a pipeline asynchronously, i.e., the result
	// contains the necessary information to access the result and status of the
	// operation. This method is intended for cases that require long-running
	// workloads.
	//
	// The pipeline is identified by its resource name, formed by the parent user
	// and ID of the pipeline.
	//
	// For more information, see [Trigger
	// Pipeline](https://www.instill.tech/docs/latest/core/concepts/pipeline#trigger-pipeline).
	TriggerAsyncUserPipeline(context.Context, *TriggerAsyncUserPipelineRequest) (*TriggerAsyncUserPipelineResponse, error)
	// Release a version of a pipeline owned by a user
	//
	// Commits the version of a pipeline, identified by its resource name, which
	// is formed by the parent user and ID of the pipeline.
	//
	// The authenticated user must be the parent of the pipeline in order to
	// perform this action.
	CreateUserPipelineRelease(context.Context, *CreateUserPipelineReleaseRequest) (*CreateUserPipelineReleaseResponse, error)
	// List the releases in a pipeline owned by a user
	//
	// Lists the commited versions of a pipeline, identified by its resource
	// name, which is formed by the parent user and ID of the pipeline.
	ListUserPipelineReleases(context.Context, *ListUserPipelineReleasesRequest) (*ListUserPipelineReleasesResponse, error)
	// Get a release in a pipeline owned by a user
	//
	// Gets the details of a pipeline release, where the pipeline is identified
	// by its resource name, formed by its parent user and ID.
	GetUserPipelineRelease(context.Context, *GetUserPipelineReleaseRequest) (*GetUserPipelineReleaseResponse, error)
	// Update a release in a pipeline owned by a user
	//
	// Updates the details of a pipeline release, where the pipeline is
	// identified by its resource name, formed by its parent user and ID.
	//
	// The authenticated user must be the parent of the pipeline in order to
	// perform this action.
	UpdateUserPipelineRelease(context.Context, *UpdateUserPipelineReleaseRequest) (*UpdateUserPipelineReleaseResponse, error)
	// Delete a release in a pipeline owned by a user
	//
	// Deletes a pipeline release, where the pipeline is identified by its
	// resource name, formed by its parent user and ID.
	//
	// The authenticated user must be the parent of the pipeline in order to
	// perform this action.
	DeleteUserPipelineRelease(context.Context, *DeleteUserPipelineReleaseRequest) (*DeleteUserPipelineReleaseResponse, error)
	// Set the version of a pipeline owned by a user to a pinned release
	//
	// Sets the pipeline configuration to a pinned version defined by a release.
	//
	// The pipeline is identified by its resource name, formed by its parent user
	// and ID.
	//
	// The authenticated user must be the parent of the pipeline in order to
	// perform this action.
	RestoreUserPipelineRelease(context.Context, *RestoreUserPipelineReleaseRequest) (*RestoreUserPipelineReleaseResponse, error)
	// Rename a release in a pipeline owned by a user
	//
	// Updates the ID of a pipeline release, where the pipeline is identified by
	// its resource name, formed by the parent user and ID. Since this is an
	// output-only field, a custom method is required to modify it.
	//
	// The pipeline release name will be updated accordingly, as it is  composed
	// by the pipeline name and the ID of the release (e.g.
	// `users/luigi/pipelines/pizza-recipe-generator/releases/v0.2.1`).
	//
	// The authenticated user must be the parent of the pipeline in order to
	// perform this action.
	RenameUserPipelineRelease(context.Context, *RenameUserPipelineReleaseRequest) (*RenameUserPipelineReleaseResponse, error)
	// Trigger a version of a pipeline owned by a user
	//
	// Triggers the synchronous execution of of a pipeline. While the trigger
	// endpoint (where the release version isn't specified) triggers the pipeline
	// at its latest release, this method allows the client to specified any
	// committed release.
	//
	// The pipeline is identified by its resource name, formed by its parent user
	// and ID.
	TriggerUserPipelineRelease(context.Context, *TriggerUserPipelineReleaseRequest) (*TriggerUserPipelineReleaseResponse, error)
	// Trigger a version of a pipeline owned by a user asynchronously
	//
	// Triggers the asynchronous execution of of a pipeline. While the trigger
	// endpoint (where the release version isn't specified) triggers the pipeline
	// at its latest release, this method allows the client to specified any
	// committed release.
	//
	// The pipeline is identified by its resource name, formed by its parent user
	// and ID.
	TriggerAsyncUserPipelineRelease(context.Context, *TriggerAsyncUserPipelineReleaseRequest) (*TriggerAsyncUserPipelineReleaseResponse, error)
	// Create a new organization pipeline
	//
	// Creates a new pipeline under the parenthood of an organization.
	CreateOrganizationPipeline(context.Context, *CreateOrganizationPipelineRequest) (*CreateOrganizationPipelineResponse, error)
	// List organization pipelines
	//
	// Returns a paginated list of pipelines that belong to the specified
	// organization.
	ListOrganizationPipelines(context.Context, *ListOrganizationPipelinesRequest) (*ListOrganizationPipelinesResponse, error)
	// Get a pipeline owned by an organization
	//
	// Returns the details of an organization-owned pipeline by its resource name,
	// which is defined by the parent organization and the ID of the pipeline.
	GetOrganizationPipeline(context.Context, *GetOrganizationPipelineRequest) (*GetOrganizationPipelineResponse, error)
	// Update a pipeline owned by an organization
	//
	// # Udpates a pipeline, accessing it by its resource name, which is defined by
	//
	// In REST requests, only the supplied pipeline fields will be taken into
	// account when updating the resource.
	UpdateOrganizationPipeline(context.Context, *UpdateOrganizationPipelineRequest) (*UpdateOrganizationPipelineResponse, error)
	// Delete a pipeline owned by an organization
	//
	// Deletes a pipeline, accesing it by its resource name, which is defined by
	// the parent organization and the ID of the pipeline.
	DeleteOrganizationPipeline(context.Context, *DeleteOrganizationPipelineRequest) (*DeleteOrganizationPipelineResponse, error)
	// Validate a pipeline a pipeline owned by an organization
	//
	// Validates a pipeline by its resource name, which is defined by the parent
	// organization and the ID of the pipeline.
	//
	// Validation checks the recipe of the pipeline and the status of its
	// components.
	ValidateOrganizationPipeline(context.Context, *ValidateOrganizationPipelineRequest) (*ValidateOrganizationPipelineResponse, error)
	// Rename a pipeline owned by an organization
	//
	// Updates the ID of a pipeline. Since this is an output-only field, a custom
	// method is required to modify it.
	//
	// The pipeline name will be updated accordingly, as it is  composed by the
	// parent organization and ID of the pipeline (e.g.
	// `organizations/luigi/pipelines/pizza-recipe-generator`).
	RenameOrganizationPipeline(context.Context, *RenameOrganizationPipelineRequest) (*RenameOrganizationPipelineResponse, error)
	// Clone a pipeline owned by an organization
	//
	// Clones a pipeline owned by an organization. The new pipeline may have a
	// different parent, and this can be either a user or an organization.
	CloneOrganizationPipeline(context.Context, *CloneOrganizationPipelineRequest) (*CloneOrganizationPipelineResponse, error)
	// Trigger a pipeline owned by an organization
	//
	// Triggers the execution of a pipeline synchronously, i.e., the result is sent
	// back to the organization right after the data is processed. This method is
	// intended for real-time inference when low latency is of concern.
	//
	// The pipeline is identified by its resource name, formed by the parent
	// organization and ID of the pipeline.
	//
	// For more information, see [Trigger
	// Pipeline](https://www.instill.tech/docs/latest/core/concepts/pipeline#trigger-pipeline).
	TriggerOrganizationPipeline(context.Context, *TriggerOrganizationPipelineRequest) (*TriggerOrganizationPipelineResponse, error)
	// Trigger a pipeline owned by an organization asynchronously
	//
	// Triggers the execution of a pipeline asynchronously, i.e., the result
	// contains the necessary information to access the result and status of the
	// operation. This method is intended for cases that require long-running
	// workloads.
	//
	// The pipeline is identified by its resource name, formed by the parent
	// organization and ID of the pipeline.
	//
	// For more information, see [Trigger
	// Pipeline](https://www.instill.tech/docs/latest/core/concepts/pipeline#trigger-pipeline).
	TriggerAsyncOrganizationPipeline(context.Context, *TriggerAsyncOrganizationPipelineRequest) (*TriggerAsyncOrganizationPipelineResponse, error)
	// Release a version of a pipeline owned by an organization
	//
	// Commits the version of a pipeline, identified by its resource name, which is
	// formed by the parent organization and ID of the pipeline.
	CreateOrganizationPipelineRelease(context.Context, *CreateOrganizationPipelineReleaseRequest) (*CreateOrganizationPipelineReleaseResponse, error)
	// List the releases in a pipeline owned by an organization
	//
	// Lists the commited versions of a pipeline, identified by its resource name,
	// which is formed by the parent organization and ID of the pipeline.
	ListOrganizationPipelineReleases(context.Context, *ListOrganizationPipelineReleasesRequest) (*ListOrganizationPipelineReleasesResponse, error)
	// Get a release in a pipeline owned by an organization
	//
	// Gets the details of a pipeline release, where the pipeline is identified by
	// its resource name, formed by its parent organization and ID.
	GetOrganizationPipelineRelease(context.Context, *GetOrganizationPipelineReleaseRequest) (*GetOrganizationPipelineReleaseResponse, error)
	// Update a release in a pipeline owned by an organization
	//
	// Updates the details of a pipeline release, where the pipeline is identified
	// by its resource name, formed by its parent organization and ID.
	UpdateOrganizationPipelineRelease(context.Context, *UpdateOrganizationPipelineReleaseRequest) (*UpdateOrganizationPipelineReleaseResponse, error)
	// Delete a release in a pipeline owned by an organization
	//
	// Deletes a pipeline release, where the pipeline is identified by its resource
	// name, formed by its parent organization and ID.
	DeleteOrganizationPipelineRelease(context.Context, *DeleteOrganizationPipelineReleaseRequest) (*DeleteOrganizationPipelineReleaseResponse, error)
	// Set the version of a pipeline owned by an organization to a pinned release
	//
	// Sets the pipeline configuration to a pinned version defined by a release.
	//
	// The pipeline is identified by its resource name, formed by its parent
	// organization and ID.
	RestoreOrganizationPipelineRelease(context.Context, *RestoreOrganizationPipelineReleaseRequest) (*RestoreOrganizationPipelineReleaseResponse, error)
	// Rename a release in a pipeline owned by an organization
	//
	// Updates the ID of a pipeline release, where the pipeline is identified by
	// its resource name, formed by the parent organization and ID. Since this is
	// an output-only field, a custom method is required to modify it.
	//
	// The pipeline release name will be updated accordingly, as it is  composed by
	// the pipeline name and the ID of the release (e.g.
	// `organizations/luigi/pipelines/pizza-recipe-generator/releases/v0.2.1`).
	RenameOrganizationPipelineRelease(context.Context, *RenameOrganizationPipelineReleaseRequest) (*RenameOrganizationPipelineReleaseResponse, error)
	// Trigger a version of a pipeline owned by an organization
	//
	// Triggers the synchronous execution of of a pipeline. While the trigger
	// endpoint (where the release version isn't specified) triggers the pipeline
	// at its latest release, this method allows the client to specified any
	// committed release.
	//
	// The pipeline is identified by its resource name, formed by its parent
	// organization and ID.
	TriggerOrganizationPipelineRelease(context.Context, *TriggerOrganizationPipelineReleaseRequest) (*TriggerOrganizationPipelineReleaseResponse, error)
	// Trigger a version of a pipeline owned by an organization asynchronously
	//
	// Triggers the asynchronous execution of of a pipeline. While the trigger
	// endpoint (where the release version isn't specified) triggers the pipeline
	// at its latest release, this method allows the client to specified any
	// committed release.
	//
	// The pipeline is identified by its resource name, formed by its parent
	// organization and ID.
	TriggerAsyncOrganizationPipelineRelease(context.Context, *TriggerAsyncOrganizationPipelineReleaseRequest) (*TriggerAsyncOrganizationPipelineReleaseResponse, error)
	// Get the details of a long-running operation
	//
	// This method allows requesters to request the status and outcome of
	// long-running operations such as asynchronous pipeline triggers.
	GetOperation(context.Context, *GetOperationRequest) (*GetOperationResponse, error)
	// List connector definitions
	//
	// Returns a paginated list of connector definitions.
	ListConnectorDefinitions(context.Context, *ListConnectorDefinitionsRequest) (*ListConnectorDefinitionsResponse, error)
	// Get connector definition
	//
	// Returns the details of a connector definition.
	GetConnectorDefinition(context.Context, *GetConnectorDefinitionRequest) (*GetConnectorDefinitionResponse, error)
	// List operator definitions
	//
	// Returns a paginated list of operator definitions.
	ListOperatorDefinitions(context.Context, *ListOperatorDefinitionsRequest) (*ListOperatorDefinitionsResponse, error)
	// List component definitions
	//
	// Returns a paginated list of component definitions, regardless their type.
	// This offers a single source of truth, with pagination and filter
	// capabilities, for the components that might be used in a VDP pipeline.
	ListComponentDefinitions(context.Context, *ListComponentDefinitionsRequest) (*ListComponentDefinitionsResponse, error)
	// Get operator definition
	//
	// Returns the details of an operator definition.
	GetOperatorDefinition(context.Context, *GetOperatorDefinitionRequest) (*GetOperatorDefinitionResponse, error)
	// Check the availibity of a resource name
	//
	// Check whether a resource name is already in use. Currently this endpoint
	// only supports pipeline and connector resource names.
	CheckName(context.Context, *CheckNameRequest) (*CheckNameResponse, error)
	// Create a new user secret
	//
	// Creates a new secret under the parenthood of an user.
	CreateUserSecret(context.Context, *CreateUserSecretRequest) (*CreateUserSecretResponse, error)
	// List user secrets
	//
	// Returns a paginated list of secrets that belong to the specified
	// user.
	ListUserSecrets(context.Context, *ListUserSecretsRequest) (*ListUserSecretsResponse, error)
	// Get a secret owned by an user
	//
	// Returns the details of an user-owned secret by its resource name,
	// which is defined by the parent user and the ID of the secret.
	GetUserSecret(context.Context, *GetUserSecretRequest) (*GetUserSecretResponse, error)
	// Update a secret owned by an user
	//
	// # Udpates a secret, accessing it by its resource name, which is defined by
	//
	// In REST requests, only the supplied secret fields will be taken into
	// account when updating the resource.
	UpdateUserSecret(context.Context, *UpdateUserSecretRequest) (*UpdateUserSecretResponse, error)
	// Delete a secret owned by an user
	//
	// Deletes a secret, accesing it by its resource name, which is defined by
	// the parent user and the ID of the secret.
	DeleteUserSecret(context.Context, *DeleteUserSecretRequest) (*DeleteUserSecretResponse, error)
	// Create a new organization secret
	//
	// Creates a new secret under the parenthood of an organization.
	CreateOrganizationSecret(context.Context, *CreateOrganizationSecretRequest) (*CreateOrganizationSecretResponse, error)
	// List organization secrets
	//
	// Returns a paginated list of secrets that belong to the specified
	// organization.
	ListOrganizationSecrets(context.Context, *ListOrganizationSecretsRequest) (*ListOrganizationSecretsResponse, error)
	// Get a secret owned by an organization
	//
	// Returns the details of an organization-owned secret by its resource name,
	// which is defined by the parent organization and the ID of the secret.
	GetOrganizationSecret(context.Context, *GetOrganizationSecretRequest) (*GetOrganizationSecretResponse, error)
	// Update a secret owned by an organization
	//
	// # Udpates a secret, accessing it by its resource name, which is defined by
	//
	// In REST requests, only the supplied secret fields will be taken into
	// account when updating the resource.
	UpdateOrganizationSecret(context.Context, *UpdateOrganizationSecretRequest) (*UpdateOrganizationSecretResponse, error)
	// Delete a secret owned by an organization
	//
	// Deletes a secret, accesing it by its resource name, which is defined by
	// the parent organization and the ID of the secret.
	DeleteOrganizationSecret(context.Context, *DeleteOrganizationSecretRequest) (*DeleteOrganizationSecretResponse, error)
}

PipelinePublicServiceServer is the server API for PipelinePublicService service. All implementations should embed UnimplementedPipelinePublicServiceServer for forward compatibility

type PipelineRelease

type PipelineRelease struct {

	// The name of the release, defined by its parent and ID.
	// - Format: `{parent_type}/{parent.id}/pipelines/{pipeline.id}/releases/{release.id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Release UUID.
	Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
	// Release resource ID (used in `name` as the last segment). It must be a
	// sematic version vX.Y.Z.
	Id string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	// Release description.
	Description *string `protobuf:"bytes,4,opt,name=description,proto3,oneof" json:"description,omitempty"`
	// Recipe of the versioned pipeline.
	Recipe *Recipe `protobuf:"bytes,5,opt,name=recipe,proto3" json:"recipe,omitempty"`
	// Pipeline creation time.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Pipeline update time.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Pipeline deletion time.
	DeleteTime *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=delete_time,json=deleteTime,proto3" json:"delete_time,omitempty"`
	// Alias.
	Alias string `protobuf:"bytes,11,opt,name=alias,proto3" json:"alias,omitempty"`
	// Key-value object with console-related data such as the pipeline builder
	// layout.
	Metadata *structpb.Struct `protobuf:"bytes,12,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// README.
	Readme string `protobuf:"bytes,13,opt,name=readme,proto3" json:"readme,omitempty"`
	// Data specifications.
	DataSpecification *DataSpecification `protobuf:"bytes,14,opt,name=data_specification,json=dataSpecification,proto3" json:"data_specification,omitempty"`
	// contains filtered or unexported fields
}

Pipeline releases contain the version control information of a pipeline. This allows users to track changes in the pipeline over time.

func (*PipelineRelease) Descriptor deprecated

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

Deprecated: Use PipelineRelease.ProtoReflect.Descriptor instead.

func (*PipelineRelease) GetAlias

func (x *PipelineRelease) GetAlias() string

func (*PipelineRelease) GetCreateTime

func (x *PipelineRelease) GetCreateTime() *timestamppb.Timestamp

func (*PipelineRelease) GetDataSpecification

func (x *PipelineRelease) GetDataSpecification() *DataSpecification

func (*PipelineRelease) GetDeleteTime

func (x *PipelineRelease) GetDeleteTime() *timestamppb.Timestamp

func (*PipelineRelease) GetDescription

func (x *PipelineRelease) GetDescription() string

func (*PipelineRelease) GetId

func (x *PipelineRelease) GetId() string

func (*PipelineRelease) GetMetadata

func (x *PipelineRelease) GetMetadata() *structpb.Struct

func (*PipelineRelease) GetName

func (x *PipelineRelease) GetName() string

func (*PipelineRelease) GetReadme

func (x *PipelineRelease) GetReadme() string

func (*PipelineRelease) GetRecipe

func (x *PipelineRelease) GetRecipe() *Recipe

func (*PipelineRelease) GetUid

func (x *PipelineRelease) GetUid() string

func (*PipelineRelease) GetUpdateTime

func (x *PipelineRelease) GetUpdateTime() *timestamppb.Timestamp

func (*PipelineRelease) ProtoMessage

func (*PipelineRelease) ProtoMessage()

func (*PipelineRelease) ProtoReflect

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

func (*PipelineRelease) Reset

func (x *PipelineRelease) Reset()

func (*PipelineRelease) String

func (x *PipelineRelease) String() string

type Pipeline_View

type Pipeline_View int32

View defines how a Pipeline is presented.

const (
	// Unspecified, equivalent to BASIC.
	Pipeline_VIEW_UNSPECIFIED Pipeline_View = 0
	// Default view, only includes basic information.
	Pipeline_VIEW_BASIC Pipeline_View = 1
	// Full representation.
	Pipeline_VIEW_FULL Pipeline_View = 2
	// Contains the recipe of the resource.
	Pipeline_VIEW_RECIPE Pipeline_View = 3
)

func (Pipeline_View) Descriptor

func (Pipeline_View) Enum

func (x Pipeline_View) Enum() *Pipeline_View

func (Pipeline_View) EnumDescriptor deprecated

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

Deprecated: Use Pipeline_View.Descriptor instead.

func (Pipeline_View) Number

func (Pipeline_View) String

func (x Pipeline_View) String() string

func (Pipeline_View) Type

type Pipeline_Visibility

type Pipeline_Visibility int32

Visibility defines who can access the pipeline.

const (
	// Unspecified, equivalent to PRIVATE.
	Pipeline_VISIBILITY_UNSPECIFIED Pipeline_Visibility = 0
	// Only the user can see the pipeline.
	Pipeline_VISIBILITY_PRIVATE Pipeline_Visibility = 1
	// Other users can see the pipeline.
	Pipeline_VISIBILITY_PUBLIC Pipeline_Visibility = 2
)

func (Pipeline_Visibility) Descriptor

func (Pipeline_Visibility) Enum

func (Pipeline_Visibility) EnumDescriptor deprecated

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

Deprecated: Use Pipeline_Visibility.Descriptor instead.

func (Pipeline_Visibility) Number

func (Pipeline_Visibility) String

func (x Pipeline_Visibility) String() string

func (Pipeline_Visibility) Type

type ReadinessRequest

type ReadinessRequest struct {

	// HealthCheckRequest message
	HealthCheckRequest *v1beta.HealthCheckRequest `protobuf:"bytes,1,opt,name=health_check_request,json=healthCheckRequest,proto3,oneof" json:"health_check_request,omitempty"`
	// contains filtered or unexported fields
}

ReadinessRequest represents a request to check a service readiness status

func (*ReadinessRequest) Descriptor deprecated

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

Deprecated: Use ReadinessRequest.ProtoReflect.Descriptor instead.

func (*ReadinessRequest) GetHealthCheckRequest

func (x *ReadinessRequest) GetHealthCheckRequest() *v1beta.HealthCheckRequest

func (*ReadinessRequest) ProtoMessage

func (*ReadinessRequest) ProtoMessage()

func (*ReadinessRequest) ProtoReflect

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

func (*ReadinessRequest) Reset

func (x *ReadinessRequest) Reset()

func (*ReadinessRequest) String

func (x *ReadinessRequest) String() string

type ReadinessResponse

type ReadinessResponse struct {

	// HealthCheckResponse message
	HealthCheckResponse *v1beta.HealthCheckResponse `protobuf:"bytes,1,opt,name=health_check_response,json=healthCheckResponse,proto3" json:"health_check_response,omitempty"`
	// contains filtered or unexported fields
}

ReadinessResponse represents a response for a service readiness status

func (*ReadinessResponse) Descriptor deprecated

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

Deprecated: Use ReadinessResponse.ProtoReflect.Descriptor instead.

func (*ReadinessResponse) GetHealthCheckResponse

func (x *ReadinessResponse) GetHealthCheckResponse() *v1beta.HealthCheckResponse

func (*ReadinessResponse) ProtoMessage

func (*ReadinessResponse) ProtoMessage()

func (*ReadinessResponse) ProtoReflect

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

func (*ReadinessResponse) Reset

func (x *ReadinessResponse) Reset()

func (*ReadinessResponse) String

func (x *ReadinessResponse) String() string

type Recipe

type Recipe struct {

	// Recipe schema version.
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// List of pipeline components.
	Components []*Component `protobuf:"bytes,2,rep,name=components,proto3" json:"components,omitempty"`
	// The component trigger method.
	Trigger *Trigger `protobuf:"bytes,3,opt,name=trigger,proto3" json:"trigger,omitempty"`
	// Local secrets
	Secrets map[string]string `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

Recipe describes the components of a Pipeline and how they are connected.

func (*Recipe) Descriptor deprecated

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

Deprecated: Use Recipe.ProtoReflect.Descriptor instead.

func (*Recipe) GetComponents

func (x *Recipe) GetComponents() []*Component

func (*Recipe) GetSecrets

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

func (*Recipe) GetTrigger

func (x *Recipe) GetTrigger() *Trigger

func (*Recipe) GetVersion

func (x *Recipe) GetVersion() string

func (*Recipe) ProtoMessage

func (*Recipe) ProtoMessage()

func (*Recipe) ProtoReflect

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

func (*Recipe) Reset

func (x *Recipe) Reset()

func (*Recipe) String

func (x *Recipe) String() string

type RenameOrganizationPipelineReleaseRequest

type RenameOrganizationPipelineReleaseRequest struct {

	// The resource name of the pipeline release, which allows its access by
	// parent pipeline and ID.
	// - Format:
	// `organizations/{organization.id}/pipelines/{pipeline.id}/releases/{release.id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The new resource ID. This will transform the resource name into
	// `organizations/{organization.id}/pipelines/{pipeline.id}/releases{new_release_id}`.
	NewPipelineReleaseId string `protobuf:"bytes,2,opt,name=new_pipeline_release_id,json=newPipelineReleaseId,proto3" json:"new_pipeline_release_id,omitempty"`
	// contains filtered or unexported fields
}

RenameOrganizationPipelineReleaseRequest represents a request to rename a release in an organization-owned pipeline.

func (*RenameOrganizationPipelineReleaseRequest) Descriptor deprecated

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

Deprecated: Use RenameOrganizationPipelineReleaseRequest.ProtoReflect.Descriptor instead.

func (*RenameOrganizationPipelineReleaseRequest) GetName

func (*RenameOrganizationPipelineReleaseRequest) GetNewPipelineReleaseId

func (x *RenameOrganizationPipelineReleaseRequest) GetNewPipelineReleaseId() string

func (*RenameOrganizationPipelineReleaseRequest) ProtoMessage

func (*RenameOrganizationPipelineReleaseRequest) ProtoReflect

func (*RenameOrganizationPipelineReleaseRequest) Reset

func (*RenameOrganizationPipelineReleaseRequest) String

type RenameOrganizationPipelineReleaseResponse

type RenameOrganizationPipelineReleaseResponse struct {

	// The renamed pipeline release.
	Release *PipelineRelease `protobuf:"bytes,1,opt,name=release,proto3" json:"release,omitempty"`
	// contains filtered or unexported fields
}

RenameOrganizationPipelineReleaseResponse contains a renamed pipeline release.

func (*RenameOrganizationPipelineReleaseResponse) Descriptor deprecated

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

Deprecated: Use RenameOrganizationPipelineReleaseResponse.ProtoReflect.Descriptor instead.

func (*RenameOrganizationPipelineReleaseResponse) GetRelease

func (*RenameOrganizationPipelineReleaseResponse) ProtoMessage

func (*RenameOrganizationPipelineReleaseResponse) ProtoReflect

func (*RenameOrganizationPipelineReleaseResponse) Reset

func (*RenameOrganizationPipelineReleaseResponse) String

type RenameOrganizationPipelineRequest

type RenameOrganizationPipelineRequest struct {

	// The resource name of the pipeline, which allows its access by parent
	// organization and ID.
	// - Format: `organizations/{organization.id}/pipelines/{pipeline.id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The new resource ID. This will transform the resource name into
	// `organizations/{organization.id}/pipelines/{new_pipeline_id}`.
	NewPipelineId string `protobuf:"bytes,2,opt,name=new_pipeline_id,json=newPipelineId,proto3" json:"new_pipeline_id,omitempty"`
	// contains filtered or unexported fields
}

RenameOrganizationPipelineRequest represents a request to rename the name of a pipeline owned by an organization.

func (*RenameOrganizationPipelineRequest) Descriptor deprecated

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

Deprecated: Use RenameOrganizationPipelineRequest.ProtoReflect.Descriptor instead.

func (*RenameOrganizationPipelineRequest) GetName

func (*RenameOrganizationPipelineRequest) GetNewPipelineId

func (x *RenameOrganizationPipelineRequest) GetNewPipelineId() string

func (*RenameOrganizationPipelineRequest) ProtoMessage

func (*RenameOrganizationPipelineRequest) ProtoMessage()

func (*RenameOrganizationPipelineRequest) ProtoReflect

func (*RenameOrganizationPipelineRequest) Reset

func (*RenameOrganizationPipelineRequest) String

type RenameOrganizationPipelineResponse

type RenameOrganizationPipelineResponse struct {

	// The renamed pipeline resource.
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// contains filtered or unexported fields
}

RenameOrganizationPipelineResponse contains a renamed pipeline.

func (*RenameOrganizationPipelineResponse) Descriptor deprecated

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

Deprecated: Use RenameOrganizationPipelineResponse.ProtoReflect.Descriptor instead.

func (*RenameOrganizationPipelineResponse) GetPipeline

func (x *RenameOrganizationPipelineResponse) GetPipeline() *Pipeline

func (*RenameOrganizationPipelineResponse) ProtoMessage

func (*RenameOrganizationPipelineResponse) ProtoMessage()

func (*RenameOrganizationPipelineResponse) ProtoReflect

func (*RenameOrganizationPipelineResponse) Reset

func (*RenameOrganizationPipelineResponse) String

type RenameUserPipelineReleaseRequest

type RenameUserPipelineReleaseRequest struct {

	// The resource name of the pipeline release, which allows its access by
	// parent pipeline and ID.
	// - Format: `users/{user.id}/pipelines/{pipeline.id}/releases/{release.id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The new resource ID. This will transform the resource name into
	// `users/{user.id}/pipelines/{pipeline.id}/releases{new_release_id}`.
	NewPipelineReleaseId string `protobuf:"bytes,2,opt,name=new_pipeline_release_id,json=newPipelineReleaseId,proto3" json:"new_pipeline_release_id,omitempty"`
	// contains filtered or unexported fields
}

RenameUserPipelineReleaseRequest represents a request to rename a release in a user-owned pipeline.

func (*RenameUserPipelineReleaseRequest) Descriptor deprecated

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

Deprecated: Use RenameUserPipelineReleaseRequest.ProtoReflect.Descriptor instead.

func (*RenameUserPipelineReleaseRequest) GetName

func (*RenameUserPipelineReleaseRequest) GetNewPipelineReleaseId

func (x *RenameUserPipelineReleaseRequest) GetNewPipelineReleaseId() string

func (*RenameUserPipelineReleaseRequest) ProtoMessage

func (*RenameUserPipelineReleaseRequest) ProtoMessage()

func (*RenameUserPipelineReleaseRequest) ProtoReflect

func (*RenameUserPipelineReleaseRequest) Reset

func (*RenameUserPipelineReleaseRequest) String

type RenameUserPipelineReleaseResponse

type RenameUserPipelineReleaseResponse struct {

	// The renamed pipeline release.
	Release *PipelineRelease `protobuf:"bytes,1,opt,name=release,proto3" json:"release,omitempty"`
	// contains filtered or unexported fields
}

RenameUserPipelineReleaseResponse contains a renamed pipeline release.

func (*RenameUserPipelineReleaseResponse) Descriptor deprecated

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

Deprecated: Use RenameUserPipelineReleaseResponse.ProtoReflect.Descriptor instead.

func (*RenameUserPipelineReleaseResponse) GetRelease

func (*RenameUserPipelineReleaseResponse) ProtoMessage

func (*RenameUserPipelineReleaseResponse) ProtoMessage()

func (*RenameUserPipelineReleaseResponse) ProtoReflect

func (*RenameUserPipelineReleaseResponse) Reset

func (*RenameUserPipelineReleaseResponse) String

type RenameUserPipelineRequest

type RenameUserPipelineRequest struct {

	// The resource name of the pipeline, which allows its access by parent user
	// and ID.
	// - Format: `users/{user.id}/pipelines/{pipeline.id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The new resource ID. This will transform the resource name into
	// `users/{user.id}/pipelines/{new_pipeline_id}`.
	NewPipelineId string `protobuf:"bytes,2,opt,name=new_pipeline_id,json=newPipelineId,proto3" json:"new_pipeline_id,omitempty"`
	// contains filtered or unexported fields
}

RenameUserPipelineRequest represents a request to rename the name of a pipeline owned by a user.

func (*RenameUserPipelineRequest) Descriptor deprecated

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

Deprecated: Use RenameUserPipelineRequest.ProtoReflect.Descriptor instead.

func (*RenameUserPipelineRequest) GetName

func (x *RenameUserPipelineRequest) GetName() string

func (*RenameUserPipelineRequest) GetNewPipelineId

func (x *RenameUserPipelineRequest) GetNewPipelineId() string

func (*RenameUserPipelineRequest) ProtoMessage

func (*RenameUserPipelineRequest) ProtoMessage()

func (*RenameUserPipelineRequest) ProtoReflect

func (*RenameUserPipelineRequest) Reset

func (x *RenameUserPipelineRequest) Reset()

func (*RenameUserPipelineRequest) String

func (x *RenameUserPipelineRequest) String() string

type RenameUserPipelineResponse

type RenameUserPipelineResponse struct {

	// The renamed pipeline resource.
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// contains filtered or unexported fields
}

RenameUserPipelineResponse contains a renamed pipeline.

func (*RenameUserPipelineResponse) Descriptor deprecated

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

Deprecated: Use RenameUserPipelineResponse.ProtoReflect.Descriptor instead.

func (*RenameUserPipelineResponse) GetPipeline

func (x *RenameUserPipelineResponse) GetPipeline() *Pipeline

func (*RenameUserPipelineResponse) ProtoMessage

func (*RenameUserPipelineResponse) ProtoMessage()

func (*RenameUserPipelineResponse) ProtoReflect

func (*RenameUserPipelineResponse) Reset

func (x *RenameUserPipelineResponse) Reset()

func (*RenameUserPipelineResponse) String

func (x *RenameUserPipelineResponse) String() string

type RestoreOrganizationPipelineReleaseRequest

type RestoreOrganizationPipelineReleaseRequest struct {

	// The resource name of the pipeline release, which allows its access by
	// parent pipeline and ID.
	// - Format:
	// `organizations/{organization.id}/pipelines/{pipeline.id}/releases/{release.id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

RestoreOrganizationPipelineReleaseRequest represents a request to set the version of an organization-owned pipeline to a pinned release.

func (*RestoreOrganizationPipelineReleaseRequest) Descriptor deprecated

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

Deprecated: Use RestoreOrganizationPipelineReleaseRequest.ProtoReflect.Descriptor instead.

func (*RestoreOrganizationPipelineReleaseRequest) GetName

func (*RestoreOrganizationPipelineReleaseRequest) ProtoMessage

func (*RestoreOrganizationPipelineReleaseRequest) ProtoReflect

func (*RestoreOrganizationPipelineReleaseRequest) Reset

func (*RestoreOrganizationPipelineReleaseRequest) String

type RestoreOrganizationPipelineReleaseResponse

type RestoreOrganizationPipelineReleaseResponse struct {

	// The pipeline release resource.
	Release *PipelineRelease `protobuf:"bytes,1,opt,name=release,proto3" json:"release,omitempty"`
	// contains filtered or unexported fields
}

RestoreOrganizationPipelineReleaseResponse contains the requested pipeline release.

func (*RestoreOrganizationPipelineReleaseResponse) Descriptor deprecated

Deprecated: Use RestoreOrganizationPipelineReleaseResponse.ProtoReflect.Descriptor instead.

func (*RestoreOrganizationPipelineReleaseResponse) GetRelease

func (*RestoreOrganizationPipelineReleaseResponse) ProtoMessage

func (*RestoreOrganizationPipelineReleaseResponse) ProtoReflect

func (*RestoreOrganizationPipelineReleaseResponse) Reset

func (*RestoreOrganizationPipelineReleaseResponse) String

type RestoreUserPipelineReleaseRequest

type RestoreUserPipelineReleaseRequest struct {

	// The resource name of the pipeline release, which allows its access by
	// parent pipeline and ID.
	// - Format: `users/{user.id}/pipelines/{pipeline.id}/releases/{release.id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

RestoreUserPipelineReleaseRequest represents a request to set the version of a user-owned pipeline to a pinned release.

func (*RestoreUserPipelineReleaseRequest) Descriptor deprecated

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

Deprecated: Use RestoreUserPipelineReleaseRequest.ProtoReflect.Descriptor instead.

func (*RestoreUserPipelineReleaseRequest) GetName

func (*RestoreUserPipelineReleaseRequest) ProtoMessage

func (*RestoreUserPipelineReleaseRequest) ProtoMessage()

func (*RestoreUserPipelineReleaseRequest) ProtoReflect

func (*RestoreUserPipelineReleaseRequest) Reset

func (*RestoreUserPipelineReleaseRequest) String

type RestoreUserPipelineReleaseResponse

type RestoreUserPipelineReleaseResponse struct {

	// The pipeline release resource.
	Release *PipelineRelease `protobuf:"bytes,1,opt,name=release,proto3" json:"release,omitempty"`
	// contains filtered or unexported fields
}

RestoreUserPipelineReleaseResponse contains the requested pipeline release.

func (*RestoreUserPipelineReleaseResponse) Descriptor deprecated

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

Deprecated: Use RestoreUserPipelineReleaseResponse.ProtoReflect.Descriptor instead.

func (*RestoreUserPipelineReleaseResponse) GetRelease

func (*RestoreUserPipelineReleaseResponse) ProtoMessage

func (*RestoreUserPipelineReleaseResponse) ProtoMessage()

func (*RestoreUserPipelineReleaseResponse) ProtoReflect

func (*RestoreUserPipelineReleaseResponse) Reset

func (*RestoreUserPipelineReleaseResponse) String

type Role

type Role int32

Role describes the permissions a user has over a resource.

const (
	// Unspecified, equivalent to VIEWER.
	Role_ROLE_UNSPECIFIED Role = 0
	// Viewers can see the resource properties.
	Role_ROLE_VIEWER Role = 1
	// Executors can execute the resource (e.g. trigger a pipeline).
	Role_ROLE_EXECUTOR Role = 2
)

func (Role) Descriptor

func (Role) Descriptor() protoreflect.EnumDescriptor

func (Role) Enum

func (x Role) Enum() *Role

func (Role) EnumDescriptor deprecated

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

Deprecated: Use Role.Descriptor instead.

func (Role) Number

func (x Role) Number() protoreflect.EnumNumber

func (Role) String

func (x Role) String() string

func (Role) Type

func (Role) Type() protoreflect.EnumType

type Secret

type Secret struct {

	// The name of the secret, define by its ID.
	// - Format: `secrets/{secret.id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Secret UUID.
	Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
	// Secret resource ID (used in `name` as the last segment). This conforms
	// to RFC-1034, which restricts to letters, numbers, and hyphen, with the
	// first character a letter, the last a letter or a number, and a 63
	// character maximum.
	Id string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	// Creation time.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Update time.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// The value of the secret, which is input-only and will never be returned in API responses.
	Value *string `protobuf:"bytes,6,opt,name=value,proto3,oneof" json:"value,omitempty"`
	// Description
	Description string `protobuf:"bytes,7,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

API secrets allow users to make requests to the Instill AI API.

func (*Secret) Descriptor deprecated

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

Deprecated: Use Secret.ProtoReflect.Descriptor instead.

func (*Secret) GetCreateTime

func (x *Secret) GetCreateTime() *timestamppb.Timestamp

func (*Secret) GetDescription

func (x *Secret) GetDescription() string

func (*Secret) GetId

func (x *Secret) GetId() string

func (*Secret) GetName

func (x *Secret) GetName() string

func (*Secret) GetUid

func (x *Secret) GetUid() string

func (*Secret) GetUpdateTime

func (x *Secret) GetUpdateTime() *timestamppb.Timestamp

func (*Secret) GetValue

func (x *Secret) GetValue() string

func (*Secret) ProtoMessage

func (*Secret) ProtoMessage()

func (*Secret) ProtoReflect

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

func (*Secret) Reset

func (x *Secret) Reset()

func (*Secret) String

func (x *Secret) String() string

type Sharing

type Sharing struct {

	// Defines sharing rules for a set of user resource names.
	//
	// Each key in this object should contain a pattern that can be matched
	// against user names.
	//
	// Each value is a user sharing configuration.
	//
	// **NOTE**: For now, the only accepted key is `*/*`.
	Users map[string]*Sharing_User `` /* 151-byte string literal not displayed */
	// Defines the configuration to share a resource via link.
	ShareCode *Sharing_ShareCode `protobuf:"bytes,2,opt,name=share_code,json=shareCode,proto3" json:"share_code,omitempty"`
	// contains filtered or unexported fields
}

Sharing contains the information to share a resource with other users.

For more information, see [Share Pipelines](https://www.instill.tech/docs/latest/vdp/share).

func (*Sharing) Descriptor deprecated

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

Deprecated: Use Sharing.ProtoReflect.Descriptor instead.

func (*Sharing) GetShareCode

func (x *Sharing) GetShareCode() *Sharing_ShareCode

func (*Sharing) GetUsers

func (x *Sharing) GetUsers() map[string]*Sharing_User

func (*Sharing) ProtoMessage

func (*Sharing) ProtoMessage()

func (*Sharing) ProtoReflect

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

func (*Sharing) Reset

func (x *Sharing) Reset()

func (*Sharing) String

func (x *Sharing) String() string

type Sharing_ShareCode

type Sharing_ShareCode struct {

	// Defines which users will be able to access the resource through the
	// code. This is a pattern that will be checked against user names.
	//
	// For now, the only accepted value is `*/*`.
	User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	// The public URL that allows users to access the resource.
	Code string `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty"`
	// Defines whether the sharing option via link is enabled.
	Enabled bool `protobuf:"varint,3,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// Defines the role users will have over the resource.
	Role Role `protobuf:"varint,4,opt,name=role,proto3,enum=vdp.pipeline.v1beta.Role" json:"role,omitempty"`
	// contains filtered or unexported fields
}

ShareCode describes a sharing configuration through a link.

func (*Sharing_ShareCode) Descriptor deprecated

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

Deprecated: Use Sharing_ShareCode.ProtoReflect.Descriptor instead.

func (*Sharing_ShareCode) GetCode

func (x *Sharing_ShareCode) GetCode() string

func (*Sharing_ShareCode) GetEnabled

func (x *Sharing_ShareCode) GetEnabled() bool

func (*Sharing_ShareCode) GetRole

func (x *Sharing_ShareCode) GetRole() Role

func (*Sharing_ShareCode) GetUser

func (x *Sharing_ShareCode) GetUser() string

func (*Sharing_ShareCode) ProtoMessage

func (*Sharing_ShareCode) ProtoMessage()

func (*Sharing_ShareCode) ProtoReflect

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

func (*Sharing_ShareCode) Reset

func (x *Sharing_ShareCode) Reset()

func (*Sharing_ShareCode) String

func (x *Sharing_ShareCode) String() string

type Sharing_User

type Sharing_User struct {

	// Defines whether the sharing option with this user is enabled.
	Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// Defines the role the user will have over the resource.
	Role Role `protobuf:"varint,4,opt,name=role,proto3,enum=vdp.pipeline.v1beta.Role" json:"role,omitempty"`
	// contains filtered or unexported fields
}

Describes the sharing configuration with a given user.

func (*Sharing_User) Descriptor deprecated

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

Deprecated: Use Sharing_User.ProtoReflect.Descriptor instead.

func (*Sharing_User) GetEnabled

func (x *Sharing_User) GetEnabled() bool

func (*Sharing_User) GetRole

func (x *Sharing_User) GetRole() Role

func (*Sharing_User) ProtoMessage

func (*Sharing_User) ProtoMessage()

func (*Sharing_User) ProtoReflect

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

func (*Sharing_User) Reset

func (x *Sharing_User) Reset()

func (*Sharing_User) String

func (x *Sharing_User) String() string

type State

type State int32

State describes the state of a pipeline.

const (
	// Unspecified.
	State_STATE_UNSPECIFIED State = 0
	// Inactive.
	State_STATE_INACTIVE State = 1
	// Active.
	State_STATE_ACTIVE State = 2
	// The pipeline has an error.
	State_STATE_ERROR State = 3
)

func (State) Descriptor

func (State) Descriptor() protoreflect.EnumDescriptor

func (State) Enum

func (x State) Enum() *State

func (State) EnumDescriptor deprecated

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

Deprecated: Use State.Descriptor instead.

func (State) Number

func (x State) Number() protoreflect.EnumNumber

func (State) String

func (x State) String() string

func (State) Type

func (State) Type() protoreflect.EnumType

type Trace

type Trace struct {

	// Statuses contains an execution status per input.
	Statuses []Trace_Status `protobuf:"varint,1,rep,packed,name=statuses,proto3,enum=vdp.pipeline.v1beta.Trace_Status" json:"statuses,omitempty"`
	// Component inputs.
	Inputs []*structpb.Struct `protobuf:"bytes,2,rep,name=inputs,proto3" json:"inputs,omitempty"`
	// Component outputs.
	Outputs []*structpb.Struct `protobuf:"bytes,3,rep,name=outputs,proto3" json:"outputs,omitempty"`
	// Error details.
	Error *structpb.Struct `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// Computation time in seconds.
	ComputeTimeInSeconds float32 `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

Trace contains the execution details of a component.

func (*Trace) Descriptor deprecated

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

Deprecated: Use Trace.ProtoReflect.Descriptor instead.

func (*Trace) GetComputeTimeInSeconds

func (x *Trace) GetComputeTimeInSeconds() float32

func (*Trace) GetError

func (x *Trace) GetError() *structpb.Struct

func (*Trace) GetInputs

func (x *Trace) GetInputs() []*structpb.Struct

func (*Trace) GetOutputs

func (x *Trace) GetOutputs() []*structpb.Struct

func (*Trace) GetStatuses

func (x *Trace) GetStatuses() []Trace_Status

func (*Trace) ProtoMessage

func (*Trace) ProtoMessage()

func (*Trace) ProtoReflect

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

func (*Trace) Reset

func (x *Trace) Reset()

func (*Trace) String

func (x *Trace) String() string

type Trace_Status

type Trace_Status int32

Status holds the the component execution outcome.

const (
	// Unspecified.
	Trace_STATUS_UNSPECIFIED Trace_Status = 0
	// Successfully completed.
	Trace_STATUS_COMPLETED Trace_Status = 1
	// Skipped.
	Trace_STATUS_SKIPPED Trace_Status = 2
	// Aborted with error.
	Trace_STATUS_ERROR Trace_Status = 3
)

func (Trace_Status) Descriptor

func (Trace_Status) Enum

func (x Trace_Status) Enum() *Trace_Status

func (Trace_Status) EnumDescriptor deprecated

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

Deprecated: Use Trace_Status.Descriptor instead.

func (Trace_Status) Number

func (Trace_Status) String

func (x Trace_Status) String() string

func (Trace_Status) Type

type Trigger

type Trigger struct {

	// Trigger Method
	//
	// Types that are assignable to Trigger:
	//
	//	*Trigger_TriggerByRequest
	Trigger isTrigger_Trigger `protobuf_oneof:"trigger"`
	// contains filtered or unexported fields
}

Trigger

func (*Trigger) Descriptor deprecated

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

Deprecated: Use Trigger.ProtoReflect.Descriptor instead.

func (*Trigger) GetTrigger

func (m *Trigger) GetTrigger() isTrigger_Trigger

func (*Trigger) GetTriggerByRequest

func (x *Trigger) GetTriggerByRequest() *TriggerByRequest

func (*Trigger) ProtoMessage

func (*Trigger) ProtoMessage()

func (*Trigger) ProtoReflect

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

func (*Trigger) Reset

func (x *Trigger) Reset()

func (*Trigger) String

func (x *Trigger) String() string

type TriggerAsyncOrganizationPipelineReleaseRequest

type TriggerAsyncOrganizationPipelineReleaseRequest struct {

	// The resource name of the pipeline release, which allows its access by
	// parent pipeline and ID.
	// - Format:
	// `organizations/{organization.id}/pipelines/{pipeline.id}/releases/{release.id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Pipeline input parameters.
	Inputs []*structpb.Struct `protobuf:"bytes,2,rep,name=inputs,proto3" json:"inputs,omitempty"`
	// Pipeline secrets parameters that will override the pipeline's or owner's secrets.
	Secrets map[string]string `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

TriggerOrganizationPipelineReleaseRequest represents a request to trigger a pinned release of an organization-owned pipeline asynchronously.

func (*TriggerAsyncOrganizationPipelineReleaseRequest) Descriptor deprecated

Deprecated: Use TriggerAsyncOrganizationPipelineReleaseRequest.ProtoReflect.Descriptor instead.

func (*TriggerAsyncOrganizationPipelineReleaseRequest) GetInputs

func (*TriggerAsyncOrganizationPipelineReleaseRequest) GetName

func (*TriggerAsyncOrganizationPipelineReleaseRequest) GetSecrets

func (*TriggerAsyncOrganizationPipelineReleaseRequest) ProtoMessage

func (*TriggerAsyncOrganizationPipelineReleaseRequest) ProtoReflect

func (*TriggerAsyncOrganizationPipelineReleaseRequest) Reset

func (*TriggerAsyncOrganizationPipelineReleaseRequest) String

type TriggerAsyncOrganizationPipelineReleaseResponse

type TriggerAsyncOrganizationPipelineReleaseResponse struct {

	// Long-running operation information.
	Operation *longrunningpb.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

TriggerAsyncOrganizationPipelineReleaseResponse contains the information to access the status of an asynchronous pipeline execution.

func (*TriggerAsyncOrganizationPipelineReleaseResponse) Descriptor deprecated

Deprecated: Use TriggerAsyncOrganizationPipelineReleaseResponse.ProtoReflect.Descriptor instead.

func (*TriggerAsyncOrganizationPipelineReleaseResponse) GetOperation

func (*TriggerAsyncOrganizationPipelineReleaseResponse) ProtoMessage

func (*TriggerAsyncOrganizationPipelineReleaseResponse) ProtoReflect

func (*TriggerAsyncOrganizationPipelineReleaseResponse) Reset

func (*TriggerAsyncOrganizationPipelineReleaseResponse) String

type TriggerAsyncOrganizationPipelineRequest

type TriggerAsyncOrganizationPipelineRequest struct {

	// The resource name of the pipeline, which allows its access by parent
	// organization and ID.
	// - Format: `organizations/{organization.id}/pipelines/{pipeline.id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Pipeline input parameters.
	Inputs []*structpb.Struct `protobuf:"bytes,2,rep,name=inputs,proto3" json:"inputs,omitempty"`
	// Pipeline secrets parameters that will override the pipeline's or owner's secrets.
	Secrets map[string]string `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

TriggerOrganizationPipelineRequest represents a request to trigger an organization-owned pipeline synchronously.

func (*TriggerAsyncOrganizationPipelineRequest) Descriptor deprecated

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

Deprecated: Use TriggerAsyncOrganizationPipelineRequest.ProtoReflect.Descriptor instead.

func (*TriggerAsyncOrganizationPipelineRequest) GetInputs

func (*TriggerAsyncOrganizationPipelineRequest) GetName

func (*TriggerAsyncOrganizationPipelineRequest) GetSecrets

func (*TriggerAsyncOrganizationPipelineRequest) ProtoMessage

func (*TriggerAsyncOrganizationPipelineRequest) ProtoReflect

func (*TriggerAsyncOrganizationPipelineRequest) Reset

func (*TriggerAsyncOrganizationPipelineRequest) String

type TriggerAsyncOrganizationPipelineResponse

type TriggerAsyncOrganizationPipelineResponse struct {

	// Long-running operation information.
	Operation *longrunningpb.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

TriggerAsyncOrganizationPipelineResponse contains the information to access the status of an asynchronous pipeline execution.

func (*TriggerAsyncOrganizationPipelineResponse) Descriptor deprecated

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

Deprecated: Use TriggerAsyncOrganizationPipelineResponse.ProtoReflect.Descriptor instead.

func (*TriggerAsyncOrganizationPipelineResponse) GetOperation

func (*TriggerAsyncOrganizationPipelineResponse) ProtoMessage

func (*TriggerAsyncOrganizationPipelineResponse) ProtoReflect

func (*TriggerAsyncOrganizationPipelineResponse) Reset

func (*TriggerAsyncOrganizationPipelineResponse) String

type TriggerAsyncUserPipelineReleaseRequest

type TriggerAsyncUserPipelineReleaseRequest struct {

	// The resource name of the pipeline release, which allows its access by
	// parent pipeline and ID.
	// - Format: `users/{user.id}/pipelines/{pipeline.id}/releases/{release.id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Pipeline input parameters.
	Inputs []*structpb.Struct `protobuf:"bytes,2,rep,name=inputs,proto3" json:"inputs,omitempty"`
	// Pipeline secrets parameters that will override the pipeline's or owner's secrets.
	Secrets map[string]string `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

TriggerUserPipelineReleaseRequest represents a request to trigger a pinned release of a user-owned pipeline asynchronously.

func (*TriggerAsyncUserPipelineReleaseRequest) Descriptor deprecated

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

Deprecated: Use TriggerAsyncUserPipelineReleaseRequest.ProtoReflect.Descriptor instead.

func (*TriggerAsyncUserPipelineReleaseRequest) GetInputs

func (*TriggerAsyncUserPipelineReleaseRequest) GetName

func (*TriggerAsyncUserPipelineReleaseRequest) GetSecrets

func (*TriggerAsyncUserPipelineReleaseRequest) ProtoMessage

func (*TriggerAsyncUserPipelineReleaseRequest) ProtoReflect

func (*TriggerAsyncUserPipelineReleaseRequest) Reset

func (*TriggerAsyncUserPipelineReleaseRequest) String

type TriggerAsyncUserPipelineReleaseResponse

type TriggerAsyncUserPipelineReleaseResponse struct {

	// Long-running operation information.
	Operation *longrunningpb.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

TriggerAsyncUserPipelineReleaseResponse contains the information to access the status of an asynchronous pipeline execution.

func (*TriggerAsyncUserPipelineReleaseResponse) Descriptor deprecated

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

Deprecated: Use TriggerAsyncUserPipelineReleaseResponse.ProtoReflect.Descriptor instead.

func (*TriggerAsyncUserPipelineReleaseResponse) GetOperation

func (*TriggerAsyncUserPipelineReleaseResponse) ProtoMessage

func (*TriggerAsyncUserPipelineReleaseResponse) ProtoReflect

func (*TriggerAsyncUserPipelineReleaseResponse) Reset

func (*TriggerAsyncUserPipelineReleaseResponse) String

type TriggerAsyncUserPipelineRequest

type TriggerAsyncUserPipelineRequest struct {

	// The resource name of the pipeline, which allows its access by parent user
	// and ID.
	// - Format: `users/{user.id}/pipelines/{pipeline.id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Pipeline input parameters.
	Inputs []*structpb.Struct `protobuf:"bytes,2,rep,name=inputs,proto3" json:"inputs,omitempty"`
	// Pipeline secrets parameters that will override the pipeline's or owner's secrets.
	Secrets map[string]string `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

TriggerUserPipelineRequest represents a request to trigger a user-owned pipeline synchronously.

func (*TriggerAsyncUserPipelineRequest) Descriptor deprecated

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

Deprecated: Use TriggerAsyncUserPipelineRequest.ProtoReflect.Descriptor instead.

func (*TriggerAsyncUserPipelineRequest) GetInputs

func (*TriggerAsyncUserPipelineRequest) GetName

func (*TriggerAsyncUserPipelineRequest) GetSecrets

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

func (*TriggerAsyncUserPipelineRequest) ProtoMessage

func (*TriggerAsyncUserPipelineRequest) ProtoMessage()

func (*TriggerAsyncUserPipelineRequest) ProtoReflect

func (*TriggerAsyncUserPipelineRequest) Reset

func (*TriggerAsyncUserPipelineRequest) String

type TriggerAsyncUserPipelineResponse

type TriggerAsyncUserPipelineResponse struct {

	// Long-running operation information.
	Operation *longrunningpb.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

TriggerAsyncUserPipelineResponse contains the information to access the status of an asynchronous pipeline execution.

func (*TriggerAsyncUserPipelineResponse) Descriptor deprecated

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

Deprecated: Use TriggerAsyncUserPipelineResponse.ProtoReflect.Descriptor instead.

func (*TriggerAsyncUserPipelineResponse) GetOperation

func (*TriggerAsyncUserPipelineResponse) ProtoMessage

func (*TriggerAsyncUserPipelineResponse) ProtoMessage()

func (*TriggerAsyncUserPipelineResponse) ProtoReflect

func (*TriggerAsyncUserPipelineResponse) Reset

func (*TriggerAsyncUserPipelineResponse) String

type TriggerByRequest

type TriggerByRequest struct {

	// Fields configuration of request.
	// Key: Key of the input data.
	// Field: Field settings of the value.
	RequestFields map[string]*TriggerByRequest_RequestField `` /* 188-byte string literal not displayed */
	// Fields configuration of response.
	// Key: Key of the input data.
	// Field: Field settings of the value.
	ResponseFields map[string]*TriggerByRequest_ResponseField `` /* 191-byte string literal not displayed */
	// contains filtered or unexported fields
}

TriggerByRequest Configures the payload format of request when triggered by a request.

func (*TriggerByRequest) Descriptor deprecated

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

Deprecated: Use TriggerByRequest.ProtoReflect.Descriptor instead.

func (*TriggerByRequest) GetRequestFields

func (x *TriggerByRequest) GetRequestFields() map[string]*TriggerByRequest_RequestField

func (*TriggerByRequest) GetResponseFields

func (x *TriggerByRequest) GetResponseFields() map[string]*TriggerByRequest_ResponseField

func (*TriggerByRequest) ProtoMessage

func (*TriggerByRequest) ProtoMessage()

func (*TriggerByRequest) ProtoReflect

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

func (*TriggerByRequest) Reset

func (x *TriggerByRequest) Reset()

func (*TriggerByRequest) String

func (x *TriggerByRequest) String() string

type TriggerByRequest_RequestField

type TriggerByRequest_RequestField struct {

	// Title of the field.
	Title string `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	// Description of the field.
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// Instill format.
	InstillFormat string `protobuf:"bytes,3,opt,name=instill_format,json=instillFormat,proto3" json:"instill_format,omitempty"`
	// Instill UI order.
	InstillUiOrder int32 `protobuf:"varint,4,opt,name=instill_ui_order,json=instillUiOrder,proto3" json:"instill_ui_order,omitempty"`
	// Instill UI Multiline.
	InstillUiMultiline bool `protobuf:"varint,5,opt,name=instill_ui_multiline,json=instillUiMultiline,proto3" json:"instill_ui_multiline,omitempty"`
	// contains filtered or unexported fields
}

Represents a field within the reqeuest.

func (*TriggerByRequest_RequestField) Descriptor deprecated

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

Deprecated: Use TriggerByRequest_RequestField.ProtoReflect.Descriptor instead.

func (*TriggerByRequest_RequestField) GetDescription

func (x *TriggerByRequest_RequestField) GetDescription() string

func (*TriggerByRequest_RequestField) GetInstillFormat

func (x *TriggerByRequest_RequestField) GetInstillFormat() string

func (*TriggerByRequest_RequestField) GetInstillUiMultiline

func (x *TriggerByRequest_RequestField) GetInstillUiMultiline() bool

func (*TriggerByRequest_RequestField) GetInstillUiOrder

func (x *TriggerByRequest_RequestField) GetInstillUiOrder() int32

func (*TriggerByRequest_RequestField) GetTitle

func (x *TriggerByRequest_RequestField) GetTitle() string

func (*TriggerByRequest_RequestField) ProtoMessage

func (*TriggerByRequest_RequestField) ProtoMessage()

func (*TriggerByRequest_RequestField) ProtoReflect

func (*TriggerByRequest_RequestField) Reset

func (x *TriggerByRequest_RequestField) Reset()

func (*TriggerByRequest_RequestField) String

type TriggerByRequest_ResponseField

type TriggerByRequest_ResponseField struct {

	// Title of the field.
	Title string `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	// Description of the field.
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// Value of the field.
	Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// Instill UI order.
	InstillUiOrder int32 `protobuf:"varint,4,opt,name=instill_ui_order,json=instillUiOrder,proto3" json:"instill_ui_order,omitempty"`
	// contains filtered or unexported fields
}

Represents a field within the response.

func (*TriggerByRequest_ResponseField) Descriptor deprecated

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

Deprecated: Use TriggerByRequest_ResponseField.ProtoReflect.Descriptor instead.

func (*TriggerByRequest_ResponseField) GetDescription

func (x *TriggerByRequest_ResponseField) GetDescription() string

func (*TriggerByRequest_ResponseField) GetInstillUiOrder

func (x *TriggerByRequest_ResponseField) GetInstillUiOrder() int32

func (*TriggerByRequest_ResponseField) GetTitle

func (x *TriggerByRequest_ResponseField) GetTitle() string

func (*TriggerByRequest_ResponseField) GetValue

func (x *TriggerByRequest_ResponseField) GetValue() string

func (*TriggerByRequest_ResponseField) ProtoMessage

func (*TriggerByRequest_ResponseField) ProtoMessage()

func (*TriggerByRequest_ResponseField) ProtoReflect

func (*TriggerByRequest_ResponseField) Reset

func (x *TriggerByRequest_ResponseField) Reset()

func (*TriggerByRequest_ResponseField) String

type TriggerMetadata

type TriggerMetadata struct {

	// Each key in the `traces` object is a component ID. The value is a Trace
	// object containing the execution details.
	Traces map[string]*Trace `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

TriggerMetadata contains the traces of the pipeline inference.

func (*TriggerMetadata) Descriptor deprecated

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

Deprecated: Use TriggerMetadata.ProtoReflect.Descriptor instead.

func (*TriggerMetadata) GetTraces

func (x *TriggerMetadata) GetTraces() map[string]*Trace

func (*TriggerMetadata) ProtoMessage

func (*TriggerMetadata) ProtoMessage()

func (*TriggerMetadata) ProtoReflect

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

func (*TriggerMetadata) Reset

func (x *TriggerMetadata) Reset()

func (*TriggerMetadata) String

func (x *TriggerMetadata) String() string

type TriggerOrganizationPipelineReleaseRequest

type TriggerOrganizationPipelineReleaseRequest struct {

	// The resource name of the pipeline release, which allows its access by
	// parent pipeline and ID.
	// - Format:
	// `organizations/{organization.id}/pipelines/{pipeline.id}/releases/{release.id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Pipeline input parameters.
	Inputs []*structpb.Struct `protobuf:"bytes,2,rep,name=inputs,proto3" json:"inputs,omitempty"`
	// Pipeline secrets parameters that will override the pipeline's or owner's secrets.
	Secrets map[string]string `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

TriggerOrganizationPipelineReleaseRequest represents a request to trigger a pinned release of an organization-owned pipeline.

func (*TriggerOrganizationPipelineReleaseRequest) Descriptor deprecated

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

Deprecated: Use TriggerOrganizationPipelineReleaseRequest.ProtoReflect.Descriptor instead.

func (*TriggerOrganizationPipelineReleaseRequest) GetInputs

func (*TriggerOrganizationPipelineReleaseRequest) GetName

func (*TriggerOrganizationPipelineReleaseRequest) GetSecrets

func (*TriggerOrganizationPipelineReleaseRequest) ProtoMessage

func (*TriggerOrganizationPipelineReleaseRequest) ProtoReflect

func (*TriggerOrganizationPipelineReleaseRequest) Reset

func (*TriggerOrganizationPipelineReleaseRequest) String

type TriggerOrganizationPipelineReleaseResponse

type TriggerOrganizationPipelineReleaseResponse struct {

	// Model inference outputs.
	Outputs []*structpb.Struct `protobuf:"bytes,1,rep,name=outputs,proto3" json:"outputs,omitempty"`
	// Traces of the pipeline inference.
	Metadata *TriggerMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

TriggerOrganizationPipelineReleaseResponse contains the pipeline execution results, i.e., the multiple model inference outputs.

func (*TriggerOrganizationPipelineReleaseResponse) Descriptor deprecated

Deprecated: Use TriggerOrganizationPipelineReleaseResponse.ProtoReflect.Descriptor instead.

func (*TriggerOrganizationPipelineReleaseResponse) GetMetadata

func (*TriggerOrganizationPipelineReleaseResponse) GetOutputs

func (*TriggerOrganizationPipelineReleaseResponse) ProtoMessage

func (*TriggerOrganizationPipelineReleaseResponse) ProtoReflect

func (*TriggerOrganizationPipelineReleaseResponse) Reset

func (*TriggerOrganizationPipelineReleaseResponse) String

type TriggerOrganizationPipelineRequest

type TriggerOrganizationPipelineRequest struct {

	// The resource name of the pipeline, which allows its access by parent
	// organization and ID.
	// - Format: `organizations/{organization.id}/pipelines/{pipeline.id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Pipeline input parameters.
	Inputs []*structpb.Struct `protobuf:"bytes,2,rep,name=inputs,proto3" json:"inputs,omitempty"`
	// Pipeline secrets parameters that will override the pipeline's or owner's secrets.
	Secrets map[string]string `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

TriggerOrganizationPipelineRequest represents a request to trigger an organization-owned pipeline synchronously.

func (*TriggerOrganizationPipelineRequest) Descriptor deprecated

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

Deprecated: Use TriggerOrganizationPipelineRequest.ProtoReflect.Descriptor instead.

func (*TriggerOrganizationPipelineRequest) GetInputs

func (*TriggerOrganizationPipelineRequest) GetName

func (*TriggerOrganizationPipelineRequest) GetSecrets

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

func (*TriggerOrganizationPipelineRequest) ProtoMessage

func (*TriggerOrganizationPipelineRequest) ProtoMessage()

func (*TriggerOrganizationPipelineRequest) ProtoReflect

func (*TriggerOrganizationPipelineRequest) Reset

func (*TriggerOrganizationPipelineRequest) String

type TriggerOrganizationPipelineResponse

type TriggerOrganizationPipelineResponse struct {

	// Model inference outputs.
	Outputs []*structpb.Struct `protobuf:"bytes,1,rep,name=outputs,proto3" json:"outputs,omitempty"`
	// Traces of the pipeline inference.
	Metadata *TriggerMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

TriggerOrganizationPipelineResponse contains the pipeline execution results, i.e., the multiple model inference outputs.

func (*TriggerOrganizationPipelineResponse) Descriptor deprecated

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

Deprecated: Use TriggerOrganizationPipelineResponse.ProtoReflect.Descriptor instead.

func (*TriggerOrganizationPipelineResponse) GetMetadata

func (*TriggerOrganizationPipelineResponse) GetOutputs

func (*TriggerOrganizationPipelineResponse) ProtoMessage

func (*TriggerOrganizationPipelineResponse) ProtoMessage()

func (*TriggerOrganizationPipelineResponse) ProtoReflect

func (*TriggerOrganizationPipelineResponse) Reset

func (*TriggerOrganizationPipelineResponse) String

type TriggerUserPipelineReleaseRequest

type TriggerUserPipelineReleaseRequest struct {

	// The resource name of the pipeline release, which allows its access by
	// parent pipeline and ID.
	// - Format: `users/{user.id}/pipelines/{pipeline.id}/releases/{release.id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Pipeline input parameters.
	Inputs []*structpb.Struct `protobuf:"bytes,2,rep,name=inputs,proto3" json:"inputs,omitempty"`
	// Pipeline secrets parameters that will override the pipeline's or owner's secrets.
	Secrets map[string]string `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

TriggerUserPipelineReleaseRequest represents a request to trigger a pinned release of a user-owned pipeline.

func (*TriggerUserPipelineReleaseRequest) Descriptor deprecated

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

Deprecated: Use TriggerUserPipelineReleaseRequest.ProtoReflect.Descriptor instead.

func (*TriggerUserPipelineReleaseRequest) GetInputs

func (*TriggerUserPipelineReleaseRequest) GetName

func (*TriggerUserPipelineReleaseRequest) GetSecrets

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

func (*TriggerUserPipelineReleaseRequest) ProtoMessage

func (*TriggerUserPipelineReleaseRequest) ProtoMessage()

func (*TriggerUserPipelineReleaseRequest) ProtoReflect

func (*TriggerUserPipelineReleaseRequest) Reset

func (*TriggerUserPipelineReleaseRequest) String

type TriggerUserPipelineReleaseResponse

type TriggerUserPipelineReleaseResponse struct {

	// Model inference outputs.
	Outputs []*structpb.Struct `protobuf:"bytes,1,rep,name=outputs,proto3" json:"outputs,omitempty"`
	// Traces of the pipeline inference.
	Metadata *TriggerMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

TriggerUserPipelineReleaseResponse contains the pipeline execution results, i.e., the multiple model inference outputs.

func (*TriggerUserPipelineReleaseResponse) Descriptor deprecated

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

Deprecated: Use TriggerUserPipelineReleaseResponse.ProtoReflect.Descriptor instead.

func (*TriggerUserPipelineReleaseResponse) GetMetadata

func (*TriggerUserPipelineReleaseResponse) GetOutputs

func (*TriggerUserPipelineReleaseResponse) ProtoMessage

func (*TriggerUserPipelineReleaseResponse) ProtoMessage()

func (*TriggerUserPipelineReleaseResponse) ProtoReflect

func (*TriggerUserPipelineReleaseResponse) Reset

func (*TriggerUserPipelineReleaseResponse) String

type TriggerUserPipelineRequest

type TriggerUserPipelineRequest struct {

	// The resource name of the pipeline, which allows its access by parent user
	// and ID.
	// - Format: `users/{user.id}/pipelines/{pipeline.id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Pipeline input parameters.
	Inputs []*structpb.Struct `protobuf:"bytes,2,rep,name=inputs,proto3" json:"inputs,omitempty"`
	// Pipeline secrets parameters that will override the pipeline's or owner's secrets.
	Secrets map[string]string `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

TriggerUserPipelineRequest represents a request to trigger a user-owned pipeline synchronously.

func (*TriggerUserPipelineRequest) Descriptor deprecated

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

Deprecated: Use TriggerUserPipelineRequest.ProtoReflect.Descriptor instead.

func (*TriggerUserPipelineRequest) GetInputs

func (x *TriggerUserPipelineRequest) GetInputs() []*structpb.Struct

func (*TriggerUserPipelineRequest) GetName

func (x *TriggerUserPipelineRequest) GetName() string

func (*TriggerUserPipelineRequest) GetSecrets

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

func (*TriggerUserPipelineRequest) ProtoMessage

func (*TriggerUserPipelineRequest) ProtoMessage()

func (*TriggerUserPipelineRequest) ProtoReflect

func (*TriggerUserPipelineRequest) Reset

func (x *TriggerUserPipelineRequest) Reset()

func (*TriggerUserPipelineRequest) String

func (x *TriggerUserPipelineRequest) String() string

type TriggerUserPipelineResponse

type TriggerUserPipelineResponse struct {

	// Model inference outputs.
	Outputs []*structpb.Struct `protobuf:"bytes,1,rep,name=outputs,proto3" json:"outputs,omitempty"`
	// Traces of the pipeline inference.
	Metadata *TriggerMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

TriggerUserPipelineResponse contains the pipeline execution results, i.e., the multiple model inference outputs.

func (*TriggerUserPipelineResponse) Descriptor deprecated

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

Deprecated: Use TriggerUserPipelineResponse.ProtoReflect.Descriptor instead.

func (*TriggerUserPipelineResponse) GetMetadata

func (x *TriggerUserPipelineResponse) GetMetadata() *TriggerMetadata

func (*TriggerUserPipelineResponse) GetOutputs

func (x *TriggerUserPipelineResponse) GetOutputs() []*structpb.Struct

func (*TriggerUserPipelineResponse) ProtoMessage

func (*TriggerUserPipelineResponse) ProtoMessage()

func (*TriggerUserPipelineResponse) ProtoReflect

func (*TriggerUserPipelineResponse) Reset

func (x *TriggerUserPipelineResponse) Reset()

func (*TriggerUserPipelineResponse) String

func (x *TriggerUserPipelineResponse) String() string

type Trigger_TriggerByRequest

type Trigger_TriggerByRequest struct {
	// Triggered by reqeust.
	TriggerByRequest *TriggerByRequest `protobuf:"bytes,1,opt,name=trigger_by_request,json=triggerByRequest,proto3,oneof"`
}

type UnimplementedPipelinePrivateServiceServer

type UnimplementedPipelinePrivateServiceServer struct {
}

UnimplementedPipelinePrivateServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedPipelinePrivateServiceServer) ListPipelinesAdmin

func (UnimplementedPipelinePrivateServiceServer) LookUpPipelineAdmin

type UnimplementedPipelinePublicServiceServer

type UnimplementedPipelinePublicServiceServer struct {
}

UnimplementedPipelinePublicServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedPipelinePublicServiceServer) CheckName

func (UnimplementedPipelinePublicServiceServer) CloneUserPipeline

func (UnimplementedPipelinePublicServiceServer) CreateUserPipeline

func (UnimplementedPipelinePublicServiceServer) CreateUserSecret

func (UnimplementedPipelinePublicServiceServer) DeleteUserPipeline

func (UnimplementedPipelinePublicServiceServer) DeleteUserSecret

func (UnimplementedPipelinePublicServiceServer) GetOperation

func (UnimplementedPipelinePublicServiceServer) GetOperatorDefinition

func (UnimplementedPipelinePublicServiceServer) GetOrganizationSecret

func (UnimplementedPipelinePublicServiceServer) GetUserPipeline

func (UnimplementedPipelinePublicServiceServer) GetUserSecret

func (UnimplementedPipelinePublicServiceServer) ListPipelines

func (UnimplementedPipelinePublicServiceServer) ListUserPipelines

func (UnimplementedPipelinePublicServiceServer) ListUserSecrets

func (UnimplementedPipelinePublicServiceServer) Liveness

func (UnimplementedPipelinePublicServiceServer) LookUpPipeline

func (UnimplementedPipelinePublicServiceServer) Readiness

func (UnimplementedPipelinePublicServiceServer) RenameUserPipeline

func (UnimplementedPipelinePublicServiceServer) TriggerUserPipeline

func (UnimplementedPipelinePublicServiceServer) UpdateUserPipeline

func (UnimplementedPipelinePublicServiceServer) UpdateUserSecret

func (UnimplementedPipelinePublicServiceServer) ValidateUserPipeline

type UnsafePipelinePrivateServiceServer

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

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

type UnsafePipelinePublicServiceServer

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

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

type UpdateOrganizationPipelineReleaseRequest

type UpdateOrganizationPipelineReleaseRequest struct {

	// The pipeline release fields that will replace the existing ones.
	// A pipeline release resource to update
	Release *PipelineRelease `protobuf:"bytes,1,opt,name=release,proto3" json:"release,omitempty"`
	// The update mask specifies the subset of fields that should be modified.
	//
	// For more information about this field, see
	// https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#field-mask.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// contains filtered or unexported fields
}

UpdateOrganizationPipelineReleaseRequest represents a request to update an organization-owned pipeline release.

func (*UpdateOrganizationPipelineReleaseRequest) Descriptor deprecated

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

Deprecated: Use UpdateOrganizationPipelineReleaseRequest.ProtoReflect.Descriptor instead.

func (*UpdateOrganizationPipelineReleaseRequest) GetRelease

func (*UpdateOrganizationPipelineReleaseRequest) GetUpdateMask

func (*UpdateOrganizationPipelineReleaseRequest) ProtoMessage

func (*UpdateOrganizationPipelineReleaseRequest) ProtoReflect

func (*UpdateOrganizationPipelineReleaseRequest) Reset

func (*UpdateOrganizationPipelineReleaseRequest) String

type UpdateOrganizationPipelineReleaseResponse

type UpdateOrganizationPipelineReleaseResponse struct {

	// The updated pipeline release resource.
	Release *PipelineRelease `protobuf:"bytes,1,opt,name=release,proto3" json:"release,omitempty"`
	// contains filtered or unexported fields
}

UpdateOrganizationPipelineReleaseResponse contains the updated pipeline release.

func (*UpdateOrganizationPipelineReleaseResponse) Descriptor deprecated

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

Deprecated: Use UpdateOrganizationPipelineReleaseResponse.ProtoReflect.Descriptor instead.

func (*UpdateOrganizationPipelineReleaseResponse) GetRelease

func (*UpdateOrganizationPipelineReleaseResponse) ProtoMessage

func (*UpdateOrganizationPipelineReleaseResponse) ProtoReflect

func (*UpdateOrganizationPipelineReleaseResponse) Reset

func (*UpdateOrganizationPipelineReleaseResponse) String

type UpdateOrganizationPipelineRequest

type UpdateOrganizationPipelineRequest struct {

	// The pipeline fields that will replace the existing ones.
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// The update mask specifies the subset of fields that should be modified.
	//
	// For more information about this field, see
	// https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#field-mask.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// contains filtered or unexported fields
}

UpdateOrganizationPipelineRequest represents a request to update a pipeline owned by an organization.

func (*UpdateOrganizationPipelineRequest) Descriptor deprecated

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

Deprecated: Use UpdateOrganizationPipelineRequest.ProtoReflect.Descriptor instead.

func (*UpdateOrganizationPipelineRequest) GetPipeline

func (x *UpdateOrganizationPipelineRequest) GetPipeline() *Pipeline

func (*UpdateOrganizationPipelineRequest) GetUpdateMask

func (*UpdateOrganizationPipelineRequest) ProtoMessage

func (*UpdateOrganizationPipelineRequest) ProtoMessage()

func (*UpdateOrganizationPipelineRequest) ProtoReflect

func (*UpdateOrganizationPipelineRequest) Reset

func (*UpdateOrganizationPipelineRequest) String

type UpdateOrganizationPipelineResponse

type UpdateOrganizationPipelineResponse struct {

	// The updated pipeline resource.
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// contains filtered or unexported fields
}

UpdateOrganizationPipelineResponse contains the updated pipeline.

func (*UpdateOrganizationPipelineResponse) Descriptor deprecated

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

Deprecated: Use UpdateOrganizationPipelineResponse.ProtoReflect.Descriptor instead.

func (*UpdateOrganizationPipelineResponse) GetPipeline

func (x *UpdateOrganizationPipelineResponse) GetPipeline() *Pipeline

func (*UpdateOrganizationPipelineResponse) ProtoMessage

func (*UpdateOrganizationPipelineResponse) ProtoMessage()

func (*UpdateOrganizationPipelineResponse) ProtoReflect

func (*UpdateOrganizationPipelineResponse) Reset

func (*UpdateOrganizationPipelineResponse) String

type UpdateOrganizationSecretRequest

type UpdateOrganizationSecretRequest struct {

	// The secret fields to update.
	Secret *Secret `protobuf:"bytes,1,opt,name=secret,proto3" json:"secret,omitempty"`
	// The update mask specifies the subset of fields that should be modified.
	//
	// For more information about this field, see
	// https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#field-mask.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// contains filtered or unexported fields
}

UpdateOrganizationSecretRequest represents a request to update a user secret.

func (*UpdateOrganizationSecretRequest) Descriptor deprecated

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

Deprecated: Use UpdateOrganizationSecretRequest.ProtoReflect.Descriptor instead.

func (*UpdateOrganizationSecretRequest) GetSecret

func (x *UpdateOrganizationSecretRequest) GetSecret() *Secret

func (*UpdateOrganizationSecretRequest) GetUpdateMask

func (*UpdateOrganizationSecretRequest) ProtoMessage

func (*UpdateOrganizationSecretRequest) ProtoMessage()

func (*UpdateOrganizationSecretRequest) ProtoReflect

func (*UpdateOrganizationSecretRequest) Reset

func (*UpdateOrganizationSecretRequest) String

type UpdateOrganizationSecretResponse

type UpdateOrganizationSecretResponse struct {

	// The updated secret resource.
	Secret *Secret `protobuf:"bytes,1,opt,name=secret,proto3" json:"secret,omitempty"`
	// contains filtered or unexported fields
}

UpdateOrganizationSecretResponse contains the updated secret.

func (*UpdateOrganizationSecretResponse) Descriptor deprecated

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

Deprecated: Use UpdateOrganizationSecretResponse.ProtoReflect.Descriptor instead.

func (*UpdateOrganizationSecretResponse) GetSecret

func (x *UpdateOrganizationSecretResponse) GetSecret() *Secret

func (*UpdateOrganizationSecretResponse) ProtoMessage

func (*UpdateOrganizationSecretResponse) ProtoMessage()

func (*UpdateOrganizationSecretResponse) ProtoReflect

func (*UpdateOrganizationSecretResponse) Reset

func (*UpdateOrganizationSecretResponse) String

type UpdateUserPipelineReleaseRequest

type UpdateUserPipelineReleaseRequest struct {

	// The pipeline release fields that will replace the existing ones.
	// A pipeline release resource to update
	Release *PipelineRelease `protobuf:"bytes,1,opt,name=release,proto3" json:"release,omitempty"`
	// The update mask specifies the subset of fields that should be modified.
	//
	// For more information about this field, see
	// https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#field-mask.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// contains filtered or unexported fields
}

UpdateUserPipelineReleaseRequest represents a request to update a user-owned pipeline release.

func (*UpdateUserPipelineReleaseRequest) Descriptor deprecated

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

Deprecated: Use UpdateUserPipelineReleaseRequest.ProtoReflect.Descriptor instead.

func (*UpdateUserPipelineReleaseRequest) GetRelease

func (*UpdateUserPipelineReleaseRequest) GetUpdateMask

func (*UpdateUserPipelineReleaseRequest) ProtoMessage

func (*UpdateUserPipelineReleaseRequest) ProtoMessage()

func (*UpdateUserPipelineReleaseRequest) ProtoReflect

func (*UpdateUserPipelineReleaseRequest) Reset

func (*UpdateUserPipelineReleaseRequest) String

type UpdateUserPipelineReleaseResponse

type UpdateUserPipelineReleaseResponse struct {

	// The updated pipeline release resource.
	Release *PipelineRelease `protobuf:"bytes,1,opt,name=release,proto3" json:"release,omitempty"`
	// contains filtered or unexported fields
}

UpdateUserPipelineReleaseResponse contains the updated pipeline release.

func (*UpdateUserPipelineReleaseResponse) Descriptor deprecated

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

Deprecated: Use UpdateUserPipelineReleaseResponse.ProtoReflect.Descriptor instead.

func (*UpdateUserPipelineReleaseResponse) GetRelease

func (*UpdateUserPipelineReleaseResponse) ProtoMessage

func (*UpdateUserPipelineReleaseResponse) ProtoMessage()

func (*UpdateUserPipelineReleaseResponse) ProtoReflect

func (*UpdateUserPipelineReleaseResponse) Reset

func (*UpdateUserPipelineReleaseResponse) String

type UpdateUserPipelineRequest

type UpdateUserPipelineRequest struct {

	// The pipeline fields that will replace the existing ones.
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// The update mask specifies the subset of fields that should be modified.
	//
	// For more information about this field, see
	// https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#field-mask.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// contains filtered or unexported fields
}

UpdateUserPipelineRequest represents a request to update a pipeline owned by a user.

func (*UpdateUserPipelineRequest) Descriptor deprecated

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

Deprecated: Use UpdateUserPipelineRequest.ProtoReflect.Descriptor instead.

func (*UpdateUserPipelineRequest) GetPipeline

func (x *UpdateUserPipelineRequest) GetPipeline() *Pipeline

func (*UpdateUserPipelineRequest) GetUpdateMask

func (x *UpdateUserPipelineRequest) GetUpdateMask() *fieldmaskpb.FieldMask

func (*UpdateUserPipelineRequest) ProtoMessage

func (*UpdateUserPipelineRequest) ProtoMessage()

func (*UpdateUserPipelineRequest) ProtoReflect

func (*UpdateUserPipelineRequest) Reset

func (x *UpdateUserPipelineRequest) Reset()

func (*UpdateUserPipelineRequest) String

func (x *UpdateUserPipelineRequest) String() string

type UpdateUserPipelineResponse

type UpdateUserPipelineResponse struct {

	// The updated pipeline resource.
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// contains filtered or unexported fields
}

UpdateUserPipelineResponse contains the updated pipeline.

func (*UpdateUserPipelineResponse) Descriptor deprecated

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

Deprecated: Use UpdateUserPipelineResponse.ProtoReflect.Descriptor instead.

func (*UpdateUserPipelineResponse) GetPipeline

func (x *UpdateUserPipelineResponse) GetPipeline() *Pipeline

func (*UpdateUserPipelineResponse) ProtoMessage

func (*UpdateUserPipelineResponse) ProtoMessage()

func (*UpdateUserPipelineResponse) ProtoReflect

func (*UpdateUserPipelineResponse) Reset

func (x *UpdateUserPipelineResponse) Reset()

func (*UpdateUserPipelineResponse) String

func (x *UpdateUserPipelineResponse) String() string

type UpdateUserSecretRequest

type UpdateUserSecretRequest struct {

	// The secret fields to update.
	Secret *Secret `protobuf:"bytes,1,opt,name=secret,proto3" json:"secret,omitempty"`
	// The update mask specifies the subset of fields that should be modified.
	//
	// For more information about this field, see
	// https://developers.google.com/protocol-buffers/docs/reference/google.protobuf#field-mask.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// contains filtered or unexported fields
}

UpdateUserSecretRequest represents a request to update a user secret.

func (*UpdateUserSecretRequest) Descriptor deprecated

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

Deprecated: Use UpdateUserSecretRequest.ProtoReflect.Descriptor instead.

func (*UpdateUserSecretRequest) GetSecret

func (x *UpdateUserSecretRequest) GetSecret() *Secret

func (*UpdateUserSecretRequest) GetUpdateMask

func (x *UpdateUserSecretRequest) GetUpdateMask() *fieldmaskpb.FieldMask

func (*UpdateUserSecretRequest) ProtoMessage

func (*UpdateUserSecretRequest) ProtoMessage()

func (*UpdateUserSecretRequest) ProtoReflect

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

func (*UpdateUserSecretRequest) Reset

func (x *UpdateUserSecretRequest) Reset()

func (*UpdateUserSecretRequest) String

func (x *UpdateUserSecretRequest) String() string

type UpdateUserSecretResponse

type UpdateUserSecretResponse struct {

	// The updated secret resource.
	Secret *Secret `protobuf:"bytes,1,opt,name=secret,proto3" json:"secret,omitempty"`
	// contains filtered or unexported fields
}

UpdateUserSecretResponse contains the updated secret.

func (*UpdateUserSecretResponse) Descriptor deprecated

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

Deprecated: Use UpdateUserSecretResponse.ProtoReflect.Descriptor instead.

func (*UpdateUserSecretResponse) GetSecret

func (x *UpdateUserSecretResponse) GetSecret() *Secret

func (*UpdateUserSecretResponse) ProtoMessage

func (*UpdateUserSecretResponse) ProtoMessage()

func (*UpdateUserSecretResponse) ProtoReflect

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

func (*UpdateUserSecretResponse) Reset

func (x *UpdateUserSecretResponse) Reset()

func (*UpdateUserSecretResponse) String

func (x *UpdateUserSecretResponse) String() string

type ValidateOrganizationPipelineRequest

type ValidateOrganizationPipelineRequest struct {

	// The resource name of the pipeline, which allows its access by parent
	// organization and ID.
	// - Format: `organizations/{organization.id}/pipelines/{pipeline.id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

ValidateOrganizationPipelineRequest represents a request to validate a pipeline owned by an organization.

func (*ValidateOrganizationPipelineRequest) Descriptor deprecated

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

Deprecated: Use ValidateOrganizationPipelineRequest.ProtoReflect.Descriptor instead.

func (*ValidateOrganizationPipelineRequest) GetName

func (*ValidateOrganizationPipelineRequest) ProtoMessage

func (*ValidateOrganizationPipelineRequest) ProtoMessage()

func (*ValidateOrganizationPipelineRequest) ProtoReflect

func (*ValidateOrganizationPipelineRequest) Reset

func (*ValidateOrganizationPipelineRequest) String

type ValidateOrganizationPipelineResponse

type ValidateOrganizationPipelineResponse struct {

	// The validated pipeline resource.
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// contains filtered or unexported fields
}

ValidateOrganizationPipelineResponse contains a validated pipeline.

func (*ValidateOrganizationPipelineResponse) Descriptor deprecated

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

Deprecated: Use ValidateOrganizationPipelineResponse.ProtoReflect.Descriptor instead.

func (*ValidateOrganizationPipelineResponse) GetPipeline

func (*ValidateOrganizationPipelineResponse) ProtoMessage

func (*ValidateOrganizationPipelineResponse) ProtoMessage()

func (*ValidateOrganizationPipelineResponse) ProtoReflect

func (*ValidateOrganizationPipelineResponse) Reset

func (*ValidateOrganizationPipelineResponse) String

type ValidateUserPipelineRequest

type ValidateUserPipelineRequest struct {

	// The resource name of the pipeline, which allows its access by parent user
	// and ID.
	// - Format: `users/{user.id}/pipelines/{pipeline.id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

ValidateUserPipelineRequest represents a request to validate a pipeline owned by a user.

func (*ValidateUserPipelineRequest) Descriptor deprecated

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

Deprecated: Use ValidateUserPipelineRequest.ProtoReflect.Descriptor instead.

func (*ValidateUserPipelineRequest) GetName

func (x *ValidateUserPipelineRequest) GetName() string

func (*ValidateUserPipelineRequest) ProtoMessage

func (*ValidateUserPipelineRequest) ProtoMessage()

func (*ValidateUserPipelineRequest) ProtoReflect

func (*ValidateUserPipelineRequest) Reset

func (x *ValidateUserPipelineRequest) Reset()

func (*ValidateUserPipelineRequest) String

func (x *ValidateUserPipelineRequest) String() string

type ValidateUserPipelineResponse

type ValidateUserPipelineResponse struct {

	// The validated pipeline resource.
	Pipeline *Pipeline `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// contains filtered or unexported fields
}

ValidateUserPipelineResponse contains a validated pipeline.

func (*ValidateUserPipelineResponse) Descriptor deprecated

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

Deprecated: Use ValidateUserPipelineResponse.ProtoReflect.Descriptor instead.

func (*ValidateUserPipelineResponse) GetPipeline

func (x *ValidateUserPipelineResponse) GetPipeline() *Pipeline

func (*ValidateUserPipelineResponse) ProtoMessage

func (*ValidateUserPipelineResponse) ProtoMessage()

func (*ValidateUserPipelineResponse) ProtoReflect

func (*ValidateUserPipelineResponse) Reset

func (x *ValidateUserPipelineResponse) Reset()

func (*ValidateUserPipelineResponse) String

Jump to

Keyboard shortcuts

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