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 ¶
- Variables
- func RegisterBackupServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterBackupServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client BackupServiceClient) error
- func RegisterBackupServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterBackupServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server BackupServiceServer) error
- func RegisterBackupServiceServer(s grpc.ServiceRegistrar, srv BackupServiceServer)
- func RegisterJobRunServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterJobRunServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client JobRunServiceClient) error
- func RegisterJobRunServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterJobRunServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server JobRunServiceServer) error
- func RegisterJobRunServiceServer(s grpc.ServiceRegistrar, srv JobRunServiceServer)
- func RegisterJobSpecificationServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterJobSpecificationServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, ...) error
- func RegisterJobSpecificationServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterJobSpecificationServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, ...) error
- func RegisterJobSpecificationServiceServer(s grpc.ServiceRegistrar, srv JobSpecificationServiceServer)
- func RegisterNamespaceServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterNamespaceServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client NamespaceServiceClient) error
- func RegisterNamespaceServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterNamespaceServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server NamespaceServiceServer) error
- func RegisterNamespaceServiceServer(s grpc.ServiceRegistrar, srv NamespaceServiceServer)
- func RegisterProjectServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterProjectServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ProjectServiceClient) error
- func RegisterProjectServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterProjectServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ProjectServiceServer) error
- func RegisterProjectServiceServer(s grpc.ServiceRegistrar, srv ProjectServiceServer)
- func RegisterReplayServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterReplayServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ReplayServiceClient) error
- func RegisterReplayServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterReplayServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ReplayServiceServer) error
- func RegisterReplayServiceServer(s grpc.ServiceRegistrar, srv ReplayServiceServer)
- func RegisterResourceServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterResourceServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ResourceServiceClient) error
- func RegisterResourceServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterResourceServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ResourceServiceServer) error
- func RegisterResourceServiceServer(s grpc.ServiceRegistrar, srv ResourceServiceServer)
- func RegisterRuntimeServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterRuntimeServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client RuntimeServiceClient) error
- func RegisterRuntimeServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterRuntimeServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server RuntimeServiceServer) error
- func RegisterRuntimeServiceServer(s grpc.ServiceRegistrar, srv RuntimeServiceServer)
- func RegisterSecretServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterSecretServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client SecretServiceClient) error
- func RegisterSecretServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterSecretServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server SecretServiceServer) error
- func RegisterSecretServiceServer(s grpc.ServiceRegistrar, srv SecretServiceServer)
- type AddJobSpecificationsRequest
- func (*AddJobSpecificationsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AddJobSpecificationsRequest) GetNamespaceName() string
- func (x *AddJobSpecificationsRequest) GetProjectName() string
- func (x *AddJobSpecificationsRequest) GetSpecs() []*JobSpecification
- func (*AddJobSpecificationsRequest) ProtoMessage()
- func (x *AddJobSpecificationsRequest) ProtoReflect() protoreflect.Message
- func (x *AddJobSpecificationsRequest) Reset()
- func (x *AddJobSpecificationsRequest) String() string
- type AddJobSpecificationsResponse
- func (*AddJobSpecificationsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AddJobSpecificationsResponse) GetLog() string
- func (*AddJobSpecificationsResponse) ProtoMessage()
- func (x *AddJobSpecificationsResponse) ProtoReflect() protoreflect.Message
- func (x *AddJobSpecificationsResponse) Reset()
- func (x *AddJobSpecificationsResponse) String() string
- type BackupServiceClient
- type BackupServiceServer
- type BackupSpec
- func (*BackupSpec) Descriptor() ([]byte, []int)deprecated
- func (x *BackupSpec) GetConfig() map[string]string
- func (x *BackupSpec) GetCreatedAt() *timestamppb.Timestamp
- func (x *BackupSpec) GetDescription() string
- func (x *BackupSpec) GetId() string
- func (x *BackupSpec) GetResourceNames() []string
- func (*BackupSpec) ProtoMessage()
- func (x *BackupSpec) ProtoReflect() protoreflect.Message
- func (x *BackupSpec) Reset()
- func (x *BackupSpec) String() string
- type ChangeJobNamespaceRequest
- func (*ChangeJobNamespaceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeJobNamespaceRequest) GetJobName() string
- func (x *ChangeJobNamespaceRequest) GetNamespaceName() string
- func (x *ChangeJobNamespaceRequest) GetNewNamespaceName() string
- func (x *ChangeJobNamespaceRequest) GetProjectName() string
- func (*ChangeJobNamespaceRequest) ProtoMessage()
- func (x *ChangeJobNamespaceRequest) ProtoReflect() protoreflect.Message
- func (x *ChangeJobNamespaceRequest) Reset()
- func (x *ChangeJobNamespaceRequest) String() string
- type ChangeJobNamespaceResponse
- type ChangeResourceNamespaceRequest
- func (*ChangeResourceNamespaceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeResourceNamespaceRequest) GetDatastoreName() string
- func (x *ChangeResourceNamespaceRequest) GetNamespaceName() string
- func (x *ChangeResourceNamespaceRequest) GetNewNamespaceName() string
- func (x *ChangeResourceNamespaceRequest) GetProjectName() string
- func (x *ChangeResourceNamespaceRequest) GetResourceName() string
- func (*ChangeResourceNamespaceRequest) ProtoMessage()
- func (x *ChangeResourceNamespaceRequest) ProtoReflect() protoreflect.Message
- func (x *ChangeResourceNamespaceRequest) Reset()
- func (x *ChangeResourceNamespaceRequest) String() string
- type ChangeResourceNamespaceResponse
- func (*ChangeResourceNamespaceResponse) Descriptor() ([]byte, []int)deprecated
- func (*ChangeResourceNamespaceResponse) ProtoMessage()
- func (x *ChangeResourceNamespaceResponse) ProtoReflect() protoreflect.Message
- func (x *ChangeResourceNamespaceResponse) Reset()
- func (x *ChangeResourceNamespaceResponse) String() string
- type CheckJobSpecificationRequest
- func (*CheckJobSpecificationRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CheckJobSpecificationRequest) GetJob() *JobSpecification
- func (x *CheckJobSpecificationRequest) GetNamespaceName() string
- func (x *CheckJobSpecificationRequest) GetProjectName() string
- func (*CheckJobSpecificationRequest) ProtoMessage()
- func (x *CheckJobSpecificationRequest) ProtoReflect() protoreflect.Message
- func (x *CheckJobSpecificationRequest) Reset()
- func (x *CheckJobSpecificationRequest) String() string
- type CheckJobSpecificationResponse
- func (*CheckJobSpecificationResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CheckJobSpecificationResponse) GetSuccess() bool
- func (*CheckJobSpecificationResponse) ProtoMessage()
- func (x *CheckJobSpecificationResponse) ProtoReflect() protoreflect.Message
- func (x *CheckJobSpecificationResponse) Reset()
- func (x *CheckJobSpecificationResponse) String() string
- type CheckJobSpecificationsRequest
- func (*CheckJobSpecificationsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CheckJobSpecificationsRequest) GetJobs() []*JobSpecification
- func (x *CheckJobSpecificationsRequest) GetNamespaceName() string
- func (x *CheckJobSpecificationsRequest) GetProjectName() string
- func (*CheckJobSpecificationsRequest) ProtoMessage()
- func (x *CheckJobSpecificationsRequest) ProtoReflect() protoreflect.Message
- func (x *CheckJobSpecificationsRequest) Reset()
- func (x *CheckJobSpecificationsRequest) String() string
- type CheckJobSpecificationsResponse
- func (*CheckJobSpecificationsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CheckJobSpecificationsResponse) GetLogStatus() *Log
- func (*CheckJobSpecificationsResponse) ProtoMessage()
- func (x *CheckJobSpecificationsResponse) ProtoReflect() protoreflect.Message
- func (x *CheckJobSpecificationsResponse) Reset()
- func (x *CheckJobSpecificationsResponse) String() string
- type CreateBackupRequest
- func (*CreateBackupRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateBackupRequest) GetConfig() map[string]string
- func (x *CreateBackupRequest) GetDatastoreName() string
- func (x *CreateBackupRequest) GetDescription() string
- func (x *CreateBackupRequest) GetNamespaceName() string
- func (x *CreateBackupRequest) GetProjectName() string
- func (x *CreateBackupRequest) GetResourceNames() []string
- func (*CreateBackupRequest) ProtoMessage()
- func (x *CreateBackupRequest) ProtoReflect() protoreflect.Message
- func (x *CreateBackupRequest) Reset()
- func (x *CreateBackupRequest) String() string
- type CreateBackupResponse
- func (*CreateBackupResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateBackupResponse) GetBackupId() string
- func (x *CreateBackupResponse) GetIgnoredResources() []*IgnoredResource
- func (x *CreateBackupResponse) GetResourceNames() []string
- func (*CreateBackupResponse) ProtoMessage()
- func (x *CreateBackupResponse) ProtoReflect() protoreflect.Message
- func (x *CreateBackupResponse) Reset()
- func (x *CreateBackupResponse) String() string
- type CreateJobSpecificationRequest
- func (*CreateJobSpecificationRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateJobSpecificationRequest) GetNamespaceName() string
- func (x *CreateJobSpecificationRequest) GetProjectName() string
- func (x *CreateJobSpecificationRequest) GetSpec() *JobSpecification
- func (*CreateJobSpecificationRequest) ProtoMessage()
- func (x *CreateJobSpecificationRequest) ProtoReflect() protoreflect.Message
- func (x *CreateJobSpecificationRequest) Reset()
- func (x *CreateJobSpecificationRequest) String() string
- type CreateJobSpecificationResponse
- func (*CreateJobSpecificationResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateJobSpecificationResponse) GetMessage() string
- func (x *CreateJobSpecificationResponse) GetSuccess() bool
- func (*CreateJobSpecificationResponse) ProtoMessage()
- func (x *CreateJobSpecificationResponse) ProtoReflect() protoreflect.Message
- func (x *CreateJobSpecificationResponse) Reset()
- func (x *CreateJobSpecificationResponse) String() string
- type CreateResourceRequest
- func (*CreateResourceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateResourceRequest) GetDatastoreName() string
- func (x *CreateResourceRequest) GetNamespaceName() string
- func (x *CreateResourceRequest) GetProjectName() string
- func (x *CreateResourceRequest) GetResource() *ResourceSpecification
- func (*CreateResourceRequest) ProtoMessage()
- func (x *CreateResourceRequest) ProtoReflect() protoreflect.Message
- func (x *CreateResourceRequest) Reset()
- func (x *CreateResourceRequest) String() string
- type CreateResourceResponse
- func (*CreateResourceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateResourceResponse) GetMessage() string
- func (x *CreateResourceResponse) GetSuccess() bool
- func (*CreateResourceResponse) ProtoMessage()
- func (x *CreateResourceResponse) ProtoReflect() protoreflect.Message
- func (x *CreateResourceResponse) Reset()
- func (x *CreateResourceResponse) String() string
- type DeleteJobSpecificationRequest
- func (*DeleteJobSpecificationRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteJobSpecificationRequest) GetCleanHistory() bool
- func (x *DeleteJobSpecificationRequest) GetForce() bool
- func (x *DeleteJobSpecificationRequest) GetJobName() string
- func (x *DeleteJobSpecificationRequest) GetNamespaceName() string
- func (x *DeleteJobSpecificationRequest) GetProjectName() string
- func (*DeleteJobSpecificationRequest) ProtoMessage()
- func (x *DeleteJobSpecificationRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteJobSpecificationRequest) Reset()
- func (x *DeleteJobSpecificationRequest) String() string
- type DeleteJobSpecificationResponse
- func (*DeleteJobSpecificationResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteJobSpecificationResponse) GetMessage() string
- func (x *DeleteJobSpecificationResponse) GetSuccess() bool
- func (*DeleteJobSpecificationResponse) ProtoMessage()
- func (x *DeleteJobSpecificationResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteJobSpecificationResponse) Reset()
- func (x *DeleteJobSpecificationResponse) String() string
- type DeleteSecretRequest
- func (*DeleteSecretRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteSecretRequest) GetNamespaceName() string
- func (x *DeleteSecretRequest) GetProjectName() string
- func (x *DeleteSecretRequest) GetSecretName() string
- func (*DeleteSecretRequest) ProtoMessage()
- func (x *DeleteSecretRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteSecretRequest) Reset()
- func (x *DeleteSecretRequest) String() string
- type DeleteSecretResponse
- type DeployJobFailure
- func (*DeployJobFailure) Descriptor() ([]byte, []int)deprecated
- func (x *DeployJobFailure) GetJobName() string
- func (x *DeployJobFailure) GetMessage() string
- func (*DeployJobFailure) ProtoMessage()
- func (x *DeployJobFailure) ProtoReflect() protoreflect.Message
- func (x *DeployJobFailure) Reset()
- func (x *DeployJobFailure) String() string
- type DeployJobSpecificationRequest
- func (*DeployJobSpecificationRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeployJobSpecificationRequest) GetJobs() []*JobSpecification
- func (x *DeployJobSpecificationRequest) GetNamespaceName() string
- func (x *DeployJobSpecificationRequest) GetProjectName() string
- func (*DeployJobSpecificationRequest) ProtoMessage()
- func (x *DeployJobSpecificationRequest) ProtoReflect() protoreflect.Message
- func (x *DeployJobSpecificationRequest) Reset()
- func (x *DeployJobSpecificationRequest) String() string
- type DeployJobSpecificationResponse
- func (*DeployJobSpecificationResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeployJobSpecificationResponse) GetDeploymentId() string
- func (x *DeployJobSpecificationResponse) GetLogStatus() *Log
- func (*DeployJobSpecificationResponse) ProtoMessage()
- func (x *DeployJobSpecificationResponse) ProtoReflect() protoreflect.Message
- func (x *DeployJobSpecificationResponse) Reset()
- func (x *DeployJobSpecificationResponse) String() string
- type DeployResourceSpecificationRequest
- func (*DeployResourceSpecificationRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeployResourceSpecificationRequest) GetDatastoreName() string
- func (x *DeployResourceSpecificationRequest) GetNamespaceName() string
- func (x *DeployResourceSpecificationRequest) GetProjectName() string
- func (x *DeployResourceSpecificationRequest) GetResources() []*ResourceSpecification
- func (*DeployResourceSpecificationRequest) ProtoMessage()
- func (x *DeployResourceSpecificationRequest) ProtoReflect() protoreflect.Message
- func (x *DeployResourceSpecificationRequest) Reset()
- func (x *DeployResourceSpecificationRequest) String() string
- type DeployResourceSpecificationResponse
- func (*DeployResourceSpecificationResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeployResourceSpecificationResponse) GetLogStatus() *Log
- func (*DeployResourceSpecificationResponse) ProtoMessage()
- func (x *DeployResourceSpecificationResponse) ProtoReflect() protoreflect.Message
- func (x *DeployResourceSpecificationResponse) Reset()
- func (x *DeployResourceSpecificationResponse) String() string
- type GetBackupRequest
- func (*GetBackupRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetBackupRequest) GetDatastoreName() string
- func (x *GetBackupRequest) GetId() string
- func (x *GetBackupRequest) GetNamespaceName() string
- func (x *GetBackupRequest) GetProjectName() string
- func (*GetBackupRequest) ProtoMessage()
- func (x *GetBackupRequest) ProtoReflect() protoreflect.Message
- func (x *GetBackupRequest) Reset()
- func (x *GetBackupRequest) String() string
- type GetBackupResponse
- type GetDeployJobsStatusRequest
- func (*GetDeployJobsStatusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetDeployJobsStatusRequest) GetDeployId() string
- func (*GetDeployJobsStatusRequest) ProtoMessage()
- func (x *GetDeployJobsStatusRequest) ProtoReflect() protoreflect.Message
- func (x *GetDeployJobsStatusRequest) Reset()
- func (x *GetDeployJobsStatusRequest) String() string
- type GetDeployJobsStatusResponse
- func (*GetDeployJobsStatusResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetDeployJobsStatusResponse) GetFailureCount() int32
- func (x *GetDeployJobsStatusResponse) GetFailures() []*DeployJobFailure
- func (x *GetDeployJobsStatusResponse) GetStatus() string
- func (x *GetDeployJobsStatusResponse) GetSuccessCount() int32
- func (x *GetDeployJobsStatusResponse) GetUnknownDependencies() map[string]string
- func (*GetDeployJobsStatusResponse) ProtoMessage()
- func (x *GetDeployJobsStatusResponse) ProtoReflect() protoreflect.Message
- func (x *GetDeployJobsStatusResponse) Reset()
- func (x *GetDeployJobsStatusResponse) String() string
- type GetJobSpecificationRequest
- func (*GetJobSpecificationRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetJobSpecificationRequest) GetJobName() string
- func (x *GetJobSpecificationRequest) GetNamespaceName() string
- func (x *GetJobSpecificationRequest) GetProjectName() string
- func (*GetJobSpecificationRequest) ProtoMessage()
- func (x *GetJobSpecificationRequest) ProtoReflect() protoreflect.Message
- func (x *GetJobSpecificationRequest) Reset()
- func (x *GetJobSpecificationRequest) String() string
- type GetJobSpecificationResponse
- func (*GetJobSpecificationResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetJobSpecificationResponse) GetSpec() *JobSpecification
- func (*GetJobSpecificationResponse) ProtoMessage()
- func (x *GetJobSpecificationResponse) ProtoReflect() protoreflect.Message
- func (x *GetJobSpecificationResponse) Reset()
- func (x *GetJobSpecificationResponse) String() string
- type GetJobSpecificationsRequest
- func (*GetJobSpecificationsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetJobSpecificationsRequest) GetJobName() string
- func (x *GetJobSpecificationsRequest) GetNamespaceName() string
- func (x *GetJobSpecificationsRequest) GetProjectName() string
- func (x *GetJobSpecificationsRequest) GetResourceDestination() string
- func (*GetJobSpecificationsRequest) ProtoMessage()
- func (x *GetJobSpecificationsRequest) ProtoReflect() protoreflect.Message
- func (x *GetJobSpecificationsRequest) Reset()
- func (x *GetJobSpecificationsRequest) String() string
- type GetJobSpecificationsResponse
- func (*GetJobSpecificationsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetJobSpecificationsResponse) GetJobSpecificationResponses() []*JobSpecificationResponse
- func (x *GetJobSpecificationsResponse) GetJobs() []*JobSpecificationdeprecated
- func (*GetJobSpecificationsResponse) ProtoMessage()
- func (x *GetJobSpecificationsResponse) ProtoReflect() protoreflect.Message
- func (x *GetJobSpecificationsResponse) Reset()
- func (x *GetJobSpecificationsResponse) String() string
- type GetJobTaskRequest
- func (*GetJobTaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetJobTaskRequest) GetJobName() string
- func (x *GetJobTaskRequest) GetNamespaceName() string
- func (x *GetJobTaskRequest) GetProjectName() string
- func (*GetJobTaskRequest) ProtoMessage()
- func (x *GetJobTaskRequest) ProtoReflect() protoreflect.Message
- func (x *GetJobTaskRequest) Reset()
- func (x *GetJobTaskRequest) String() string
- type GetJobTaskResponse
- func (*GetJobTaskResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetJobTaskResponse) GetTask() *JobTask
- func (*GetJobTaskResponse) ProtoMessage()
- func (x *GetJobTaskResponse) ProtoReflect() protoreflect.Message
- func (x *GetJobTaskResponse) Reset()
- func (x *GetJobTaskResponse) String() string
- type GetNamespaceRequest
- func (*GetNamespaceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetNamespaceRequest) GetNamespaceName() string
- func (x *GetNamespaceRequest) GetProjectName() string
- func (*GetNamespaceRequest) ProtoMessage()
- func (x *GetNamespaceRequest) ProtoReflect() protoreflect.Message
- func (x *GetNamespaceRequest) Reset()
- func (x *GetNamespaceRequest) String() string
- type GetNamespaceResponse
- func (*GetNamespaceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetNamespaceResponse) GetNamespace() *NamespaceSpecification
- func (*GetNamespaceResponse) ProtoMessage()
- func (x *GetNamespaceResponse) ProtoReflect() protoreflect.Message
- func (x *GetNamespaceResponse) Reset()
- func (x *GetNamespaceResponse) String() string
- type GetProjectRequest
- func (*GetProjectRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetProjectRequest) GetProjectName() string
- func (*GetProjectRequest) ProtoMessage()
- func (x *GetProjectRequest) ProtoReflect() protoreflect.Message
- func (x *GetProjectRequest) Reset()
- func (x *GetProjectRequest) String() string
- type GetProjectResponse
- func (*GetProjectResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetProjectResponse) GetProject() *ProjectSpecification
- func (*GetProjectResponse) ProtoMessage()
- func (x *GetProjectResponse) ProtoReflect() protoreflect.Message
- func (x *GetProjectResponse) Reset()
- func (x *GetProjectResponse) String() string
- type GetReplayRequest
- func (*GetReplayRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetReplayRequest) GetProjectName() string
- func (x *GetReplayRequest) GetReplayId() string
- func (*GetReplayRequest) ProtoMessage()
- func (x *GetReplayRequest) ProtoReflect() protoreflect.Message
- func (x *GetReplayRequest) Reset()
- func (x *GetReplayRequest) String() string
- type GetReplayResponse
- func (*GetReplayResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetReplayResponse) GetId() string
- func (x *GetReplayResponse) GetJobName() string
- func (x *GetReplayResponse) GetReplayConfig() *ReplayConfig
- func (x *GetReplayResponse) GetReplayRuns() []*ReplayRun
- func (x *GetReplayResponse) GetStatus() string
- func (*GetReplayResponse) ProtoMessage()
- func (x *GetReplayResponse) ProtoReflect() protoreflect.Message
- func (x *GetReplayResponse) Reset()
- func (x *GetReplayResponse) String() string
- type GetWindowRequest
- func (*GetWindowRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetWindowRequest) GetOffset() string
- func (x *GetWindowRequest) GetScheduledAt() *timestamppb.Timestamp
- func (x *GetWindowRequest) GetSize() string
- func (x *GetWindowRequest) GetTruncateTo() string
- func (x *GetWindowRequest) GetVersion() int32
- func (*GetWindowRequest) ProtoMessage()
- func (x *GetWindowRequest) ProtoReflect() protoreflect.Message
- func (x *GetWindowRequest) Reset()
- func (x *GetWindowRequest) String() string
- type GetWindowResponse
- func (*GetWindowResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetWindowResponse) GetEnd() *timestamppb.Timestamp
- func (x *GetWindowResponse) GetStart() *timestamppb.Timestamp
- func (*GetWindowResponse) ProtoMessage()
- func (x *GetWindowResponse) ProtoReflect() protoreflect.Message
- func (x *GetWindowResponse) Reset()
- func (x *GetWindowResponse) String() string
- type HttpDependency
- func (*HttpDependency) Descriptor() ([]byte, []int)deprecated
- func (x *HttpDependency) GetHeaders() map[string]string
- func (x *HttpDependency) GetName() string
- func (x *HttpDependency) GetParams() map[string]string
- func (x *HttpDependency) GetUrl() string
- func (*HttpDependency) ProtoMessage()
- func (x *HttpDependency) ProtoReflect() protoreflect.Message
- func (x *HttpDependency) Reset()
- func (x *HttpDependency) String() string
- type IgnoredResource
- func (*IgnoredResource) Descriptor() ([]byte, []int)deprecated
- func (x *IgnoredResource) GetName() string
- func (x *IgnoredResource) GetReason() string
- func (*IgnoredResource) ProtoMessage()
- func (x *IgnoredResource) ProtoReflect() protoreflect.Message
- func (x *IgnoredResource) Reset()
- func (x *IgnoredResource) String() string
- type InstanceSpec
- func (*InstanceSpec) Descriptor() ([]byte, []int)deprecated
- func (x *InstanceSpec) GetData() []*InstanceSpecData
- func (x *InstanceSpec) GetExecutedAt() *timestamppb.Timestamp
- func (x *InstanceSpec) GetName() string
- func (x *InstanceSpec) GetState() string
- func (x *InstanceSpec) GetType() InstanceSpec_Type
- func (*InstanceSpec) ProtoMessage()
- func (x *InstanceSpec) ProtoReflect() protoreflect.Message
- func (x *InstanceSpec) Reset()
- func (x *InstanceSpec) String() string
- type InstanceSpecData
- func (*InstanceSpecData) Descriptor() ([]byte, []int)deprecated
- func (x *InstanceSpecData) GetName() string
- func (x *InstanceSpecData) GetType() InstanceSpecData_Type
- func (x *InstanceSpecData) GetValue() string
- func (*InstanceSpecData) ProtoMessage()
- func (x *InstanceSpecData) ProtoReflect() protoreflect.Message
- func (x *InstanceSpecData) Reset()
- func (x *InstanceSpecData) String() string
- type InstanceSpecData_Type
- func (InstanceSpecData_Type) Descriptor() protoreflect.EnumDescriptor
- func (x InstanceSpecData_Type) Enum() *InstanceSpecData_Type
- func (InstanceSpecData_Type) EnumDescriptor() ([]byte, []int)deprecated
- func (x InstanceSpecData_Type) Number() protoreflect.EnumNumber
- func (x InstanceSpecData_Type) String() string
- func (InstanceSpecData_Type) Type() protoreflect.EnumType
- type InstanceSpec_Type
- func (InstanceSpec_Type) Descriptor() protoreflect.EnumDescriptor
- func (x InstanceSpec_Type) Enum() *InstanceSpec_Type
- func (InstanceSpec_Type) EnumDescriptor() ([]byte, []int)deprecated
- func (x InstanceSpec_Type) Number() protoreflect.EnumNumber
- func (x InstanceSpec_Type) String() string
- func (InstanceSpec_Type) Type() protoreflect.EnumType
- type JobConfigItem
- func (*JobConfigItem) Descriptor() ([]byte, []int)deprecated
- func (x *JobConfigItem) GetName() string
- func (x *JobConfigItem) GetValue() string
- func (*JobConfigItem) ProtoMessage()
- func (x *JobConfigItem) ProtoReflect() protoreflect.Message
- func (x *JobConfigItem) Reset()
- func (x *JobConfigItem) String() string
- type JobDependency
- func (*JobDependency) Descriptor() ([]byte, []int)deprecated
- func (x *JobDependency) GetHttpDependency() *HttpDependency
- func (x *JobDependency) GetName() string
- func (x *JobDependency) GetType() string
- func (*JobDependency) ProtoMessage()
- func (x *JobDependency) ProtoReflect() protoreflect.Message
- func (x *JobDependency) Reset()
- func (x *JobDependency) String() string
- type JobEvent
- type JobEvent_Type
- func (JobEvent_Type) Descriptor() protoreflect.EnumDescriptor
- func (x JobEvent_Type) Enum() *JobEvent_Type
- func (JobEvent_Type) EnumDescriptor() ([]byte, []int)deprecated
- func (x JobEvent_Type) Number() protoreflect.EnumNumber
- func (x JobEvent_Type) String() string
- func (JobEvent_Type) Type() protoreflect.EnumType
- type JobInspectRequest
- func (*JobInspectRequest) Descriptor() ([]byte, []int)deprecated
- func (x *JobInspectRequest) GetJobName() string
- func (x *JobInspectRequest) GetNamespaceName() string
- func (x *JobInspectRequest) GetProjectName() string
- func (x *JobInspectRequest) GetScheduledAt() *timestamppb.Timestamp
- func (x *JobInspectRequest) GetSpec() *JobSpecification
- func (*JobInspectRequest) ProtoMessage()
- func (x *JobInspectRequest) ProtoReflect() protoreflect.Message
- func (x *JobInspectRequest) Reset()
- func (x *JobInspectRequest) String() string
- type JobInspectResponse
- func (*JobInspectResponse) Descriptor() ([]byte, []int)deprecated
- func (x *JobInspectResponse) GetBasicInfo() *JobInspectResponse_BasicInfoSection
- func (x *JobInspectResponse) GetDownstreams() *JobInspectResponse_DownstreamSection
- func (x *JobInspectResponse) GetUpstreams() *JobInspectResponse_UpstreamSection
- func (*JobInspectResponse) ProtoMessage()
- func (x *JobInspectResponse) ProtoReflect() protoreflect.Message
- func (x *JobInspectResponse) Reset()
- func (x *JobInspectResponse) String() string
- type JobInspectResponse_BasicInfoSection
- func (*JobInspectResponse_BasicInfoSection) Descriptor() ([]byte, []int)deprecated
- func (x *JobInspectResponse_BasicInfoSection) GetDestination() string
- func (x *JobInspectResponse_BasicInfoSection) GetJob() *JobSpecification
- func (x *JobInspectResponse_BasicInfoSection) GetNotice() []*Log
- func (x *JobInspectResponse_BasicInfoSection) GetSource() []string
- func (*JobInspectResponse_BasicInfoSection) ProtoMessage()
- func (x *JobInspectResponse_BasicInfoSection) ProtoReflect() protoreflect.Message
- func (x *JobInspectResponse_BasicInfoSection) Reset()
- func (x *JobInspectResponse_BasicInfoSection) String() string
- type JobInspectResponse_DownstreamSection
- func (*JobInspectResponse_DownstreamSection) Descriptor() ([]byte, []int)deprecated
- func (x *JobInspectResponse_DownstreamSection) GetDownstreamJobs() []*JobInspectResponse_JobDependency
- func (x *JobInspectResponse_DownstreamSection) GetNotice() []*Log
- func (*JobInspectResponse_DownstreamSection) ProtoMessage()
- func (x *JobInspectResponse_DownstreamSection) ProtoReflect() protoreflect.Message
- func (x *JobInspectResponse_DownstreamSection) Reset()
- func (x *JobInspectResponse_DownstreamSection) String() string
- type JobInspectResponse_JobDependency
- func (*JobInspectResponse_JobDependency) Descriptor() ([]byte, []int)deprecated
- func (x *JobInspectResponse_JobDependency) GetHost() string
- func (x *JobInspectResponse_JobDependency) GetName() string
- func (x *JobInspectResponse_JobDependency) GetNamespaceName() string
- func (x *JobInspectResponse_JobDependency) GetProjectName() string
- func (x *JobInspectResponse_JobDependency) GetRuns() []*JobRun
- func (x *JobInspectResponse_JobDependency) GetTaskName() string
- func (*JobInspectResponse_JobDependency) ProtoMessage()
- func (x *JobInspectResponse_JobDependency) ProtoReflect() protoreflect.Message
- func (x *JobInspectResponse_JobDependency) Reset()
- func (x *JobInspectResponse_JobDependency) String() string
- type JobInspectResponse_UpstreamSection
- func (*JobInspectResponse_UpstreamSection) Descriptor() ([]byte, []int)deprecated
- func (x *JobInspectResponse_UpstreamSection) GetExternalDependency() []*JobInspectResponse_JobDependency
- func (x *JobInspectResponse_UpstreamSection) GetHttpDependency() []*HttpDependency
- func (x *JobInspectResponse_UpstreamSection) GetInternalDependency() []*JobInspectResponse_JobDependency
- func (x *JobInspectResponse_UpstreamSection) GetNotice() []*Log
- func (x *JobInspectResponse_UpstreamSection) GetUnknownDependencies() []*JobInspectResponse_UpstreamSection_UnknownDependencies
- func (*JobInspectResponse_UpstreamSection) ProtoMessage()
- func (x *JobInspectResponse_UpstreamSection) ProtoReflect() protoreflect.Message
- func (x *JobInspectResponse_UpstreamSection) Reset()
- func (x *JobInspectResponse_UpstreamSection) String() string
- type JobInspectResponse_UpstreamSection_UnknownDependencies
- func (*JobInspectResponse_UpstreamSection_UnknownDependencies) Descriptor() ([]byte, []int)deprecated
- func (x *JobInspectResponse_UpstreamSection_UnknownDependencies) GetJobName() string
- func (x *JobInspectResponse_UpstreamSection_UnknownDependencies) GetProjectName() string
- func (x *JobInspectResponse_UpstreamSection_UnknownDependencies) GetResourceDestination() string
- func (*JobInspectResponse_UpstreamSection_UnknownDependencies) ProtoMessage()
- func (x *JobInspectResponse_UpstreamSection_UnknownDependencies) ProtoReflect() protoreflect.Message
- func (x *JobInspectResponse_UpstreamSection_UnknownDependencies) Reset()
- func (x *JobInspectResponse_UpstreamSection_UnknownDependencies) String() string
- type JobMetadata
- func (*JobMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *JobMetadata) GetAirflow() *JobSpecMetadataAirflow
- func (x *JobMetadata) GetResource() *JobSpecMetadataResource
- func (*JobMetadata) ProtoMessage()
- func (x *JobMetadata) ProtoReflect() protoreflect.Message
- func (x *JobMetadata) Reset()
- func (x *JobMetadata) String() string
- type JobRun
- type JobRunInputRequest
- func (*JobRunInputRequest) Descriptor() ([]byte, []int)deprecated
- func (x *JobRunInputRequest) GetInstanceName() string
- func (x *JobRunInputRequest) GetInstanceType() InstanceSpec_Type
- func (x *JobRunInputRequest) GetJobName() string
- func (x *JobRunInputRequest) GetJobrunId() string
- func (x *JobRunInputRequest) GetProjectName() string
- func (x *JobRunInputRequest) GetScheduledAt() *timestamppb.Timestamp
- func (*JobRunInputRequest) ProtoMessage()
- func (x *JobRunInputRequest) ProtoReflect() protoreflect.Message
- func (x *JobRunInputRequest) Reset()
- func (x *JobRunInputRequest) String() string
- type JobRunInputResponse
- func (*JobRunInputResponse) Descriptor() ([]byte, []int)deprecated
- func (x *JobRunInputResponse) GetEnvs() map[string]string
- func (x *JobRunInputResponse) GetFiles() map[string]string
- func (x *JobRunInputResponse) GetSecrets() map[string]string
- func (*JobRunInputResponse) ProtoMessage()
- func (x *JobRunInputResponse) ProtoReflect() protoreflect.Message
- func (x *JobRunInputResponse) Reset()
- func (x *JobRunInputResponse) String() string
- type JobRunRequest
- func (*JobRunRequest) Descriptor() ([]byte, []int)deprecated
- func (x *JobRunRequest) GetEndDate() *timestamppb.Timestamp
- func (x *JobRunRequest) GetFilter() []string
- func (x *JobRunRequest) GetJobName() string
- func (x *JobRunRequest) GetProjectName() string
- func (x *JobRunRequest) GetStartDate() *timestamppb.Timestamp
- func (*JobRunRequest) ProtoMessage()
- func (x *JobRunRequest) ProtoReflect() protoreflect.Message
- func (x *JobRunRequest) Reset()
- func (x *JobRunRequest) String() string
- type JobRunResponse
- type JobRunServiceClient
- type JobRunServiceServer
- type JobSpecHook
- func (*JobSpecHook) Descriptor() ([]byte, []int)deprecated
- func (x *JobSpecHook) GetConfig() []*JobConfigItem
- func (x *JobSpecHook) GetName() string
- func (*JobSpecHook) ProtoMessage()
- func (x *JobSpecHook) ProtoReflect() protoreflect.Message
- func (x *JobSpecHook) Reset()
- func (x *JobSpecHook) String() string
- type JobSpecMetadataAirflow
- func (*JobSpecMetadataAirflow) Descriptor() ([]byte, []int)deprecated
- func (x *JobSpecMetadataAirflow) GetPool() string
- func (x *JobSpecMetadataAirflow) GetQueue() string
- func (*JobSpecMetadataAirflow) ProtoMessage()
- func (x *JobSpecMetadataAirflow) ProtoReflect() protoreflect.Message
- func (x *JobSpecMetadataAirflow) Reset()
- func (x *JobSpecMetadataAirflow) String() string
- type JobSpecMetadataResource
- func (*JobSpecMetadataResource) Descriptor() ([]byte, []int)deprecated
- func (x *JobSpecMetadataResource) GetLimit() *JobSpecMetadataResourceConfig
- func (x *JobSpecMetadataResource) GetRequest() *JobSpecMetadataResourceConfig
- func (*JobSpecMetadataResource) ProtoMessage()
- func (x *JobSpecMetadataResource) ProtoReflect() protoreflect.Message
- func (x *JobSpecMetadataResource) Reset()
- func (x *JobSpecMetadataResource) String() string
- type JobSpecMetadataResourceConfig
- func (*JobSpecMetadataResourceConfig) Descriptor() ([]byte, []int)deprecated
- func (x *JobSpecMetadataResourceConfig) GetCpu() string
- func (x *JobSpecMetadataResourceConfig) GetMemory() string
- func (*JobSpecMetadataResourceConfig) ProtoMessage()
- func (x *JobSpecMetadataResourceConfig) ProtoReflect() protoreflect.Message
- func (x *JobSpecMetadataResourceConfig) Reset()
- func (x *JobSpecMetadataResourceConfig) String() string
- type JobSpecification
- func (*JobSpecification) Descriptor() ([]byte, []int)deprecated
- func (x *JobSpecification) GetAssets() map[string]string
- func (x *JobSpecification) GetBehavior() *JobSpecification_Behavior
- func (x *JobSpecification) GetCatchUp() booldeprecated
- func (x *JobSpecification) GetConfig() []*JobConfigItem
- func (x *JobSpecification) GetDependencies() []*JobDependency
- func (x *JobSpecification) GetDependsOnPast() bool
- func (x *JobSpecification) GetDescription() string
- func (x *JobSpecification) GetDestination() string
- func (x *JobSpecification) GetEndDate() string
- func (x *JobSpecification) GetHooks() []*JobSpecHook
- func (x *JobSpecification) GetInterval() string
- func (x *JobSpecification) GetLabels() map[string]string
- func (x *JobSpecification) GetMetadata() *JobMetadata
- func (x *JobSpecification) GetName() string
- func (x *JobSpecification) GetOwner() string
- func (x *JobSpecification) GetSources() []string
- func (x *JobSpecification) GetStartDate() string
- func (x *JobSpecification) GetTaskName() string
- func (x *JobSpecification) GetVersion() int32
- func (x *JobSpecification) GetWindowOffset() string
- func (x *JobSpecification) GetWindowSize() string
- func (x *JobSpecification) GetWindowTruncateTo() string
- func (*JobSpecification) ProtoMessage()
- func (x *JobSpecification) ProtoReflect() protoreflect.Message
- func (x *JobSpecification) Reset()
- func (x *JobSpecification) String() string
- type JobSpecificationResponse
- func (*JobSpecificationResponse) Descriptor() ([]byte, []int)deprecated
- func (x *JobSpecificationResponse) GetJob() *JobSpecification
- func (x *JobSpecificationResponse) GetNamespaceName() string
- func (x *JobSpecificationResponse) GetProjectName() string
- func (*JobSpecificationResponse) ProtoMessage()
- func (x *JobSpecificationResponse) ProtoReflect() protoreflect.Message
- func (x *JobSpecificationResponse) Reset()
- func (x *JobSpecificationResponse) String() string
- type JobSpecificationServiceClient
- type JobSpecificationServiceServer
- type JobSpecificationService_CheckJobSpecificationsClient
- type JobSpecificationService_CheckJobSpecificationsServer
- type JobSpecificationService_DeployJobSpecificationClient
- type JobSpecificationService_DeployJobSpecificationServer
- type JobSpecificationService_RefreshJobsClient
- type JobSpecificationService_RefreshJobsServer
- type JobSpecificationService_ReplaceAllJobSpecificationsClient
- type JobSpecificationService_ReplaceAllJobSpecificationsServer
- type JobSpecification_Behavior
- func (*JobSpecification_Behavior) Descriptor() ([]byte, []int)deprecated
- func (x *JobSpecification_Behavior) GetNotify() []*JobSpecification_Behavior_Notifiers
- func (x *JobSpecification_Behavior) GetRetry() *JobSpecification_Behavior_Retry
- func (*JobSpecification_Behavior) ProtoMessage()
- func (x *JobSpecification_Behavior) ProtoReflect() protoreflect.Message
- func (x *JobSpecification_Behavior) Reset()
- func (x *JobSpecification_Behavior) String() string
- type JobSpecification_Behavior_Notifiers
- func (*JobSpecification_Behavior_Notifiers) Descriptor() ([]byte, []int)deprecated
- func (x *JobSpecification_Behavior_Notifiers) GetChannels() []string
- func (x *JobSpecification_Behavior_Notifiers) GetConfig() map[string]string
- func (x *JobSpecification_Behavior_Notifiers) GetOn() JobEvent_Type
- func (*JobSpecification_Behavior_Notifiers) ProtoMessage()
- func (x *JobSpecification_Behavior_Notifiers) ProtoReflect() protoreflect.Message
- func (x *JobSpecification_Behavior_Notifiers) Reset()
- func (x *JobSpecification_Behavior_Notifiers) String() string
- type JobSpecification_Behavior_Retry
- func (*JobSpecification_Behavior_Retry) Descriptor() ([]byte, []int)deprecated
- func (x *JobSpecification_Behavior_Retry) GetCount() int32
- func (x *JobSpecification_Behavior_Retry) GetDelay() *durationpb.Duration
- func (x *JobSpecification_Behavior_Retry) GetExponentialBackoff() bool
- func (*JobSpecification_Behavior_Retry) ProtoMessage()
- func (x *JobSpecification_Behavior_Retry) ProtoReflect() protoreflect.Message
- func (x *JobSpecification_Behavior_Retry) Reset()
- func (x *JobSpecification_Behavior_Retry) String() string
- type JobTask
- func (*JobTask) Descriptor() ([]byte, []int)deprecated
- func (x *JobTask) GetDependencies() []*JobTask_Dependency
- func (x *JobTask) GetDescription() string
- func (x *JobTask) GetDestination() *JobTask_Destination
- func (x *JobTask) GetImage() string
- func (x *JobTask) GetName() string
- func (*JobTask) ProtoMessage()
- func (x *JobTask) ProtoReflect() protoreflect.Message
- func (x *JobTask) Reset()
- func (x *JobTask) String() string
- type JobTask_Dependency
- func (*JobTask_Dependency) Descriptor() ([]byte, []int)deprecated
- func (x *JobTask_Dependency) GetDependency() string
- func (*JobTask_Dependency) ProtoMessage()
- func (x *JobTask_Dependency) ProtoReflect() protoreflect.Message
- func (x *JobTask_Dependency) Reset()
- func (x *JobTask_Dependency) String() string
- type JobTask_Destination
- func (*JobTask_Destination) Descriptor() ([]byte, []int)deprecated
- func (x *JobTask_Destination) GetDestination() string
- func (x *JobTask_Destination) GetType() string
- func (*JobTask_Destination) ProtoMessage()
- func (x *JobTask_Destination) ProtoReflect() protoreflect.Message
- func (x *JobTask_Destination) Reset()
- func (x *JobTask_Destination) String() string
- type Level
- type ListBackupsRequest
- func (*ListBackupsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListBackupsRequest) GetDatastoreName() string
- func (x *ListBackupsRequest) GetNamespaceName() string
- func (x *ListBackupsRequest) GetProjectName() string
- func (*ListBackupsRequest) ProtoMessage()
- func (x *ListBackupsRequest) ProtoReflect() protoreflect.Message
- func (x *ListBackupsRequest) Reset()
- func (x *ListBackupsRequest) String() string
- type ListBackupsResponse
- func (*ListBackupsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListBackupsResponse) GetBackups() []*BackupSpec
- func (*ListBackupsResponse) ProtoMessage()
- func (x *ListBackupsResponse) ProtoReflect() protoreflect.Message
- func (x *ListBackupsResponse) Reset()
- func (x *ListBackupsResponse) String() string
- type ListJobSpecificationRequest
- func (*ListJobSpecificationRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListJobSpecificationRequest) GetNamespaceName() string
- func (x *ListJobSpecificationRequest) GetProjectName() string
- func (*ListJobSpecificationRequest) ProtoMessage()
- func (x *ListJobSpecificationRequest) ProtoReflect() protoreflect.Message
- func (x *ListJobSpecificationRequest) Reset()
- func (x *ListJobSpecificationRequest) String() string
- type ListJobSpecificationResponse
- func (*ListJobSpecificationResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListJobSpecificationResponse) GetJobs() []*JobSpecification
- func (*ListJobSpecificationResponse) ProtoMessage()
- func (x *ListJobSpecificationResponse) ProtoReflect() protoreflect.Message
- func (x *ListJobSpecificationResponse) Reset()
- func (x *ListJobSpecificationResponse) String() string
- type ListProjectNamespacesRequest
- func (*ListProjectNamespacesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListProjectNamespacesRequest) GetProjectName() string
- func (*ListProjectNamespacesRequest) ProtoMessage()
- func (x *ListProjectNamespacesRequest) ProtoReflect() protoreflect.Message
- func (x *ListProjectNamespacesRequest) Reset()
- func (x *ListProjectNamespacesRequest) String() string
- type ListProjectNamespacesResponse
- func (*ListProjectNamespacesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListProjectNamespacesResponse) GetNamespaces() []*NamespaceSpecification
- func (*ListProjectNamespacesResponse) ProtoMessage()
- func (x *ListProjectNamespacesResponse) ProtoReflect() protoreflect.Message
- func (x *ListProjectNamespacesResponse) Reset()
- func (x *ListProjectNamespacesResponse) String() string
- type ListProjectsRequest
- type ListProjectsResponse
- func (*ListProjectsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListProjectsResponse) GetProjects() []*ProjectSpecification
- func (*ListProjectsResponse) ProtoMessage()
- func (x *ListProjectsResponse) ProtoReflect() protoreflect.Message
- func (x *ListProjectsResponse) Reset()
- func (x *ListProjectsResponse) String() string
- type ListReplayRequest
- func (*ListReplayRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListReplayRequest) GetProjectName() string
- func (*ListReplayRequest) ProtoMessage()
- func (x *ListReplayRequest) ProtoReflect() protoreflect.Message
- func (x *ListReplayRequest) Reset()
- func (x *ListReplayRequest) String() string
- type ListReplayResponse
- func (*ListReplayResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListReplayResponse) GetReplays() []*GetReplayResponse
- func (*ListReplayResponse) ProtoMessage()
- func (x *ListReplayResponse) ProtoReflect() protoreflect.Message
- func (x *ListReplayResponse) Reset()
- func (x *ListReplayResponse) String() string
- type ListResourceSpecificationRequest
- func (*ListResourceSpecificationRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListResourceSpecificationRequest) GetDatastoreName() string
- func (x *ListResourceSpecificationRequest) GetNamespaceName() string
- func (x *ListResourceSpecificationRequest) GetProjectName() string
- func (*ListResourceSpecificationRequest) ProtoMessage()
- func (x *ListResourceSpecificationRequest) ProtoReflect() protoreflect.Message
- func (x *ListResourceSpecificationRequest) Reset()
- func (x *ListResourceSpecificationRequest) String() string
- type ListResourceSpecificationResponse
- func (*ListResourceSpecificationResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListResourceSpecificationResponse) GetResources() []*ResourceSpecification
- func (*ListResourceSpecificationResponse) ProtoMessage()
- func (x *ListResourceSpecificationResponse) ProtoReflect() protoreflect.Message
- func (x *ListResourceSpecificationResponse) Reset()
- func (x *ListResourceSpecificationResponse) String() string
- type ListSecretsRequest
- func (*ListSecretsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListSecretsRequest) GetProjectName() string
- func (*ListSecretsRequest) ProtoMessage()
- func (x *ListSecretsRequest) ProtoReflect() protoreflect.Message
- func (x *ListSecretsRequest) Reset()
- func (x *ListSecretsRequest) String() string
- type ListSecretsResponse
- func (*ListSecretsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListSecretsResponse) GetSecrets() []*ListSecretsResponse_Secret
- func (*ListSecretsResponse) ProtoMessage()
- func (x *ListSecretsResponse) ProtoReflect() protoreflect.Message
- func (x *ListSecretsResponse) Reset()
- func (x *ListSecretsResponse) String() string
- type ListSecretsResponse_Secret
- func (*ListSecretsResponse_Secret) Descriptor() ([]byte, []int)deprecated
- func (x *ListSecretsResponse_Secret) GetDigest() string
- func (x *ListSecretsResponse_Secret) GetName() string
- func (x *ListSecretsResponse_Secret) GetNamespace() string
- func (x *ListSecretsResponse_Secret) GetUpdatedAt() *timestamppb.Timestamp
- func (*ListSecretsResponse_Secret) ProtoMessage()
- func (x *ListSecretsResponse_Secret) ProtoReflect() protoreflect.Message
- func (x *ListSecretsResponse_Secret) Reset()
- func (x *ListSecretsResponse_Secret) String() string
- type Log
- type NamespaceServiceClient
- type NamespaceServiceServer
- type NamespaceSpecification
- func (*NamespaceSpecification) Descriptor() ([]byte, []int)deprecated
- func (x *NamespaceSpecification) GetConfig() map[string]string
- func (x *NamespaceSpecification) GetName() string
- func (*NamespaceSpecification) ProtoMessage()
- func (x *NamespaceSpecification) ProtoReflect() protoreflect.Message
- func (x *NamespaceSpecification) Reset()
- func (x *NamespaceSpecification) String() string
- type ProjectServiceClient
- type ProjectServiceServer
- type ProjectSpecification
- func (*ProjectSpecification) Descriptor() ([]byte, []int)deprecated
- func (x *ProjectSpecification) GetConfig() map[string]string
- func (x *ProjectSpecification) GetName() string
- func (x *ProjectSpecification) GetSecrets() []*ProjectSpecification_ProjectSecret
- func (*ProjectSpecification) ProtoMessage()
- func (x *ProjectSpecification) ProtoReflect() protoreflect.Message
- func (x *ProjectSpecification) Reset()
- func (x *ProjectSpecification) String() string
- type ProjectSpecification_ProjectSecret
- func (*ProjectSpecification_ProjectSecret) Descriptor() ([]byte, []int)deprecated
- func (x *ProjectSpecification_ProjectSecret) GetName() string
- func (x *ProjectSpecification_ProjectSecret) GetValue() string
- func (*ProjectSpecification_ProjectSecret) ProtoMessage()
- func (x *ProjectSpecification_ProjectSecret) ProtoReflect() protoreflect.Message
- func (x *ProjectSpecification_ProjectSecret) Reset()
- func (x *ProjectSpecification_ProjectSecret) String() string
- type ReadResourceRequest
- func (*ReadResourceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReadResourceRequest) GetDatastoreName() string
- func (x *ReadResourceRequest) GetNamespaceName() string
- func (x *ReadResourceRequest) GetProjectName() string
- func (x *ReadResourceRequest) GetResourceName() string
- func (*ReadResourceRequest) ProtoMessage()
- func (x *ReadResourceRequest) ProtoReflect() protoreflect.Message
- func (x *ReadResourceRequest) Reset()
- func (x *ReadResourceRequest) String() string
- type ReadResourceResponse
- func (*ReadResourceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ReadResourceResponse) GetMessage() string
- func (x *ReadResourceResponse) GetResource() *ResourceSpecification
- func (x *ReadResourceResponse) GetSuccess() bool
- func (*ReadResourceResponse) ProtoMessage()
- func (x *ReadResourceResponse) ProtoReflect() protoreflect.Message
- func (x *ReadResourceResponse) Reset()
- func (x *ReadResourceResponse) String() string
- type RefreshJobsRequest
- func (*RefreshJobsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RefreshJobsRequest) GetJobNames() []string
- func (x *RefreshJobsRequest) GetNamespaceNames() []string
- func (x *RefreshJobsRequest) GetProjectName() string
- func (*RefreshJobsRequest) ProtoMessage()
- func (x *RefreshJobsRequest) ProtoReflect() protoreflect.Message
- func (x *RefreshJobsRequest) Reset()
- func (x *RefreshJobsRequest) String() string
- type RefreshJobsResponse
- func (*RefreshJobsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RefreshJobsResponse) GetLogStatus() *Log
- func (*RefreshJobsResponse) ProtoMessage()
- func (x *RefreshJobsResponse) ProtoReflect() protoreflect.Message
- func (x *RefreshJobsResponse) Reset()
- func (x *RefreshJobsResponse) String() string
- type RegisterJobEventRequest
- func (*RegisterJobEventRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterJobEventRequest) GetEvent() *JobEvent
- func (x *RegisterJobEventRequest) GetJobName() string
- func (x *RegisterJobEventRequest) GetNamespaceName() string
- func (x *RegisterJobEventRequest) GetProjectName() string
- func (*RegisterJobEventRequest) ProtoMessage()
- func (x *RegisterJobEventRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterJobEventRequest) Reset()
- func (x *RegisterJobEventRequest) String() string
- type RegisterJobEventResponse
- type RegisterProjectNamespaceRequest
- func (*RegisterProjectNamespaceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterProjectNamespaceRequest) GetNamespace() *NamespaceSpecification
- func (x *RegisterProjectNamespaceRequest) GetProjectName() string
- func (*RegisterProjectNamespaceRequest) ProtoMessage()
- func (x *RegisterProjectNamespaceRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterProjectNamespaceRequest) Reset()
- func (x *RegisterProjectNamespaceRequest) String() string
- type RegisterProjectNamespaceResponse
- func (*RegisterProjectNamespaceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterProjectNamespaceResponse) GetMessage() string
- func (x *RegisterProjectNamespaceResponse) GetSuccess() bool
- func (*RegisterProjectNamespaceResponse) ProtoMessage()
- func (x *RegisterProjectNamespaceResponse) ProtoReflect() protoreflect.Message
- func (x *RegisterProjectNamespaceResponse) Reset()
- func (x *RegisterProjectNamespaceResponse) String() string
- type RegisterProjectRequest
- func (*RegisterProjectRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterProjectRequest) GetProject() *ProjectSpecification
- func (*RegisterProjectRequest) ProtoMessage()
- func (x *RegisterProjectRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterProjectRequest) Reset()
- func (x *RegisterProjectRequest) String() string
- type RegisterProjectResponse
- func (*RegisterProjectResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterProjectResponse) GetMessage() string
- func (x *RegisterProjectResponse) GetSuccess() bool
- func (*RegisterProjectResponse) ProtoMessage()
- func (x *RegisterProjectResponse) ProtoReflect() protoreflect.Message
- func (x *RegisterProjectResponse) Reset()
- func (x *RegisterProjectResponse) String() string
- type RegisterSecretRequest
- func (*RegisterSecretRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterSecretRequest) GetNamespaceName() string
- func (x *RegisterSecretRequest) GetProjectName() string
- func (x *RegisterSecretRequest) GetSecretName() string
- func (x *RegisterSecretRequest) GetValue() string
- func (*RegisterSecretRequest) ProtoMessage()
- func (x *RegisterSecretRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterSecretRequest) Reset()
- func (x *RegisterSecretRequest) String() string
- type RegisterSecretResponse
- type ReplaceAllJobSpecificationsRequest
- func (*ReplaceAllJobSpecificationsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReplaceAllJobSpecificationsRequest) GetJobs() []*JobSpecification
- func (x *ReplaceAllJobSpecificationsRequest) GetNamespaceName() string
- func (x *ReplaceAllJobSpecificationsRequest) GetProjectName() string
- func (*ReplaceAllJobSpecificationsRequest) ProtoMessage()
- func (x *ReplaceAllJobSpecificationsRequest) ProtoReflect() protoreflect.Message
- func (x *ReplaceAllJobSpecificationsRequest) Reset()
- func (x *ReplaceAllJobSpecificationsRequest) String() string
- type ReplaceAllJobSpecificationsResponse
- func (*ReplaceAllJobSpecificationsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ReplaceAllJobSpecificationsResponse) GetLogStatus() *Log
- func (*ReplaceAllJobSpecificationsResponse) ProtoMessage()
- func (x *ReplaceAllJobSpecificationsResponse) ProtoReflect() protoreflect.Message
- func (x *ReplaceAllJobSpecificationsResponse) Reset()
- func (x *ReplaceAllJobSpecificationsResponse) String() string
- type ReplayConfig
- func (*ReplayConfig) Descriptor() ([]byte, []int)deprecated
- func (x *ReplayConfig) GetDescription() string
- func (x *ReplayConfig) GetEndTime() *timestamppb.Timestamp
- func (x *ReplayConfig) GetJobConfig() map[string]string
- func (x *ReplayConfig) GetParallel() bool
- func (x *ReplayConfig) GetStartTime() *timestamppb.Timestamp
- func (*ReplayConfig) ProtoMessage()
- func (x *ReplayConfig) ProtoReflect() protoreflect.Message
- func (x *ReplayConfig) Reset()
- func (x *ReplayConfig) String() string
- type ReplayRequest
- func (*ReplayRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReplayRequest) GetDescription() string
- func (x *ReplayRequest) GetEndTime() *timestamppb.Timestamp
- func (x *ReplayRequest) GetJobConfig() string
- func (x *ReplayRequest) GetJobName() string
- func (x *ReplayRequest) GetNamespaceName() string
- func (x *ReplayRequest) GetParallel() bool
- func (x *ReplayRequest) GetProjectName() string
- func (x *ReplayRequest) GetStartTime() *timestamppb.Timestamp
- func (*ReplayRequest) ProtoMessage()
- func (x *ReplayRequest) ProtoReflect() protoreflect.Message
- func (x *ReplayRequest) Reset()
- func (x *ReplayRequest) String() string
- type ReplayResponse
- type ReplayRun
- func (*ReplayRun) Descriptor() ([]byte, []int)deprecated
- func (x *ReplayRun) GetScheduledAt() *timestamppb.Timestamp
- func (x *ReplayRun) GetStatus() string
- func (*ReplayRun) ProtoMessage()
- func (x *ReplayRun) ProtoReflect() protoreflect.Message
- func (x *ReplayRun) Reset()
- func (x *ReplayRun) String() string
- type ReplayServiceClient
- type ReplayServiceServer
- type ResourceServiceClient
- type ResourceServiceServer
- type ResourceService_DeployResourceSpecificationClient
- type ResourceService_DeployResourceSpecificationServer
- type ResourceSpecification
- func (*ResourceSpecification) Descriptor() ([]byte, []int)deprecated
- func (x *ResourceSpecification) GetAssets() map[string]string
- func (x *ResourceSpecification) GetLabels() map[string]string
- func (x *ResourceSpecification) GetName() string
- func (x *ResourceSpecification) GetSpec() *structpb.Struct
- func (x *ResourceSpecification) GetType() string
- func (x *ResourceSpecification) GetVersion() int32
- func (*ResourceSpecification) ProtoMessage()
- func (x *ResourceSpecification) ProtoReflect() protoreflect.Message
- func (x *ResourceSpecification) Reset()
- func (x *ResourceSpecification) String() string
- type RuntimeServiceClient
- type RuntimeServiceServer
- type SecretServiceClient
- type SecretServiceServer
- type TaskWindow
- func (*TaskWindow) Descriptor() ([]byte, []int)deprecated
- func (x *TaskWindow) GetOffset() *durationpb.Duration
- func (x *TaskWindow) GetSize() *durationpb.Duration
- func (x *TaskWindow) GetTruncateTo() string
- func (*TaskWindow) ProtoMessage()
- func (x *TaskWindow) ProtoReflect() protoreflect.Message
- func (x *TaskWindow) Reset()
- func (x *TaskWindow) String() string
- type UnimplementedBackupServiceServer
- func (UnimplementedBackupServiceServer) CreateBackup(context.Context, *CreateBackupRequest) (*CreateBackupResponse, error)
- func (UnimplementedBackupServiceServer) GetBackup(context.Context, *GetBackupRequest) (*GetBackupResponse, error)
- func (UnimplementedBackupServiceServer) ListBackups(context.Context, *ListBackupsRequest) (*ListBackupsResponse, error)
- type UnimplementedJobRunServiceServer
- func (UnimplementedJobRunServiceServer) JobRun(context.Context, *JobRunRequest) (*JobRunResponse, error)
- func (UnimplementedJobRunServiceServer) JobRunInput(context.Context, *JobRunInputRequest) (*JobRunInputResponse, error)
- func (UnimplementedJobRunServiceServer) RegisterJobEvent(context.Context, *RegisterJobEventRequest) (*RegisterJobEventResponse, error)
- func (UnimplementedJobRunServiceServer) UploadToScheduler(context.Context, *UploadToSchedulerRequest) (*UploadToSchedulerResponse, error)
- type UnimplementedJobSpecificationServiceServer
- func (UnimplementedJobSpecificationServiceServer) AddJobSpecifications(context.Context, *AddJobSpecificationsRequest) (*AddJobSpecificationsResponse, error)
- func (UnimplementedJobSpecificationServiceServer) ChangeJobNamespace(context.Context, *ChangeJobNamespaceRequest) (*ChangeJobNamespaceResponse, error)
- func (UnimplementedJobSpecificationServiceServer) CheckJobSpecification(context.Context, *CheckJobSpecificationRequest) (*CheckJobSpecificationResponse, error)
- func (UnimplementedJobSpecificationServiceServer) CheckJobSpecifications(*CheckJobSpecificationsRequest, ...) error
- func (UnimplementedJobSpecificationServiceServer) CreateJobSpecification(context.Context, *CreateJobSpecificationRequest) (*CreateJobSpecificationResponse, error)
- func (UnimplementedJobSpecificationServiceServer) DeleteJobSpecification(context.Context, *DeleteJobSpecificationRequest) (*DeleteJobSpecificationResponse, error)
- func (UnimplementedJobSpecificationServiceServer) DeployJobSpecification(JobSpecificationService_DeployJobSpecificationServer) error
- func (UnimplementedJobSpecificationServiceServer) GetDeployJobsStatus(context.Context, *GetDeployJobsStatusRequest) (*GetDeployJobsStatusResponse, error)
- func (UnimplementedJobSpecificationServiceServer) GetJobSpecification(context.Context, *GetJobSpecificationRequest) (*GetJobSpecificationResponse, error)
- func (UnimplementedJobSpecificationServiceServer) GetJobSpecifications(context.Context, *GetJobSpecificationsRequest) (*GetJobSpecificationsResponse, error)
- func (UnimplementedJobSpecificationServiceServer) GetJobTask(context.Context, *GetJobTaskRequest) (*GetJobTaskResponse, error)
- func (UnimplementedJobSpecificationServiceServer) GetWindow(context.Context, *GetWindowRequest) (*GetWindowResponse, error)
- func (UnimplementedJobSpecificationServiceServer) JobInspect(context.Context, *JobInspectRequest) (*JobInspectResponse, error)
- func (UnimplementedJobSpecificationServiceServer) ListJobSpecification(context.Context, *ListJobSpecificationRequest) (*ListJobSpecificationResponse, error)
- func (UnimplementedJobSpecificationServiceServer) RefreshJobs(*RefreshJobsRequest, JobSpecificationService_RefreshJobsServer) error
- func (UnimplementedJobSpecificationServiceServer) ReplaceAllJobSpecifications(JobSpecificationService_ReplaceAllJobSpecificationsServer) error
- func (UnimplementedJobSpecificationServiceServer) UpdateJobSpecifications(context.Context, *UpdateJobSpecificationsRequest) (*UpdateJobSpecificationsResponse, error)
- type UnimplementedNamespaceServiceServer
- func (UnimplementedNamespaceServiceServer) GetNamespace(context.Context, *GetNamespaceRequest) (*GetNamespaceResponse, error)
- func (UnimplementedNamespaceServiceServer) ListProjectNamespaces(context.Context, *ListProjectNamespacesRequest) (*ListProjectNamespacesResponse, error)
- func (UnimplementedNamespaceServiceServer) RegisterProjectNamespace(context.Context, *RegisterProjectNamespaceRequest) (*RegisterProjectNamespaceResponse, error)
- type UnimplementedProjectServiceServer
- func (UnimplementedProjectServiceServer) GetProject(context.Context, *GetProjectRequest) (*GetProjectResponse, error)
- func (UnimplementedProjectServiceServer) ListProjects(context.Context, *ListProjectsRequest) (*ListProjectsResponse, error)
- func (UnimplementedProjectServiceServer) RegisterProject(context.Context, *RegisterProjectRequest) (*RegisterProjectResponse, error)
- type UnimplementedReplayServiceServer
- func (UnimplementedReplayServiceServer) GetReplay(context.Context, *GetReplayRequest) (*GetReplayResponse, error)
- func (UnimplementedReplayServiceServer) ListReplay(context.Context, *ListReplayRequest) (*ListReplayResponse, error)
- func (UnimplementedReplayServiceServer) Replay(context.Context, *ReplayRequest) (*ReplayResponse, error)
- type UnimplementedResourceServiceServer
- func (UnimplementedResourceServiceServer) ChangeResourceNamespace(context.Context, *ChangeResourceNamespaceRequest) (*ChangeResourceNamespaceResponse, error)
- func (UnimplementedResourceServiceServer) CreateResource(context.Context, *CreateResourceRequest) (*CreateResourceResponse, error)
- func (UnimplementedResourceServiceServer) DeployResourceSpecification(ResourceService_DeployResourceSpecificationServer) error
- func (UnimplementedResourceServiceServer) ListResourceSpecification(context.Context, *ListResourceSpecificationRequest) (*ListResourceSpecificationResponse, error)
- func (UnimplementedResourceServiceServer) ReadResource(context.Context, *ReadResourceRequest) (*ReadResourceResponse, error)
- func (UnimplementedResourceServiceServer) UpdateResource(context.Context, *UpdateResourceRequest) (*UpdateResourceResponse, error)
- type UnimplementedRuntimeServiceServer
- type UnimplementedSecretServiceServer
- func (UnimplementedSecretServiceServer) DeleteSecret(context.Context, *DeleteSecretRequest) (*DeleteSecretResponse, error)
- func (UnimplementedSecretServiceServer) ListSecrets(context.Context, *ListSecretsRequest) (*ListSecretsResponse, error)
- func (UnimplementedSecretServiceServer) RegisterSecret(context.Context, *RegisterSecretRequest) (*RegisterSecretResponse, error)
- func (UnimplementedSecretServiceServer) UpdateSecret(context.Context, *UpdateSecretRequest) (*UpdateSecretResponse, error)
- type UnsafeBackupServiceServer
- type UnsafeJobRunServiceServer
- type UnsafeJobSpecificationServiceServer
- type UnsafeNamespaceServiceServer
- type UnsafeProjectServiceServer
- type UnsafeReplayServiceServer
- type UnsafeResourceServiceServer
- type UnsafeRuntimeServiceServer
- type UnsafeSecretServiceServer
- type UpdateJobSpecificationsRequest
- func (*UpdateJobSpecificationsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateJobSpecificationsRequest) GetNamespaceName() string
- func (x *UpdateJobSpecificationsRequest) GetProjectName() string
- func (x *UpdateJobSpecificationsRequest) GetSpecs() []*JobSpecification
- func (*UpdateJobSpecificationsRequest) ProtoMessage()
- func (x *UpdateJobSpecificationsRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateJobSpecificationsRequest) Reset()
- func (x *UpdateJobSpecificationsRequest) String() string
- type UpdateJobSpecificationsResponse
- func (*UpdateJobSpecificationsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateJobSpecificationsResponse) GetLog() string
- func (*UpdateJobSpecificationsResponse) ProtoMessage()
- func (x *UpdateJobSpecificationsResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateJobSpecificationsResponse) Reset()
- func (x *UpdateJobSpecificationsResponse) String() string
- type UpdateResourceRequest
- func (*UpdateResourceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateResourceRequest) GetDatastoreName() string
- func (x *UpdateResourceRequest) GetNamespaceName() string
- func (x *UpdateResourceRequest) GetProjectName() string
- func (x *UpdateResourceRequest) GetResource() *ResourceSpecification
- func (*UpdateResourceRequest) ProtoMessage()
- func (x *UpdateResourceRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateResourceRequest) Reset()
- func (x *UpdateResourceRequest) String() string
- type UpdateResourceResponse
- func (*UpdateResourceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateResourceResponse) GetMessage() string
- func (x *UpdateResourceResponse) GetSuccess() bool
- func (*UpdateResourceResponse) ProtoMessage()
- func (x *UpdateResourceResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateResourceResponse) Reset()
- func (x *UpdateResourceResponse) String() string
- type UpdateSecretRequest
- func (*UpdateSecretRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateSecretRequest) GetNamespaceName() string
- func (x *UpdateSecretRequest) GetProjectName() string
- func (x *UpdateSecretRequest) GetSecretName() string
- func (x *UpdateSecretRequest) GetValue() string
- func (*UpdateSecretRequest) ProtoMessage()
- func (x *UpdateSecretRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateSecretRequest) Reset()
- func (x *UpdateSecretRequest) String() string
- type UpdateSecretResponse
- type UploadToSchedulerRequest
- func (*UploadToSchedulerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UploadToSchedulerRequest) GetNamespaceName() string
- func (x *UploadToSchedulerRequest) GetProjectName() string
- func (*UploadToSchedulerRequest) ProtoMessage()
- func (x *UploadToSchedulerRequest) ProtoReflect() protoreflect.Message
- func (x *UploadToSchedulerRequest) Reset()
- func (x *UploadToSchedulerRequest) String() string
- type UploadToSchedulerResponse
- func (*UploadToSchedulerResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UploadToSchedulerResponse) GetErrorMessage() string
- func (x *UploadToSchedulerResponse) GetStatus() bool
- func (*UploadToSchedulerResponse) ProtoMessage()
- func (x *UploadToSchedulerResponse) ProtoReflect() protoreflect.Message
- func (x *UploadToSchedulerResponse) Reset()
- func (x *UploadToSchedulerResponse) String() string
- type VersionRequest
- type VersionResponse
Constants ¶
This section is empty.
Variables ¶
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.
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.
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.
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.
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)
var File_gotocompany_optimus_core_v1beta1_backup_proto protoreflect.FileDescriptor
var File_gotocompany_optimus_core_v1beta1_job_run_proto protoreflect.FileDescriptor
var File_gotocompany_optimus_core_v1beta1_job_spec_proto protoreflect.FileDescriptor
var File_gotocompany_optimus_core_v1beta1_namespace_proto protoreflect.FileDescriptor
var File_gotocompany_optimus_core_v1beta1_project_proto protoreflect.FileDescriptor
var File_gotocompany_optimus_core_v1beta1_replay_proto protoreflect.FileDescriptor
var File_gotocompany_optimus_core_v1beta1_resource_proto protoreflect.FileDescriptor
var File_gotocompany_optimus_core_v1beta1_runtime_proto protoreflect.FileDescriptor
var File_gotocompany_optimus_core_v1beta1_secret_proto protoreflect.FileDescriptor
var File_gotocompany_optimus_core_v1beta1_status_proto protoreflect.FileDescriptor
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)
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, }, }, 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)
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)
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)
var ReplayService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "gotocompany.optimus.core.v1beta1.ReplayService", HandlerType: (*ReplayServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Replay", Handler: _ReplayService_Replay_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)
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, }, }, 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)
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)
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 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) GetType ¶
func (x *JobEvent) GetType() JobEvent_Type
func (*JobEvent) ProtoMessage ¶
func (*JobEvent) ProtoMessage()
func (*JobEvent) ProtoReflect ¶
func (x *JobEvent) ProtoReflect() protoreflect.Message
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) GetScheduledAt ¶
func (x *JobRun) GetScheduledAt() *timestamppb.Timestamp
func (*JobRun) ProtoMessage ¶
func (*JobRun) ProtoMessage()
func (*JobRun) ProtoReflect ¶
func (x *JobRun) ProtoReflect() protoreflect.Message
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) }
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) // 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 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) GetDependencies ¶
func (x *JobTask) GetDependencies() []*JobTask_Dependency
func (*JobTask) GetDescription ¶
func (*JobTask) GetDestination ¶
func (x *JobTask) GetDestination() *JobTask_Destination
func (*JobTask) ProtoMessage ¶
func (*JobTask) ProtoMessage()
func (*JobTask) ProtoReflect ¶
func (x *JobTask) ProtoReflect() protoreflect.Message
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
func (Level) Descriptor ¶
func (Level) Descriptor() protoreflect.EnumDescriptor
func (Level) EnumDescriptor
deprecated
func (Level) Number ¶
func (x Level) Number() protoreflect.EnumNumber
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) GetMessage ¶
func (*Log) ProtoMessage ¶
func (*Log) ProtoMessage()
func (*Log) ProtoReflect ¶
func (x *Log) ProtoReflect() protoreflect.Message
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 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) GetScheduledAt ¶ added in v0.7.0
func (x *ReplayRun) GetScheduledAt() *timestamppb.Timestamp
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
type ReplayServiceClient ¶
type ReplayServiceClient interface { Replay(ctx context.Context, in *ReplayRequest, opts ...grpc.CallOption) (*ReplayResponse, 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) 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) }
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) // 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 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) ReplaceAllJobSpecifications ¶
func (UnimplementedJobSpecificationServiceServer) ReplaceAllJobSpecifications(JobSpecificationService_ReplaceAllJobSpecificationsServer) error
func (UnimplementedJobSpecificationServiceServer) UpdateJobSpecifications ¶
func (UnimplementedJobSpecificationServiceServer) UpdateJobSpecifications(context.Context, *UpdateJobSpecificationsRequest) (*UpdateJobSpecificationsResponse, 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)
type UnimplementedResourceServiceServer ¶
type UnimplementedResourceServiceServer struct { }
UnimplementedResourceServiceServer must be embedded to have forward compatible implementations.
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 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 ¶
- backup.pb.go
- backup.pb.gw.go
- backup_grpc.pb.go
- job_run.pb.go
- job_run.pb.gw.go
- job_run_grpc.pb.go
- job_spec.pb.go
- job_spec.pb.gw.go
- job_spec_grpc.pb.go
- namespace.pb.go
- namespace.pb.gw.go
- namespace_grpc.pb.go
- project.pb.go
- project.pb.gw.go
- project_grpc.pb.go
- replay.pb.go
- replay.pb.gw.go
- replay_grpc.pb.go
- resource.pb.go
- resource.pb.gw.go
- resource_grpc.pb.go
- runtime.pb.go
- runtime.pb.gw.go
- runtime_grpc.pb.go
- secret.pb.go
- secret.pb.gw.go
- secret_grpc.pb.go
- status.pb.go