optimus

package
v0.9.6 Latest Latest
Warning

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

 Go to latest Published: Sep 4, 2023 License: Apache-2.0 Imports: 20 Imported by: 2

Documentation

Overview

Package optimus is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package optimus is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package optimus is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package optimus is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package optimus is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package optimus is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package optimus is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package optimus is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package optimus is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	InstanceSpec_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "TYPE_TASK",
		2: "TYPE_HOOK",
	}
	InstanceSpec_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED": 0,
		"TYPE_TASK":        1,
		"TYPE_HOOK":        2,
	}
)

Enum value maps for InstanceSpec_Type.

View Source 
var (
	InstanceSpecData_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "TYPE_ENV",
		2: "TYPE_FILE",
	}
	InstanceSpecData_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED": 0,
		"TYPE_ENV":         1,
		"TYPE_FILE":        2,
	}
)

Enum value maps for InstanceSpecData_Type.

View Source 
var (
	JobState_name = map[int32]string{
		0: "JOB_STATE_UNSPECIFIED",
		1: "JOB_STATE_ENABLED",
		2: "JOB_STATE_DISABLED",
	}
	JobState_value = map[string]int32{
		"JOB_STATE_UNSPECIFIED": 0,
		"JOB_STATE_ENABLED":     1,
		"JOB_STATE_DISABLED":    2,
	}
)

Enum value maps for JobState.

View Source 
var (
	JobEvent_Type_name = map[int32]string{
		0:  "TYPE_UNSPECIFIED",
		1:  "TYPE_SLA_MISS",
		6:  "TYPE_JOB_SUCCESS",
		7:  "TYPE_FAILURE",
		8:  "TYPE_TASK_RETRY",
		9:  "TYPE_TASK_SUCCESS",
		10: "TYPE_TASK_START",
		11: "TYPE_TASK_FAIL",
		12: "TYPE_SENSOR_RETRY",
		13: "TYPE_SENSOR_SUCCESS",
		14: "TYPE_SENSOR_START",
		15: "TYPE_SENSOR_FAIL",
		16: "TYPE_HOOK_START",
		17: "TYPE_HOOK_RETRY",
		18: "TYPE_HOOK_FAIL",
		19: "TYPE_HOOK_SUCCESS",
	}
	JobEvent_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED":    0,
		"TYPE_SLA_MISS":       1,
		"TYPE_JOB_SUCCESS":    6,
		"TYPE_FAILURE":        7,
		"TYPE_TASK_RETRY":     8,
		"TYPE_TASK_SUCCESS":   9,
		"TYPE_TASK_START":     10,
		"TYPE_TASK_FAIL":      11,
		"TYPE_SENSOR_RETRY":   12,
		"TYPE_SENSOR_SUCCESS": 13,
		"TYPE_SENSOR_START":   14,
		"TYPE_SENSOR_FAIL":    15,
		"TYPE_HOOK_START":     16,
		"TYPE_HOOK_RETRY":     17,
		"TYPE_HOOK_FAIL":      18,
		"TYPE_HOOK_SUCCESS":   19,
	}
)

Enum value maps for JobEvent_Type.

View Source 
var (
	Level_name = map[int32]string{
		0: "LEVEL_UNSPECIFIED",
		1: "LEVEL_TRACE",
		2: "LEVEL_DEBUG",
		3: "LEVEL_INFO",
		4: "LEVEL_WARNING",
		5: "LEVEL_ERROR",
		6: "LEVEL_FATAL",
	}
	Level_value = map[string]int32{
		"LEVEL_UNSPECIFIED": 0,
		"LEVEL_TRACE":       1,
		"LEVEL_DEBUG":       2,
		"LEVEL_INFO":        3,
		"LEVEL_WARNING":     4,
		"LEVEL_ERROR":       5,
		"LEVEL_FATAL":       6,
	}
)

Enum value maps for Level.

View Source 
var BackupService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gotocompany.optimus.core.v1beta1.BackupService",
	HandlerType: (*BackupServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateBackup",
			Handler:    _BackupService_CreateBackup_Handler,
		},
		{
			MethodName: "ListBackups",
			Handler:    _BackupService_ListBackups_Handler,
		},
		{
			MethodName: "GetBackup",
			Handler:    _BackupService_GetBackup_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "gotocompany/optimus/core/v1beta1/backup.proto",
}

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

View Source 
var File_gotocompany_optimus_core_v1beta1_backup_proto protoreflect.FileDescriptor
View Source 
var File_gotocompany_optimus_core_v1beta1_job_run_proto protoreflect.FileDescriptor
View Source 
var File_gotocompany_optimus_core_v1beta1_job_spec_proto protoreflect.FileDescriptor
View Source 
var File_gotocompany_optimus_core_v1beta1_namespace_proto protoreflect.FileDescriptor
View Source 
var File_gotocompany_optimus_core_v1beta1_project_proto protoreflect.FileDescriptor
View Source 
var File_gotocompany_optimus_core_v1beta1_replay_proto protoreflect.FileDescriptor
View Source 
var File_gotocompany_optimus_core_v1beta1_resource_proto protoreflect.FileDescriptor
View Source 
var File_gotocompany_optimus_core_v1beta1_runtime_proto protoreflect.FileDescriptor
View Source 
var File_gotocompany_optimus_core_v1beta1_secret_proto protoreflect.FileDescriptor
View Source 
var File_gotocompany_optimus_core_v1beta1_status_proto protoreflect.FileDescriptor
View Source 
var JobRunService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gotocompany.optimus.core.v1beta1.JobRunService",
	HandlerType: (*JobRunServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "JobRunInput",
			Handler:    _JobRunService_JobRunInput_Handler,
		},
		{
			MethodName: "JobRun",
			Handler:    _JobRunService_JobRun_Handler,
		},
		{
			MethodName: "RegisterJobEvent",
			Handler:    _JobRunService_RegisterJobEvent_Handler,
		},
		{
			MethodName: "UploadToScheduler",
			Handler:    _JobRunService_UploadToScheduler_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "gotocompany/optimus/core/v1beta1/job_run.proto",
}

JobRunService_ServiceDesc is the grpc.ServiceDesc for JobRunService 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 JobSpecificationService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gotocompany.optimus.core.v1beta1.JobSpecificationService",
	HandlerType: (*JobSpecificationServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "JobInspect",
			Handler:    _JobSpecificationService_JobInspect_Handler,
		},
		{
			MethodName: "CreateJobSpecification",
			Handler:    _JobSpecificationService_CreateJobSpecification_Handler,
		},
		{
			MethodName: "AddJobSpecifications",
			Handler:    _JobSpecificationService_AddJobSpecifications_Handler,
		},
		{
			MethodName: "UpdateJobSpecifications",
			Handler:    _JobSpecificationService_UpdateJobSpecifications_Handler,
		},
		{
			MethodName: "GetJobSpecification",
			Handler:    _JobSpecificationService_GetJobSpecification_Handler,
		},
		{
			MethodName: "GetJobSpecifications",
			Handler:    _JobSpecificationService_GetJobSpecifications_Handler,
		},
		{
			MethodName: "DeleteJobSpecification",
			Handler:    _JobSpecificationService_DeleteJobSpecification_Handler,
		},
		{
			MethodName: "ChangeJobNamespace",
			Handler:    _JobSpecificationService_ChangeJobNamespace_Handler,
		},
		{
			MethodName: "ListJobSpecification",
			Handler:    _JobSpecificationService_ListJobSpecification_Handler,
		},
		{
			MethodName: "CheckJobSpecification",
			Handler:    _JobSpecificationService_CheckJobSpecification_Handler,
		},
		{
			MethodName: "GetDeployJobsStatus",
			Handler:    _JobSpecificationService_GetDeployJobsStatus_Handler,
		},
		{
			MethodName: "GetJobTask",
			Handler:    _JobSpecificationService_GetJobTask_Handler,
		},
		{
			MethodName: "GetWindow",
			Handler:    _JobSpecificationService_GetWindow_Handler,
		},
		{
			MethodName: "UpdateJobsState",
			Handler:    _JobSpecificationService_UpdateJobsState_Handler,
		},
		{
			MethodName: "SyncJobsState",
			Handler:    _JobSpecificationService_SyncJobsState_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "DeployJobSpecification",
			Handler:       _JobSpecificationService_DeployJobSpecification_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "CheckJobSpecifications",
			Handler:       _JobSpecificationService_CheckJobSpecifications_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "RefreshJobs",
			Handler:       _JobSpecificationService_RefreshJobs_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ReplaceAllJobSpecifications",
			Handler:       _JobSpecificationService_ReplaceAllJobSpecifications_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "gotocompany/optimus/core/v1beta1/job_spec.proto",
}

JobSpecificationService_ServiceDesc is the grpc.ServiceDesc for JobSpecificationService 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 NamespaceService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gotocompany.optimus.core.v1beta1.NamespaceService",
	HandlerType: (*NamespaceServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RegisterProjectNamespace",
			Handler:    _NamespaceService_RegisterProjectNamespace_Handler,
		},
		{
			MethodName: "ListProjectNamespaces",
			Handler:    _NamespaceService_ListProjectNamespaces_Handler,
		},
		{
			MethodName: "GetNamespace",
			Handler:    _NamespaceService_GetNamespace_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "gotocompany/optimus/core/v1beta1/namespace.proto",
}

NamespaceService_ServiceDesc is the grpc.ServiceDesc for NamespaceService 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 ProjectService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gotocompany.optimus.core.v1beta1.ProjectService",
	HandlerType: (*ProjectServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RegisterProject",
			Handler:    _ProjectService_RegisterProject_Handler,
		},
		{
			MethodName: "ListProjects",
			Handler:    _ProjectService_ListProjects_Handler,
		},
		{
			MethodName: "GetProject",
			Handler:    _ProjectService_GetProject_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "gotocompany/optimus/core/v1beta1/project.proto",
}

ProjectService_ServiceDesc is the grpc.ServiceDesc for ProjectService 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 ReplayService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gotocompany.optimus.core.v1beta1.ReplayService",
	HandlerType: (*ReplayServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Replay",
			Handler:    _ReplayService_Replay_Handler,
		},
		{
			MethodName: "ReplayDryRun",
			Handler:    _ReplayService_ReplayDryRun_Handler,
		},
		{
			MethodName: "ListReplay",
			Handler:    _ReplayService_ListReplay_Handler,
		},
		{
			MethodName: "GetReplay",
			Handler:    _ReplayService_GetReplay_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "gotocompany/optimus/core/v1beta1/replay.proto",
}

ReplayService_ServiceDesc is the grpc.ServiceDesc for ReplayService 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 ResourceService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gotocompany.optimus.core.v1beta1.ResourceService",
	HandlerType: (*ResourceServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListResourceSpecification",
			Handler:    _ResourceService_ListResourceSpecification_Handler,
		},
		{
			MethodName: "CreateResource",
			Handler:    _ResourceService_CreateResource_Handler,
		},
		{
			MethodName: "ReadResource",
			Handler:    _ResourceService_ReadResource_Handler,
		},
		{
			MethodName: "UpdateResource",
			Handler:    _ResourceService_UpdateResource_Handler,
		},
		{
			MethodName: "ChangeResourceNamespace",
			Handler:    _ResourceService_ChangeResourceNamespace_Handler,
		},
		{
			MethodName: "ApplyResources",
			Handler:    _ResourceService_ApplyResources_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "DeployResourceSpecification",
			Handler:       _ResourceService_DeployResourceSpecification_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "gotocompany/optimus/core/v1beta1/resource.proto",
}

ResourceService_ServiceDesc is the grpc.ServiceDesc for ResourceService 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 RuntimeService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gotocompany.optimus.core.v1beta1.RuntimeService",
	HandlerType: (*RuntimeServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Version",
			Handler:    _RuntimeService_Version_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "gotocompany/optimus/core/v1beta1/runtime.proto",
}

RuntimeService_ServiceDesc is the grpc.ServiceDesc for RuntimeService 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 SecretService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gotocompany.optimus.core.v1beta1.SecretService",
	HandlerType: (*SecretServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RegisterSecret",
			Handler:    _SecretService_RegisterSecret_Handler,
		},
		{
			MethodName: "UpdateSecret",
			Handler:    _SecretService_UpdateSecret_Handler,
		},
		{
			MethodName: "ListSecrets",
			Handler:    _SecretService_ListSecrets_Handler,
		},
		{
			MethodName: "DeleteSecret",
			Handler:    _SecretService_DeleteSecret_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "gotocompany/optimus/core/v1beta1/secret.proto",
}

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

Functions

func RegisterBackupServiceHandler 

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

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

func RegisterBackupServiceHandlerClient 

func RegisterBackupServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client BackupServiceClient) error

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

func RegisterBackupServiceHandlerFromEndpoint 

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

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

func RegisterBackupServiceHandlerServer 

func RegisterBackupServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server BackupServiceServer) error

RegisterBackupServiceHandlerServer registers the http handlers for service BackupService to "mux". UnaryRPC :call BackupServiceServer 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 RegisterBackupServiceHandlerFromEndpoint instead.

func RegisterBackupServiceServer 

func RegisterBackupServiceServer(s grpc.ServiceRegistrar, srv BackupServiceServer)

func RegisterJobRunServiceHandler 

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

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

func RegisterJobRunServiceHandlerClient 

func RegisterJobRunServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client JobRunServiceClient) error

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

func RegisterJobRunServiceHandlerFromEndpoint 

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

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

func RegisterJobRunServiceHandlerServer 

func RegisterJobRunServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server JobRunServiceServer) error

RegisterJobRunServiceHandlerServer registers the http handlers for service JobRunService to "mux". UnaryRPC :call JobRunServiceServer 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 RegisterJobRunServiceHandlerFromEndpoint instead.

func RegisterJobRunServiceServer 

func RegisterJobRunServiceServer(s grpc.ServiceRegistrar, srv JobRunServiceServer)

func RegisterJobSpecificationServiceHandler 

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

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

func RegisterJobSpecificationServiceHandlerClient 

func RegisterJobSpecificationServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client JobSpecificationServiceClient) error

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

func RegisterJobSpecificationServiceHandlerFromEndpoint 

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

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

func RegisterJobSpecificationServiceHandlerServer 

func RegisterJobSpecificationServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server JobSpecificationServiceServer) error

RegisterJobSpecificationServiceHandlerServer registers the http handlers for service JobSpecificationService to "mux". UnaryRPC :call JobSpecificationServiceServer 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 RegisterJobSpecificationServiceHandlerFromEndpoint instead.

func RegisterJobSpecificationServiceServer 

func RegisterJobSpecificationServiceServer(s grpc.ServiceRegistrar, srv JobSpecificationServiceServer)

func RegisterNamespaceServiceHandler 

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

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

func RegisterNamespaceServiceHandlerClient 

func RegisterNamespaceServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client NamespaceServiceClient) error

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

func RegisterNamespaceServiceHandlerFromEndpoint 

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

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

func RegisterNamespaceServiceHandlerServer 

func RegisterNamespaceServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server NamespaceServiceServer) error

RegisterNamespaceServiceHandlerServer registers the http handlers for service NamespaceService to "mux". UnaryRPC :call NamespaceServiceServer 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 RegisterNamespaceServiceHandlerFromEndpoint instead.

func RegisterNamespaceServiceServer 

func RegisterNamespaceServiceServer(s grpc.ServiceRegistrar, srv NamespaceServiceServer)

func RegisterProjectServiceHandler 

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

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

func RegisterProjectServiceHandlerClient 

func RegisterProjectServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ProjectServiceClient) error

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

func RegisterProjectServiceHandlerFromEndpoint 

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

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

func RegisterProjectServiceHandlerServer 

func RegisterProjectServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ProjectServiceServer) error

RegisterProjectServiceHandlerServer registers the http handlers for service ProjectService to "mux". UnaryRPC :call ProjectServiceServer 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 RegisterProjectServiceHandlerFromEndpoint instead.

func RegisterProjectServiceServer 

func RegisterProjectServiceServer(s grpc.ServiceRegistrar, srv ProjectServiceServer)

func RegisterReplayServiceHandler 

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

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

func RegisterReplayServiceHandlerClient 

func RegisterReplayServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ReplayServiceClient) error

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

func RegisterReplayServiceHandlerFromEndpoint 

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

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

func RegisterReplayServiceHandlerServer 

func RegisterReplayServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ReplayServiceServer) error

RegisterReplayServiceHandlerServer registers the http handlers for service ReplayService to "mux". UnaryRPC :call ReplayServiceServer 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 RegisterReplayServiceHandlerFromEndpoint instead.

func RegisterReplayServiceServer 

func RegisterReplayServiceServer(s grpc.ServiceRegistrar, srv ReplayServiceServer)

func RegisterResourceServiceHandler 

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

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

func RegisterResourceServiceHandlerClient 

func RegisterResourceServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ResourceServiceClient) error

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

func RegisterResourceServiceHandlerFromEndpoint 

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

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

func RegisterResourceServiceHandlerServer 

func RegisterResourceServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ResourceServiceServer) error

RegisterResourceServiceHandlerServer registers the http handlers for service ResourceService to "mux". UnaryRPC :call ResourceServiceServer 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 RegisterResourceServiceHandlerFromEndpoint instead.

func RegisterResourceServiceServer 

func RegisterResourceServiceServer(s grpc.ServiceRegistrar, srv ResourceServiceServer)

func RegisterRuntimeServiceHandler 

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

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

func RegisterRuntimeServiceHandlerClient 

func RegisterRuntimeServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client RuntimeServiceClient) error

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

func RegisterRuntimeServiceHandlerFromEndpoint 

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

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

func RegisterRuntimeServiceHandlerServer 

func RegisterRuntimeServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server RuntimeServiceServer) error

RegisterRuntimeServiceHandlerServer registers the http handlers for service RuntimeService to "mux". UnaryRPC :call RuntimeServiceServer 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 RegisterRuntimeServiceHandlerFromEndpoint instead.

func RegisterRuntimeServiceServer 

func RegisterRuntimeServiceServer(s grpc.ServiceRegistrar, srv RuntimeServiceServer)

func RegisterSecretServiceHandler 

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

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

func RegisterSecretServiceHandlerClient 

func RegisterSecretServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client SecretServiceClient) error

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

func RegisterSecretServiceHandlerFromEndpoint 

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

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

func RegisterSecretServiceHandlerServer 

func RegisterSecretServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server SecretServiceServer) error

RegisterSecretServiceHandlerServer registers the http handlers for service SecretService to "mux". UnaryRPC :call SecretServiceServer 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 RegisterSecretServiceHandlerFromEndpoint instead.

func RegisterSecretServiceServer 

func RegisterSecretServiceServer(s grpc.ServiceRegistrar, srv SecretServiceServer)

Types

type AddJobSpecificationsRequest 

type AddJobSpecificationsRequest struct {
	ProjectName   string              `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	NamespaceName string              `protobuf:"bytes,2,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	Specs         []*JobSpecification `protobuf:"bytes,3,rep,name=specs,proto3" json:"specs,omitempty"`
	// contains filtered or unexported fields
}

func (*AddJobSpecificationsRequest) Descriptor deprecated 

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

Deprecated: Use AddJobSpecificationsRequest.ProtoReflect.Descriptor instead.

func (*AddJobSpecificationsRequest) GetNamespaceName 

func (x *AddJobSpecificationsRequest) GetNamespaceName() string

func (*AddJobSpecificationsRequest) GetProjectName 

func (x *AddJobSpecificationsRequest) GetProjectName() string

func (*AddJobSpecificationsRequest) GetSpecs 

func (x *AddJobSpecificationsRequest) GetSpecs() []*JobSpecification

func (*AddJobSpecificationsRequest) ProtoMessage 

func (*AddJobSpecificationsRequest) ProtoMessage()

func (*AddJobSpecificationsRequest) ProtoReflect 

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

func (*AddJobSpecificationsRequest) Reset 

func (x *AddJobSpecificationsRequest) Reset()

func (*AddJobSpecificationsRequest) String 

func (x *AddJobSpecificationsRequest) String() string

type AddJobSpecificationsResponse 

type AddJobSpecificationsResponse struct {
	Log string `protobuf:"bytes,2,opt,name=log,proto3" json:"log,omitempty"`
	// contains filtered or unexported fields
}

func (*AddJobSpecificationsResponse) Descriptor deprecated 

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

Deprecated: Use AddJobSpecificationsResponse.ProtoReflect.Descriptor instead.

func (*AddJobSpecificationsResponse) GetLog 

func (x *AddJobSpecificationsResponse) GetLog() string

func (*AddJobSpecificationsResponse) ProtoMessage 

func (*AddJobSpecificationsResponse) ProtoMessage()

func (*AddJobSpecificationsResponse) ProtoReflect 

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

func (*AddJobSpecificationsResponse) Reset 

func (x *AddJobSpecificationsResponse) Reset()

func (*AddJobSpecificationsResponse) String 

func (x *AddJobSpecificationsResponse) String() string

type ApplyResourcesRequest added in v0.9.0 

type ApplyResourcesRequest struct {
	ProjectName   string   `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	NamespaceName string   `protobuf:"bytes,2,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	DatastoreName string   `protobuf:"bytes,3,opt,name=datastore_name,json=datastoreName,proto3" json:"datastore_name,omitempty"`
	ResourceNames []string `protobuf:"bytes,4,rep,name=resource_names,json=resourceNames,proto3" json:"resource_names,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplyResourcesRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use ApplyResourcesRequest.ProtoReflect.Descriptor instead.

func (*ApplyResourcesRequest) GetDatastoreName added in v0.9.0 

func (x *ApplyResourcesRequest) GetDatastoreName() string

func (*ApplyResourcesRequest) GetNamespaceName added in v0.9.0 

func (x *ApplyResourcesRequest) GetNamespaceName() string

func (*ApplyResourcesRequest) GetProjectName added in v0.9.0 

func (x *ApplyResourcesRequest) GetProjectName() string

func (*ApplyResourcesRequest) GetResourceNames added in v0.9.0 

func (x *ApplyResourcesRequest) GetResourceNames() []string

func (*ApplyResourcesRequest) ProtoMessage added in v0.9.0 

func (*ApplyResourcesRequest) ProtoMessage()

func (*ApplyResourcesRequest) ProtoReflect added in v0.9.0 

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

func (*ApplyResourcesRequest) Reset added in v0.9.0 

func (x *ApplyResourcesRequest) Reset()

func (*ApplyResourcesRequest) String added in v0.9.0 

func (x *ApplyResourcesRequest) String() string

type ApplyResourcesResponse added in v0.9.0 

type ApplyResourcesResponse struct {
	Statuses []*ApplyResourcesResponse_ResourceStatus `protobuf:"bytes,1,rep,name=statuses,proto3" json:"statuses,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplyResourcesResponse) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use ApplyResourcesResponse.ProtoReflect.Descriptor instead.

func (*ApplyResourcesResponse) GetStatuses added in v0.9.0 

func (x *ApplyResourcesResponse) GetStatuses() []*ApplyResourcesResponse_ResourceStatus

func (*ApplyResourcesResponse) ProtoMessage added in v0.9.0 

func (*ApplyResourcesResponse) ProtoMessage()

func (*ApplyResourcesResponse) ProtoReflect added in v0.9.0 

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

func (*ApplyResourcesResponse) Reset added in v0.9.0 

func (x *ApplyResourcesResponse) Reset()

func (*ApplyResourcesResponse) String added in v0.9.0 

func (x *ApplyResourcesResponse) String() string

type ApplyResourcesResponse_ResourceStatus added in v0.9.0 

type ApplyResourcesResponse_ResourceStatus struct {
	ResourceName string `protobuf:"bytes,1,opt,name=resource_name,json=resourceName,proto3" json:"resource_name,omitempty"`
	Status       string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	Reason       string `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplyResourcesResponse_ResourceStatus) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use ApplyResourcesResponse_ResourceStatus.ProtoReflect.Descriptor instead.

func (*ApplyResourcesResponse_ResourceStatus) GetReason added in v0.9.0 

func (x *ApplyResourcesResponse_ResourceStatus) GetReason() string

func (*ApplyResourcesResponse_ResourceStatus) GetResourceName added in v0.9.0 

func (x *ApplyResourcesResponse_ResourceStatus) GetResourceName() string

func (*ApplyResourcesResponse_ResourceStatus) GetStatus added in v0.9.0 

func (x *ApplyResourcesResponse_ResourceStatus) GetStatus() string

func (*ApplyResourcesResponse_ResourceStatus) ProtoMessage added in v0.9.0 

func (*ApplyResourcesResponse_ResourceStatus) ProtoMessage()

func (*ApplyResourcesResponse_ResourceStatus) ProtoReflect added in v0.9.0 

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

func (*ApplyResourcesResponse_ResourceStatus) Reset added in v0.9.0 

func (x *ApplyResourcesResponse_ResourceStatus) Reset()

func (*ApplyResourcesResponse_ResourceStatus) String added in v0.9.0 

func (x *ApplyResourcesResponse_ResourceStatus) String() string

type BackupServiceClient 

type BackupServiceClient interface {
	CreateBackup(ctx context.Context, in *CreateBackupRequest, opts ...grpc.CallOption) (*CreateBackupResponse, error)
	ListBackups(ctx context.Context, in *ListBackupsRequest, opts ...grpc.CallOption) (*ListBackupsResponse, error)
	GetBackup(ctx context.Context, in *GetBackupRequest, opts ...grpc.CallOption) (*GetBackupResponse, error)
}

BackupServiceClient is the client API for BackupService service.

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

func NewBackupServiceClient 

func NewBackupServiceClient(cc grpc.ClientConnInterface) BackupServiceClient

type BackupServiceServer 

type BackupServiceServer interface {
	CreateBackup(context.Context, *CreateBackupRequest) (*CreateBackupResponse, error)
	ListBackups(context.Context, *ListBackupsRequest) (*ListBackupsResponse, error)
	GetBackup(context.Context, *GetBackupRequest) (*GetBackupResponse, error)
	// contains filtered or unexported methods
}

BackupServiceServer is the server API for BackupService service. All implementations must embed UnimplementedBackupServiceServer for forward compatibility

type BackupSpec 

type BackupSpec struct {
	Id            string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	CreatedAt     *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	Description   string                 `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	Config        map[string]string      `` /* 153-byte string literal not displayed */
	ResourceNames []string               `protobuf:"bytes,6,rep,name=resource_names,json=resourceNames,proto3" json:"resource_names,omitempty"`
	// contains filtered or unexported fields
}

func (*BackupSpec) Descriptor deprecated 

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

Deprecated: Use BackupSpec.ProtoReflect.Descriptor instead.

func (*BackupSpec) GetConfig 

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

func (*BackupSpec) GetCreatedAt 

func (x *BackupSpec) GetCreatedAt() *timestamppb.Timestamp

func (*BackupSpec) GetDescription 

func (x *BackupSpec) GetDescription() string

func (*BackupSpec) GetId 

func (x *BackupSpec) GetId() string

func (*BackupSpec) GetResourceNames 

func (x *BackupSpec) GetResourceNames() []string

func (*BackupSpec) ProtoMessage 

func (*BackupSpec) ProtoMessage()

func (*BackupSpec) ProtoReflect 

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

func (*BackupSpec) Reset 

func (x *BackupSpec) Reset()

func (*BackupSpec) String 

func (x *BackupSpec) String() string

type ChangeJobNamespaceRequest added in v0.8.0 

type ChangeJobNamespaceRequest struct {
	ProjectName      string `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	NamespaceName    string `protobuf:"bytes,2,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	JobName          string `protobuf:"bytes,3,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	NewNamespaceName string `protobuf:"bytes,4,opt,name=new_namespace_name,json=newNamespaceName,proto3" json:"new_namespace_name,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangeJobNamespaceRequest) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use ChangeJobNamespaceRequest.ProtoReflect.Descriptor instead.

func (*ChangeJobNamespaceRequest) GetJobName added in v0.8.0 

func (x *ChangeJobNamespaceRequest) GetJobName() string

func (*ChangeJobNamespaceRequest) GetNamespaceName added in v0.8.0 

func (x *ChangeJobNamespaceRequest) GetNamespaceName() string

func (*ChangeJobNamespaceRequest) GetNewNamespaceName added in v0.8.0 

func (x *ChangeJobNamespaceRequest) GetNewNamespaceName() string

func (*ChangeJobNamespaceRequest) GetProjectName added in v0.8.0 

func (x *ChangeJobNamespaceRequest) GetProjectName() string

func (*ChangeJobNamespaceRequest) ProtoMessage added in v0.8.0 

func (*ChangeJobNamespaceRequest) ProtoMessage()

func (*ChangeJobNamespaceRequest) ProtoReflect added in v0.8.0 

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

func (*ChangeJobNamespaceRequest) Reset added in v0.8.0 

func (x *ChangeJobNamespaceRequest) Reset()

func (*ChangeJobNamespaceRequest) String added in v0.8.0 

func (x *ChangeJobNamespaceRequest) String() string

type ChangeJobNamespaceResponse added in v0.8.0 

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

func (*ChangeJobNamespaceResponse) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use ChangeJobNamespaceResponse.ProtoReflect.Descriptor instead.

func (*ChangeJobNamespaceResponse) ProtoMessage added in v0.8.0 

func (*ChangeJobNamespaceResponse) ProtoMessage()

func (*ChangeJobNamespaceResponse) ProtoReflect added in v0.8.0 

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

func (*ChangeJobNamespaceResponse) Reset added in v0.8.0 

func (x *ChangeJobNamespaceResponse) Reset()

func (*ChangeJobNamespaceResponse) String added in v0.8.0 

func (x *ChangeJobNamespaceResponse) String() string

type ChangeResourceNamespaceRequest added in v0.8.0 

type ChangeResourceNamespaceRequest struct {
	ProjectName      string `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	NamespaceName    string `protobuf:"bytes,2,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	DatastoreName    string `protobuf:"bytes,3,opt,name=datastore_name,json=datastoreName,proto3" json:"datastore_name,omitempty"`
	ResourceName     string `protobuf:"bytes,4,opt,name=resource_name,json=resourceName,proto3" json:"resource_name,omitempty"`
	NewNamespaceName string `protobuf:"bytes,5,opt,name=new_namespace_name,json=newNamespaceName,proto3" json:"new_namespace_name,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangeResourceNamespaceRequest) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use ChangeResourceNamespaceRequest.ProtoReflect.Descriptor instead.

func (*ChangeResourceNamespaceRequest) GetDatastoreName added in v0.8.0 

func (x *ChangeResourceNamespaceRequest) GetDatastoreName() string

func (*ChangeResourceNamespaceRequest) GetNamespaceName added in v0.8.0 

func (x *ChangeResourceNamespaceRequest) GetNamespaceName() string

func (*ChangeResourceNamespaceRequest) GetNewNamespaceName added in v0.8.0 

func (x *ChangeResourceNamespaceRequest) GetNewNamespaceName() string

func (*ChangeResourceNamespaceRequest) GetProjectName added in v0.8.0 

func (x *ChangeResourceNamespaceRequest) GetProjectName() string

func (*ChangeResourceNamespaceRequest) GetResourceName added in v0.8.0 

func (x *ChangeResourceNamespaceRequest) GetResourceName() string

func (*ChangeResourceNamespaceRequest) ProtoMessage added in v0.8.0 

func (*ChangeResourceNamespaceRequest) ProtoMessage()

func (*ChangeResourceNamespaceRequest) ProtoReflect added in v0.8.0 

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

func (*ChangeResourceNamespaceRequest) Reset added in v0.8.0 

func (x *ChangeResourceNamespaceRequest) Reset()

func (*ChangeResourceNamespaceRequest) String added in v0.8.0 

func (x *ChangeResourceNamespaceRequest) String() string

type ChangeResourceNamespaceResponse added in v0.8.0 

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

func (*ChangeResourceNamespaceResponse) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use ChangeResourceNamespaceResponse.ProtoReflect.Descriptor instead.

func (*ChangeResourceNamespaceResponse) ProtoMessage added in v0.8.0 

func (*ChangeResourceNamespaceResponse) ProtoMessage()

func (*ChangeResourceNamespaceResponse) ProtoReflect added in v0.8.0 

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

func (*ChangeResourceNamespaceResponse) Reset added in v0.8.0 

func (x *ChangeResourceNamespaceResponse) Reset()

func (*ChangeResourceNamespaceResponse) String added in v0.8.0 

func (x *ChangeResourceNamespaceResponse) String() string

type CheckJobSpecificationRequest 

type CheckJobSpecificationRequest struct {
	ProjectName   string            `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	Job           *JobSpecification `protobuf:"bytes,2,opt,name=job,proto3" json:"job,omitempty"`
	NamespaceName string            `protobuf:"bytes,3,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckJobSpecificationRequest) Descriptor deprecated 

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

Deprecated: Use CheckJobSpecificationRequest.ProtoReflect.Descriptor instead.

func (*CheckJobSpecificationRequest) GetJob 

func (x *CheckJobSpecificationRequest) GetJob() *JobSpecification

func (*CheckJobSpecificationRequest) GetNamespaceName 

func (x *CheckJobSpecificationRequest) GetNamespaceName() string

func (*CheckJobSpecificationRequest) GetProjectName 

func (x *CheckJobSpecificationRequest) GetProjectName() string

func (*CheckJobSpecificationRequest) ProtoMessage 

func (*CheckJobSpecificationRequest) ProtoMessage()

func (*CheckJobSpecificationRequest) ProtoReflect 

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

func (*CheckJobSpecificationRequest) Reset 

func (x *CheckJobSpecificationRequest) Reset()

func (*CheckJobSpecificationRequest) String 

func (x *CheckJobSpecificationRequest) String() string

type CheckJobSpecificationResponse 

type CheckJobSpecificationResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckJobSpecificationResponse) Descriptor deprecated 

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

Deprecated: Use CheckJobSpecificationResponse.ProtoReflect.Descriptor instead.

func (*CheckJobSpecificationResponse) GetSuccess 

func (x *CheckJobSpecificationResponse) GetSuccess() bool

func (*CheckJobSpecificationResponse) ProtoMessage 

func (*CheckJobSpecificationResponse) ProtoMessage()

func (*CheckJobSpecificationResponse) ProtoReflect 

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

func (*CheckJobSpecificationResponse) Reset 

func (x *CheckJobSpecificationResponse) Reset()

func (*CheckJobSpecificationResponse) String 

func (x *CheckJobSpecificationResponse) String() string

type CheckJobSpecificationsRequest 

type CheckJobSpecificationsRequest struct {
	ProjectName   string              `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	Jobs          []*JobSpecification `protobuf:"bytes,2,rep,name=jobs,proto3" json:"jobs,omitempty"`
	NamespaceName string              `protobuf:"bytes,3,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckJobSpecificationsRequest) Descriptor deprecated 

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

Deprecated: Use CheckJobSpecificationsRequest.ProtoReflect.Descriptor instead.

func (*CheckJobSpecificationsRequest) GetJobs 

func (x *CheckJobSpecificationsRequest) GetJobs() []*JobSpecification

func (*CheckJobSpecificationsRequest) GetNamespaceName 

func (x *CheckJobSpecificationsRequest) GetNamespaceName() string

func (*CheckJobSpecificationsRequest) GetProjectName 

func (x *CheckJobSpecificationsRequest) GetProjectName() string

func (*CheckJobSpecificationsRequest) ProtoMessage 

func (*CheckJobSpecificationsRequest) ProtoMessage()

func (*CheckJobSpecificationsRequest) ProtoReflect 

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

func (*CheckJobSpecificationsRequest) Reset 

func (x *CheckJobSpecificationsRequest) Reset()

func (*CheckJobSpecificationsRequest) String 

func (x *CheckJobSpecificationsRequest) String() string

type CheckJobSpecificationsResponse 

type CheckJobSpecificationsResponse struct {
	LogStatus *Log `protobuf:"bytes,5,opt,name=log_status,json=logStatus,proto3" json:"log_status,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckJobSpecificationsResponse) Descriptor deprecated 

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

Deprecated: Use CheckJobSpecificationsResponse.ProtoReflect.Descriptor instead.

func (*CheckJobSpecificationsResponse) GetLogStatus 

func (x *CheckJobSpecificationsResponse) GetLogStatus() *Log

func (*CheckJobSpecificationsResponse) ProtoMessage 

func (*CheckJobSpecificationsResponse) ProtoMessage()

func (*CheckJobSpecificationsResponse) ProtoReflect 

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

func (*CheckJobSpecificationsResponse) Reset 

func (x *CheckJobSpecificationsResponse) Reset()

func (*CheckJobSpecificationsResponse) String 

func (x *CheckJobSpecificationsResponse) String() string

type CreateBackupRequest 

type CreateBackupRequest struct {
	ProjectName   string            `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	DatastoreName string            `protobuf:"bytes,2,opt,name=datastore_name,json=datastoreName,proto3" json:"datastore_name,omitempty"`
	NamespaceName string            `protobuf:"bytes,4,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	Description   string            `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"`
	Config        map[string]string `` /* 153-byte string literal not displayed */
	ResourceNames []string          `protobuf:"bytes,9,rep,name=resource_names,json=resourceNames,proto3" json:"resource_names,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateBackupRequest) Descriptor deprecated 

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

Deprecated: Use CreateBackupRequest.ProtoReflect.Descriptor instead.

func (*CreateBackupRequest) GetConfig 

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

func (*CreateBackupRequest) GetDatastoreName 

func (x *CreateBackupRequest) GetDatastoreName() string

func (*CreateBackupRequest) GetDescription 

func (x *CreateBackupRequest) GetDescription() string

func (*CreateBackupRequest) GetNamespaceName 

func (x *CreateBackupRequest) GetNamespaceName() string

func (*CreateBackupRequest) GetProjectName 

func (x *CreateBackupRequest) GetProjectName() string

func (*CreateBackupRequest) GetResourceNames 

func (x *CreateBackupRequest) GetResourceNames() []string

func (*CreateBackupRequest) ProtoMessage 

func (*CreateBackupRequest) ProtoMessage()

func (*CreateBackupRequest) ProtoReflect 

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

func (*CreateBackupRequest) Reset 

func (x *CreateBackupRequest) Reset()

func (*CreateBackupRequest) String 

func (x *CreateBackupRequest) String() string

type CreateBackupResponse 

type CreateBackupResponse struct {
	ResourceNames    []string           `protobuf:"bytes,1,rep,name=resource_names,json=resourceNames,proto3" json:"resource_names,omitempty"`
	IgnoredResources []*IgnoredResource `protobuf:"bytes,3,rep,name=ignored_resources,json=ignoredResources,proto3" json:"ignored_resources,omitempty"`
	BackupId         string             `protobuf:"bytes,4,opt,name=backup_id,json=backupId,proto3" json:"backup_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateBackupResponse) Descriptor deprecated 

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

Deprecated: Use CreateBackupResponse.ProtoReflect.Descriptor instead.

func (*CreateBackupResponse) GetBackupId 

func (x *CreateBackupResponse) GetBackupId() string

func (*CreateBackupResponse) GetIgnoredResources 

func (x *CreateBackupResponse) GetIgnoredResources() []*IgnoredResource

func (*CreateBackupResponse) GetResourceNames 

func (x *CreateBackupResponse) GetResourceNames() []string

func (*CreateBackupResponse) ProtoMessage 

func (*CreateBackupResponse) ProtoMessage()

func (*CreateBackupResponse) ProtoReflect 

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

func (*CreateBackupResponse) Reset 

func (x *CreateBackupResponse) Reset()

func (*CreateBackupResponse) String 

func (x *CreateBackupResponse) String() string

type CreateJobSpecificationRequest 

type CreateJobSpecificationRequest struct {
	ProjectName   string            `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	NamespaceName string            `protobuf:"bytes,2,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	Spec          *JobSpecification `protobuf:"bytes,3,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateJobSpecificationRequest) Descriptor deprecated 

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

Deprecated: Use CreateJobSpecificationRequest.ProtoReflect.Descriptor instead.

func (*CreateJobSpecificationRequest) GetNamespaceName 

func (x *CreateJobSpecificationRequest) GetNamespaceName() string

func (*CreateJobSpecificationRequest) GetProjectName 

func (x *CreateJobSpecificationRequest) GetProjectName() string

func (*CreateJobSpecificationRequest) GetSpec 

func (x *CreateJobSpecificationRequest) GetSpec() *JobSpecification

func (*CreateJobSpecificationRequest) ProtoMessage 

func (*CreateJobSpecificationRequest) ProtoMessage()

func (*CreateJobSpecificationRequest) ProtoReflect 

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

func (*CreateJobSpecificationRequest) Reset 

func (x *CreateJobSpecificationRequest) Reset()

func (*CreateJobSpecificationRequest) String 

func (x *CreateJobSpecificationRequest) String() string

type CreateJobSpecificationResponse 

type CreateJobSpecificationResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateJobSpecificationResponse) Descriptor deprecated 

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

Deprecated: Use CreateJobSpecificationResponse.ProtoReflect.Descriptor instead.

func (*CreateJobSpecificationResponse) GetMessage 

func (x *CreateJobSpecificationResponse) GetMessage() string

func (*CreateJobSpecificationResponse) GetSuccess 

func (x *CreateJobSpecificationResponse) GetSuccess() bool

func (*CreateJobSpecificationResponse) ProtoMessage 

func (*CreateJobSpecificationResponse) ProtoMessage()

func (*CreateJobSpecificationResponse) ProtoReflect 

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

func (*CreateJobSpecificationResponse) Reset 

func (x *CreateJobSpecificationResponse) Reset()

func (*CreateJobSpecificationResponse) String 

func (x *CreateJobSpecificationResponse) String() string

type CreateResourceRequest 

type CreateResourceRequest struct {
	ProjectName   string                 `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	DatastoreName string                 `protobuf:"bytes,2,opt,name=datastore_name,json=datastoreName,proto3" json:"datastore_name,omitempty"`
	Resource      *ResourceSpecification `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"`
	NamespaceName string                 `protobuf:"bytes,4,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateResourceRequest) Descriptor deprecated 

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

Deprecated: Use CreateResourceRequest.ProtoReflect.Descriptor instead.

func (*CreateResourceRequest) GetDatastoreName 

func (x *CreateResourceRequest) GetDatastoreName() string

func (*CreateResourceRequest) GetNamespaceName 

func (x *CreateResourceRequest) GetNamespaceName() string

func (*CreateResourceRequest) GetProjectName 

func (x *CreateResourceRequest) GetProjectName() string

func (*CreateResourceRequest) GetResource 

func (x *CreateResourceRequest) GetResource() *ResourceSpecification

func (*CreateResourceRequest) ProtoMessage 

func (*CreateResourceRequest) ProtoMessage()

func (*CreateResourceRequest) ProtoReflect 

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

func (*CreateResourceRequest) Reset 

func (x *CreateResourceRequest) Reset()

func (*CreateResourceRequest) String 

func (x *CreateResourceRequest) String() string

type CreateResourceResponse 

type CreateResourceResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateResourceResponse) Descriptor deprecated 

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

Deprecated: Use CreateResourceResponse.ProtoReflect.Descriptor instead.

func (*CreateResourceResponse) GetMessage 

func (x *CreateResourceResponse) GetMessage() string

func (*CreateResourceResponse) GetSuccess 

func (x *CreateResourceResponse) GetSuccess() bool

func (*CreateResourceResponse) ProtoMessage 

func (*CreateResourceResponse) ProtoMessage()

func (*CreateResourceResponse) ProtoReflect 

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

func (*CreateResourceResponse) Reset 

func (x *CreateResourceResponse) Reset()

func (*CreateResourceResponse) String 

func (x *CreateResourceResponse) String() string

type DeleteJobSpecificationRequest 

type DeleteJobSpecificationRequest struct {
	ProjectName   string `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	NamespaceName string `protobuf:"bytes,2,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	JobName       string `protobuf:"bytes,3,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	CleanHistory  bool   `protobuf:"varint,4,opt,name=clean_history,json=cleanHistory,proto3" json:"clean_history,omitempty"`
	Force         bool   `protobuf:"varint,5,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteJobSpecificationRequest) Descriptor deprecated 

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

Deprecated: Use DeleteJobSpecificationRequest.ProtoReflect.Descriptor instead.

func (*DeleteJobSpecificationRequest) GetCleanHistory 

func (x *DeleteJobSpecificationRequest) GetCleanHistory() bool

func (*DeleteJobSpecificationRequest) GetForce 

func (x *DeleteJobSpecificationRequest) GetForce() bool

func (*DeleteJobSpecificationRequest) GetJobName 

func (x *DeleteJobSpecificationRequest) GetJobName() string

func (*DeleteJobSpecificationRequest) GetNamespaceName 

func (x *DeleteJobSpecificationRequest) GetNamespaceName() string

func (*DeleteJobSpecificationRequest) GetProjectName 

func (x *DeleteJobSpecificationRequest) GetProjectName() string

func (*DeleteJobSpecificationRequest) ProtoMessage 

func (*DeleteJobSpecificationRequest) ProtoMessage()

func (*DeleteJobSpecificationRequest) ProtoReflect 

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

func (*DeleteJobSpecificationRequest) Reset 

func (x *DeleteJobSpecificationRequest) Reset()

func (*DeleteJobSpecificationRequest) String 

func (x *DeleteJobSpecificationRequest) String() string

type DeleteJobSpecificationResponse 

type DeleteJobSpecificationResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteJobSpecificationResponse) Descriptor deprecated 

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

Deprecated: Use DeleteJobSpecificationResponse.ProtoReflect.Descriptor instead.

func (*DeleteJobSpecificationResponse) GetMessage 

func (x *DeleteJobSpecificationResponse) GetMessage() string

func (*DeleteJobSpecificationResponse) GetSuccess 

func (x *DeleteJobSpecificationResponse) GetSuccess() bool

func (*DeleteJobSpecificationResponse) ProtoMessage 

func (*DeleteJobSpecificationResponse) ProtoMessage()

func (*DeleteJobSpecificationResponse) ProtoReflect 

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

func (*DeleteJobSpecificationResponse) Reset 

func (x *DeleteJobSpecificationResponse) Reset()

func (*DeleteJobSpecificationResponse) String 

func (x *DeleteJobSpecificationResponse) String() string

type DeleteSecretRequest 

type DeleteSecretRequest struct {
	ProjectName   string `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	SecretName    string `protobuf:"bytes,2,opt,name=secret_name,json=secretName,proto3" json:"secret_name,omitempty"`
	NamespaceName string `protobuf:"bytes,3,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteSecretRequest) Descriptor deprecated 

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

Deprecated: Use DeleteSecretRequest.ProtoReflect.Descriptor instead.

func (*DeleteSecretRequest) GetNamespaceName 

func (x *DeleteSecretRequest) GetNamespaceName() string

func (*DeleteSecretRequest) GetProjectName 

func (x *DeleteSecretRequest) GetProjectName() string

func (*DeleteSecretRequest) GetSecretName 

func (x *DeleteSecretRequest) GetSecretName() string

func (*DeleteSecretRequest) ProtoMessage 

func (*DeleteSecretRequest) ProtoMessage()

func (*DeleteSecretRequest) ProtoReflect 

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

func (*DeleteSecretRequest) Reset 

func (x *DeleteSecretRequest) Reset()

func (*DeleteSecretRequest) String 

func (x *DeleteSecretRequest) String() string

type DeleteSecretResponse 

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

func (*DeleteSecretResponse) Descriptor deprecated 

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

Deprecated: Use DeleteSecretResponse.ProtoReflect.Descriptor instead.

func (*DeleteSecretResponse) ProtoMessage 

func (*DeleteSecretResponse) ProtoMessage()

func (*DeleteSecretResponse) ProtoReflect 

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

func (*DeleteSecretResponse) Reset 

func (x *DeleteSecretResponse) Reset()

func (*DeleteSecretResponse) String 

func (x *DeleteSecretResponse) String() string

type DeployJobFailure 

type DeployJobFailure struct {
	JobName string `protobuf:"bytes,1,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*DeployJobFailure) Descriptor deprecated 

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

Deprecated: Use DeployJobFailure.ProtoReflect.Descriptor instead.

func (*DeployJobFailure) GetJobName 

func (x *DeployJobFailure) GetJobName() string

func (*DeployJobFailure) GetMessage 

func (x *DeployJobFailure) GetMessage() string

func (*DeployJobFailure) ProtoMessage 

func (*DeployJobFailure) ProtoMessage()

func (*DeployJobFailure) ProtoReflect 

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

func (*DeployJobFailure) Reset 

func (x *DeployJobFailure) Reset()

func (*DeployJobFailure) String 

func (x *DeployJobFailure) String() string

type DeployJobSpecificationRequest 

type DeployJobSpecificationRequest struct {
	ProjectName   string              `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"` // unique project identifier
	Jobs          []*JobSpecification `protobuf:"bytes,2,rep,name=jobs,proto3" json:"jobs,omitempty"`
	NamespaceName string              `protobuf:"bytes,4,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeployJobSpecificationRequest) Descriptor deprecated 

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

Deprecated: Use DeployJobSpecificationRequest.ProtoReflect.Descriptor instead.

func (*DeployJobSpecificationRequest) GetJobs 

func (x *DeployJobSpecificationRequest) GetJobs() []*JobSpecification

func (*DeployJobSpecificationRequest) GetNamespaceName 

func (x *DeployJobSpecificationRequest) GetNamespaceName() string

func (*DeployJobSpecificationRequest) GetProjectName 

func (x *DeployJobSpecificationRequest) GetProjectName() string

func (*DeployJobSpecificationRequest) ProtoMessage 

func (*DeployJobSpecificationRequest) ProtoMessage()

func (*DeployJobSpecificationRequest) ProtoReflect 

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

func (*DeployJobSpecificationRequest) Reset 

func (x *DeployJobSpecificationRequest) Reset()

func (*DeployJobSpecificationRequest) String 

func (x *DeployJobSpecificationRequest) String() string

type DeployJobSpecificationResponse 

type DeployJobSpecificationResponse struct {
	DeploymentId string `protobuf:"bytes,7,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"`
	LogStatus    *Log   `protobuf:"bytes,8,opt,name=log_status,json=logStatus,proto3" json:"log_status,omitempty"`
	// contains filtered or unexported fields
}

DeployJobSpecificationResponse hold the value of DeploymentID and the log messages

func (*DeployJobSpecificationResponse) Descriptor deprecated 

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

Deprecated: Use DeployJobSpecificationResponse.ProtoReflect.Descriptor instead.

func (*DeployJobSpecificationResponse) GetDeploymentId 

func (x *DeployJobSpecificationResponse) GetDeploymentId() string

func (*DeployJobSpecificationResponse) GetLogStatus 

func (x *DeployJobSpecificationResponse) GetLogStatus() *Log

func (*DeployJobSpecificationResponse) ProtoMessage 

func (*DeployJobSpecificationResponse) ProtoMessage()

func (*DeployJobSpecificationResponse) ProtoReflect 

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

func (*DeployJobSpecificationResponse) Reset 

func (x *DeployJobSpecificationResponse) Reset()

func (*DeployJobSpecificationResponse) String 

func (x *DeployJobSpecificationResponse) String() string

type DeployResourceSpecificationRequest 

type DeployResourceSpecificationRequest struct {
	ProjectName   string                   `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	DatastoreName string                   `protobuf:"bytes,2,opt,name=datastore_name,json=datastoreName,proto3" json:"datastore_name,omitempty"`
	Resources     []*ResourceSpecification `protobuf:"bytes,3,rep,name=resources,proto3" json:"resources,omitempty"`
	NamespaceName string                   `protobuf:"bytes,4,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeployResourceSpecificationRequest) Descriptor deprecated 

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

Deprecated: Use DeployResourceSpecificationRequest.ProtoReflect.Descriptor instead.

func (*DeployResourceSpecificationRequest) GetDatastoreName 

func (x *DeployResourceSpecificationRequest) GetDatastoreName() string

func (*DeployResourceSpecificationRequest) GetNamespaceName 

func (x *DeployResourceSpecificationRequest) GetNamespaceName() string

func (*DeployResourceSpecificationRequest) GetProjectName 

func (x *DeployResourceSpecificationRequest) GetProjectName() string

func (*DeployResourceSpecificationRequest) GetResources 

func (x *DeployResourceSpecificationRequest) GetResources() []*ResourceSpecification

func (*DeployResourceSpecificationRequest) ProtoMessage 

func (*DeployResourceSpecificationRequest) ProtoMessage()

func (*DeployResourceSpecificationRequest) ProtoReflect 

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

func (*DeployResourceSpecificationRequest) Reset 

func (x *DeployResourceSpecificationRequest) Reset()

func (*DeployResourceSpecificationRequest) String 

func (x *DeployResourceSpecificationRequest) String() string

type DeployResourceSpecificationResponse 

type DeployResourceSpecificationResponse struct {
	LogStatus *Log `protobuf:"bytes,5,opt,name=log_status,json=logStatus,proto3" json:"log_status,omitempty"`
	// contains filtered or unexported fields
}

func (*DeployResourceSpecificationResponse) Descriptor deprecated 

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

Deprecated: Use DeployResourceSpecificationResponse.ProtoReflect.Descriptor instead.

func (*DeployResourceSpecificationResponse) GetLogStatus 

func (x *DeployResourceSpecificationResponse) GetLogStatus() *Log

func (*DeployResourceSpecificationResponse) ProtoMessage 

func (*DeployResourceSpecificationResponse) ProtoMessage()

func (*DeployResourceSpecificationResponse) ProtoReflect 

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

func (*DeployResourceSpecificationResponse) Reset 

func (x *DeployResourceSpecificationResponse) Reset()

func (*DeployResourceSpecificationResponse) String 

func (x *DeployResourceSpecificationResponse) String() string

type GetBackupRequest 

type GetBackupRequest struct {
	ProjectName   string `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	DatastoreName string `protobuf:"bytes,2,opt,name=datastore_name,json=datastoreName,proto3" json:"datastore_name,omitempty"`
	NamespaceName string `protobuf:"bytes,3,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	Id            string `protobuf:"bytes,4,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBackupRequest) Descriptor deprecated 

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

Deprecated: Use GetBackupRequest.ProtoReflect.Descriptor instead.

func (*GetBackupRequest) GetDatastoreName 

func (x *GetBackupRequest) GetDatastoreName() string

func (*GetBackupRequest) GetId 

func (x *GetBackupRequest) GetId() string

func (*GetBackupRequest) GetNamespaceName 

func (x *GetBackupRequest) GetNamespaceName() string

func (*GetBackupRequest) GetProjectName 

func (x *GetBackupRequest) GetProjectName() string

func (*GetBackupRequest) ProtoMessage 

func (*GetBackupRequest) ProtoMessage()

func (*GetBackupRequest) ProtoReflect 

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

func (*GetBackupRequest) Reset 

func (x *GetBackupRequest) Reset()

func (*GetBackupRequest) String 

func (x *GetBackupRequest) String() string

type GetBackupResponse 

type GetBackupResponse struct {
	Spec *BackupSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBackupResponse) Descriptor deprecated 

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

Deprecated: Use GetBackupResponse.ProtoReflect.Descriptor instead.

func (*GetBackupResponse) GetSpec 

func (x *GetBackupResponse) GetSpec() *BackupSpec

func (*GetBackupResponse) ProtoMessage 

func (*GetBackupResponse) ProtoMessage()

func (*GetBackupResponse) ProtoReflect 

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

func (*GetBackupResponse) Reset 

func (x *GetBackupResponse) Reset()

func (*GetBackupResponse) String 

func (x *GetBackupResponse) String() string

type GetDeployJobsStatusRequest 

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

func (*GetDeployJobsStatusRequest) Descriptor deprecated 

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

Deprecated: Use GetDeployJobsStatusRequest.ProtoReflect.Descriptor instead.

func (*GetDeployJobsStatusRequest) GetDeployId 

func (x *GetDeployJobsStatusRequest) GetDeployId() string

func (*GetDeployJobsStatusRequest) ProtoMessage 

func (*GetDeployJobsStatusRequest) ProtoMessage()

func (*GetDeployJobsStatusRequest) ProtoReflect 

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

func (*GetDeployJobsStatusRequest) Reset 

func (x *GetDeployJobsStatusRequest) Reset()

func (*GetDeployJobsStatusRequest) String 

func (x *GetDeployJobsStatusRequest) String() string

type GetDeployJobsStatusResponse 

type GetDeployJobsStatusResponse struct {
	Status              string              `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Failures            []*DeployJobFailure `protobuf:"bytes,2,rep,name=failures,proto3" json:"failures,omitempty"`
	SuccessCount        int32               `protobuf:"varint,3,opt,name=success_count,json=successCount,proto3" json:"success_count,omitempty"`
	FailureCount        int32               `protobuf:"varint,4,opt,name=failure_count,json=failureCount,proto3" json:"failure_count,omitempty"`
	UnknownDependencies map[string]string   `` /* 206-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetDeployJobsStatusResponse) Descriptor deprecated 

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

Deprecated: Use GetDeployJobsStatusResponse.ProtoReflect.Descriptor instead.

func (*GetDeployJobsStatusResponse) GetFailureCount 

func (x *GetDeployJobsStatusResponse) GetFailureCount() int32

func (*GetDeployJobsStatusResponse) GetFailures 

func (x *GetDeployJobsStatusResponse) GetFailures() []*DeployJobFailure

func (*GetDeployJobsStatusResponse) GetStatus 

func (x *GetDeployJobsStatusResponse) GetStatus() string

func (*GetDeployJobsStatusResponse) GetSuccessCount 

func (x *GetDeployJobsStatusResponse) GetSuccessCount() int32

func (*GetDeployJobsStatusResponse) GetUnknownDependencies 

func (x *GetDeployJobsStatusResponse) GetUnknownDependencies() map[string]string

func (*GetDeployJobsStatusResponse) ProtoMessage 

func (*GetDeployJobsStatusResponse) ProtoMessage()

func (*GetDeployJobsStatusResponse) ProtoReflect 

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

func (*GetDeployJobsStatusResponse) Reset 

func (x *GetDeployJobsStatusResponse) Reset()

func (*GetDeployJobsStatusResponse) String 

func (x *GetDeployJobsStatusResponse) String() string

type GetJobSpecificationRequest 

type GetJobSpecificationRequest struct {
	ProjectName   string `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	NamespaceName string `protobuf:"bytes,2,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	JobName       string `protobuf:"bytes,3,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetJobSpecificationRequest) Descriptor deprecated 

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

Deprecated: Use GetJobSpecificationRequest.ProtoReflect.Descriptor instead.

func (*GetJobSpecificationRequest) GetJobName 

func (x *GetJobSpecificationRequest) GetJobName() string

func (*GetJobSpecificationRequest) GetNamespaceName 

func (x *GetJobSpecificationRequest) GetNamespaceName() string

func (*GetJobSpecificationRequest) GetProjectName 

func (x *GetJobSpecificationRequest) GetProjectName() string

func (*GetJobSpecificationRequest) ProtoMessage 

func (*GetJobSpecificationRequest) ProtoMessage()

func (*GetJobSpecificationRequest) ProtoReflect 

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

func (*GetJobSpecificationRequest) Reset 

func (x *GetJobSpecificationRequest) Reset()

func (*GetJobSpecificationRequest) String 

func (x *GetJobSpecificationRequest) String() string

type GetJobSpecificationResponse 

type GetJobSpecificationResponse struct {
	Spec *JobSpecification `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

func (*GetJobSpecificationResponse) Descriptor deprecated 

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

Deprecated: Use GetJobSpecificationResponse.ProtoReflect.Descriptor instead.

func (*GetJobSpecificationResponse) GetSpec 

func (x *GetJobSpecificationResponse) GetSpec() *JobSpecification

func (*GetJobSpecificationResponse) ProtoMessage 

func (*GetJobSpecificationResponse) ProtoMessage()

func (*GetJobSpecificationResponse) ProtoReflect 

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

func (*GetJobSpecificationResponse) Reset 

func (x *GetJobSpecificationResponse) Reset()

func (*GetJobSpecificationResponse) String 

func (x *GetJobSpecificationResponse) String() string

type GetJobSpecificationsRequest 

type GetJobSpecificationsRequest struct {
	ProjectName         string `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	ResourceDestination string `protobuf:"bytes,2,opt,name=resource_destination,json=resourceDestination,proto3" json:"resource_destination,omitempty"`
	JobName             string `protobuf:"bytes,3,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	NamespaceName       string `protobuf:"bytes,4,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetJobSpecificationsRequest) Descriptor deprecated 

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

Deprecated: Use GetJobSpecificationsRequest.ProtoReflect.Descriptor instead.

func (*GetJobSpecificationsRequest) GetJobName 

func (x *GetJobSpecificationsRequest) GetJobName() string

func (*GetJobSpecificationsRequest) GetNamespaceName 

func (x *GetJobSpecificationsRequest) GetNamespaceName() string

func (*GetJobSpecificationsRequest) GetProjectName 

func (x *GetJobSpecificationsRequest) GetProjectName() string

func (*GetJobSpecificationsRequest) GetResourceDestination 

func (x *GetJobSpecificationsRequest) GetResourceDestination() string

func (*GetJobSpecificationsRequest) ProtoMessage 

func (*GetJobSpecificationsRequest) ProtoMessage()

func (*GetJobSpecificationsRequest) ProtoReflect 

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

func (*GetJobSpecificationsRequest) Reset 

func (x *GetJobSpecificationsRequest) Reset()

func (*GetJobSpecificationsRequest) String 

func (x *GetJobSpecificationsRequest) String() string

type GetJobSpecificationsResponse 

type GetJobSpecificationsResponse struct {

	// Deprecated: Do not use.
	Jobs                      []*JobSpecification         `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	JobSpecificationResponses []*JobSpecificationResponse `` /* 138-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetJobSpecificationsResponse) Descriptor deprecated 

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

Deprecated: Use GetJobSpecificationsResponse.ProtoReflect.Descriptor instead.

func (*GetJobSpecificationsResponse) GetJobSpecificationResponses 

func (x *GetJobSpecificationsResponse) GetJobSpecificationResponses() []*JobSpecificationResponse

func (*GetJobSpecificationsResponse) GetJobs deprecated 

func (x *GetJobSpecificationsResponse) GetJobs() []*JobSpecification

Deprecated: Do not use.

func (*GetJobSpecificationsResponse) ProtoMessage 

func (*GetJobSpecificationsResponse) ProtoMessage()

func (*GetJobSpecificationsResponse) ProtoReflect 

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

func (*GetJobSpecificationsResponse) Reset 

func (x *GetJobSpecificationsResponse) Reset()

func (*GetJobSpecificationsResponse) String 

func (x *GetJobSpecificationsResponse) String() string

type GetJobTaskRequest 

type GetJobTaskRequest struct {
	ProjectName   string `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	NamespaceName string `protobuf:"bytes,2,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	JobName       string `protobuf:"bytes,3,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetJobTaskRequest) Descriptor deprecated 

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

Deprecated: Use GetJobTaskRequest.ProtoReflect.Descriptor instead.

func (*GetJobTaskRequest) GetJobName 

func (x *GetJobTaskRequest) GetJobName() string

func (*GetJobTaskRequest) GetNamespaceName 

func (x *GetJobTaskRequest) GetNamespaceName() string

func (*GetJobTaskRequest) GetProjectName 

func (x *GetJobTaskRequest) GetProjectName() string

func (*GetJobTaskRequest) ProtoMessage 

func (*GetJobTaskRequest) ProtoMessage()

func (*GetJobTaskRequest) ProtoReflect 

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

func (*GetJobTaskRequest) Reset 

func (x *GetJobTaskRequest) Reset()

func (*GetJobTaskRequest) String 

func (x *GetJobTaskRequest) String() string

type GetJobTaskResponse 

type GetJobTaskResponse struct {
	Task *JobTask `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

func (*GetJobTaskResponse) Descriptor deprecated 

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

Deprecated: Use GetJobTaskResponse.ProtoReflect.Descriptor instead.

func (*GetJobTaskResponse) GetTask 

func (x *GetJobTaskResponse) GetTask() *JobTask

func (*GetJobTaskResponse) ProtoMessage 

func (*GetJobTaskResponse) ProtoMessage()

func (*GetJobTaskResponse) ProtoReflect 

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

func (*GetJobTaskResponse) Reset 

func (x *GetJobTaskResponse) Reset()

func (*GetJobTaskResponse) String 

func (x *GetJobTaskResponse) String() string

type GetNamespaceRequest 

type GetNamespaceRequest struct {
	ProjectName   string `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	NamespaceName string `protobuf:"bytes,2,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetNamespaceRequest) Descriptor deprecated 

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

Deprecated: Use GetNamespaceRequest.ProtoReflect.Descriptor instead.

func (*GetNamespaceRequest) GetNamespaceName 

func (x *GetNamespaceRequest) GetNamespaceName() string

func (*GetNamespaceRequest) GetProjectName 

func (x *GetNamespaceRequest) GetProjectName() string

func (*GetNamespaceRequest) ProtoMessage 

func (*GetNamespaceRequest) ProtoMessage()

func (*GetNamespaceRequest) ProtoReflect 

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

func (*GetNamespaceRequest) Reset 

func (x *GetNamespaceRequest) Reset()

func (*GetNamespaceRequest) String 

func (x *GetNamespaceRequest) String() string

type GetNamespaceResponse 

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

func (*GetNamespaceResponse) Descriptor deprecated 

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

Deprecated: Use GetNamespaceResponse.ProtoReflect.Descriptor instead.

func (*GetNamespaceResponse) GetNamespace 

func (x *GetNamespaceResponse) GetNamespace() *NamespaceSpecification

func (*GetNamespaceResponse) ProtoMessage 

func (*GetNamespaceResponse) ProtoMessage()

func (*GetNamespaceResponse) ProtoReflect 

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

func (*GetNamespaceResponse) Reset 

func (x *GetNamespaceResponse) Reset()

func (*GetNamespaceResponse) String 

func (x *GetNamespaceResponse) String() string

type GetProjectRequest 

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

func (*GetProjectRequest) Descriptor deprecated 

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

Deprecated: Use GetProjectRequest.ProtoReflect.Descriptor instead.

func (*GetProjectRequest) GetProjectName 

func (x *GetProjectRequest) GetProjectName() string

func (*GetProjectRequest) ProtoMessage 

func (*GetProjectRequest) ProtoMessage()

func (*GetProjectRequest) ProtoReflect 

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

func (*GetProjectRequest) Reset 

func (x *GetProjectRequest) Reset()

func (*GetProjectRequest) String 

func (x *GetProjectRequest) String() string

type GetProjectResponse 

type GetProjectResponse struct {
	Project *ProjectSpecification `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// contains filtered or unexported fields
}

func (*GetProjectResponse) Descriptor deprecated 

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

Deprecated: Use GetProjectResponse.ProtoReflect.Descriptor instead.

func (*GetProjectResponse) GetProject 

func (x *GetProjectResponse) GetProject() *ProjectSpecification

func (*GetProjectResponse) ProtoMessage 

func (*GetProjectResponse) ProtoMessage()

func (*GetProjectResponse) ProtoReflect 

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

func (*GetProjectResponse) Reset 

func (x *GetProjectResponse) Reset()

func (*GetProjectResponse) String 

func (x *GetProjectResponse) String() string

type GetReplayRequest added in v0.7.0 

type GetReplayRequest struct {
	ReplayId    string `protobuf:"bytes,1,opt,name=replay_id,json=replayId,proto3" json:"replay_id,omitempty"`
	ProjectName string `protobuf:"bytes,2,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetReplayRequest) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use GetReplayRequest.ProtoReflect.Descriptor instead.

func (*GetReplayRequest) GetProjectName added in v0.7.0 

func (x *GetReplayRequest) GetProjectName() string

func (*GetReplayRequest) GetReplayId added in v0.7.0 

func (x *GetReplayRequest) GetReplayId() string

func (*GetReplayRequest) ProtoMessage added in v0.7.0 

func (*GetReplayRequest) ProtoMessage()

func (*GetReplayRequest) ProtoReflect added in v0.7.0 

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

func (*GetReplayRequest) Reset added in v0.7.0 

func (x *GetReplayRequest) Reset()

func (*GetReplayRequest) String added in v0.7.0 

func (x *GetReplayRequest) String() string

type GetReplayResponse added in v0.7.0 

type GetReplayResponse struct {
	Id           string        `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	JobName      string        `protobuf:"bytes,2,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	Status       string        `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	ReplayConfig *ReplayConfig `protobuf:"bytes,4,opt,name=replay_config,json=replayConfig,proto3" json:"replay_config,omitempty"`
	ReplayRuns   []*ReplayRun  `protobuf:"bytes,5,rep,name=replay_runs,json=replayRuns,proto3" json:"replay_runs,omitempty"`
	// contains filtered or unexported fields
}

func (*GetReplayResponse) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use GetReplayResponse.ProtoReflect.Descriptor instead.

func (*GetReplayResponse) GetId added in v0.7.0 

func (x *GetReplayResponse) GetId() string

func (*GetReplayResponse) GetJobName added in v0.7.0 

func (x *GetReplayResponse) GetJobName() string

func (*GetReplayResponse) GetReplayConfig added in v0.7.0 

func (x *GetReplayResponse) GetReplayConfig() *ReplayConfig

func (*GetReplayResponse) GetReplayRuns added in v0.7.0 

func (x *GetReplayResponse) GetReplayRuns() []*ReplayRun

func (*GetReplayResponse) GetStatus added in v0.7.0 

func (x *GetReplayResponse) GetStatus() string

func (*GetReplayResponse) ProtoMessage added in v0.7.0 

func (*GetReplayResponse) ProtoMessage()

func (*GetReplayResponse) ProtoReflect added in v0.7.0 

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

func (*GetReplayResponse) Reset added in v0.7.0 

func (x *GetReplayResponse) Reset()

func (*GetReplayResponse) String added in v0.7.0 

func (x *GetReplayResponse) String() string

type GetWindowRequest 

type GetWindowRequest struct {
	ScheduledAt *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=scheduled_at,json=scheduledAt,proto3" json:"scheduled_at,omitempty"`
	Size        string                 `protobuf:"bytes,2,opt,name=size,proto3" json:"size,omitempty"`
	Offset      string                 `protobuf:"bytes,3,opt,name=offset,proto3" json:"offset,omitempty"`
	TruncateTo  string                 `protobuf:"bytes,4,opt,name=truncate_to,json=truncateTo,proto3" json:"truncate_to,omitempty"`
	Version     int32                  `protobuf:"varint,5,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWindowRequest) Descriptor deprecated 

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

Deprecated: Use GetWindowRequest.ProtoReflect.Descriptor instead.

func (*GetWindowRequest) GetOffset 

func (x *GetWindowRequest) GetOffset() string

func (*GetWindowRequest) GetScheduledAt 

func (x *GetWindowRequest) GetScheduledAt() *timestamppb.Timestamp

func (*GetWindowRequest) GetSize 

func (x *GetWindowRequest) GetSize() string

func (*GetWindowRequest) GetTruncateTo 

func (x *GetWindowRequest) GetTruncateTo() string

func (*GetWindowRequest) GetVersion 

func (x *GetWindowRequest) GetVersion() int32

func (*GetWindowRequest) ProtoMessage 

func (*GetWindowRequest) ProtoMessage()

func (*GetWindowRequest) ProtoReflect 

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

func (*GetWindowRequest) Reset 

func (x *GetWindowRequest) Reset()

func (*GetWindowRequest) String 

func (x *GetWindowRequest) String() string

type GetWindowResponse 

type GetWindowResponse struct {
	Start *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	End   *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end,proto3" json:"end,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWindowResponse) Descriptor deprecated 

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

Deprecated: Use GetWindowResponse.ProtoReflect.Descriptor instead.

func (*GetWindowResponse) GetEnd 

func (x *GetWindowResponse) GetEnd() *timestamppb.Timestamp

func (*GetWindowResponse) GetStart 

func (x *GetWindowResponse) GetStart() *timestamppb.Timestamp

func (*GetWindowResponse) ProtoMessage 

func (*GetWindowResponse) ProtoMessage()

func (*GetWindowResponse) ProtoReflect 

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

func (*GetWindowResponse) Reset 

func (x *GetWindowResponse) Reset()

func (*GetWindowResponse) String 

func (x *GetWindowResponse) String() string

type HttpDependency 

type HttpDependency struct {
	Name    string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Url     string            `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	Headers map[string]string `` /* 155-byte string literal not displayed */
	Params  map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*HttpDependency) Descriptor deprecated 

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

Deprecated: Use HttpDependency.ProtoReflect.Descriptor instead.

func (*HttpDependency) GetHeaders 

func (x *HttpDependency) GetHeaders() map[string]string

func (*HttpDependency) GetName 

func (x *HttpDependency) GetName() string

func (*HttpDependency) GetParams 

func (x *HttpDependency) GetParams() map[string]string

func (*HttpDependency) GetUrl 

func (x *HttpDependency) GetUrl() string

func (*HttpDependency) ProtoMessage 

func (*HttpDependency) ProtoMessage()

func (*HttpDependency) ProtoReflect 

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

func (*HttpDependency) Reset 

func (x *HttpDependency) Reset()

func (*HttpDependency) String 

func (x *HttpDependency) String() string

type IgnoredResource 

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

func (*IgnoredResource) Descriptor deprecated 

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

Deprecated: Use IgnoredResource.ProtoReflect.Descriptor instead.

func (*IgnoredResource) GetName 

func (x *IgnoredResource) GetName() string

func (*IgnoredResource) GetReason 

func (x *IgnoredResource) GetReason() string

func (*IgnoredResource) ProtoMessage 

func (*IgnoredResource) ProtoMessage()

func (*IgnoredResource) ProtoReflect 

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

func (*IgnoredResource) Reset 

func (x *IgnoredResource) Reset()

func (*IgnoredResource) String 

func (x *IgnoredResource) String() string

type InstanceSpec 

type InstanceSpec struct {
	State      string                 `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	Data       []*InstanceSpecData    `protobuf:"bytes,3,rep,name=data,proto3" json:"data,omitempty"`
	ExecutedAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=executed_at,json=executedAt,proto3" json:"executed_at,omitempty"`
	Name       string                 `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty"`
	Type       InstanceSpec_Type      `protobuf:"varint,7,opt,name=type,proto3,enum=gotocompany.optimus.core.v1beta1.InstanceSpec_Type" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*InstanceSpec) Descriptor deprecated 

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

Deprecated: Use InstanceSpec.ProtoReflect.Descriptor instead.

func (*InstanceSpec) GetData 

func (x *InstanceSpec) GetData() []*InstanceSpecData

func (*InstanceSpec) GetExecutedAt 

func (x *InstanceSpec) GetExecutedAt() *timestamppb.Timestamp

func (*InstanceSpec) GetName 

func (x *InstanceSpec) GetName() string

func (*InstanceSpec) GetState 

func (x *InstanceSpec) GetState() string

func (*InstanceSpec) GetType 

func (x *InstanceSpec) GetType() InstanceSpec_Type

func (*InstanceSpec) ProtoMessage 

func (*InstanceSpec) ProtoMessage()

func (*InstanceSpec) ProtoReflect 

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

func (*InstanceSpec) Reset 

func (x *InstanceSpec) Reset()

func (*InstanceSpec) String 

func (x *InstanceSpec) String() string

type InstanceSpecData 

type InstanceSpecData struct {
	Name  string                `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value string                `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Type  InstanceSpecData_Type `protobuf:"varint,5,opt,name=type,proto3,enum=gotocompany.optimus.core.v1beta1.InstanceSpecData_Type" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*InstanceSpecData) Descriptor deprecated 

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

Deprecated: Use InstanceSpecData.ProtoReflect.Descriptor instead.

func (*InstanceSpecData) GetName 

func (x *InstanceSpecData) GetName() string

func (*InstanceSpecData) GetType 

func (x *InstanceSpecData) GetType() InstanceSpecData_Type

func (*InstanceSpecData) GetValue 

func (x *InstanceSpecData) GetValue() string

func (*InstanceSpecData) ProtoMessage 

func (*InstanceSpecData) ProtoMessage()

func (*InstanceSpecData) ProtoReflect 

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

func (*InstanceSpecData) Reset 

func (x *InstanceSpecData) Reset()

func (*InstanceSpecData) String 

func (x *InstanceSpecData) String() string

type InstanceSpecData_Type 

type InstanceSpecData_Type int32

type of data, could be an env var or file 

const (
	InstanceSpecData_TYPE_UNSPECIFIED InstanceSpecData_Type = 0
	InstanceSpecData_TYPE_ENV         InstanceSpecData_Type = 1
	InstanceSpecData_TYPE_FILE        InstanceSpecData_Type = 2
)

func (InstanceSpecData_Type) Descriptor 

func (InstanceSpecData_Type) Descriptor() protoreflect.EnumDescriptor

func (InstanceSpecData_Type) Enum 

func (x InstanceSpecData_Type) Enum() *InstanceSpecData_Type

func (InstanceSpecData_Type) EnumDescriptor deprecated 

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

Deprecated: Use InstanceSpecData_Type.Descriptor instead.

func (InstanceSpecData_Type) Number 

func (x InstanceSpecData_Type) Number() protoreflect.EnumNumber

func (InstanceSpecData_Type) String 

func (x InstanceSpecData_Type) String() string

func (InstanceSpecData_Type) Type 

func (InstanceSpecData_Type) Type() protoreflect.EnumType

type InstanceSpec_Type 

type InstanceSpec_Type int32
const (
	InstanceSpec_TYPE_UNSPECIFIED InstanceSpec_Type = 0
	InstanceSpec_TYPE_TASK        InstanceSpec_Type = 1
	InstanceSpec_TYPE_HOOK        InstanceSpec_Type = 2
)

func (InstanceSpec_Type) Descriptor 

func (InstanceSpec_Type) Descriptor() protoreflect.EnumDescriptor

func (InstanceSpec_Type) Enum 

func (x InstanceSpec_Type) Enum() *InstanceSpec_Type

func (InstanceSpec_Type) EnumDescriptor deprecated 

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

Deprecated: Use InstanceSpec_Type.Descriptor instead.

func (InstanceSpec_Type) Number 

func (x InstanceSpec_Type) Number() protoreflect.EnumNumber

func (InstanceSpec_Type) String 

func (x InstanceSpec_Type) String() string

func (InstanceSpec_Type) Type 

func (InstanceSpec_Type) Type() protoreflect.EnumType

type JobConfigItem 

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

func (*JobConfigItem) Descriptor deprecated 

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

Deprecated: Use JobConfigItem.ProtoReflect.Descriptor instead.

func (*JobConfigItem) GetName 

func (x *JobConfigItem) GetName() string

func (*JobConfigItem) GetValue 

func (x *JobConfigItem) GetValue() string

func (*JobConfigItem) ProtoMessage 

func (*JobConfigItem) ProtoMessage()

func (*JobConfigItem) ProtoReflect 

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

func (*JobConfigItem) Reset 

func (x *JobConfigItem) Reset()

func (*JobConfigItem) String 

func (x *JobConfigItem) String() string

type JobDependency 

type JobDependency struct {
	Name           string          `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type           string          `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`                                           // intra/inter/extra
	HttpDependency *HttpDependency `protobuf:"bytes,3,opt,name=http_dependency,json=httpDependency,proto3" json:"http_dependency,omitempty"` // http sensor dependency
	// contains filtered or unexported fields
}

func (*JobDependency) Descriptor deprecated 

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

Deprecated: Use JobDependency.ProtoReflect.Descriptor instead.

func (*JobDependency) GetHttpDependency 

func (x *JobDependency) GetHttpDependency() *HttpDependency

func (*JobDependency) GetName 

func (x *JobDependency) GetName() string

func (*JobDependency) GetType 

func (x *JobDependency) GetType() string

func (*JobDependency) ProtoMessage 

func (*JobDependency) ProtoMessage()

func (*JobDependency) ProtoReflect 

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

func (*JobDependency) Reset 

func (x *JobDependency) Reset()

func (*JobDependency) String 

func (x *JobDependency) String() string

type JobEvent 

type JobEvent struct {
	Type  JobEvent_Type    `protobuf:"varint,1,opt,name=type,proto3,enum=gotocompany.optimus.core.v1beta1.JobEvent_Type" json:"type,omitempty"`
	Value *structpb.Struct `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*JobEvent) Descriptor deprecated 

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

Deprecated: Use JobEvent.ProtoReflect.Descriptor instead.

func (*JobEvent) GetType 

func (x *JobEvent) GetType() JobEvent_Type

func (*JobEvent) GetValue 

func (x *JobEvent) GetValue() *structpb.Struct

func (*JobEvent) ProtoMessage 

func (*JobEvent) ProtoMessage()

func (*JobEvent) ProtoReflect 

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

func (*JobEvent) Reset 

func (x *JobEvent) Reset()

func (*JobEvent) String 

func (x *JobEvent) String() string

type JobEvent_Type 

type JobEvent_Type int32
const (
	JobEvent_TYPE_UNSPECIFIED    JobEvent_Type = 0
	JobEvent_TYPE_SLA_MISS       JobEvent_Type = 1
	JobEvent_TYPE_JOB_SUCCESS    JobEvent_Type = 6
	JobEvent_TYPE_FAILURE        JobEvent_Type = 7
	JobEvent_TYPE_TASK_RETRY     JobEvent_Type = 8
	JobEvent_TYPE_TASK_SUCCESS   JobEvent_Type = 9
	JobEvent_TYPE_TASK_START     JobEvent_Type = 10
	JobEvent_TYPE_TASK_FAIL      JobEvent_Type = 11
	JobEvent_TYPE_SENSOR_RETRY   JobEvent_Type = 12
	JobEvent_TYPE_SENSOR_SUCCESS JobEvent_Type = 13
	JobEvent_TYPE_SENSOR_START   JobEvent_Type = 14
	JobEvent_TYPE_SENSOR_FAIL    JobEvent_Type = 15
	JobEvent_TYPE_HOOK_START     JobEvent_Type = 16
	JobEvent_TYPE_HOOK_RETRY     JobEvent_Type = 17
	JobEvent_TYPE_HOOK_FAIL      JobEvent_Type = 18
	JobEvent_TYPE_HOOK_SUCCESS   JobEvent_Type = 19
)

func (JobEvent_Type) Descriptor 

func (JobEvent_Type) Descriptor() protoreflect.EnumDescriptor

func (JobEvent_Type) Enum 

func (x JobEvent_Type) Enum() *JobEvent_Type

func (JobEvent_Type) EnumDescriptor deprecated 

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

Deprecated: Use JobEvent_Type.Descriptor instead.

func (JobEvent_Type) Number 

func (x JobEvent_Type) Number() protoreflect.EnumNumber

func (JobEvent_Type) String 

func (x JobEvent_Type) String() string

func (JobEvent_Type) Type 

func (JobEvent_Type) Type() protoreflect.EnumType

type JobInspectRequest 

type JobInspectRequest struct {
	ProjectName   string                 `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	NamespaceName string                 `protobuf:"bytes,2,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	JobName       string                 `protobuf:"bytes,3,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	Spec          *JobSpecification      `protobuf:"bytes,4,opt,name=spec,proto3" json:"spec,omitempty"`
	ScheduledAt   *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=scheduled_at,json=scheduledAt,proto3" json:"scheduled_at,omitempty"`
	// contains filtered or unexported fields
}

func (*JobInspectRequest) Descriptor deprecated 

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

Deprecated: Use JobInspectRequest.ProtoReflect.Descriptor instead.

func (*JobInspectRequest) GetJobName 

func (x *JobInspectRequest) GetJobName() string

func (*JobInspectRequest) GetNamespaceName 

func (x *JobInspectRequest) GetNamespaceName() string

func (*JobInspectRequest) GetProjectName 

func (x *JobInspectRequest) GetProjectName() string

func (*JobInspectRequest) GetScheduledAt 

func (x *JobInspectRequest) GetScheduledAt() *timestamppb.Timestamp

func (*JobInspectRequest) GetSpec 

func (x *JobInspectRequest) GetSpec() *JobSpecification

func (*JobInspectRequest) ProtoMessage 

func (*JobInspectRequest) ProtoMessage()

func (*JobInspectRequest) ProtoReflect 

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

func (*JobInspectRequest) Reset 

func (x *JobInspectRequest) Reset()

func (*JobInspectRequest) String 

func (x *JobInspectRequest) String() string

type JobInspectResponse 

type JobInspectResponse struct {
	BasicInfo   *JobInspectResponse_BasicInfoSection  `protobuf:"bytes,1,opt,name=basic_info,json=basicInfo,proto3" json:"basic_info,omitempty"`
	Upstreams   *JobInspectResponse_UpstreamSection   `protobuf:"bytes,2,opt,name=upstreams,proto3" json:"upstreams,omitempty"`
	Downstreams *JobInspectResponse_DownstreamSection `protobuf:"bytes,3,opt,name=downstreams,proto3" json:"downstreams,omitempty"`
	// contains filtered or unexported fields
}

func (*JobInspectResponse) Descriptor deprecated 

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

Deprecated: Use JobInspectResponse.ProtoReflect.Descriptor instead.

func (*JobInspectResponse) GetBasicInfo 

func (x *JobInspectResponse) GetBasicInfo() *JobInspectResponse_BasicInfoSection

func (*JobInspectResponse) GetDownstreams 

func (x *JobInspectResponse) GetDownstreams() *JobInspectResponse_DownstreamSection

func (*JobInspectResponse) GetUpstreams 

func (x *JobInspectResponse) GetUpstreams() *JobInspectResponse_UpstreamSection

func (*JobInspectResponse) ProtoMessage 

func (*JobInspectResponse) ProtoMessage()

func (*JobInspectResponse) ProtoReflect 

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

func (*JobInspectResponse) Reset 

func (x *JobInspectResponse) Reset()

func (*JobInspectResponse) String 

func (x *JobInspectResponse) String() string

type JobInspectResponse_BasicInfoSection 

type JobInspectResponse_BasicInfoSection struct {
	Job         *JobSpecification `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	Source      []string          `protobuf:"bytes,2,rep,name=source,proto3" json:"source,omitempty"`
	Destination string            `protobuf:"bytes,3,opt,name=destination,proto3" json:"destination,omitempty"`
	Notice      []*Log            `protobuf:"bytes,4,rep,name=notice,proto3" json:"notice,omitempty"`
	// contains filtered or unexported fields
}

func (*JobInspectResponse_BasicInfoSection) Descriptor deprecated 

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

Deprecated: Use JobInspectResponse_BasicInfoSection.ProtoReflect.Descriptor instead.

func (*JobInspectResponse_BasicInfoSection) GetDestination 

func (x *JobInspectResponse_BasicInfoSection) GetDestination() string

func (*JobInspectResponse_BasicInfoSection) GetJob 

func (x *JobInspectResponse_BasicInfoSection) GetJob() *JobSpecification

func (*JobInspectResponse_BasicInfoSection) GetNotice 

func (x *JobInspectResponse_BasicInfoSection) GetNotice() []*Log

func (*JobInspectResponse_BasicInfoSection) GetSource 

func (x *JobInspectResponse_BasicInfoSection) GetSource() []string

func (*JobInspectResponse_BasicInfoSection) ProtoMessage 

func (*JobInspectResponse_BasicInfoSection) ProtoMessage()

func (*JobInspectResponse_BasicInfoSection) ProtoReflect 

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

func (*JobInspectResponse_BasicInfoSection) Reset 

func (x *JobInspectResponse_BasicInfoSection) Reset()

func (*JobInspectResponse_BasicInfoSection) String 

func (x *JobInspectResponse_BasicInfoSection) String() string

type JobInspectResponse_DownstreamSection 

type JobInspectResponse_DownstreamSection struct {
	DownstreamJobs []*JobInspectResponse_JobDependency `protobuf:"bytes,1,rep,name=downstream_jobs,json=downstreamJobs,proto3" json:"downstream_jobs,omitempty"`
	Notice         []*Log                              `protobuf:"bytes,2,rep,name=notice,proto3" json:"notice,omitempty"`
	// contains filtered or unexported fields
}

func (*JobInspectResponse_DownstreamSection) Descriptor deprecated 

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

Deprecated: Use JobInspectResponse_DownstreamSection.ProtoReflect.Descriptor instead.

func (*JobInspectResponse_DownstreamSection) GetDownstreamJobs 

func (x *JobInspectResponse_DownstreamSection) GetDownstreamJobs() []*JobInspectResponse_JobDependency

func (*JobInspectResponse_DownstreamSection) GetNotice 

func (x *JobInspectResponse_DownstreamSection) GetNotice() []*Log

func (*JobInspectResponse_DownstreamSection) ProtoMessage 

func (*JobInspectResponse_DownstreamSection) ProtoMessage()

func (*JobInspectResponse_DownstreamSection) ProtoReflect 

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

func (*JobInspectResponse_DownstreamSection) Reset 

func (x *JobInspectResponse_DownstreamSection) Reset()

func (*JobInspectResponse_DownstreamSection) String 

func (x *JobInspectResponse_DownstreamSection) String() string

type JobInspectResponse_JobDependency 

type JobInspectResponse_JobDependency struct {
	Name          string    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Host          string    `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	ProjectName   string    `protobuf:"bytes,3,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	NamespaceName string    `protobuf:"bytes,4,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	TaskName      string    `protobuf:"bytes,5,opt,name=task_name,json=taskName,proto3" json:"task_name,omitempty"`
	Runs          []*JobRun `protobuf:"bytes,6,rep,name=runs,proto3" json:"runs,omitempty"`
	// contains filtered or unexported fields
}

func (*JobInspectResponse_JobDependency) Descriptor deprecated 

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

Deprecated: Use JobInspectResponse_JobDependency.ProtoReflect.Descriptor instead.

func (*JobInspectResponse_JobDependency) GetHost 

func (x *JobInspectResponse_JobDependency) GetHost() string

func (*JobInspectResponse_JobDependency) GetName 

func (x *JobInspectResponse_JobDependency) GetName() string

func (*JobInspectResponse_JobDependency) GetNamespaceName 

func (x *JobInspectResponse_JobDependency) GetNamespaceName() string

func (*JobInspectResponse_JobDependency) GetProjectName 

func (x *JobInspectResponse_JobDependency) GetProjectName() string

func (*JobInspectResponse_JobDependency) GetRuns 

func (x *JobInspectResponse_JobDependency) GetRuns() []*JobRun

func (*JobInspectResponse_JobDependency) GetTaskName 

func (x *JobInspectResponse_JobDependency) GetTaskName() string

func (*JobInspectResponse_JobDependency) ProtoMessage 

func (*JobInspectResponse_JobDependency) ProtoMessage()

func (*JobInspectResponse_JobDependency) ProtoReflect 

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

func (*JobInspectResponse_JobDependency) Reset 

func (x *JobInspectResponse_JobDependency) Reset()

func (*JobInspectResponse_JobDependency) String 

func (x *JobInspectResponse_JobDependency) String() string

type JobInspectResponse_UpstreamSection 

type JobInspectResponse_UpstreamSection struct {
	ExternalDependency  []*JobInspectResponse_JobDependency                       `protobuf:"bytes,1,rep,name=external_dependency,json=externalDependency,proto3" json:"external_dependency,omitempty"`
	InternalDependency  []*JobInspectResponse_JobDependency                       `protobuf:"bytes,2,rep,name=internal_dependency,json=internalDependency,proto3" json:"internal_dependency,omitempty"`
	HttpDependency      []*HttpDependency                                         `protobuf:"bytes,3,rep,name=http_dependency,json=httpDependency,proto3" json:"http_dependency,omitempty"`
	UnknownDependencies []*JobInspectResponse_UpstreamSection_UnknownDependencies `protobuf:"bytes,4,rep,name=unknown_dependencies,json=unknownDependencies,proto3" json:"unknown_dependencies,omitempty"`
	Notice              []*Log                                                    `protobuf:"bytes,5,rep,name=notice,proto3" json:"notice,omitempty"`
	// contains filtered or unexported fields
}

func (*JobInspectResponse_UpstreamSection) Descriptor deprecated 

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

Deprecated: Use JobInspectResponse_UpstreamSection.ProtoReflect.Descriptor instead.

func (*JobInspectResponse_UpstreamSection) GetExternalDependency 

func (x *JobInspectResponse_UpstreamSection) GetExternalDependency() []*JobInspectResponse_JobDependency

func (*JobInspectResponse_UpstreamSection) GetHttpDependency 

func (x *JobInspectResponse_UpstreamSection) GetHttpDependency() []*HttpDependency

func (*JobInspectResponse_UpstreamSection) GetInternalDependency 

func (x *JobInspectResponse_UpstreamSection) GetInternalDependency() []*JobInspectResponse_JobDependency

func (*JobInspectResponse_UpstreamSection) GetNotice 

func (x *JobInspectResponse_UpstreamSection) GetNotice() []*Log

func (*JobInspectResponse_UpstreamSection) GetUnknownDependencies 

func (x *JobInspectResponse_UpstreamSection) GetUnknownDependencies() []*JobInspectResponse_UpstreamSection_UnknownDependencies

func (*JobInspectResponse_UpstreamSection) ProtoMessage 

func (*JobInspectResponse_UpstreamSection) ProtoMessage()

func (*JobInspectResponse_UpstreamSection) ProtoReflect 

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

func (*JobInspectResponse_UpstreamSection) Reset 

func (x *JobInspectResponse_UpstreamSection) Reset()

func (*JobInspectResponse_UpstreamSection) String 

func (x *JobInspectResponse_UpstreamSection) String() string

type JobInspectResponse_UpstreamSection_UnknownDependencies 

type JobInspectResponse_UpstreamSection_UnknownDependencies struct {
	JobName             string `protobuf:"bytes,1,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	ProjectName         string `protobuf:"bytes,2,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	ResourceDestination string `protobuf:"bytes,3,opt,name=resource_destination,json=resourceDestination,proto3" json:"resource_destination,omitempty"`
	// contains filtered or unexported fields
}

func (*JobInspectResponse_UpstreamSection_UnknownDependencies) Descriptor deprecated 

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

Deprecated: Use JobInspectResponse_UpstreamSection_UnknownDependencies.ProtoReflect.Descriptor instead.

func (*JobInspectResponse_UpstreamSection_UnknownDependencies) GetJobName 

func (x *JobInspectResponse_UpstreamSection_UnknownDependencies) GetJobName() string

func (*JobInspectResponse_UpstreamSection_UnknownDependencies) GetProjectName 

func (x *JobInspectResponse_UpstreamSection_UnknownDependencies) GetProjectName() string

func (*JobInspectResponse_UpstreamSection_UnknownDependencies) GetResourceDestination 

func (x *JobInspectResponse_UpstreamSection_UnknownDependencies) GetResourceDestination() string

func (*JobInspectResponse_UpstreamSection_UnknownDependencies) ProtoMessage 

func (*JobInspectResponse_UpstreamSection_UnknownDependencies) ProtoMessage()

func (*JobInspectResponse_UpstreamSection_UnknownDependencies) ProtoReflect 

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

func (*JobInspectResponse_UpstreamSection_UnknownDependencies) Reset 

func (x *JobInspectResponse_UpstreamSection_UnknownDependencies) Reset()

func (*JobInspectResponse_UpstreamSection_UnknownDependencies) String 

func (x *JobInspectResponse_UpstreamSection_UnknownDependencies) String() string

type JobMetadata 

type JobMetadata struct {
	Resource *JobSpecMetadataResource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
	Airflow  *JobSpecMetadataAirflow  `protobuf:"bytes,2,opt,name=airflow,proto3" json:"airflow,omitempty"`
	// contains filtered or unexported fields
}

func (*JobMetadata) Descriptor deprecated 

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

Deprecated: Use JobMetadata.ProtoReflect.Descriptor instead.

func (*JobMetadata) GetAirflow 

func (x *JobMetadata) GetAirflow() *JobSpecMetadataAirflow

func (*JobMetadata) GetResource 

func (x *JobMetadata) GetResource() *JobSpecMetadataResource

func (*JobMetadata) ProtoMessage 

func (*JobMetadata) ProtoMessage()

func (*JobMetadata) ProtoReflect 

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

func (*JobMetadata) Reset 

func (x *JobMetadata) Reset()

func (*JobMetadata) String 

func (x *JobMetadata) String() string

type JobRun 

type JobRun struct {
	State       string                 `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	ScheduledAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=scheduled_at,json=scheduledAt,proto3" json:"scheduled_at,omitempty"`
	// contains filtered or unexported fields
}

func (*JobRun) Descriptor deprecated 

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

Deprecated: Use JobRun.ProtoReflect.Descriptor instead.

func (*JobRun) GetScheduledAt 

func (x *JobRun) GetScheduledAt() *timestamppb.Timestamp

func (*JobRun) GetState 

func (x *JobRun) GetState() string

func (*JobRun) ProtoMessage 

func (*JobRun) ProtoMessage()

func (*JobRun) ProtoReflect 

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

func (*JobRun) Reset 

func (x *JobRun) Reset()

func (*JobRun) String 

func (x *JobRun) String() string

type JobRunInputRequest 

type JobRunInputRequest struct {
	ProjectName  string                 `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	JobName      string                 `protobuf:"bytes,2,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	ScheduledAt  *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=scheduled_at,json=scheduledAt,proto3" json:"scheduled_at,omitempty"`
	InstanceName string                 `protobuf:"bytes,5,opt,name=instance_name,json=instanceName,proto3" json:"instance_name,omitempty"`
	InstanceType InstanceSpec_Type      `` /* 154-byte string literal not displayed */
	// either set job_name if this is a scheduled execution
	// or set jobrun_id if this is a manual triggered execution
	// and not really registered as a valid job
	JobrunId string `protobuf:"bytes,7,opt,name=jobrun_id,json=jobrunId,proto3" json:"jobrun_id,omitempty"`
	// contains filtered or unexported fields
}

func (*JobRunInputRequest) Descriptor deprecated 

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

Deprecated: Use JobRunInputRequest.ProtoReflect.Descriptor instead.

func (*JobRunInputRequest) GetInstanceName 

func (x *JobRunInputRequest) GetInstanceName() string

func (*JobRunInputRequest) GetInstanceType 

func (x *JobRunInputRequest) GetInstanceType() InstanceSpec_Type

func (*JobRunInputRequest) GetJobName 

func (x *JobRunInputRequest) GetJobName() string

func (*JobRunInputRequest) GetJobrunId 

func (x *JobRunInputRequest) GetJobrunId() string

func (*JobRunInputRequest) GetProjectName 

func (x *JobRunInputRequest) GetProjectName() string

func (*JobRunInputRequest) GetScheduledAt 

func (x *JobRunInputRequest) GetScheduledAt() *timestamppb.Timestamp

func (*JobRunInputRequest) ProtoMessage 

func (*JobRunInputRequest) ProtoMessage()

func (*JobRunInputRequest) ProtoReflect 

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

func (*JobRunInputRequest) Reset 

func (x *JobRunInputRequest) Reset()

func (*JobRunInputRequest) String 

func (x *JobRunInputRequest) String() string

type JobRunInputResponse 

type JobRunInputResponse struct {
	Envs    map[string]string `` /* 149-byte string literal not displayed */
	Files   map[string]string `` /* 151-byte string literal not displayed */
	Secrets map[string]string `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*JobRunInputResponse) Descriptor deprecated 

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

Deprecated: Use JobRunInputResponse.ProtoReflect.Descriptor instead.

func (*JobRunInputResponse) GetEnvs 

func (x *JobRunInputResponse) GetEnvs() map[string]string

func (*JobRunInputResponse) GetFiles 

func (x *JobRunInputResponse) GetFiles() map[string]string

func (*JobRunInputResponse) GetSecrets 

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

func (*JobRunInputResponse) ProtoMessage 

func (*JobRunInputResponse) ProtoMessage()

func (*JobRunInputResponse) ProtoReflect 

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

func (*JobRunInputResponse) Reset 

func (x *JobRunInputResponse) Reset()

func (*JobRunInputResponse) String 

func (x *JobRunInputResponse) String() string

type JobRunRequest 

type JobRunRequest struct {
	ProjectName string                 `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	JobName     string                 `protobuf:"bytes,2,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	StartDate   *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=start_date,json=startDate,proto3" json:"start_date,omitempty"`
	EndDate     *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=end_date,json=endDate,proto3" json:"end_date,omitempty"`
	Filter      []string               `protobuf:"bytes,5,rep,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*JobRunRequest) Descriptor deprecated 

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

Deprecated: Use JobRunRequest.ProtoReflect.Descriptor instead.

func (*JobRunRequest) GetEndDate 

func (x *JobRunRequest) GetEndDate() *timestamppb.Timestamp

func (*JobRunRequest) GetFilter 

func (x *JobRunRequest) GetFilter() []string

func (*JobRunRequest) GetJobName 

func (x *JobRunRequest) GetJobName() string

func (*JobRunRequest) GetProjectName 

func (x *JobRunRequest) GetProjectName() string

func (*JobRunRequest) GetStartDate 

func (x *JobRunRequest) GetStartDate() *timestamppb.Timestamp

func (*JobRunRequest) ProtoMessage 

func (*JobRunRequest) ProtoMessage()

func (*JobRunRequest) ProtoReflect 

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

func (*JobRunRequest) Reset 

func (x *JobRunRequest) Reset()

func (*JobRunRequest) String 

func (x *JobRunRequest) String() string

type JobRunResponse 

type JobRunResponse struct {
	JobRuns []*JobRun `protobuf:"bytes,1,rep,name=job_runs,json=jobRuns,proto3" json:"job_runs,omitempty"`
	// contains filtered or unexported fields
}

func (*JobRunResponse) Descriptor deprecated 

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

Deprecated: Use JobRunResponse.ProtoReflect.Descriptor instead.

func (*JobRunResponse) GetJobRuns 

func (x *JobRunResponse) GetJobRuns() []*JobRun

func (*JobRunResponse) ProtoMessage 

func (*JobRunResponse) ProtoMessage()

func (*JobRunResponse) ProtoReflect 

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

func (*JobRunResponse) Reset 

func (x *JobRunResponse) Reset()

func (*JobRunResponse) String 

func (x *JobRunResponse) String() string

type JobRunServiceClient 

type JobRunServiceClient interface {
	// JobRunInput is used to fetch task/hook compiled configuration and assets.
	JobRunInput(ctx context.Context, in *JobRunInputRequest, opts ...grpc.CallOption) (*JobRunInputResponse, error)
	// JobRun returns the current and past run status of jobs on a given range
	JobRun(ctx context.Context, in *JobRunRequest, opts ...grpc.CallOption) (*JobRunResponse, error)
	// RegisterJobEvent notifies optimus service about an event related to job
	RegisterJobEvent(ctx context.Context, in *RegisterJobEventRequest, opts ...grpc.CallOption) (*RegisterJobEventResponse, error)
	// UploadToScheduler comiles jobSpec from database into DAGs and uploads the generated DAGs to scheduler
	UploadToScheduler(ctx context.Context, in *UploadToSchedulerRequest, opts ...grpc.CallOption) (*UploadToSchedulerResponse, error)
}

JobRunServiceClient is the client API for JobRunService service.

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

func NewJobRunServiceClient 

func NewJobRunServiceClient(cc grpc.ClientConnInterface) JobRunServiceClient

type JobRunServiceServer 

type JobRunServiceServer interface {
	// JobRunInput is used to fetch task/hook compiled configuration and assets.
	JobRunInput(context.Context, *JobRunInputRequest) (*JobRunInputResponse, error)
	// JobRun returns the current and past run status of jobs on a given range
	JobRun(context.Context, *JobRunRequest) (*JobRunResponse, error)
	// RegisterJobEvent notifies optimus service about an event related to job
	RegisterJobEvent(context.Context, *RegisterJobEventRequest) (*RegisterJobEventResponse, error)
	// UploadToScheduler comiles jobSpec from database into DAGs and uploads the generated DAGs to scheduler
	UploadToScheduler(context.Context, *UploadToSchedulerRequest) (*UploadToSchedulerResponse, error)
	// contains filtered or unexported methods
}

JobRunServiceServer is the server API for JobRunService service. All implementations must embed UnimplementedJobRunServiceServer for forward compatibility

type JobSpecHook 

type JobSpecHook struct {
	Name   string           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Config []*JobConfigItem `protobuf:"bytes,2,rep,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*JobSpecHook) Descriptor deprecated 

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

Deprecated: Use JobSpecHook.ProtoReflect.Descriptor instead.

func (*JobSpecHook) GetConfig 

func (x *JobSpecHook) GetConfig() []*JobConfigItem

func (*JobSpecHook) GetName 

func (x *JobSpecHook) GetName() string

func (*JobSpecHook) ProtoMessage 

func (*JobSpecHook) ProtoMessage()

func (*JobSpecHook) ProtoReflect 

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

func (*JobSpecHook) Reset 

func (x *JobSpecHook) Reset()

func (*JobSpecHook) String 

func (x *JobSpecHook) String() string

type JobSpecMetadataAirflow 

type JobSpecMetadataAirflow struct {
	Pool  string `protobuf:"bytes,1,opt,name=pool,proto3" json:"pool,omitempty"`
	Queue string `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"`
	// contains filtered or unexported fields
}

func (*JobSpecMetadataAirflow) Descriptor deprecated 

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

Deprecated: Use JobSpecMetadataAirflow.ProtoReflect.Descriptor instead.

func (*JobSpecMetadataAirflow) GetPool 

func (x *JobSpecMetadataAirflow) GetPool() string

func (*JobSpecMetadataAirflow) GetQueue 

func (x *JobSpecMetadataAirflow) GetQueue() string

func (*JobSpecMetadataAirflow) ProtoMessage 

func (*JobSpecMetadataAirflow) ProtoMessage()

func (*JobSpecMetadataAirflow) ProtoReflect 

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

func (*JobSpecMetadataAirflow) Reset 

func (x *JobSpecMetadataAirflow) Reset()

func (*JobSpecMetadataAirflow) String 

func (x *JobSpecMetadataAirflow) String() string

type JobSpecMetadataResource 

type JobSpecMetadataResource struct {
	Request *JobSpecMetadataResourceConfig `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	Limit   *JobSpecMetadataResourceConfig `protobuf:"bytes,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*JobSpecMetadataResource) Descriptor deprecated 

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

Deprecated: Use JobSpecMetadataResource.ProtoReflect.Descriptor instead.

func (*JobSpecMetadataResource) GetLimit 

func (x *JobSpecMetadataResource) GetLimit() *JobSpecMetadataResourceConfig

func (*JobSpecMetadataResource) GetRequest 

func (x *JobSpecMetadataResource) GetRequest() *JobSpecMetadataResourceConfig

func (*JobSpecMetadataResource) ProtoMessage 

func (*JobSpecMetadataResource) ProtoMessage()

func (*JobSpecMetadataResource) ProtoReflect 

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

func (*JobSpecMetadataResource) Reset 

func (x *JobSpecMetadataResource) Reset()

func (*JobSpecMetadataResource) String 

func (x *JobSpecMetadataResource) String() string

type JobSpecMetadataResourceConfig 

type JobSpecMetadataResourceConfig struct {
	Cpu    string `protobuf:"bytes,1,opt,name=cpu,proto3" json:"cpu,omitempty"`
	Memory string `protobuf:"bytes,2,opt,name=memory,proto3" json:"memory,omitempty"`
	// contains filtered or unexported fields
}

func (*JobSpecMetadataResourceConfig) Descriptor deprecated 

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

Deprecated: Use JobSpecMetadataResourceConfig.ProtoReflect.Descriptor instead.

func (*JobSpecMetadataResourceConfig) GetCpu 

func (x *JobSpecMetadataResourceConfig) GetCpu() string

func (*JobSpecMetadataResourceConfig) GetMemory 

func (x *JobSpecMetadataResourceConfig) GetMemory() string

func (*JobSpecMetadataResourceConfig) ProtoMessage 

func (*JobSpecMetadataResourceConfig) ProtoMessage()

func (*JobSpecMetadataResourceConfig) ProtoReflect 

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

func (*JobSpecMetadataResourceConfig) Reset 

func (x *JobSpecMetadataResourceConfig) Reset()

func (*JobSpecMetadataResourceConfig) String 

func (x *JobSpecMetadataResourceConfig) String() string

type JobSpecification 

type JobSpecification struct {
	Version       int32  `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	Name          string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Owner         string `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"`
	StartDate     string `protobuf:"bytes,4,opt,name=start_date,json=startDate,proto3" json:"start_date,omitempty"`
	EndDate       string `protobuf:"bytes,5,opt,name=end_date,json=endDate,proto3" json:"end_date,omitempty"` // optional
	Interval      string `protobuf:"bytes,6,opt,name=interval,proto3" json:"interval,omitempty"`
	DependsOnPast bool   `protobuf:"varint,7,opt,name=depends_on_past,json=dependsOnPast,proto3" json:"depends_on_past,omitempty"` // should only execute today if yesterday was completed with success?
	// Deprecated: Do not use.
	CatchUp          bool                       `protobuf:"varint,8,opt,name=catch_up,json=catchUp,proto3" json:"catch_up,omitempty"` // should backfill till today?
	TaskName         string                     `protobuf:"bytes,9,opt,name=task_name,json=taskName,proto3" json:"task_name,omitempty"`
	Config           []*JobConfigItem           `protobuf:"bytes,10,rep,name=config,proto3" json:"config,omitempty"`
	WindowSize       string                     `protobuf:"bytes,11,opt,name=window_size,json=windowSize,proto3" json:"window_size,omitempty"`
	WindowOffset     string                     `protobuf:"bytes,12,opt,name=window_offset,json=windowOffset,proto3" json:"window_offset,omitempty"`
	WindowTruncateTo string                     `protobuf:"bytes,13,opt,name=window_truncate_to,json=windowTruncateTo,proto3" json:"window_truncate_to,omitempty"`
	Dependencies     []*JobDependency           `protobuf:"bytes,14,rep,name=dependencies,proto3" json:"dependencies,omitempty"` // static dependencies
	Assets           map[string]string          ``                                                                               /* 154-byte string literal not displayed */
	Hooks            []*JobSpecHook             `protobuf:"bytes,16,rep,name=hooks,proto3" json:"hooks,omitempty"`               // optional
	Description      string                     `protobuf:"bytes,17,opt,name=description,proto3" json:"description,omitempty"`   // optional
	Labels           map[string]string          ``                                                                               /* 154-byte string literal not displayed */
	Behavior         *JobSpecification_Behavior `protobuf:"bytes,19,opt,name=behavior,proto3" json:"behavior,omitempty"`
	Metadata         *JobMetadata               `protobuf:"bytes,20,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Destination      string                     `protobuf:"bytes,21,opt,name=destination,proto3" json:"destination,omitempty"`
	Sources          []string                   `protobuf:"bytes,22,rep,name=sources,proto3" json:"sources,omitempty"`
	// contains filtered or unexported fields
}

func (*JobSpecification) Descriptor deprecated 

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

Deprecated: Use JobSpecification.ProtoReflect.Descriptor instead.

func (*JobSpecification) GetAssets 

func (x *JobSpecification) GetAssets() map[string]string

func (*JobSpecification) GetBehavior 

func (x *JobSpecification) GetBehavior() *JobSpecification_Behavior

func (*JobSpecification) GetCatchUp deprecated 

func (x *JobSpecification) GetCatchUp() bool

Deprecated: Do not use.

func (*JobSpecification) GetConfig 

func (x *JobSpecification) GetConfig() []*JobConfigItem

func (*JobSpecification) GetDependencies 

func (x *JobSpecification) GetDependencies() []*JobDependency

func (*JobSpecification) GetDependsOnPast 

func (x *JobSpecification) GetDependsOnPast() bool

func (*JobSpecification) GetDescription 

func (x *JobSpecification) GetDescription() string

func (*JobSpecification) GetDestination 

func (x *JobSpecification) GetDestination() string

func (*JobSpecification) GetEndDate 

func (x *JobSpecification) GetEndDate() string

func (*JobSpecification) GetHooks 

func (x *JobSpecification) GetHooks() []*JobSpecHook

func (*JobSpecification) GetInterval 

func (x *JobSpecification) GetInterval() string

func (*JobSpecification) GetLabels 

func (x *JobSpecification) GetLabels() map[string]string

func (*JobSpecification) GetMetadata 

func (x *JobSpecification) GetMetadata() *JobMetadata

func (*JobSpecification) GetName 

func (x *JobSpecification) GetName() string

func (*JobSpecification) GetOwner 

func (x *JobSpecification) GetOwner() string

func (*JobSpecification) GetSources 

func (x *JobSpecification) GetSources() []string

func (*JobSpecification) GetStartDate 

func (x *JobSpecification) GetStartDate() string

func (*JobSpecification) GetTaskName 

func (x *JobSpecification) GetTaskName() string

func (*JobSpecification) GetVersion 

func (x *JobSpecification) GetVersion() int32

func (*JobSpecification) GetWindowOffset 

func (x *JobSpecification) GetWindowOffset() string

func (*JobSpecification) GetWindowSize 

func (x *JobSpecification) GetWindowSize() string

func (*JobSpecification) GetWindowTruncateTo 

func (x *JobSpecification) GetWindowTruncateTo() string

func (*JobSpecification) ProtoMessage 

func (*JobSpecification) ProtoMessage()

func (*JobSpecification) ProtoReflect 

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

func (*JobSpecification) Reset 

func (x *JobSpecification) Reset()

func (*JobSpecification) String 

func (x *JobSpecification) String() string

type JobSpecificationResponse 

type JobSpecificationResponse struct {
	ProjectName   string            `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	NamespaceName string            `protobuf:"bytes,2,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	Job           *JobSpecification `protobuf:"bytes,3,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

func (*JobSpecificationResponse) Descriptor deprecated 

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

Deprecated: Use JobSpecificationResponse.ProtoReflect.Descriptor instead.

func (*JobSpecificationResponse) GetJob 

func (x *JobSpecificationResponse) GetJob() *JobSpecification

func (*JobSpecificationResponse) GetNamespaceName 

func (x *JobSpecificationResponse) GetNamespaceName() string

func (*JobSpecificationResponse) GetProjectName 

func (x *JobSpecificationResponse) GetProjectName() string

func (*JobSpecificationResponse) ProtoMessage 

func (*JobSpecificationResponse) ProtoMessage()

func (*JobSpecificationResponse) ProtoReflect 

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

func (*JobSpecificationResponse) Reset 

func (x *JobSpecificationResponse) Reset()

func (*JobSpecificationResponse) String 

func (x *JobSpecificationResponse) String() string

type JobSpecificationServiceClient 

type JobSpecificationServiceClient interface {
	// DeployJobSpecification schedules jobs for execution
	// returns a stream of messages which can be used to track the progress
	// of deployments. Message containing ack are status events other are progress
	// events
	// State of the world request
	DeployJobSpecification(ctx context.Context, opts ...grpc.CallOption) (JobSpecificationService_DeployJobSpecificationClient, error)
	// JobInspect return a new jobSpec for a namespace which belongs to a project
	JobInspect(ctx context.Context, in *JobInspectRequest, opts ...grpc.CallOption) (*JobInspectResponse, error)
	// CreateJobSpecification registers a new job for a namespace which belongs to a project
	CreateJobSpecification(ctx context.Context, in *CreateJobSpecificationRequest, opts ...grpc.CallOption) (*CreateJobSpecificationResponse, error)
	// AddJobSpecification registers new jobs for a namespace which belongs to the given project
	AddJobSpecifications(ctx context.Context, in *AddJobSpecificationsRequest, opts ...grpc.CallOption) (*AddJobSpecificationsResponse, error)
	// UpdateJobSpecifications modify jobs for a namespace which belongs to the given project
	UpdateJobSpecifications(ctx context.Context, in *UpdateJobSpecificationsRequest, opts ...grpc.CallOption) (*UpdateJobSpecificationsResponse, error)
	// GetJobSpecification reads a provided job spec of a namespace
	GetJobSpecification(ctx context.Context, in *GetJobSpecificationRequest, opts ...grpc.CallOption) (*GetJobSpecificationResponse, error)
	// GetJobSpecifications read a job spec for provided filters
	GetJobSpecifications(ctx context.Context, in *GetJobSpecificationsRequest, opts ...grpc.CallOption) (*GetJobSpecificationsResponse, error)
	// DeleteJobSpecification deletes a job spec of a namespace
	DeleteJobSpecification(ctx context.Context, in *DeleteJobSpecificationRequest, opts ...grpc.CallOption) (*DeleteJobSpecificationResponse, error)
	// ChangeJobNamespace move a job spec from one namespace to another
	ChangeJobNamespace(ctx context.Context, in *ChangeJobNamespaceRequest, opts ...grpc.CallOption) (*ChangeJobNamespaceResponse, error)
	// ListJobSpecification returns list of jobs created in a project
	ListJobSpecification(ctx context.Context, in *ListJobSpecificationRequest, opts ...grpc.CallOption) (*ListJobSpecificationResponse, error)
	// CheckJobSpecification checks if a job specification is valid
	CheckJobSpecification(ctx context.Context, in *CheckJobSpecificationRequest, opts ...grpc.CallOption) (*CheckJobSpecificationResponse, error)
	// CheckJobSpecifications checks if the job specifications are valid
	CheckJobSpecifications(ctx context.Context, in *CheckJobSpecificationsRequest, opts ...grpc.CallOption) (JobSpecificationService_CheckJobSpecificationsClient, error)
	// RefreshJobs do redeployment using the current persisted state.
	// It will returns a stream of messages which can be used to track the progress.
	RefreshJobs(ctx context.Context, in *RefreshJobsRequest, opts ...grpc.CallOption) (JobSpecificationService_RefreshJobsClient, error)
	// GetDeployJobsStatus check status of job deployment.
	// It will returns status of the job deployment and the failure details.
	GetDeployJobsStatus(ctx context.Context, in *GetDeployJobsStatusRequest, opts ...grpc.CallOption) (*GetDeployJobsStatusResponse, error)
	// ReplaceAllJobSpecifications replaces all jobs in server for a given tenant
	ReplaceAllJobSpecifications(ctx context.Context, opts ...grpc.CallOption) (JobSpecificationService_ReplaceAllJobSpecificationsClient, error)
	// GetJobTask provides task details specific to plugin used in a job
	GetJobTask(ctx context.Context, in *GetJobTaskRequest, opts ...grpc.CallOption) (*GetJobTaskResponse, error)
	// GetWindow provides the start and end dates provided a scheduled date
	// of the execution window
	GetWindow(ctx context.Context, in *GetWindowRequest, opts ...grpc.CallOption) (*GetWindowResponse, error)
	// UpdateJobState enable / disable job on scheuler
	UpdateJobsState(ctx context.Context, in *UpdateJobsStateRequest, opts ...grpc.CallOption) (*UpdateJobsStateResponse, error)
	// SyncJobsState enable / disable job on scheuler
	SyncJobsState(ctx context.Context, in *SyncJobsStateRequest, opts ...grpc.CallOption) (*SyncJobsStateResponse, error)
}

JobSpecificationServiceClient is the client API for JobSpecificationService service.

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

func NewJobSpecificationServiceClient 

func NewJobSpecificationServiceClient(cc grpc.ClientConnInterface) JobSpecificationServiceClient

type JobSpecificationServiceServer 

type JobSpecificationServiceServer interface {
	// DeployJobSpecification schedules jobs for execution
	// returns a stream of messages which can be used to track the progress
	// of deployments. Message containing ack are status events other are progress
	// events
	// State of the world request
	DeployJobSpecification(JobSpecificationService_DeployJobSpecificationServer) error
	// JobInspect return a new jobSpec for a namespace which belongs to a project
	JobInspect(context.Context, *JobInspectRequest) (*JobInspectResponse, error)
	// CreateJobSpecification registers a new job for a namespace which belongs to a project
	CreateJobSpecification(context.Context, *CreateJobSpecificationRequest) (*CreateJobSpecificationResponse, error)
	// AddJobSpecification registers new jobs for a namespace which belongs to the given project
	AddJobSpecifications(context.Context, *AddJobSpecificationsRequest) (*AddJobSpecificationsResponse, error)
	// UpdateJobSpecifications modify jobs for a namespace which belongs to the given project
	UpdateJobSpecifications(context.Context, *UpdateJobSpecificationsRequest) (*UpdateJobSpecificationsResponse, error)
	// GetJobSpecification reads a provided job spec of a namespace
	GetJobSpecification(context.Context, *GetJobSpecificationRequest) (*GetJobSpecificationResponse, error)
	// GetJobSpecifications read a job spec for provided filters
	GetJobSpecifications(context.Context, *GetJobSpecificationsRequest) (*GetJobSpecificationsResponse, error)
	// DeleteJobSpecification deletes a job spec of a namespace
	DeleteJobSpecification(context.Context, *DeleteJobSpecificationRequest) (*DeleteJobSpecificationResponse, error)
	// ChangeJobNamespace move a job spec from one namespace to another
	ChangeJobNamespace(context.Context, *ChangeJobNamespaceRequest) (*ChangeJobNamespaceResponse, error)
	// ListJobSpecification returns list of jobs created in a project
	ListJobSpecification(context.Context, *ListJobSpecificationRequest) (*ListJobSpecificationResponse, error)
	// CheckJobSpecification checks if a job specification is valid
	CheckJobSpecification(context.Context, *CheckJobSpecificationRequest) (*CheckJobSpecificationResponse, error)
	// CheckJobSpecifications checks if the job specifications are valid
	CheckJobSpecifications(*CheckJobSpecificationsRequest, JobSpecificationService_CheckJobSpecificationsServer) error
	// RefreshJobs do redeployment using the current persisted state.
	// It will returns a stream of messages which can be used to track the progress.
	RefreshJobs(*RefreshJobsRequest, JobSpecificationService_RefreshJobsServer) error
	// GetDeployJobsStatus check status of job deployment.
	// It will returns status of the job deployment and the failure details.
	GetDeployJobsStatus(context.Context, *GetDeployJobsStatusRequest) (*GetDeployJobsStatusResponse, error)
	// ReplaceAllJobSpecifications replaces all jobs in server for a given tenant
	ReplaceAllJobSpecifications(JobSpecificationService_ReplaceAllJobSpecificationsServer) error
	// GetJobTask provides task details specific to plugin used in a job
	GetJobTask(context.Context, *GetJobTaskRequest) (*GetJobTaskResponse, error)
	// GetWindow provides the start and end dates provided a scheduled date
	// of the execution window
	GetWindow(context.Context, *GetWindowRequest) (*GetWindowResponse, error)
	// UpdateJobState enable / disable job on scheuler
	UpdateJobsState(context.Context, *UpdateJobsStateRequest) (*UpdateJobsStateResponse, error)
	// SyncJobsState enable / disable job on scheuler
	SyncJobsState(context.Context, *SyncJobsStateRequest) (*SyncJobsStateResponse, error)
	// contains filtered or unexported methods
}

JobSpecificationServiceServer is the server API for JobSpecificationService service. All implementations must embed UnimplementedJobSpecificationServiceServer for forward compatibility

type JobSpecificationService_CheckJobSpecificationsClient 

type JobSpecificationService_CheckJobSpecificationsClient interface {
	Recv() (*CheckJobSpecificationsResponse, error)
	grpc.ClientStream
}

type JobSpecificationService_CheckJobSpecificationsServer 

type JobSpecificationService_CheckJobSpecificationsServer interface {
	Send(*CheckJobSpecificationsResponse) error
	grpc.ServerStream
}

type JobSpecificationService_DeployJobSpecificationClient 

type JobSpecificationService_DeployJobSpecificationClient interface {
	Send(*DeployJobSpecificationRequest) error
	Recv() (*DeployJobSpecificationResponse, error)
	grpc.ClientStream
}

type JobSpecificationService_DeployJobSpecificationServer 

type JobSpecificationService_DeployJobSpecificationServer interface {
	Send(*DeployJobSpecificationResponse) error
	Recv() (*DeployJobSpecificationRequest, error)
	grpc.ServerStream
}

type JobSpecificationService_RefreshJobsClient 

type JobSpecificationService_RefreshJobsClient interface {
	Recv() (*RefreshJobsResponse, error)
	grpc.ClientStream
}

type JobSpecificationService_RefreshJobsServer 

type JobSpecificationService_RefreshJobsServer interface {
	Send(*RefreshJobsResponse) error
	grpc.ServerStream
}

type JobSpecificationService_ReplaceAllJobSpecificationsClient 

type JobSpecificationService_ReplaceAllJobSpecificationsClient interface {
	Send(*ReplaceAllJobSpecificationsRequest) error
	Recv() (*ReplaceAllJobSpecificationsResponse, error)
	grpc.ClientStream
}

type JobSpecificationService_ReplaceAllJobSpecificationsServer 

type JobSpecificationService_ReplaceAllJobSpecificationsServer interface {
	Send(*ReplaceAllJobSpecificationsResponse) error
	Recv() (*ReplaceAllJobSpecificationsRequest, error)
	grpc.ServerStream
}

type JobSpecification_Behavior 

type JobSpecification_Behavior struct {
	Retry  *JobSpecification_Behavior_Retry       `protobuf:"bytes,1,opt,name=retry,proto3" json:"retry,omitempty"`
	Notify []*JobSpecification_Behavior_Notifiers `protobuf:"bytes,2,rep,name=notify,proto3" json:"notify,omitempty"`
	// contains filtered or unexported fields
}

func (*JobSpecification_Behavior) Descriptor deprecated 

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

Deprecated: Use JobSpecification_Behavior.ProtoReflect.Descriptor instead.

func (*JobSpecification_Behavior) GetNotify 

func (x *JobSpecification_Behavior) GetNotify() []*JobSpecification_Behavior_Notifiers

func (*JobSpecification_Behavior) GetRetry 

func (x *JobSpecification_Behavior) GetRetry() *JobSpecification_Behavior_Retry

func (*JobSpecification_Behavior) ProtoMessage 

func (*JobSpecification_Behavior) ProtoMessage()

func (*JobSpecification_Behavior) ProtoReflect 

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

func (*JobSpecification_Behavior) Reset 

func (x *JobSpecification_Behavior) Reset()

func (*JobSpecification_Behavior) String 

func (x *JobSpecification_Behavior) String() string

type JobSpecification_Behavior_Notifiers 

type JobSpecification_Behavior_Notifiers struct {
	On       JobEvent_Type     `protobuf:"varint,1,opt,name=on,proto3,enum=gotocompany.optimus.core.v1beta1.JobEvent_Type" json:"on,omitempty"`
	Channels []string          `protobuf:"bytes,2,rep,name=channels,proto3" json:"channels,omitempty"`
	Config   map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

Notifiers are used to set custom alerting in case of job failure/sla_miss

func (*JobSpecification_Behavior_Notifiers) Descriptor deprecated 

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

Deprecated: Use JobSpecification_Behavior_Notifiers.ProtoReflect.Descriptor instead.

func (*JobSpecification_Behavior_Notifiers) GetChannels 

func (x *JobSpecification_Behavior_Notifiers) GetChannels() []string

func (*JobSpecification_Behavior_Notifiers) GetConfig 

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

func (*JobSpecification_Behavior_Notifiers) GetOn 

func (x *JobSpecification_Behavior_Notifiers) GetOn() JobEvent_Type

func (*JobSpecification_Behavior_Notifiers) ProtoMessage 

func (*JobSpecification_Behavior_Notifiers) ProtoMessage()

func (*JobSpecification_Behavior_Notifiers) ProtoReflect 

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

func (*JobSpecification_Behavior_Notifiers) Reset 

func (x *JobSpecification_Behavior_Notifiers) Reset()

func (*JobSpecification_Behavior_Notifiers) String 

func (x *JobSpecification_Behavior_Notifiers) String() string

type JobSpecification_Behavior_Retry 

type JobSpecification_Behavior_Retry struct {
	Count              int32                `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	Delay              *durationpb.Duration `protobuf:"bytes,2,opt,name=delay,proto3" json:"delay,omitempty"`
	ExponentialBackoff bool                 `protobuf:"varint,3,opt,name=exponential_backoff,json=exponentialBackoff,proto3" json:"exponential_backoff,omitempty"`
	// contains filtered or unexported fields
}

retry behaviour if job failed to execute for the first time

func (*JobSpecification_Behavior_Retry) Descriptor deprecated 

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

Deprecated: Use JobSpecification_Behavior_Retry.ProtoReflect.Descriptor instead.

func (*JobSpecification_Behavior_Retry) GetCount 

func (x *JobSpecification_Behavior_Retry) GetCount() int32

func (*JobSpecification_Behavior_Retry) GetDelay 

func (x *JobSpecification_Behavior_Retry) GetDelay() *durationpb.Duration

func (*JobSpecification_Behavior_Retry) GetExponentialBackoff 

func (x *JobSpecification_Behavior_Retry) GetExponentialBackoff() bool

func (*JobSpecification_Behavior_Retry) ProtoMessage 

func (*JobSpecification_Behavior_Retry) ProtoMessage()

func (*JobSpecification_Behavior_Retry) ProtoReflect 

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

func (*JobSpecification_Behavior_Retry) Reset 

func (x *JobSpecification_Behavior_Retry) Reset()

func (*JobSpecification_Behavior_Retry) String 

func (x *JobSpecification_Behavior_Retry) String() string

type JobState added in v0.9.0 

type JobState int32
const (
	JobState_JOB_STATE_UNSPECIFIED JobState = 0
	JobState_JOB_STATE_ENABLED     JobState = 1
	JobState_JOB_STATE_DISABLED    JobState = 2
)

func (JobState) Descriptor added in v0.9.0 

func (JobState) Descriptor() protoreflect.EnumDescriptor

func (JobState) Enum added in v0.9.0 

func (x JobState) Enum() *JobState

func (JobState) EnumDescriptor deprecated added in v0.9.0 

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

Deprecated: Use JobState.Descriptor instead.

func (JobState) Number added in v0.9.0 

func (x JobState) Number() protoreflect.EnumNumber

func (JobState) String added in v0.9.0 

func (x JobState) String() string

func (JobState) Type added in v0.9.0 

func (JobState) Type() protoreflect.EnumType

type JobTask 

type JobTask struct {
	Name         string                `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description  string                `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Image        string                `protobuf:"bytes,3,opt,name=image,proto3" json:"image,omitempty"`
	Destination  *JobTask_Destination  `protobuf:"bytes,4,opt,name=destination,proto3" json:"destination,omitempty"`
	Dependencies []*JobTask_Dependency `protobuf:"bytes,5,rep,name=dependencies,proto3" json:"dependencies,omitempty"`
	// contains filtered or unexported fields
}

JobTask is part of a job that dictates main transformation each job has exactly one task

func (*JobTask) Descriptor deprecated 

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

Deprecated: Use JobTask.ProtoReflect.Descriptor instead.

func (*JobTask) GetDependencies 

func (x *JobTask) GetDependencies() []*JobTask_Dependency

func (*JobTask) GetDescription 

func (x *JobTask) GetDescription() string

func (*JobTask) GetDestination 

func (x *JobTask) GetDestination() *JobTask_Destination

func (*JobTask) GetImage 

func (x *JobTask) GetImage() string

func (*JobTask) GetName 

func (x *JobTask) GetName() string

func (*JobTask) ProtoMessage 

func (*JobTask) ProtoMessage()

func (*JobTask) ProtoReflect 

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

func (*JobTask) Reset 

func (x *JobTask) Reset()

func (*JobTask) String 

func (x *JobTask) String() string

type JobTask_Dependency 

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

func (*JobTask_Dependency) Descriptor deprecated 

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

Deprecated: Use JobTask_Dependency.ProtoReflect.Descriptor instead.

func (*JobTask_Dependency) GetDependency 

func (x *JobTask_Dependency) GetDependency() string

func (*JobTask_Dependency) ProtoMessage 

func (*JobTask_Dependency) ProtoMessage()

func (*JobTask_Dependency) ProtoReflect 

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

func (*JobTask_Dependency) Reset 

func (x *JobTask_Dependency) Reset()

func (*JobTask_Dependency) String 

func (x *JobTask_Dependency) String() string

type JobTask_Destination 

type JobTask_Destination struct {
	Destination string `protobuf:"bytes,1,opt,name=destination,proto3" json:"destination,omitempty"`
	Type        string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*JobTask_Destination) Descriptor deprecated 

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

Deprecated: Use JobTask_Destination.ProtoReflect.Descriptor instead.

func (*JobTask_Destination) GetDestination 

func (x *JobTask_Destination) GetDestination() string

func (*JobTask_Destination) GetType 

func (x *JobTask_Destination) GetType() string

func (*JobTask_Destination) ProtoMessage 

func (*JobTask_Destination) ProtoMessage()

func (*JobTask_Destination) ProtoReflect 

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

func (*JobTask_Destination) Reset 

func (x *JobTask_Destination) Reset()

func (*JobTask_Destination) String 

func (x *JobTask_Destination) String() string

type Level 

type Level int32
const (
	Level_LEVEL_UNSPECIFIED Level = 0
	Level_LEVEL_TRACE       Level = 1
	Level_LEVEL_DEBUG       Level = 2
	Level_LEVEL_INFO        Level = 3
	Level_LEVEL_WARNING     Level = 4
	Level_LEVEL_ERROR       Level = 5
	Level_LEVEL_FATAL       Level = 6
)

func (Level) Descriptor 

func (Level) Descriptor() protoreflect.EnumDescriptor

func (Level) Enum 

func (x Level) Enum() *Level

func (Level) EnumDescriptor deprecated 

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

Deprecated: Use Level.Descriptor instead.

func (Level) Number 

func (x Level) Number() protoreflect.EnumNumber

func (Level) String 

func (x Level) String() string

func (Level) Type 

func (Level) Type() protoreflect.EnumType

type ListBackupsRequest 

type ListBackupsRequest struct {
	ProjectName   string `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	DatastoreName string `protobuf:"bytes,2,opt,name=datastore_name,json=datastoreName,proto3" json:"datastore_name,omitempty"`
	NamespaceName string `protobuf:"bytes,3,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBackupsRequest) Descriptor deprecated 

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

Deprecated: Use ListBackupsRequest.ProtoReflect.Descriptor instead.

func (*ListBackupsRequest) GetDatastoreName 

func (x *ListBackupsRequest) GetDatastoreName() string

func (*ListBackupsRequest) GetNamespaceName 

func (x *ListBackupsRequest) GetNamespaceName() string

func (*ListBackupsRequest) GetProjectName 

func (x *ListBackupsRequest) GetProjectName() string

func (*ListBackupsRequest) ProtoMessage 

func (*ListBackupsRequest) ProtoMessage()

func (*ListBackupsRequest) ProtoReflect 

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

func (*ListBackupsRequest) Reset 

func (x *ListBackupsRequest) Reset()

func (*ListBackupsRequest) String 

func (x *ListBackupsRequest) String() string

type ListBackupsResponse 

type ListBackupsResponse struct {
	Backups []*BackupSpec `protobuf:"bytes,1,rep,name=backups,proto3" json:"backups,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBackupsResponse) Descriptor deprecated 

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

Deprecated: Use ListBackupsResponse.ProtoReflect.Descriptor instead.

func (*ListBackupsResponse) GetBackups 

func (x *ListBackupsResponse) GetBackups() []*BackupSpec

func (*ListBackupsResponse) ProtoMessage 

func (*ListBackupsResponse) ProtoMessage()

func (*ListBackupsResponse) ProtoReflect 

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

func (*ListBackupsResponse) Reset 

func (x *ListBackupsResponse) Reset()

func (*ListBackupsResponse) String 

func (x *ListBackupsResponse) String() string

type ListJobSpecificationRequest 

type ListJobSpecificationRequest struct {
	ProjectName   string `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	NamespaceName string `protobuf:"bytes,2,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	// contains filtered or unexported fields
}

func (*ListJobSpecificationRequest) Descriptor deprecated 

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

Deprecated: Use ListJobSpecificationRequest.ProtoReflect.Descriptor instead.

func (*ListJobSpecificationRequest) GetNamespaceName 

func (x *ListJobSpecificationRequest) GetNamespaceName() string

func (*ListJobSpecificationRequest) GetProjectName 

func (x *ListJobSpecificationRequest) GetProjectName() string

func (*ListJobSpecificationRequest) ProtoMessage 

func (*ListJobSpecificationRequest) ProtoMessage()

func (*ListJobSpecificationRequest) ProtoReflect 

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

func (*ListJobSpecificationRequest) Reset 

func (x *ListJobSpecificationRequest) Reset()

func (*ListJobSpecificationRequest) String 

func (x *ListJobSpecificationRequest) String() string

type ListJobSpecificationResponse 

type ListJobSpecificationResponse struct {
	Jobs []*JobSpecification `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// contains filtered or unexported fields
}

func (*ListJobSpecificationResponse) Descriptor deprecated 

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

Deprecated: Use ListJobSpecificationResponse.ProtoReflect.Descriptor instead.

func (*ListJobSpecificationResponse) GetJobs 

func (x *ListJobSpecificationResponse) GetJobs() []*JobSpecification

func (*ListJobSpecificationResponse) ProtoMessage 

func (*ListJobSpecificationResponse) ProtoMessage()

func (*ListJobSpecificationResponse) ProtoReflect 

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

func (*ListJobSpecificationResponse) Reset 

func (x *ListJobSpecificationResponse) Reset()

func (*ListJobSpecificationResponse) String 

func (x *ListJobSpecificationResponse) String() string

type ListProjectNamespacesRequest 

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

func (*ListProjectNamespacesRequest) Descriptor deprecated 

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

Deprecated: Use ListProjectNamespacesRequest.ProtoReflect.Descriptor instead.

func (*ListProjectNamespacesRequest) GetProjectName 

func (x *ListProjectNamespacesRequest) GetProjectName() string

func (*ListProjectNamespacesRequest) ProtoMessage 

func (*ListProjectNamespacesRequest) ProtoMessage()

func (*ListProjectNamespacesRequest) ProtoReflect 

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

func (*ListProjectNamespacesRequest) Reset 

func (x *ListProjectNamespacesRequest) Reset()

func (*ListProjectNamespacesRequest) String 

func (x *ListProjectNamespacesRequest) String() string

type ListProjectNamespacesResponse 

type ListProjectNamespacesResponse struct {
	Namespaces []*NamespaceSpecification `protobuf:"bytes,1,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	// contains filtered or unexported fields
}

func (*ListProjectNamespacesResponse) Descriptor deprecated 

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

Deprecated: Use ListProjectNamespacesResponse.ProtoReflect.Descriptor instead.

func (*ListProjectNamespacesResponse) GetNamespaces 

func (x *ListProjectNamespacesResponse) GetNamespaces() []*NamespaceSpecification

func (*ListProjectNamespacesResponse) ProtoMessage 

func (*ListProjectNamespacesResponse) ProtoMessage()

func (*ListProjectNamespacesResponse) ProtoReflect 

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

func (*ListProjectNamespacesResponse) Reset 

func (x *ListProjectNamespacesResponse) Reset()

func (*ListProjectNamespacesResponse) String 

func (x *ListProjectNamespacesResponse) String() string

type ListProjectsRequest 

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

func (*ListProjectsRequest) Descriptor deprecated 

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

Deprecated: Use ListProjectsRequest.ProtoReflect.Descriptor instead.

func (*ListProjectsRequest) ProtoMessage 

func (*ListProjectsRequest) ProtoMessage()

func (*ListProjectsRequest) ProtoReflect 

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

func (*ListProjectsRequest) Reset 

func (x *ListProjectsRequest) Reset()

func (*ListProjectsRequest) String 

func (x *ListProjectsRequest) String() string

type ListProjectsResponse 

type ListProjectsResponse struct {
	Projects []*ProjectSpecification `protobuf:"bytes,1,rep,name=projects,proto3" json:"projects,omitempty"`
	// contains filtered or unexported fields
}

func (*ListProjectsResponse) Descriptor deprecated 

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

Deprecated: Use ListProjectsResponse.ProtoReflect.Descriptor instead.

func (*ListProjectsResponse) GetProjects 

func (x *ListProjectsResponse) GetProjects() []*ProjectSpecification

func (*ListProjectsResponse) ProtoMessage 

func (*ListProjectsResponse) ProtoMessage()

func (*ListProjectsResponse) ProtoReflect 

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

func (*ListProjectsResponse) Reset 

func (x *ListProjectsResponse) Reset()

func (*ListProjectsResponse) String 

func (x *ListProjectsResponse) String() string

type ListReplayRequest added in v0.7.0 

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

func (*ListReplayRequest) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use ListReplayRequest.ProtoReflect.Descriptor instead.

func (*ListReplayRequest) GetProjectName added in v0.7.0 

func (x *ListReplayRequest) GetProjectName() string

func (*ListReplayRequest) ProtoMessage added in v0.7.0 

func (*ListReplayRequest) ProtoMessage()

func (*ListReplayRequest) ProtoReflect added in v0.7.0 

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

func (*ListReplayRequest) Reset added in v0.7.0 

func (x *ListReplayRequest) Reset()

func (*ListReplayRequest) String added in v0.7.0 

func (x *ListReplayRequest) String() string

type ListReplayResponse added in v0.7.0 

type ListReplayResponse struct {
	Replays []*GetReplayResponse `protobuf:"bytes,1,rep,name=replays,proto3" json:"replays,omitempty"`
	// contains filtered or unexported fields
}

func (*ListReplayResponse) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use ListReplayResponse.ProtoReflect.Descriptor instead.

func (*ListReplayResponse) GetReplays added in v0.7.0 

func (x *ListReplayResponse) GetReplays() []*GetReplayResponse

func (*ListReplayResponse) ProtoMessage added in v0.7.0 

func (*ListReplayResponse) ProtoMessage()

func (*ListReplayResponse) ProtoReflect added in v0.7.0 

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

func (*ListReplayResponse) Reset added in v0.7.0 

func (x *ListReplayResponse) Reset()

func (*ListReplayResponse) String added in v0.7.0 

func (x *ListReplayResponse) String() string

type ListResourceSpecificationRequest 

type ListResourceSpecificationRequest struct {
	ProjectName   string `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	DatastoreName string `protobuf:"bytes,2,opt,name=datastore_name,json=datastoreName,proto3" json:"datastore_name,omitempty"`
	NamespaceName string `protobuf:"bytes,3,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	// contains filtered or unexported fields
}

ListResourceSpecificationRequest lists all resource specifications of a datastore in project

func (*ListResourceSpecificationRequest) Descriptor deprecated 

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

Deprecated: Use ListResourceSpecificationRequest.ProtoReflect.Descriptor instead.

func (*ListResourceSpecificationRequest) GetDatastoreName 

func (x *ListResourceSpecificationRequest) GetDatastoreName() string

func (*ListResourceSpecificationRequest) GetNamespaceName 

func (x *ListResourceSpecificationRequest) GetNamespaceName() string

func (*ListResourceSpecificationRequest) GetProjectName 

func (x *ListResourceSpecificationRequest) GetProjectName() string

func (*ListResourceSpecificationRequest) ProtoMessage 

func (*ListResourceSpecificationRequest) ProtoMessage()

func (*ListResourceSpecificationRequest) ProtoReflect 

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

func (*ListResourceSpecificationRequest) Reset 

func (x *ListResourceSpecificationRequest) Reset()

func (*ListResourceSpecificationRequest) String 

func (x *ListResourceSpecificationRequest) String() string

type ListResourceSpecificationResponse 

type ListResourceSpecificationResponse struct {
	Resources []*ResourceSpecification `protobuf:"bytes,1,rep,name=resources,proto3" json:"resources,omitempty"`
	// contains filtered or unexported fields
}

func (*ListResourceSpecificationResponse) Descriptor deprecated 

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

Deprecated: Use ListResourceSpecificationResponse.ProtoReflect.Descriptor instead.

func (*ListResourceSpecificationResponse) GetResources 

func (x *ListResourceSpecificationResponse) GetResources() []*ResourceSpecification

func (*ListResourceSpecificationResponse) ProtoMessage 

func (*ListResourceSpecificationResponse) ProtoMessage()

func (*ListResourceSpecificationResponse) ProtoReflect 

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

func (*ListResourceSpecificationResponse) Reset 

func (x *ListResourceSpecificationResponse) Reset()

func (*ListResourceSpecificationResponse) String 

func (x *ListResourceSpecificationResponse) String() string

type ListSecretsRequest 

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

func (*ListSecretsRequest) Descriptor deprecated 

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

Deprecated: Use ListSecretsRequest.ProtoReflect.Descriptor instead.

func (*ListSecretsRequest) GetProjectName 

func (x *ListSecretsRequest) GetProjectName() string

func (*ListSecretsRequest) ProtoMessage 

func (*ListSecretsRequest) ProtoMessage()

func (*ListSecretsRequest) ProtoReflect 

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

func (*ListSecretsRequest) Reset 

func (x *ListSecretsRequest) Reset()

func (*ListSecretsRequest) String 

func (x *ListSecretsRequest) String() string

type ListSecretsResponse 

type ListSecretsResponse struct {
	Secrets []*ListSecretsResponse_Secret `protobuf:"bytes,1,rep,name=secrets,proto3" json:"secrets,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSecretsResponse) Descriptor deprecated 

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

Deprecated: Use ListSecretsResponse.ProtoReflect.Descriptor instead.

func (*ListSecretsResponse) GetSecrets 

func (x *ListSecretsResponse) GetSecrets() []*ListSecretsResponse_Secret

func (*ListSecretsResponse) ProtoMessage 

func (*ListSecretsResponse) ProtoMessage()

func (*ListSecretsResponse) ProtoReflect 

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

func (*ListSecretsResponse) Reset 

func (x *ListSecretsResponse) Reset()

func (*ListSecretsResponse) String 

func (x *ListSecretsResponse) String() string

type ListSecretsResponse_Secret 

type ListSecretsResponse_Secret struct {
	Name      string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Digest    string                 `protobuf:"bytes,2,opt,name=digest,proto3" json:"digest,omitempty"`
	Namespace string                 `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSecretsResponse_Secret) Descriptor deprecated 

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

Deprecated: Use ListSecretsResponse_Secret.ProtoReflect.Descriptor instead.

func (*ListSecretsResponse_Secret) GetDigest 

func (x *ListSecretsResponse_Secret) GetDigest() string

func (*ListSecretsResponse_Secret) GetName 

func (x *ListSecretsResponse_Secret) GetName() string

func (*ListSecretsResponse_Secret) GetNamespace 

func (x *ListSecretsResponse_Secret) GetNamespace() string

func (*ListSecretsResponse_Secret) GetUpdatedAt 

func (x *ListSecretsResponse_Secret) GetUpdatedAt() *timestamppb.Timestamp

func (*ListSecretsResponse_Secret) ProtoMessage 

func (*ListSecretsResponse_Secret) ProtoMessage()

func (*ListSecretsResponse_Secret) ProtoReflect 

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

func (*ListSecretsResponse_Secret) Reset 

func (x *ListSecretsResponse_Secret) Reset()

func (*ListSecretsResponse_Secret) String 

func (x *ListSecretsResponse_Secret) String() string

type Log 

type Log struct {
	Level   Level  `protobuf:"varint,1,opt,name=level,proto3,enum=gotocompany.optimus.core.v1beta1.Level" json:"level,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Log) Descriptor deprecated 

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

Deprecated: Use Log.ProtoReflect.Descriptor instead.

func (*Log) GetLevel 

func (x *Log) GetLevel() Level

func (*Log) GetMessage 

func (x *Log) GetMessage() string

func (*Log) ProtoMessage 

func (*Log) ProtoMessage()

func (*Log) ProtoReflect 

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

func (*Log) Reset 

func (x *Log) Reset()

func (*Log) String 

func (x *Log) String() string

type NamespaceServiceClient 

type NamespaceServiceClient interface {
	// RegisterProjectNamespace creates a new namespace for a project
	RegisterProjectNamespace(ctx context.Context, in *RegisterProjectNamespaceRequest, opts ...grpc.CallOption) (*RegisterProjectNamespaceResponse, error)
	// ListProjectNamespaces returns list of namespaces of a project
	ListProjectNamespaces(ctx context.Context, in *ListProjectNamespacesRequest, opts ...grpc.CallOption) (*ListProjectNamespacesResponse, error)
	// GetNamespace returns namespace details based on project_name and namespace_name
	GetNamespace(ctx context.Context, in *GetNamespaceRequest, opts ...grpc.CallOption) (*GetNamespaceResponse, error)
}

NamespaceServiceClient is the client API for NamespaceService service.

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

func NewNamespaceServiceClient 

func NewNamespaceServiceClient(cc grpc.ClientConnInterface) NamespaceServiceClient

type NamespaceServiceServer 

type NamespaceServiceServer interface {
	// RegisterProjectNamespace creates a new namespace for a project
	RegisterProjectNamespace(context.Context, *RegisterProjectNamespaceRequest) (*RegisterProjectNamespaceResponse, error)
	// ListProjectNamespaces returns list of namespaces of a project
	ListProjectNamespaces(context.Context, *ListProjectNamespacesRequest) (*ListProjectNamespacesResponse, error)
	// GetNamespace returns namespace details based on project_name and namespace_name
	GetNamespace(context.Context, *GetNamespaceRequest) (*GetNamespaceResponse, error)
	// contains filtered or unexported methods
}

NamespaceServiceServer is the server API for NamespaceService service. All implementations must embed UnimplementedNamespaceServiceServer for forward compatibility

type NamespaceSpecification 

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

func (*NamespaceSpecification) Descriptor deprecated 

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

Deprecated: Use NamespaceSpecification.ProtoReflect.Descriptor instead.

func (*NamespaceSpecification) GetConfig 

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

func (*NamespaceSpecification) GetName 

func (x *NamespaceSpecification) GetName() string

func (*NamespaceSpecification) ProtoMessage 

func (*NamespaceSpecification) ProtoMessage()

func (*NamespaceSpecification) ProtoReflect 

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

func (*NamespaceSpecification) Reset 

func (x *NamespaceSpecification) Reset()

func (*NamespaceSpecification) String 

func (x *NamespaceSpecification) String() string

type ProjectServiceClient 

type ProjectServiceClient interface {
	// RegisterProject creates a new optimus project
	RegisterProject(ctx context.Context, in *RegisterProjectRequest, opts ...grpc.CallOption) (*RegisterProjectResponse, error)
	// ListProjects returns list of registered projects and configurations
	ListProjects(ctx context.Context, in *ListProjectsRequest, opts ...grpc.CallOption) (*ListProjectsResponse, error)
	// GetProject returns project details based on project_name
	GetProject(ctx context.Context, in *GetProjectRequest, opts ...grpc.CallOption) (*GetProjectResponse, error)
}

ProjectServiceClient is the client API for ProjectService service.

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

func NewProjectServiceClient 

func NewProjectServiceClient(cc grpc.ClientConnInterface) ProjectServiceClient

type ProjectServiceServer 

type ProjectServiceServer interface {
	// RegisterProject creates a new optimus project
	RegisterProject(context.Context, *RegisterProjectRequest) (*RegisterProjectResponse, error)
	// ListProjects returns list of registered projects and configurations
	ListProjects(context.Context, *ListProjectsRequest) (*ListProjectsResponse, error)
	// GetProject returns project details based on project_name
	GetProject(context.Context, *GetProjectRequest) (*GetProjectResponse, error)
	// contains filtered or unexported methods
}

ProjectServiceServer is the server API for ProjectService service. All implementations must embed UnimplementedProjectServiceServer for forward compatibility

type ProjectSpecification 

type ProjectSpecification struct {
	Name    string                                `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Config  map[string]string                     `` /* 153-byte string literal not displayed */
	Secrets []*ProjectSpecification_ProjectSecret `protobuf:"bytes,3,rep,name=secrets,proto3" json:"secrets,omitempty"`
	// contains filtered or unexported fields
}

func (*ProjectSpecification) Descriptor deprecated 

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

Deprecated: Use ProjectSpecification.ProtoReflect.Descriptor instead.

func (*ProjectSpecification) GetConfig 

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

func (*ProjectSpecification) GetName 

func (x *ProjectSpecification) GetName() string

func (*ProjectSpecification) GetSecrets 

func (x *ProjectSpecification) GetSecrets() []*ProjectSpecification_ProjectSecret

func (*ProjectSpecification) ProtoMessage 

func (*ProjectSpecification) ProtoMessage()

func (*ProjectSpecification) ProtoReflect 

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

func (*ProjectSpecification) Reset 

func (x *ProjectSpecification) Reset()

func (*ProjectSpecification) String 

func (x *ProjectSpecification) String() string

type ProjectSpecification_ProjectSecret 

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

func (*ProjectSpecification_ProjectSecret) Descriptor deprecated 

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

Deprecated: Use ProjectSpecification_ProjectSecret.ProtoReflect.Descriptor instead.

func (*ProjectSpecification_ProjectSecret) GetName 

func (x *ProjectSpecification_ProjectSecret) GetName() string

func (*ProjectSpecification_ProjectSecret) GetValue 

func (x *ProjectSpecification_ProjectSecret) GetValue() string

func (*ProjectSpecification_ProjectSecret) ProtoMessage 

func (*ProjectSpecification_ProjectSecret) ProtoMessage()

func (*ProjectSpecification_ProjectSecret) ProtoReflect 

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

func (*ProjectSpecification_ProjectSecret) Reset 

func (x *ProjectSpecification_ProjectSecret) Reset()

func (*ProjectSpecification_ProjectSecret) String 

func (x *ProjectSpecification_ProjectSecret) String() string

type ReadResourceRequest 

type ReadResourceRequest struct {
	ProjectName   string `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	DatastoreName string `protobuf:"bytes,2,opt,name=datastore_name,json=datastoreName,proto3" json:"datastore_name,omitempty"`
	ResourceName  string `protobuf:"bytes,3,opt,name=resource_name,json=resourceName,proto3" json:"resource_name,omitempty"`
	NamespaceName string `protobuf:"bytes,4,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadResourceRequest) Descriptor deprecated 

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

Deprecated: Use ReadResourceRequest.ProtoReflect.Descriptor instead.

func (*ReadResourceRequest) GetDatastoreName 

func (x *ReadResourceRequest) GetDatastoreName() string

func (*ReadResourceRequest) GetNamespaceName 

func (x *ReadResourceRequest) GetNamespaceName() string

func (*ReadResourceRequest) GetProjectName 

func (x *ReadResourceRequest) GetProjectName() string

func (*ReadResourceRequest) GetResourceName 

func (x *ReadResourceRequest) GetResourceName() string

func (*ReadResourceRequest) ProtoMessage 

func (*ReadResourceRequest) ProtoMessage()

func (*ReadResourceRequest) ProtoReflect 

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

func (*ReadResourceRequest) Reset 

func (x *ReadResourceRequest) Reset()

func (*ReadResourceRequest) String 

func (x *ReadResourceRequest) String() string

type ReadResourceResponse 

type ReadResourceResponse struct {
	Success  bool                   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Message  string                 `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Resource *ResourceSpecification `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadResourceResponse) Descriptor deprecated 

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

Deprecated: Use ReadResourceResponse.ProtoReflect.Descriptor instead.

func (*ReadResourceResponse) GetMessage 

func (x *ReadResourceResponse) GetMessage() string

func (*ReadResourceResponse) GetResource 

func (x *ReadResourceResponse) GetResource() *ResourceSpecification

func (*ReadResourceResponse) GetSuccess 

func (x *ReadResourceResponse) GetSuccess() bool

func (*ReadResourceResponse) ProtoMessage 

func (*ReadResourceResponse) ProtoMessage()

func (*ReadResourceResponse) ProtoReflect 

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

func (*ReadResourceResponse) Reset 

func (x *ReadResourceResponse) Reset()

func (*ReadResourceResponse) String 

func (x *ReadResourceResponse) String() string

type RefreshJobsRequest 

type RefreshJobsRequest struct {
	ProjectName    string   `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	NamespaceNames []string `protobuf:"bytes,2,rep,name=namespace_names,json=namespaceNames,proto3" json:"namespace_names,omitempty"`
	JobNames       []string `protobuf:"bytes,3,rep,name=job_names,json=jobNames,proto3" json:"job_names,omitempty"`
	// contains filtered or unexported fields
}

func (*RefreshJobsRequest) Descriptor deprecated 

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

Deprecated: Use RefreshJobsRequest.ProtoReflect.Descriptor instead.

func (*RefreshJobsRequest) GetJobNames 

func (x *RefreshJobsRequest) GetJobNames() []string

func (*RefreshJobsRequest) GetNamespaceNames 

func (x *RefreshJobsRequest) GetNamespaceNames() []string

func (*RefreshJobsRequest) GetProjectName 

func (x *RefreshJobsRequest) GetProjectName() string

func (*RefreshJobsRequest) ProtoMessage 

func (*RefreshJobsRequest) ProtoMessage()

func (*RefreshJobsRequest) ProtoReflect 

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

func (*RefreshJobsRequest) Reset 

func (x *RefreshJobsRequest) Reset()

func (*RefreshJobsRequest) String 

func (x *RefreshJobsRequest) String() string

type RefreshJobsResponse 

type RefreshJobsResponse struct {
	LogStatus *Log `protobuf:"bytes,6,opt,name=log_status,json=logStatus,proto3" json:"log_status,omitempty"`
	// contains filtered or unexported fields
}

func (*RefreshJobsResponse) Descriptor deprecated 

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

Deprecated: Use RefreshJobsResponse.ProtoReflect.Descriptor instead.

func (*RefreshJobsResponse) GetLogStatus 

func (x *RefreshJobsResponse) GetLogStatus() *Log

func (*RefreshJobsResponse) ProtoMessage 

func (*RefreshJobsResponse) ProtoMessage()

func (*RefreshJobsResponse) ProtoReflect 

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

func (*RefreshJobsResponse) Reset 

func (x *RefreshJobsResponse) Reset()

func (*RefreshJobsResponse) String 

func (x *RefreshJobsResponse) String() string

type RegisterJobEventRequest 

type RegisterJobEventRequest struct {
	ProjectName   string    `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	JobName       string    `protobuf:"bytes,2,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	NamespaceName string    `protobuf:"bytes,3,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	Event         *JobEvent `protobuf:"bytes,4,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterJobEventRequest) Descriptor deprecated 

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

Deprecated: Use RegisterJobEventRequest.ProtoReflect.Descriptor instead.

func (*RegisterJobEventRequest) GetEvent 

func (x *RegisterJobEventRequest) GetEvent() *JobEvent

func (*RegisterJobEventRequest) GetJobName 

func (x *RegisterJobEventRequest) GetJobName() string

func (*RegisterJobEventRequest) GetNamespaceName 

func (x *RegisterJobEventRequest) GetNamespaceName() string

func (*RegisterJobEventRequest) GetProjectName 

func (x *RegisterJobEventRequest) GetProjectName() string

func (*RegisterJobEventRequest) ProtoMessage 

func (*RegisterJobEventRequest) ProtoMessage()

func (*RegisterJobEventRequest) ProtoReflect 

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

func (*RegisterJobEventRequest) Reset 

func (x *RegisterJobEventRequest) Reset()

func (*RegisterJobEventRequest) String 

func (x *RegisterJobEventRequest) String() string

type RegisterJobEventResponse 

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

func (*RegisterJobEventResponse) Descriptor deprecated 

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

Deprecated: Use RegisterJobEventResponse.ProtoReflect.Descriptor instead.

func (*RegisterJobEventResponse) ProtoMessage 

func (*RegisterJobEventResponse) ProtoMessage()

func (*RegisterJobEventResponse) ProtoReflect 

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

func (*RegisterJobEventResponse) Reset 

func (x *RegisterJobEventResponse) Reset()

func (*RegisterJobEventResponse) String 

func (x *RegisterJobEventResponse) String() string

type RegisterProjectNamespaceRequest 

type RegisterProjectNamespaceRequest struct {
	ProjectName string                  `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	Namespace   *NamespaceSpecification `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterProjectNamespaceRequest) Descriptor deprecated 

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

Deprecated: Use RegisterProjectNamespaceRequest.ProtoReflect.Descriptor instead.

func (*RegisterProjectNamespaceRequest) GetNamespace 

func (x *RegisterProjectNamespaceRequest) GetNamespace() *NamespaceSpecification

func (*RegisterProjectNamespaceRequest) GetProjectName 

func (x *RegisterProjectNamespaceRequest) GetProjectName() string

func (*RegisterProjectNamespaceRequest) ProtoMessage 

func (*RegisterProjectNamespaceRequest) ProtoMessage()

func (*RegisterProjectNamespaceRequest) ProtoReflect 

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

func (*RegisterProjectNamespaceRequest) Reset 

func (x *RegisterProjectNamespaceRequest) Reset()

func (*RegisterProjectNamespaceRequest) String 

func (x *RegisterProjectNamespaceRequest) String() string

type RegisterProjectNamespaceResponse 

type RegisterProjectNamespaceResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterProjectNamespaceResponse) Descriptor deprecated 

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

Deprecated: Use RegisterProjectNamespaceResponse.ProtoReflect.Descriptor instead.

func (*RegisterProjectNamespaceResponse) GetMessage 

func (x *RegisterProjectNamespaceResponse) GetMessage() string

func (*RegisterProjectNamespaceResponse) GetSuccess 

func (x *RegisterProjectNamespaceResponse) GetSuccess() bool

func (*RegisterProjectNamespaceResponse) ProtoMessage 

func (*RegisterProjectNamespaceResponse) ProtoMessage()

func (*RegisterProjectNamespaceResponse) ProtoReflect 

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

func (*RegisterProjectNamespaceResponse) Reset 

func (x *RegisterProjectNamespaceResponse) Reset()

func (*RegisterProjectNamespaceResponse) String 

func (x *RegisterProjectNamespaceResponse) String() string

type RegisterProjectRequest 

type RegisterProjectRequest struct {
	Project *ProjectSpecification `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterProjectRequest) Descriptor deprecated 

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

Deprecated: Use RegisterProjectRequest.ProtoReflect.Descriptor instead.

func (*RegisterProjectRequest) GetProject 

func (x *RegisterProjectRequest) GetProject() *ProjectSpecification

func (*RegisterProjectRequest) ProtoMessage 

func (*RegisterProjectRequest) ProtoMessage()

func (*RegisterProjectRequest) ProtoReflect 

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

func (*RegisterProjectRequest) Reset 

func (x *RegisterProjectRequest) Reset()

func (*RegisterProjectRequest) String 

func (x *RegisterProjectRequest) String() string

type RegisterProjectResponse 

type RegisterProjectResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterProjectResponse) Descriptor deprecated 

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

Deprecated: Use RegisterProjectResponse.ProtoReflect.Descriptor instead.

func (*RegisterProjectResponse) GetMessage 

func (x *RegisterProjectResponse) GetMessage() string

func (*RegisterProjectResponse) GetSuccess 

func (x *RegisterProjectResponse) GetSuccess() bool

func (*RegisterProjectResponse) ProtoMessage 

func (*RegisterProjectResponse) ProtoMessage()

func (*RegisterProjectResponse) ProtoReflect 

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

func (*RegisterProjectResponse) Reset 

func (x *RegisterProjectResponse) Reset()

func (*RegisterProjectResponse) String 

func (x *RegisterProjectResponse) String() string

type RegisterSecretRequest 

type RegisterSecretRequest struct {
	ProjectName   string `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	SecretName    string `protobuf:"bytes,2,opt,name=secret_name,json=secretName,proto3" json:"secret_name,omitempty"`
	Value         string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` // base64 encoded secret value
	NamespaceName string `protobuf:"bytes,4,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterSecretRequest) Descriptor deprecated 

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

Deprecated: Use RegisterSecretRequest.ProtoReflect.Descriptor instead.

func (*RegisterSecretRequest) GetNamespaceName 

func (x *RegisterSecretRequest) GetNamespaceName() string

func (*RegisterSecretRequest) GetProjectName 

func (x *RegisterSecretRequest) GetProjectName() string

func (*RegisterSecretRequest) GetSecretName 

func (x *RegisterSecretRequest) GetSecretName() string

func (*RegisterSecretRequest) GetValue 

func (x *RegisterSecretRequest) GetValue() string

func (*RegisterSecretRequest) ProtoMessage 

func (*RegisterSecretRequest) ProtoMessage()

func (*RegisterSecretRequest) ProtoReflect 

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

func (*RegisterSecretRequest) Reset 

func (x *RegisterSecretRequest) Reset()

func (*RegisterSecretRequest) String 

func (x *RegisterSecretRequest) String() string

type RegisterSecretResponse 

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

func (*RegisterSecretResponse) Descriptor deprecated 

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

Deprecated: Use RegisterSecretResponse.ProtoReflect.Descriptor instead.

func (*RegisterSecretResponse) ProtoMessage 

func (*RegisterSecretResponse) ProtoMessage()

func (*RegisterSecretResponse) ProtoReflect 

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

func (*RegisterSecretResponse) Reset 

func (x *RegisterSecretResponse) Reset()

func (*RegisterSecretResponse) String 

func (x *RegisterSecretResponse) String() string

type ReplaceAllJobSpecificationsRequest 

type ReplaceAllJobSpecificationsRequest struct {
	ProjectName   string              `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	NamespaceName string              `protobuf:"bytes,2,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	Jobs          []*JobSpecification `protobuf:"bytes,3,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceAllJobSpecificationsRequest) Descriptor deprecated 

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

Deprecated: Use ReplaceAllJobSpecificationsRequest.ProtoReflect.Descriptor instead.

func (*ReplaceAllJobSpecificationsRequest) GetJobs 

func (x *ReplaceAllJobSpecificationsRequest) GetJobs() []*JobSpecification

func (*ReplaceAllJobSpecificationsRequest) GetNamespaceName 

func (x *ReplaceAllJobSpecificationsRequest) GetNamespaceName() string

func (*ReplaceAllJobSpecificationsRequest) GetProjectName 

func (x *ReplaceAllJobSpecificationsRequest) GetProjectName() string

func (*ReplaceAllJobSpecificationsRequest) ProtoMessage 

func (*ReplaceAllJobSpecificationsRequest) ProtoMessage()

func (*ReplaceAllJobSpecificationsRequest) ProtoReflect 

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

func (*ReplaceAllJobSpecificationsRequest) Reset 

func (x *ReplaceAllJobSpecificationsRequest) Reset()

func (*ReplaceAllJobSpecificationsRequest) String 

func (x *ReplaceAllJobSpecificationsRequest) String() string

type ReplaceAllJobSpecificationsResponse 

type ReplaceAllJobSpecificationsResponse struct {
	LogStatus *Log `protobuf:"bytes,1,opt,name=log_status,json=logStatus,proto3" json:"log_status,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceAllJobSpecificationsResponse) Descriptor deprecated 

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

Deprecated: Use ReplaceAllJobSpecificationsResponse.ProtoReflect.Descriptor instead.

func (*ReplaceAllJobSpecificationsResponse) GetLogStatus 

func (x *ReplaceAllJobSpecificationsResponse) GetLogStatus() *Log

func (*ReplaceAllJobSpecificationsResponse) ProtoMessage 

func (*ReplaceAllJobSpecificationsResponse) ProtoMessage()

func (*ReplaceAllJobSpecificationsResponse) ProtoReflect 

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

func (*ReplaceAllJobSpecificationsResponse) Reset 

func (x *ReplaceAllJobSpecificationsResponse) Reset()

func (*ReplaceAllJobSpecificationsResponse) String 

func (x *ReplaceAllJobSpecificationsResponse) String() string

type ReplayConfig added in v0.7.0 

type ReplayConfig struct {
	StartTime   *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime     *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	Parallel    bool                   `protobuf:"varint,3,opt,name=parallel,proto3" json:"parallel,omitempty"`
	JobConfig   map[string]string      `` /* 176-byte string literal not displayed */
	Description string                 `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplayConfig) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use ReplayConfig.ProtoReflect.Descriptor instead.

func (*ReplayConfig) GetDescription added in v0.7.0 

func (x *ReplayConfig) GetDescription() string

func (*ReplayConfig) GetEndTime added in v0.7.0 

func (x *ReplayConfig) GetEndTime() *timestamppb.Timestamp

func (*ReplayConfig) GetJobConfig added in v0.7.0 

func (x *ReplayConfig) GetJobConfig() map[string]string

func (*ReplayConfig) GetParallel added in v0.7.0 

func (x *ReplayConfig) GetParallel() bool

func (*ReplayConfig) GetStartTime added in v0.7.0 

func (x *ReplayConfig) GetStartTime() *timestamppb.Timestamp

func (*ReplayConfig) ProtoMessage added in v0.7.0 

func (*ReplayConfig) ProtoMessage()

func (*ReplayConfig) ProtoReflect added in v0.7.0 

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

func (*ReplayConfig) Reset added in v0.7.0 

func (x *ReplayConfig) Reset()

func (*ReplayConfig) String added in v0.7.0 

func (x *ReplayConfig) String() string

type ReplayDryRunRequest 

type ReplayDryRunRequest struct {
	ProjectName   string                 `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	JobName       string                 `protobuf:"bytes,2,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	NamespaceName string                 `protobuf:"bytes,3,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	StartTime     *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime       *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	Parallel      bool                   `protobuf:"varint,6,opt,name=parallel,proto3" json:"parallel,omitempty"`
	Description   string                 `protobuf:"bytes,7,opt,name=description,proto3" json:"description,omitempty"`
	JobConfig     string                 `protobuf:"bytes,8,opt,name=job_config,json=jobConfig,proto3" json:"job_config,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplayDryRunRequest) Descriptor deprecated 

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

Deprecated: Use ReplayDryRunRequest.ProtoReflect.Descriptor instead.

func (*ReplayDryRunRequest) GetDescription added in v0.9.0 

func (x *ReplayDryRunRequest) GetDescription() string

func (*ReplayDryRunRequest) GetEndTime added in v0.9.0 

func (x *ReplayDryRunRequest) GetEndTime() *timestamppb.Timestamp

func (*ReplayDryRunRequest) GetJobConfig added in v0.9.0 

func (x *ReplayDryRunRequest) GetJobConfig() string

func (*ReplayDryRunRequest) GetJobName 

func (x *ReplayDryRunRequest) GetJobName() string

func (*ReplayDryRunRequest) GetNamespaceName 

func (x *ReplayDryRunRequest) GetNamespaceName() string

func (*ReplayDryRunRequest) GetParallel added in v0.9.0 

func (x *ReplayDryRunRequest) GetParallel() bool

func (*ReplayDryRunRequest) GetProjectName 

func (x *ReplayDryRunRequest) GetProjectName() string

func (*ReplayDryRunRequest) GetStartTime added in v0.9.0 

func (x *ReplayDryRunRequest) GetStartTime() *timestamppb.Timestamp

func (*ReplayDryRunRequest) ProtoMessage 

func (*ReplayDryRunRequest) ProtoMessage()

func (*ReplayDryRunRequest) ProtoReflect 

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

func (*ReplayDryRunRequest) Reset 

func (x *ReplayDryRunRequest) Reset()

func (*ReplayDryRunRequest) String 

func (x *ReplayDryRunRequest) String() string

type ReplayDryRunResponse 

type ReplayDryRunResponse struct {
	ReplayRuns []*ReplayRun `protobuf:"bytes,1,rep,name=replay_runs,json=replayRuns,proto3" json:"replay_runs,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplayDryRunResponse) Descriptor deprecated 

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

Deprecated: Use ReplayDryRunResponse.ProtoReflect.Descriptor instead.

func (*ReplayDryRunResponse) GetReplayRuns added in v0.9.0 

func (x *ReplayDryRunResponse) GetReplayRuns() []*ReplayRun

func (*ReplayDryRunResponse) ProtoMessage 

func (*ReplayDryRunResponse) ProtoMessage()

func (*ReplayDryRunResponse) ProtoReflect 

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

func (*ReplayDryRunResponse) Reset 

func (x *ReplayDryRunResponse) Reset()

func (*ReplayDryRunResponse) String 

func (x *ReplayDryRunResponse) String() string

type ReplayRequest 

type ReplayRequest struct {
	ProjectName   string                 `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	JobName       string                 `protobuf:"bytes,2,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	NamespaceName string                 `protobuf:"bytes,3,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	StartTime     *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime       *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	Parallel      bool                   `protobuf:"varint,6,opt,name=parallel,proto3" json:"parallel,omitempty"`
	Description   string                 `protobuf:"bytes,7,opt,name=description,proto3" json:"description,omitempty"`
	JobConfig     string                 `protobuf:"bytes,8,opt,name=job_config,json=jobConfig,proto3" json:"job_config,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplayRequest) Descriptor deprecated 

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

Deprecated: Use ReplayRequest.ProtoReflect.Descriptor instead.

func (*ReplayRequest) GetDescription added in v0.7.0 

func (x *ReplayRequest) GetDescription() string

func (*ReplayRequest) GetEndTime added in v0.7.0 

func (x *ReplayRequest) GetEndTime() *timestamppb.Timestamp

func (*ReplayRequest) GetJobConfig added in v0.7.0 

func (x *ReplayRequest) GetJobConfig() string

func (*ReplayRequest) GetJobName 

func (x *ReplayRequest) GetJobName() string

func (*ReplayRequest) GetNamespaceName 

func (x *ReplayRequest) GetNamespaceName() string

func (*ReplayRequest) GetParallel added in v0.7.0 

func (x *ReplayRequest) GetParallel() bool

func (*ReplayRequest) GetProjectName 

func (x *ReplayRequest) GetProjectName() string

func (*ReplayRequest) GetStartTime added in v0.7.0 

func (x *ReplayRequest) GetStartTime() *timestamppb.Timestamp

func (*ReplayRequest) ProtoMessage 

func (*ReplayRequest) ProtoMessage()

func (*ReplayRequest) ProtoReflect 

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

func (*ReplayRequest) Reset 

func (x *ReplayRequest) Reset()

func (*ReplayRequest) String 

func (x *ReplayRequest) String() string

type ReplayResponse 

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

func (*ReplayResponse) Descriptor deprecated 

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

Deprecated: Use ReplayResponse.ProtoReflect.Descriptor instead.

func (*ReplayResponse) GetId 

func (x *ReplayResponse) GetId() string

func (*ReplayResponse) ProtoMessage 

func (*ReplayResponse) ProtoMessage()

func (*ReplayResponse) ProtoReflect 

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

func (*ReplayResponse) Reset 

func (x *ReplayResponse) Reset()

func (*ReplayResponse) String 

func (x *ReplayResponse) String() string

type ReplayRun added in v0.7.0 

type ReplayRun struct {
	ScheduledAt *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=scheduled_at,json=scheduledAt,proto3" json:"scheduled_at,omitempty"`
	Status      string                 `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplayRun) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use ReplayRun.ProtoReflect.Descriptor instead.

func (*ReplayRun) GetScheduledAt added in v0.7.0 

func (x *ReplayRun) GetScheduledAt() *timestamppb.Timestamp

func (*ReplayRun) GetStatus added in v0.7.0 

func (x *ReplayRun) GetStatus() string

func (*ReplayRun) ProtoMessage added in v0.7.0 

func (*ReplayRun) ProtoMessage()

func (*ReplayRun) ProtoReflect added in v0.7.0 

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

func (*ReplayRun) Reset added in v0.7.0 

func (x *ReplayRun) Reset()

func (*ReplayRun) String added in v0.7.0 

func (x *ReplayRun) String() string

type ReplayServiceClient 

type ReplayServiceClient interface {
	Replay(ctx context.Context, in *ReplayRequest, opts ...grpc.CallOption) (*ReplayResponse, error)
	ReplayDryRun(ctx context.Context, in *ReplayDryRunRequest, opts ...grpc.CallOption) (*ReplayDryRunResponse, error)
	ListReplay(ctx context.Context, in *ListReplayRequest, opts ...grpc.CallOption) (*ListReplayResponse, error)
	GetReplay(ctx context.Context, in *GetReplayRequest, opts ...grpc.CallOption) (*GetReplayResponse, error)
}

ReplayServiceClient is the client API for ReplayService service.

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

func NewReplayServiceClient 

func NewReplayServiceClient(cc grpc.ClientConnInterface) ReplayServiceClient

type ReplayServiceServer 

type ReplayServiceServer interface {
	Replay(context.Context, *ReplayRequest) (*ReplayResponse, error)
	ReplayDryRun(context.Context, *ReplayDryRunRequest) (*ReplayDryRunResponse, error)
	ListReplay(context.Context, *ListReplayRequest) (*ListReplayResponse, error)
	GetReplay(context.Context, *GetReplayRequest) (*GetReplayResponse, error)
	// contains filtered or unexported methods
}

ReplayServiceServer is the server API for ReplayService service. All implementations must embed UnimplementedReplayServiceServer for forward compatibility

type ResourceServiceClient 

type ResourceServiceClient interface {
	// DeployResourceSpecification migrate all resource specifications of a datastore in project
	// State of the world request
	DeployResourceSpecification(ctx context.Context, opts ...grpc.CallOption) (ResourceService_DeployResourceSpecificationClient, error)
	// ListResourceSpecification lists all resource specifications of a datastore in project
	ListResourceSpecification(ctx context.Context, in *ListResourceSpecificationRequest, opts ...grpc.CallOption) (*ListResourceSpecificationResponse, error)
	// Database CRUD
	// CreateResource registers a new resource of a namespace which belongs to a project
	CreateResource(ctx context.Context, in *CreateResourceRequest, opts ...grpc.CallOption) (*CreateResourceResponse, error)
	// ReadResource reads a provided resource spec of a namespace
	ReadResource(ctx context.Context, in *ReadResourceRequest, opts ...grpc.CallOption) (*ReadResourceResponse, error)
	// UpdateResource updates a resource specification of a datastore in project
	UpdateResource(ctx context.Context, in *UpdateResourceRequest, opts ...grpc.CallOption) (*UpdateResourceResponse, error)
	// ChangeJobNamespace move a job spec from one namespace to another
	ChangeResourceNamespace(ctx context.Context, in *ChangeResourceNamespaceRequest, opts ...grpc.CallOption) (*ChangeResourceNamespaceResponse, error)
	// apply a resource from optimus to datastore
	ApplyResources(ctx context.Context, in *ApplyResourcesRequest, opts ...grpc.CallOption) (*ApplyResourcesResponse, error)
}

ResourceServiceClient is the client API for ResourceService service.

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

func NewResourceServiceClient 

func NewResourceServiceClient(cc grpc.ClientConnInterface) ResourceServiceClient

type ResourceServiceServer 

type ResourceServiceServer interface {
	// DeployResourceSpecification migrate all resource specifications of a datastore in project
	// State of the world request
	DeployResourceSpecification(ResourceService_DeployResourceSpecificationServer) error
	// ListResourceSpecification lists all resource specifications of a datastore in project
	ListResourceSpecification(context.Context, *ListResourceSpecificationRequest) (*ListResourceSpecificationResponse, error)
	// Database CRUD
	// CreateResource registers a new resource of a namespace which belongs to a project
	CreateResource(context.Context, *CreateResourceRequest) (*CreateResourceResponse, error)
	// ReadResource reads a provided resource spec of a namespace
	ReadResource(context.Context, *ReadResourceRequest) (*ReadResourceResponse, error)
	// UpdateResource updates a resource specification of a datastore in project
	UpdateResource(context.Context, *UpdateResourceRequest) (*UpdateResourceResponse, error)
	// ChangeJobNamespace move a job spec from one namespace to another
	ChangeResourceNamespace(context.Context, *ChangeResourceNamespaceRequest) (*ChangeResourceNamespaceResponse, error)
	// apply a resource from optimus to datastore
	ApplyResources(context.Context, *ApplyResourcesRequest) (*ApplyResourcesResponse, error)
	// contains filtered or unexported methods
}

ResourceServiceServer is the server API for ResourceService service. All implementations must embed UnimplementedResourceServiceServer for forward compatibility

type ResourceService_DeployResourceSpecificationClient 

type ResourceService_DeployResourceSpecificationClient interface {
	Send(*DeployResourceSpecificationRequest) error
	Recv() (*DeployResourceSpecificationResponse, error)
	grpc.ClientStream
}

type ResourceService_DeployResourceSpecificationServer 

type ResourceService_DeployResourceSpecificationServer interface {
	Send(*DeployResourceSpecificationResponse) error
	Recv() (*DeployResourceSpecificationRequest, error)
	grpc.ServerStream
}

type ResourceSpecification 

type ResourceSpecification struct {
	Version int32             `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	Name    string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Type    string            `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	Spec    *structpb.Struct  `protobuf:"bytes,5,opt,name=spec,proto3" json:"spec,omitempty"`
	Assets  map[string]string `` /* 153-byte string literal not displayed */
	Labels  map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

ResourceSpecification are datastore specification representation of a resource

func (*ResourceSpecification) Descriptor deprecated 

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

Deprecated: Use ResourceSpecification.ProtoReflect.Descriptor instead.

func (*ResourceSpecification) GetAssets 

func (x *ResourceSpecification) GetAssets() map[string]string

func (*ResourceSpecification) GetLabels 

func (x *ResourceSpecification) GetLabels() map[string]string

func (*ResourceSpecification) GetName 

func (x *ResourceSpecification) GetName() string

func (*ResourceSpecification) GetSpec 

func (x *ResourceSpecification) GetSpec() *structpb.Struct

func (*ResourceSpecification) GetType 

func (x *ResourceSpecification) GetType() string

func (*ResourceSpecification) GetVersion 

func (x *ResourceSpecification) GetVersion() int32

func (*ResourceSpecification) ProtoMessage 

func (*ResourceSpecification) ProtoMessage()

func (*ResourceSpecification) ProtoReflect 

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

func (*ResourceSpecification) Reset 

func (x *ResourceSpecification) Reset()

func (*ResourceSpecification) String 

func (x *ResourceSpecification) String() string

type RuntimeServiceClient 

type RuntimeServiceClient interface {
	// server ping with version
	Version(ctx context.Context, in *VersionRequest, opts ...grpc.CallOption) (*VersionResponse, error)
}

RuntimeServiceClient is the client API for RuntimeService service.

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

func NewRuntimeServiceClient 

func NewRuntimeServiceClient(cc grpc.ClientConnInterface) RuntimeServiceClient

type RuntimeServiceServer 

type RuntimeServiceServer interface {
	// server ping with version
	Version(context.Context, *VersionRequest) (*VersionResponse, error)
	// contains filtered or unexported methods
}

RuntimeServiceServer is the server API for RuntimeService service. All implementations must embed UnimplementedRuntimeServiceServer for forward compatibility

type SecretServiceClient 

type SecretServiceClient interface {
	// RegisterSecret creates a new secret of a project
	RegisterSecret(ctx context.Context, in *RegisterSecretRequest, opts ...grpc.CallOption) (*RegisterSecretResponse, error)
	// UpdateSecret updates secret at project level
	UpdateSecret(ctx context.Context, in *UpdateSecretRequest, opts ...grpc.CallOption) (*UpdateSecretResponse, error)
	// ListSecrets shows the secrets registered for a project
	ListSecrets(ctx context.Context, in *ListSecretsRequest, opts ...grpc.CallOption) (*ListSecretsResponse, error)
	// DeleteSecret deletes a secret for a project
	DeleteSecret(ctx context.Context, in *DeleteSecretRequest, opts ...grpc.CallOption) (*DeleteSecretResponse, error)
}

SecretServiceClient is the client API for SecretService service.

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

func NewSecretServiceClient 

func NewSecretServiceClient(cc grpc.ClientConnInterface) SecretServiceClient

type SecretServiceServer 

type SecretServiceServer interface {
	// RegisterSecret creates a new secret of a project
	RegisterSecret(context.Context, *RegisterSecretRequest) (*RegisterSecretResponse, error)
	// UpdateSecret updates secret at project level
	UpdateSecret(context.Context, *UpdateSecretRequest) (*UpdateSecretResponse, error)
	// ListSecrets shows the secrets registered for a project
	ListSecrets(context.Context, *ListSecretsRequest) (*ListSecretsResponse, error)
	// DeleteSecret deletes a secret for a project
	DeleteSecret(context.Context, *DeleteSecretRequest) (*DeleteSecretResponse, error)
	// contains filtered or unexported methods
}

SecretServiceServer is the server API for SecretService service. All implementations must embed UnimplementedSecretServiceServer for forward compatibility

type SyncJobsStateRequest added in v0.9.0 

type SyncJobsStateRequest struct {
	ProjectName   string                               `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	NamespaceName string                               `protobuf:"bytes,2,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	JobStates     []*SyncJobsStateRequest_JobStatePair `protobuf:"bytes,3,rep,name=job_states,json=jobStates,proto3" json:"job_states,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncJobsStateRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use SyncJobsStateRequest.ProtoReflect.Descriptor instead.

func (*SyncJobsStateRequest) GetJobStates added in v0.9.0 

func (x *SyncJobsStateRequest) GetJobStates() []*SyncJobsStateRequest_JobStatePair

func (*SyncJobsStateRequest) GetNamespaceName added in v0.9.0 

func (x *SyncJobsStateRequest) GetNamespaceName() string

func (*SyncJobsStateRequest) GetProjectName added in v0.9.0 

func (x *SyncJobsStateRequest) GetProjectName() string

func (*SyncJobsStateRequest) ProtoMessage added in v0.9.0 

func (*SyncJobsStateRequest) ProtoMessage()

func (*SyncJobsStateRequest) ProtoReflect added in v0.9.0 

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

func (*SyncJobsStateRequest) Reset added in v0.9.0 

func (x *SyncJobsStateRequest) Reset()

func (*SyncJobsStateRequest) String added in v0.9.0 

func (x *SyncJobsStateRequest) String() string

type SyncJobsStateRequest_JobStatePair added in v0.9.0 

type SyncJobsStateRequest_JobStatePair struct {
	JobName string   `protobuf:"bytes,1,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	State   JobState `protobuf:"varint,2,opt,name=state,proto3,enum=gotocompany.optimus.core.v1beta1.JobState" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncJobsStateRequest_JobStatePair) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use SyncJobsStateRequest_JobStatePair.ProtoReflect.Descriptor instead.

func (*SyncJobsStateRequest_JobStatePair) GetJobName added in v0.9.0 

func (x *SyncJobsStateRequest_JobStatePair) GetJobName() string

func (*SyncJobsStateRequest_JobStatePair) GetState added in v0.9.0 

func (x *SyncJobsStateRequest_JobStatePair) GetState() JobState

func (*SyncJobsStateRequest_JobStatePair) ProtoMessage added in v0.9.0 

func (*SyncJobsStateRequest_JobStatePair) ProtoMessage()

func (*SyncJobsStateRequest_JobStatePair) ProtoReflect added in v0.9.0 

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

func (*SyncJobsStateRequest_JobStatePair) Reset added in v0.9.0 

func (x *SyncJobsStateRequest_JobStatePair) Reset()

func (*SyncJobsStateRequest_JobStatePair) String added in v0.9.0 

func (x *SyncJobsStateRequest_JobStatePair) String() string

type SyncJobsStateResponse added in v0.9.0 

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

func (*SyncJobsStateResponse) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use SyncJobsStateResponse.ProtoReflect.Descriptor instead.

func (*SyncJobsStateResponse) ProtoMessage added in v0.9.0 

func (*SyncJobsStateResponse) ProtoMessage()

func (*SyncJobsStateResponse) ProtoReflect added in v0.9.0 

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

func (*SyncJobsStateResponse) Reset added in v0.9.0 

func (x *SyncJobsStateResponse) Reset()

func (*SyncJobsStateResponse) String added in v0.9.0 

func (x *SyncJobsStateResponse) String() string

type TaskWindow 

type TaskWindow struct {
	Size       *durationpb.Duration `protobuf:"bytes,1,opt,name=size,proto3" json:"size,omitempty"`
	Offset     *durationpb.Duration `protobuf:"bytes,2,opt,name=offset,proto3" json:"offset,omitempty"`
	TruncateTo string               `protobuf:"bytes,3,opt,name=truncate_to,json=truncateTo,proto3" json:"truncate_to,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskWindow) Descriptor deprecated 

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

Deprecated: Use TaskWindow.ProtoReflect.Descriptor instead.

func (*TaskWindow) GetOffset 

func (x *TaskWindow) GetOffset() *durationpb.Duration

func (*TaskWindow) GetSize 

func (x *TaskWindow) GetSize() *durationpb.Duration

func (*TaskWindow) GetTruncateTo 

func (x *TaskWindow) GetTruncateTo() string

func (*TaskWindow) ProtoMessage 

func (*TaskWindow) ProtoMessage()

func (*TaskWindow) ProtoReflect 

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

func (*TaskWindow) Reset 

func (x *TaskWindow) Reset()

func (*TaskWindow) String 

func (x *TaskWindow) String() string

type UnimplementedBackupServiceServer 

type UnimplementedBackupServiceServer struct {
}

UnimplementedBackupServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedBackupServiceServer) CreateBackup 

func (UnimplementedBackupServiceServer) CreateBackup(context.Context, *CreateBackupRequest) (*CreateBackupResponse, error)

func (UnimplementedBackupServiceServer) GetBackup 

func (UnimplementedBackupServiceServer) GetBackup(context.Context, *GetBackupRequest) (*GetBackupResponse, error)

func (UnimplementedBackupServiceServer) ListBackups 

func (UnimplementedBackupServiceServer) ListBackups(context.Context, *ListBackupsRequest) (*ListBackupsResponse, error)

type UnimplementedJobRunServiceServer 

type UnimplementedJobRunServiceServer struct {
}

UnimplementedJobRunServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedJobRunServiceServer) JobRun 

func (UnimplementedJobRunServiceServer) JobRun(context.Context, *JobRunRequest) (*JobRunResponse, error)

func (UnimplementedJobRunServiceServer) JobRunInput 

func (UnimplementedJobRunServiceServer) JobRunInput(context.Context, *JobRunInputRequest) (*JobRunInputResponse, error)

func (UnimplementedJobRunServiceServer) RegisterJobEvent 

func (UnimplementedJobRunServiceServer) RegisterJobEvent(context.Context, *RegisterJobEventRequest) (*RegisterJobEventResponse, error)

func (UnimplementedJobRunServiceServer) UploadToScheduler 

func (UnimplementedJobRunServiceServer) UploadToScheduler(context.Context, *UploadToSchedulerRequest) (*UploadToSchedulerResponse, error)

type UnimplementedJobSpecificationServiceServer 

type UnimplementedJobSpecificationServiceServer struct {
}

UnimplementedJobSpecificationServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedJobSpecificationServiceServer) AddJobSpecifications 

func (UnimplementedJobSpecificationServiceServer) AddJobSpecifications(context.Context, *AddJobSpecificationsRequest) (*AddJobSpecificationsResponse, error)

func (UnimplementedJobSpecificationServiceServer) ChangeJobNamespace added in v0.8.0 

func (UnimplementedJobSpecificationServiceServer) ChangeJobNamespace(context.Context, *ChangeJobNamespaceRequest) (*ChangeJobNamespaceResponse, error)

func (UnimplementedJobSpecificationServiceServer) CheckJobSpecification 

func (UnimplementedJobSpecificationServiceServer) CheckJobSpecification(context.Context, *CheckJobSpecificationRequest) (*CheckJobSpecificationResponse, error)

func (UnimplementedJobSpecificationServiceServer) CheckJobSpecifications 

func (UnimplementedJobSpecificationServiceServer) CheckJobSpecifications(*CheckJobSpecificationsRequest, JobSpecificationService_CheckJobSpecificationsServer) error

func (UnimplementedJobSpecificationServiceServer) CreateJobSpecification 

func (UnimplementedJobSpecificationServiceServer) CreateJobSpecification(context.Context, *CreateJobSpecificationRequest) (*CreateJobSpecificationResponse, error)

func (UnimplementedJobSpecificationServiceServer) DeleteJobSpecification 

func (UnimplementedJobSpecificationServiceServer) DeleteJobSpecification(context.Context, *DeleteJobSpecificationRequest) (*DeleteJobSpecificationResponse, error)

func (UnimplementedJobSpecificationServiceServer) DeployJobSpecification 

func (UnimplementedJobSpecificationServiceServer) DeployJobSpecification(JobSpecificationService_DeployJobSpecificationServer) error

func (UnimplementedJobSpecificationServiceServer) GetDeployJobsStatus 

func (UnimplementedJobSpecificationServiceServer) GetDeployJobsStatus(context.Context, *GetDeployJobsStatusRequest) (*GetDeployJobsStatusResponse, error)

func (UnimplementedJobSpecificationServiceServer) GetJobSpecification 

func (UnimplementedJobSpecificationServiceServer) GetJobSpecification(context.Context, *GetJobSpecificationRequest) (*GetJobSpecificationResponse, error)

func (UnimplementedJobSpecificationServiceServer) GetJobSpecifications 

func (UnimplementedJobSpecificationServiceServer) GetJobSpecifications(context.Context, *GetJobSpecificationsRequest) (*GetJobSpecificationsResponse, error)

func (UnimplementedJobSpecificationServiceServer) GetJobTask 

func (UnimplementedJobSpecificationServiceServer) GetJobTask(context.Context, *GetJobTaskRequest) (*GetJobTaskResponse, error)

func (UnimplementedJobSpecificationServiceServer) GetWindow 

func (UnimplementedJobSpecificationServiceServer) GetWindow(context.Context, *GetWindowRequest) (*GetWindowResponse, error)

func (UnimplementedJobSpecificationServiceServer) JobInspect 

func (UnimplementedJobSpecificationServiceServer) JobInspect(context.Context, *JobInspectRequest) (*JobInspectResponse, error)

func (UnimplementedJobSpecificationServiceServer) ListJobSpecification 

func (UnimplementedJobSpecificationServiceServer) ListJobSpecification(context.Context, *ListJobSpecificationRequest) (*ListJobSpecificationResponse, error)

func (UnimplementedJobSpecificationServiceServer) RefreshJobs 

func (UnimplementedJobSpecificationServiceServer) RefreshJobs(*RefreshJobsRequest, JobSpecificationService_RefreshJobsServer) error

func (UnimplementedJobSpecificationServiceServer) ReplaceAllJobSpecifications 

func (UnimplementedJobSpecificationServiceServer) ReplaceAllJobSpecifications(JobSpecificationService_ReplaceAllJobSpecificationsServer) error

func (UnimplementedJobSpecificationServiceServer) SyncJobsState added in v0.9.0 

func (UnimplementedJobSpecificationServiceServer) SyncJobsState(context.Context, *SyncJobsStateRequest) (*SyncJobsStateResponse, error)

func (UnimplementedJobSpecificationServiceServer) UpdateJobSpecifications 

func (UnimplementedJobSpecificationServiceServer) UpdateJobSpecifications(context.Context, *UpdateJobSpecificationsRequest) (*UpdateJobSpecificationsResponse, error)

func (UnimplementedJobSpecificationServiceServer) UpdateJobsState added in v0.9.0 

func (UnimplementedJobSpecificationServiceServer) UpdateJobsState(context.Context, *UpdateJobsStateRequest) (*UpdateJobsStateResponse, error)

type UnimplementedNamespaceServiceServer 

type UnimplementedNamespaceServiceServer struct {
}

UnimplementedNamespaceServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedNamespaceServiceServer) GetNamespace 

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

func (UnimplementedNamespaceServiceServer) ListProjectNamespaces 

func (UnimplementedNamespaceServiceServer) ListProjectNamespaces(context.Context, *ListProjectNamespacesRequest) (*ListProjectNamespacesResponse, error)

func (UnimplementedNamespaceServiceServer) RegisterProjectNamespace 

func (UnimplementedNamespaceServiceServer) RegisterProjectNamespace(context.Context, *RegisterProjectNamespaceRequest) (*RegisterProjectNamespaceResponse, error)

type UnimplementedProjectServiceServer 

type UnimplementedProjectServiceServer struct {
}

UnimplementedProjectServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedProjectServiceServer) GetProject 

func (UnimplementedProjectServiceServer) GetProject(context.Context, *GetProjectRequest) (*GetProjectResponse, error)

func (UnimplementedProjectServiceServer) ListProjects 

func (UnimplementedProjectServiceServer) ListProjects(context.Context, *ListProjectsRequest) (*ListProjectsResponse, error)

func (UnimplementedProjectServiceServer) RegisterProject 

func (UnimplementedProjectServiceServer) RegisterProject(context.Context, *RegisterProjectRequest) (*RegisterProjectResponse, error)

type UnimplementedReplayServiceServer 

type UnimplementedReplayServiceServer struct {
}

UnimplementedReplayServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedReplayServiceServer) GetReplay added in v0.7.0 

func (UnimplementedReplayServiceServer) GetReplay(context.Context, *GetReplayRequest) (*GetReplayResponse, error)

func (UnimplementedReplayServiceServer) ListReplay added in v0.7.0 

func (UnimplementedReplayServiceServer) ListReplay(context.Context, *ListReplayRequest) (*ListReplayResponse, error)

func (UnimplementedReplayServiceServer) Replay 

func (UnimplementedReplayServiceServer) Replay(context.Context, *ReplayRequest) (*ReplayResponse, error)

func (UnimplementedReplayServiceServer) ReplayDryRun 

func (UnimplementedReplayServiceServer) ReplayDryRun(context.Context, *ReplayDryRunRequest) (*ReplayDryRunResponse, error)

type UnimplementedResourceServiceServer 

type UnimplementedResourceServiceServer struct {
}

UnimplementedResourceServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedResourceServiceServer) ApplyResources added in v0.9.0 

func (UnimplementedResourceServiceServer) ApplyResources(context.Context, *ApplyResourcesRequest) (*ApplyResourcesResponse, error)

func (UnimplementedResourceServiceServer) ChangeResourceNamespace added in v0.8.0 

func (UnimplementedResourceServiceServer) ChangeResourceNamespace(context.Context, *ChangeResourceNamespaceRequest) (*ChangeResourceNamespaceResponse, error)

func (UnimplementedResourceServiceServer) CreateResource 

func (UnimplementedResourceServiceServer) CreateResource(context.Context, *CreateResourceRequest) (*CreateResourceResponse, error)

func (UnimplementedResourceServiceServer) DeployResourceSpecification 

func (UnimplementedResourceServiceServer) DeployResourceSpecification(ResourceService_DeployResourceSpecificationServer) error

func (UnimplementedResourceServiceServer) ListResourceSpecification 

func (UnimplementedResourceServiceServer) ListResourceSpecification(context.Context, *ListResourceSpecificationRequest) (*ListResourceSpecificationResponse, error)

func (UnimplementedResourceServiceServer) ReadResource 

func (UnimplementedResourceServiceServer) ReadResource(context.Context, *ReadResourceRequest) (*ReadResourceResponse, error)

func (UnimplementedResourceServiceServer) UpdateResource 

func (UnimplementedResourceServiceServer) UpdateResource(context.Context, *UpdateResourceRequest) (*UpdateResourceResponse, error)

type UnimplementedRuntimeServiceServer 

type UnimplementedRuntimeServiceServer struct {
}

UnimplementedRuntimeServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedRuntimeServiceServer) Version 

func (UnimplementedRuntimeServiceServer) Version(context.Context, *VersionRequest) (*VersionResponse, error)

type UnimplementedSecretServiceServer 

type UnimplementedSecretServiceServer struct {
}

UnimplementedSecretServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSecretServiceServer) DeleteSecret 

func (UnimplementedSecretServiceServer) DeleteSecret(context.Context, *DeleteSecretRequest) (*DeleteSecretResponse, error)

func (UnimplementedSecretServiceServer) ListSecrets 

func (UnimplementedSecretServiceServer) ListSecrets(context.Context, *ListSecretsRequest) (*ListSecretsResponse, error)

func (UnimplementedSecretServiceServer) RegisterSecret 

func (UnimplementedSecretServiceServer) RegisterSecret(context.Context, *RegisterSecretRequest) (*RegisterSecretResponse, error)

func (UnimplementedSecretServiceServer) UpdateSecret 

func (UnimplementedSecretServiceServer) UpdateSecret(context.Context, *UpdateSecretRequest) (*UpdateSecretResponse, error)

type UnsafeBackupServiceServer 

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

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

type UnsafeJobRunServiceServer 

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

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

type UnsafeJobSpecificationServiceServer 

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

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

type UnsafeNamespaceServiceServer 

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

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

type UnsafeProjectServiceServer 

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

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

type UnsafeReplayServiceServer 

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

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

type UnsafeResourceServiceServer 

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

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

type UnsafeRuntimeServiceServer 

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

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

type UnsafeSecretServiceServer 

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

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

type UpdateJobSpecificationsRequest 

type UpdateJobSpecificationsRequest struct {
	ProjectName   string              `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	NamespaceName string              `protobuf:"bytes,2,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	Specs         []*JobSpecification `protobuf:"bytes,3,rep,name=specs,proto3" json:"specs,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateJobSpecificationsRequest) Descriptor deprecated 

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

Deprecated: Use UpdateJobSpecificationsRequest.ProtoReflect.Descriptor instead.

func (*UpdateJobSpecificationsRequest) GetNamespaceName 

func (x *UpdateJobSpecificationsRequest) GetNamespaceName() string

func (*UpdateJobSpecificationsRequest) GetProjectName 

func (x *UpdateJobSpecificationsRequest) GetProjectName() string

func (*UpdateJobSpecificationsRequest) GetSpecs 

func (x *UpdateJobSpecificationsRequest) GetSpecs() []*JobSpecification

func (*UpdateJobSpecificationsRequest) ProtoMessage 

func (*UpdateJobSpecificationsRequest) ProtoMessage()

func (*UpdateJobSpecificationsRequest) ProtoReflect 

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

func (*UpdateJobSpecificationsRequest) Reset 

func (x *UpdateJobSpecificationsRequest) Reset()

func (*UpdateJobSpecificationsRequest) String 

func (x *UpdateJobSpecificationsRequest) String() string

type UpdateJobSpecificationsResponse 

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

func (*UpdateJobSpecificationsResponse) Descriptor deprecated 

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

Deprecated: Use UpdateJobSpecificationsResponse.ProtoReflect.Descriptor instead.

func (*UpdateJobSpecificationsResponse) GetLog 

func (x *UpdateJobSpecificationsResponse) GetLog() string

func (*UpdateJobSpecificationsResponse) ProtoMessage 

func (*UpdateJobSpecificationsResponse) ProtoMessage()

func (*UpdateJobSpecificationsResponse) ProtoReflect 

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

func (*UpdateJobSpecificationsResponse) Reset 

func (x *UpdateJobSpecificationsResponse) Reset()

func (*UpdateJobSpecificationsResponse) String 

func (x *UpdateJobSpecificationsResponse) String() string

type UpdateJobsStateRequest added in v0.9.0 

type UpdateJobsStateRequest struct {
	ProjectName   string   `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	NamespaceName string   `protobuf:"bytes,2,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	Remark        string   `protobuf:"bytes,3,opt,name=remark,proto3" json:"remark,omitempty"`
	State         JobState `protobuf:"varint,4,opt,name=state,proto3,enum=gotocompany.optimus.core.v1beta1.JobState" json:"state,omitempty"`
	JobNames      []string `protobuf:"bytes,5,rep,name=job_names,json=jobNames,proto3" json:"job_names,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateJobsStateRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use UpdateJobsStateRequest.ProtoReflect.Descriptor instead.

func (*UpdateJobsStateRequest) GetJobNames added in v0.9.0 

func (x *UpdateJobsStateRequest) GetJobNames() []string

func (*UpdateJobsStateRequest) GetNamespaceName added in v0.9.0 

func (x *UpdateJobsStateRequest) GetNamespaceName() string

func (*UpdateJobsStateRequest) GetProjectName added in v0.9.0 

func (x *UpdateJobsStateRequest) GetProjectName() string

func (*UpdateJobsStateRequest) GetRemark added in v0.9.0 

func (x *UpdateJobsStateRequest) GetRemark() string

func (*UpdateJobsStateRequest) GetState added in v0.9.0 

func (x *UpdateJobsStateRequest) GetState() JobState

func (*UpdateJobsStateRequest) ProtoMessage added in v0.9.0 

func (*UpdateJobsStateRequest) ProtoMessage()

func (*UpdateJobsStateRequest) ProtoReflect added in v0.9.0 

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

func (*UpdateJobsStateRequest) Reset added in v0.9.0 

func (x *UpdateJobsStateRequest) Reset()

func (*UpdateJobsStateRequest) String added in v0.9.0 

func (x *UpdateJobsStateRequest) String() string

type UpdateJobsStateResponse added in v0.9.0 

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

func (*UpdateJobsStateResponse) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use UpdateJobsStateResponse.ProtoReflect.Descriptor instead.

func (*UpdateJobsStateResponse) ProtoMessage added in v0.9.0 

func (*UpdateJobsStateResponse) ProtoMessage()

func (*UpdateJobsStateResponse) ProtoReflect added in v0.9.0 

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

func (*UpdateJobsStateResponse) Reset added in v0.9.0 

func (x *UpdateJobsStateResponse) Reset()

func (*UpdateJobsStateResponse) String added in v0.9.0 

func (x *UpdateJobsStateResponse) String() string

type UpdateResourceRequest 

type UpdateResourceRequest struct {
	ProjectName   string                 `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	DatastoreName string                 `protobuf:"bytes,2,opt,name=datastore_name,json=datastoreName,proto3" json:"datastore_name,omitempty"`
	Resource      *ResourceSpecification `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"`
	NamespaceName string                 `protobuf:"bytes,4,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateResourceRequest) Descriptor deprecated 

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

Deprecated: Use UpdateResourceRequest.ProtoReflect.Descriptor instead.

func (*UpdateResourceRequest) GetDatastoreName 

func (x *UpdateResourceRequest) GetDatastoreName() string

func (*UpdateResourceRequest) GetNamespaceName 

func (x *UpdateResourceRequest) GetNamespaceName() string

func (*UpdateResourceRequest) GetProjectName 

func (x *UpdateResourceRequest) GetProjectName() string

func (*UpdateResourceRequest) GetResource 

func (x *UpdateResourceRequest) GetResource() *ResourceSpecification

func (*UpdateResourceRequest) ProtoMessage 

func (*UpdateResourceRequest) ProtoMessage()

func (*UpdateResourceRequest) ProtoReflect 

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

func (*UpdateResourceRequest) Reset 

func (x *UpdateResourceRequest) Reset()

func (*UpdateResourceRequest) String 

func (x *UpdateResourceRequest) String() string

type UpdateResourceResponse 

type UpdateResourceResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateResourceResponse) Descriptor deprecated 

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

Deprecated: Use UpdateResourceResponse.ProtoReflect.Descriptor instead.

func (*UpdateResourceResponse) GetMessage 

func (x *UpdateResourceResponse) GetMessage() string

func (*UpdateResourceResponse) GetSuccess 

func (x *UpdateResourceResponse) GetSuccess() bool

func (*UpdateResourceResponse) ProtoMessage 

func (*UpdateResourceResponse) ProtoMessage()

func (*UpdateResourceResponse) ProtoReflect 

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

func (*UpdateResourceResponse) Reset 

func (x *UpdateResourceResponse) Reset()

func (*UpdateResourceResponse) String 

func (x *UpdateResourceResponse) String() string

type UpdateSecretRequest 

type UpdateSecretRequest struct {
	ProjectName   string `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	SecretName    string `protobuf:"bytes,2,opt,name=secret_name,json=secretName,proto3" json:"secret_name,omitempty"`
	Value         string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` // base64 encoded secret value
	NamespaceName string `protobuf:"bytes,4,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSecretRequest) Descriptor deprecated 

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

Deprecated: Use UpdateSecretRequest.ProtoReflect.Descriptor instead.

func (*UpdateSecretRequest) GetNamespaceName 

func (x *UpdateSecretRequest) GetNamespaceName() string

func (*UpdateSecretRequest) GetProjectName 

func (x *UpdateSecretRequest) GetProjectName() string

func (*UpdateSecretRequest) GetSecretName 

func (x *UpdateSecretRequest) GetSecretName() string

func (*UpdateSecretRequest) GetValue 

func (x *UpdateSecretRequest) GetValue() string

func (*UpdateSecretRequest) ProtoMessage 

func (*UpdateSecretRequest) ProtoMessage()

func (*UpdateSecretRequest) ProtoReflect 

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

func (*UpdateSecretRequest) Reset 

func (x *UpdateSecretRequest) Reset()

func (*UpdateSecretRequest) String 

func (x *UpdateSecretRequest) String() string

type UpdateSecretResponse 

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

func (*UpdateSecretResponse) Descriptor deprecated 

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

Deprecated: Use UpdateSecretResponse.ProtoReflect.Descriptor instead.

func (*UpdateSecretResponse) ProtoMessage 

func (*UpdateSecretResponse) ProtoMessage()

func (*UpdateSecretResponse) ProtoReflect 

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

func (*UpdateSecretResponse) Reset 

func (x *UpdateSecretResponse) Reset()

func (*UpdateSecretResponse) String 

func (x *UpdateSecretResponse) String() string

type UploadToSchedulerRequest 

type UploadToSchedulerRequest struct {
	ProjectName   string  `protobuf:"bytes,1,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	NamespaceName *string `protobuf:"bytes,2,opt,name=namespace_name,json=namespaceName,proto3,oneof" json:"namespace_name,omitempty"`
	// contains filtered or unexported fields
}

func (*UploadToSchedulerRequest) Descriptor deprecated 

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

Deprecated: Use UploadToSchedulerRequest.ProtoReflect.Descriptor instead.

func (*UploadToSchedulerRequest) GetNamespaceName 

func (x *UploadToSchedulerRequest) GetNamespaceName() string

func (*UploadToSchedulerRequest) GetProjectName 

func (x *UploadToSchedulerRequest) GetProjectName() string

func (*UploadToSchedulerRequest) ProtoMessage 

func (*UploadToSchedulerRequest) ProtoMessage()

func (*UploadToSchedulerRequest) ProtoReflect 

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

func (*UploadToSchedulerRequest) Reset 

func (x *UploadToSchedulerRequest) Reset()

func (*UploadToSchedulerRequest) String 

func (x *UploadToSchedulerRequest) String() string

type UploadToSchedulerResponse 

type UploadToSchedulerResponse struct {
	Status       bool   `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// contains filtered or unexported fields
}

func (*UploadToSchedulerResponse) Descriptor deprecated 

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

Deprecated: Use UploadToSchedulerResponse.ProtoReflect.Descriptor instead.

func (*UploadToSchedulerResponse) GetErrorMessage 

func (x *UploadToSchedulerResponse) GetErrorMessage() string

func (*UploadToSchedulerResponse) GetStatus 

func (x *UploadToSchedulerResponse) GetStatus() bool

func (*UploadToSchedulerResponse) ProtoMessage 

func (*UploadToSchedulerResponse) ProtoMessage()

func (*UploadToSchedulerResponse) ProtoReflect 

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

func (*UploadToSchedulerResponse) Reset 

func (x *UploadToSchedulerResponse) Reset()

func (*UploadToSchedulerResponse) String 

func (x *UploadToSchedulerResponse) String() string

type VersionRequest 

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

func (*VersionRequest) Descriptor deprecated 

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

Deprecated: Use VersionRequest.ProtoReflect.Descriptor instead.

func (*VersionRequest) GetClient 

func (x *VersionRequest) GetClient() string

func (*VersionRequest) ProtoMessage 

func (*VersionRequest) ProtoMessage()

func (*VersionRequest) ProtoReflect 

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

func (*VersionRequest) Reset 

func (x *VersionRequest) Reset()

func (*VersionRequest) String 

func (x *VersionRequest) String() string

type VersionResponse 

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

func (*VersionResponse) Descriptor deprecated 

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

Deprecated: Use VersionResponse.ProtoReflect.Descriptor instead.

func (*VersionResponse) GetServer 

func (x *VersionResponse) GetServer() string

func (*VersionResponse) ProtoMessage 

func (*VersionResponse) ProtoMessage()

func (*VersionResponse) ProtoReflect 

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

func (*VersionResponse) Reset 

func (x *VersionResponse) Reset()

func (*VersionResponse) String 

func (x *VersionResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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