optimus

package

Go to main page

Versions in this module

v0

v0.18.2

Nov 15, 2024

v0.18.1

Nov 15, 2024

v0.18.0

Nov 15, 2024

Changes in this version

type JobEvent_Type

+ const JobEvent_TYPE_REPLAY_LIFECYCLE

type JobSpecification_Behavior_Notifiers

+ Severity string

+ Team string

+ func (x *JobSpecification_Behavior_Notifiers) GetSeverity() string

+ func (x *JobSpecification_Behavior_Notifiers) GetTeam() string

v0.17.3

Nov 7, 2024

Changes in this version

+ type JobRunWithDetail struct

+ EndTime *timestamppb.Timestamp

+ ScheduledAt *timestamppb.Timestamp

+ StartTime *timestamppb.Timestamp

+ State string

+ func (*JobRunWithDetail) Descriptor() ([]byte, []int)

+ func (*JobRunWithDetail) ProtoMessage()

+ func (x *JobRunWithDetail) GetEndTime() *timestamppb.Timestamp

+ func (x *JobRunWithDetail) GetScheduledAt() *timestamppb.Timestamp

+ func (x *JobRunWithDetail) GetStartTime() *timestamppb.Timestamp

+ func (x *JobRunWithDetail) GetState() string

+ func (x *JobRunWithDetail) ProtoReflect() protoreflect.Message

+ func (x *JobRunWithDetail) Reset()

+ func (x *JobRunWithDetail) String() string

v0.17.2

Oct 29, 2024

v0.17.1

Oct 23, 2024

v0.17.0

Oct 21, 2024

Changes in this version

+ type GetJobRunsRequest struct

+ JobName string

+ ProjectName string

+ Since *timestamppb.Timestamp

+ State string

+ Until *timestamppb.Timestamp

+ func (*GetJobRunsRequest) Descriptor() ([]byte, []int)

+ func (*GetJobRunsRequest) ProtoMessage()

+ func (x *GetJobRunsRequest) GetJobName() string

+ func (x *GetJobRunsRequest) GetProjectName() string

+ func (x *GetJobRunsRequest) GetSince() *timestamppb.Timestamp

+ func (x *GetJobRunsRequest) GetState() string

+ func (x *GetJobRunsRequest) GetUntil() *timestamppb.Timestamp

+ func (x *GetJobRunsRequest) ProtoReflect() protoreflect.Message

+ func (x *GetJobRunsRequest) Reset()

+ func (x *GetJobRunsRequest) String() string

+ type GetJobRunsResponse struct

+ JobRuns []*JobRun

+ func (*GetJobRunsResponse) Descriptor() ([]byte, []int)

+ func (*GetJobRunsResponse) ProtoMessage()

+ func (x *GetJobRunsResponse) GetJobRuns() []*JobRun

+ func (x *GetJobRunsResponse) ProtoReflect() protoreflect.Message

+ func (x *GetJobRunsResponse) Reset()

+ func (x *GetJobRunsResponse) String() string

type JobRunServiceClient

+ GetJobRuns func(ctx context.Context, in *GetJobRunsRequest, opts ...grpc.CallOption) (*GetJobRunsResponse, error)

type JobRunServiceServer

+ GetJobRuns func(context.Context, *GetJobRunsRequest) (*GetJobRunsResponse, error)

type NamespaceSpecification

+ Variables map[string]string

+ func (x *NamespaceSpecification) GetVariables() map[string]string

type ProjectSpecification

+ Variables map[string]string

+ func (x *ProjectSpecification) GetVariables() map[string]string

type UnimplementedJobRunServiceServer

+ func (UnimplementedJobRunServiceServer) GetJobRuns(context.Context, *GetJobRunsRequest) (*GetJobRunsResponse, error)

v0.16.2

Sep 24, 2024

v0.16.1

Sep 10, 2024

Changes in this version

+ type GetReplayDetailsRequest struct

+ JobNames []string

+ ProjectName string

+ ReplayId string

+ ScheduledAt *timestamppb.Timestamp

+ Status string

+ func (*GetReplayDetailsRequest) Descriptor() ([]byte, []int)

+ func (*GetReplayDetailsRequest) ProtoMessage()

+ func (x *GetReplayDetailsRequest) GetJobNames() []string

+ func (x *GetReplayDetailsRequest) GetProjectName() string

+ func (x *GetReplayDetailsRequest) GetReplayId() string

+ func (x *GetReplayDetailsRequest) GetScheduledAt() *timestamppb.Timestamp

+ func (x *GetReplayDetailsRequest) GetStatus() string

+ func (x *GetReplayDetailsRequest) ProtoReflect() protoreflect.Message

+ func (x *GetReplayDetailsRequest) Reset()

+ func (x *GetReplayDetailsRequest) String() string

+ type GetReplayDetailsResponse struct

+ Replays []*GetReplayResponse

+ func (*GetReplayDetailsResponse) Descriptor() ([]byte, []int)

+ func (*GetReplayDetailsResponse) ProtoMessage()

+ func (x *GetReplayDetailsResponse) GetReplays() []*GetReplayResponse

+ func (x *GetReplayDetailsResponse) ProtoReflect() protoreflect.Message

+ func (x *GetReplayDetailsResponse) Reset()

+ func (x *GetReplayDetailsResponse) String() string

type ReplayServiceClient

+ GetReplayDetails func(ctx context.Context, in *GetReplayDetailsRequest, opts ...grpc.CallOption) (*GetReplayDetailsResponse, error)

type ReplayServiceServer

+ GetReplayDetails func(context.Context, *GetReplayDetailsRequest) (*GetReplayDetailsResponse, error)

type UnimplementedReplayServiceServer

+ func (UnimplementedReplayServiceServer) GetReplayDetails(context.Context, *GetReplayDetailsRequest) (*GetReplayDetailsResponse, error)

v0.16.0

Aug 5, 2024

Changes in this version

+ type BulkDeleteJobsRequest struct

+ Jobs []*BulkDeleteJobsRequest_JobToDelete

+ ProjectName string

+ func (*BulkDeleteJobsRequest) Descriptor() ([]byte, []int)

+ func (*BulkDeleteJobsRequest) ProtoMessage()

+ func (x *BulkDeleteJobsRequest) GetJobs() []*BulkDeleteJobsRequest_JobToDelete

+ func (x *BulkDeleteJobsRequest) GetProjectName() string

+ func (x *BulkDeleteJobsRequest) ProtoReflect() protoreflect.Message

+ func (x *BulkDeleteJobsRequest) Reset()

+ func (x *BulkDeleteJobsRequest) String() string

+ type BulkDeleteJobsRequest_JobToDelete struct

+ JobName string

+ NamespaceName string

+ func (*BulkDeleteJobsRequest_JobToDelete) Descriptor() ([]byte, []int)

+ func (*BulkDeleteJobsRequest_JobToDelete) ProtoMessage()

+ func (x *BulkDeleteJobsRequest_JobToDelete) GetJobName() string

+ func (x *BulkDeleteJobsRequest_JobToDelete) GetNamespaceName() string

+ func (x *BulkDeleteJobsRequest_JobToDelete) ProtoReflect() protoreflect.Message

+ func (x *BulkDeleteJobsRequest_JobToDelete) Reset()

+ func (x *BulkDeleteJobsRequest_JobToDelete) String() string

+ type BulkDeleteJobsResponse struct

+ ResultsByJobName map[string]*BulkDeleteJobsResponse_JobDeletionStatus

+ func (*BulkDeleteJobsResponse) Descriptor() ([]byte, []int)

+ func (*BulkDeleteJobsResponse) ProtoMessage()

+ func (x *BulkDeleteJobsResponse) GetResultsByJobName() map[string]*BulkDeleteJobsResponse_JobDeletionStatus

+ func (x *BulkDeleteJobsResponse) ProtoReflect() protoreflect.Message

+ func (x *BulkDeleteJobsResponse) Reset()

+ func (x *BulkDeleteJobsResponse) String() string

+ type BulkDeleteJobsResponse_JobDeletionStatus struct

+ Message string

+ Success bool

+ func (*BulkDeleteJobsResponse_JobDeletionStatus) Descriptor() ([]byte, []int)

+ func (*BulkDeleteJobsResponse_JobDeletionStatus) ProtoMessage()

+ func (x *BulkDeleteJobsResponse_JobDeletionStatus) GetMessage() string

+ func (x *BulkDeleteJobsResponse_JobDeletionStatus) GetSuccess() bool

+ func (x *BulkDeleteJobsResponse_JobDeletionStatus) ProtoReflect() protoreflect.Message

+ func (x *BulkDeleteJobsResponse_JobDeletionStatus) Reset()

+ func (x *BulkDeleteJobsResponse_JobDeletionStatus) String() string

type JobSpecificationServiceClient

+ BulkDeleteJobs func(ctx context.Context, in *BulkDeleteJobsRequest, opts ...grpc.CallOption) (*BulkDeleteJobsResponse, error)

type JobSpecificationServiceServer

+ BulkDeleteJobs func(context.Context, *BulkDeleteJobsRequest) (*BulkDeleteJobsResponse, error)

type UnimplementedJobSpecificationServiceServer

+ func (UnimplementedJobSpecificationServiceServer) BulkDeleteJobs(context.Context, *BulkDeleteJobsRequest) (*BulkDeleteJobsResponse, error)

v0.15.2

Jul 22, 2024

v0.15.1

Jul 22, 2024

v0.15.0

Jul 10, 2024

Changes in this version

+ type GetResourceChangelogsRequest struct

+ ProjectName string

+ ResourceName string

+ func (*GetResourceChangelogsRequest) Descriptor() ([]byte, []int)

+ func (*GetResourceChangelogsRequest) ProtoMessage()

+ func (x *GetResourceChangelogsRequest) GetProjectName() string

+ func (x *GetResourceChangelogsRequest) GetResourceName() string

+ func (x *GetResourceChangelogsRequest) ProtoReflect() protoreflect.Message

+ func (x *GetResourceChangelogsRequest) Reset()

+ func (x *GetResourceChangelogsRequest) String() string

+ type GetResourceChangelogsResponse struct

+ History []*ResourceChangelog

+ func (*GetResourceChangelogsResponse) Descriptor() ([]byte, []int)

+ func (*GetResourceChangelogsResponse) ProtoMessage()

+ func (x *GetResourceChangelogsResponse) GetHistory() []*ResourceChangelog

+ func (x *GetResourceChangelogsResponse) ProtoReflect() protoreflect.Message

+ func (x *GetResourceChangelogsResponse) Reset()

+ func (x *GetResourceChangelogsResponse) String() string

+ type ResourceChange struct

+ AttributeName string

+ Diff string

+ func (*ResourceChange) Descriptor() ([]byte, []int)

+ func (*ResourceChange) ProtoMessage()

+ func (x *ResourceChange) GetAttributeName() string

+ func (x *ResourceChange) GetDiff() string

+ func (x *ResourceChange) ProtoReflect() protoreflect.Message

+ func (x *ResourceChange) Reset()

+ func (x *ResourceChange) String() string

+ type ResourceChangelog struct

+ Change []*ResourceChange

+ EventType string

+ Timestamp string

+ func (*ResourceChangelog) Descriptor() ([]byte, []int)

+ func (*ResourceChangelog) ProtoMessage()

+ func (x *ResourceChangelog) GetChange() []*ResourceChange

+ func (x *ResourceChangelog) GetEventType() string

+ func (x *ResourceChangelog) GetTimestamp() string

+ func (x *ResourceChangelog) ProtoReflect() protoreflect.Message

+ func (x *ResourceChangelog) Reset()

+ func (x *ResourceChangelog) String() string

type ResourceServiceClient

+ GetResourceChangelogs func(ctx context.Context, in *GetResourceChangelogsRequest, opts ...grpc.CallOption) (*GetResourceChangelogsResponse, error)

type ResourceServiceServer

+ GetResourceChangelogs func(context.Context, *GetResourceChangelogsRequest) (*GetResourceChangelogsResponse, error)

type UnimplementedResourceServiceServer

+ func (UnimplementedResourceServiceServer) GetResourceChangelogs(context.Context, *GetResourceChangelogsRequest) (*GetResourceChangelogsResponse, error)

v0.14.4

Jul 8, 2024

v0.14.3

Jul 3, 2024

v0.14.2

Jun 27, 2024

v0.14.1

Jun 25, 2024

v0.14.0

Jun 25, 2024

Changes in this version

type JobSpecificationServiceClient

+ UpsertJobSpecifications func(ctx context.Context, in *UpsertJobSpecificationsRequest, ...) (*UpsertJobSpecificationsResponse, error)

type JobSpecificationServiceServer

+ UpsertJobSpecifications func(context.Context, *UpsertJobSpecificationsRequest) (*UpsertJobSpecificationsResponse, error)

type ResourceServiceClient

+ UpsertResource func(ctx context.Context, in *UpsertResourceRequest, opts ...grpc.CallOption) (*UpsertResourceResponse, error)

type ResourceServiceServer

+ UpsertResource func(context.Context, *UpsertResourceRequest) (*UpsertResourceResponse, error)

+ type ResourceStatus struct

+ Message string

+ ResourceName string

+ Status string

+ func (*ResourceStatus) Descriptor() ([]byte, []int)

+ func (*ResourceStatus) ProtoMessage()

+ func (x *ResourceStatus) GetMessage() string

+ func (x *ResourceStatus) GetResourceName() string

+ func (x *ResourceStatus) GetStatus() string

+ func (x *ResourceStatus) ProtoReflect() protoreflect.Message

+ func (x *ResourceStatus) Reset()

+ func (x *ResourceStatus) String() string

type UnimplementedJobSpecificationServiceServer

+ func (UnimplementedJobSpecificationServiceServer) UpsertJobSpecifications(context.Context, *UpsertJobSpecificationsRequest) (*UpsertJobSpecificationsResponse, error)

type UnimplementedResourceServiceServer

+ func (UnimplementedResourceServiceServer) UpsertResource(context.Context, *UpsertResourceRequest) (*UpsertResourceResponse, error)

+ type UpsertJobSpecificationsRequest struct

+ NamespaceName string

+ ProjectName string

+ Specs []*JobSpecification

+ func (*UpsertJobSpecificationsRequest) Descriptor() ([]byte, []int)

+ func (*UpsertJobSpecificationsRequest) ProtoMessage()

+ func (x *UpsertJobSpecificationsRequest) GetNamespaceName() string

+ func (x *UpsertJobSpecificationsRequest) GetProjectName() string

+ func (x *UpsertJobSpecificationsRequest) GetSpecs() []*JobSpecification

+ func (x *UpsertJobSpecificationsRequest) ProtoReflect() protoreflect.Message

+ func (x *UpsertJobSpecificationsRequest) Reset()

+ func (x *UpsertJobSpecificationsRequest) String() string

+ type UpsertJobSpecificationsResponse struct

+ FailedJobNames []string

+ Log string

+ SkippedJobNames []string

+ SuccessfulJobNames []string

+ func (*UpsertJobSpecificationsResponse) Descriptor() ([]byte, []int)

+ func (*UpsertJobSpecificationsResponse) ProtoMessage()

+ func (x *UpsertJobSpecificationsResponse) GetFailedJobNames() []string

+ func (x *UpsertJobSpecificationsResponse) GetLog() string

+ func (x *UpsertJobSpecificationsResponse) GetSkippedJobNames() []string

+ func (x *UpsertJobSpecificationsResponse) GetSuccessfulJobNames() []string

+ func (x *UpsertJobSpecificationsResponse) ProtoReflect() protoreflect.Message

+ func (x *UpsertJobSpecificationsResponse) Reset()

+ func (x *UpsertJobSpecificationsResponse) String() string

+ type UpsertResourceRequest struct

+ DatastoreName string

+ NamespaceName string

+ ProjectName string

+ Resources []*ResourceSpecification

+ func (*UpsertResourceRequest) Descriptor() ([]byte, []int)

+ func (*UpsertResourceRequest) ProtoMessage()

+ func (x *UpsertResourceRequest) GetDatastoreName() string

+ func (x *UpsertResourceRequest) GetNamespaceName() string

+ func (x *UpsertResourceRequest) GetProjectName() string

+ func (x *UpsertResourceRequest) GetResources() []*ResourceSpecification

+ func (x *UpsertResourceRequest) ProtoReflect() protoreflect.Message

+ func (x *UpsertResourceRequest) Reset()

+ func (x *UpsertResourceRequest) String() string

+ type UpsertResourceResponse struct

+ Message string

+ Results []*ResourceStatus

+ Success bool

+ SuccessfulResourceNames []string

+ func (*UpsertResourceResponse) Descriptor() ([]byte, []int)

+ func (*UpsertResourceResponse) ProtoMessage()

+ func (x *UpsertResourceResponse) GetMessage() string

+ func (x *UpsertResourceResponse) GetResults() []*ResourceStatus

+ func (x *UpsertResourceResponse) GetSuccess() bool

+ func (x *UpsertResourceResponse) GetSuccessfulResourceNames() []string

+ func (x *UpsertResourceResponse) ProtoReflect() protoreflect.Message

+ func (x *UpsertResourceResponse) Reset()

+ func (x *UpsertResourceResponse) String() string

v0.13.1

Jun 21, 2024

v0.13.0

Jun 14, 2024

Changes in this version

type AddJobSpecificationsResponse

+ SuccessfulJobNames []string

+ func (x *AddJobSpecificationsResponse) GetSuccessfulJobNames() []string

+ type GetJobChangelogRequest struct

+ JobName string

+ ProjectName string

+ func (*GetJobChangelogRequest) Descriptor() ([]byte, []int)

+ func (*GetJobChangelogRequest) ProtoMessage()

+ func (x *GetJobChangelogRequest) GetJobName() string

+ func (x *GetJobChangelogRequest) GetProjectName() string

+ func (x *GetJobChangelogRequest) ProtoReflect() protoreflect.Message

+ func (x *GetJobChangelogRequest) Reset()

+ func (x *GetJobChangelogRequest) String() string

+ type GetJobChangelogResponse struct

+ History []*JobChangelog

+ func (*GetJobChangelogResponse) Descriptor() ([]byte, []int)

+ func (*GetJobChangelogResponse) ProtoMessage()

+ func (x *GetJobChangelogResponse) GetHistory() []*JobChangelog

+ func (x *GetJobChangelogResponse) ProtoReflect() protoreflect.Message

+ func (x *GetJobChangelogResponse) Reset()

+ func (x *GetJobChangelogResponse) String() string

+ type JobChange struct

+ AttributeName string

+ Diff string

+ func (*JobChange) Descriptor() ([]byte, []int)

+ func (*JobChange) ProtoMessage()

+ func (x *JobChange) GetAttributeName() string

+ func (x *JobChange) GetDiff() string

+ func (x *JobChange) ProtoReflect() protoreflect.Message

+ func (x *JobChange) Reset()

+ func (x *JobChange) String() string

+ type JobChangelog struct

+ Change []*JobChange

+ EventType string

+ Timestamp string

+ func (*JobChangelog) Descriptor() ([]byte, []int)

+ func (*JobChangelog) ProtoMessage()

+ func (x *JobChangelog) GetChange() []*JobChange

+ func (x *JobChangelog) GetEventType() string

+ func (x *JobChangelog) GetTimestamp() string

+ func (x *JobChangelog) ProtoReflect() protoreflect.Message

+ func (x *JobChangelog) Reset()

+ func (x *JobChangelog) String() string

type JobSpecificationServiceClient

+ GetJobChangelog func(ctx context.Context, in *GetJobChangelogRequest, opts ...grpc.CallOption) (*GetJobChangelogResponse, error)

type JobSpecificationServiceServer

+ GetJobChangelog func(context.Context, *GetJobChangelogRequest) (*GetJobChangelogResponse, error)

type UnimplementedJobSpecificationServiceServer

+ func (UnimplementedJobSpecificationServiceServer) GetJobChangelog(context.Context, *GetJobChangelogRequest) (*GetJobChangelogResponse, error)

type UpdateJobSpecificationsResponse

+ SuccessfulJobNames []string

+ func (x *UpdateJobSpecificationsResponse) GetSuccessfulJobNames() []string

v0.13.0-rc.3

May 20, 2024

v0.13.0-rc.2

May 20, 2024

v0.13.0-rc.1

May 17, 2024

v0.12.4

Jun 12, 2024

v0.12.2

May 14, 2024

v0.12.1

May 9, 2024

v0.12.0

May 2, 2024

Changes in this version

+ type DeleteResourceRequest struct

+ DatastoreName string

+ Force bool

+ NamespaceName string

+ ProjectName string

+ ResourceName string

+ func (*DeleteResourceRequest) Descriptor() ([]byte, []int)

+ func (*DeleteResourceRequest) ProtoMessage()

+ func (x *DeleteResourceRequest) GetDatastoreName() string

+ func (x *DeleteResourceRequest) GetForce() bool

+ func (x *DeleteResourceRequest) GetNamespaceName() string

+ func (x *DeleteResourceRequest) GetProjectName() string

+ func (x *DeleteResourceRequest) GetResourceName() string

+ func (x *DeleteResourceRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteResourceRequest) Reset()

+ func (x *DeleteResourceRequest) String() string

+ type DeleteResourceResponse struct

+ DownstreamJobs []string

+ func (*DeleteResourceResponse) Descriptor() ([]byte, []int)

+ func (*DeleteResourceResponse) ProtoMessage()

+ func (x *DeleteResourceResponse) GetDownstreamJobs() []string

+ func (x *DeleteResourceResponse) ProtoReflect() protoreflect.Message

+ func (x *DeleteResourceResponse) Reset()

+ func (x *DeleteResourceResponse) String() string

type JobSpecificationServiceClient

+ Validate func(ctx context.Context, in *ValidateRequest, opts ...grpc.CallOption) (*ValidateResponse, error)

type JobSpecificationServiceServer

+ Validate func(context.Context, *ValidateRequest) (*ValidateResponse, error)

type JobSpecification_Window

+ ShiftBy string

+ func (x *JobSpecification_Window) GetShiftBy() string

type ProjectSpecification_ProjectPreset

+ ShiftBy string

+ func (x *ProjectSpecification_ProjectPreset) GetShiftBy() string

type ResourceServiceClient

+ DeleteResource func(ctx context.Context, in *DeleteResourceRequest, opts ...grpc.CallOption) (*DeleteResourceResponse, error)

type ResourceServiceServer

+ DeleteResource func(context.Context, *DeleteResourceRequest) (*DeleteResourceResponse, error)

type UnimplementedJobSpecificationServiceServer

+ func (UnimplementedJobSpecificationServiceServer) Validate(context.Context, *ValidateRequest) (*ValidateResponse, error)

type UnimplementedResourceServiceServer

+ func (UnimplementedResourceServiceServer) DeleteResource(context.Context, *DeleteResourceRequest) (*DeleteResourceResponse, error)

+ type ValidateRequest struct

+ NamespaceName string

+ Payload isValidateRequest_Payload

+ ProjectName string

+ func (*ValidateRequest) Descriptor() ([]byte, []int)

+ func (*ValidateRequest) ProtoMessage()

+ func (m *ValidateRequest) GetPayload() isValidateRequest_Payload

+ func (x *ValidateRequest) GetFromOutside() *ValidateRequest_FromOutside

+ func (x *ValidateRequest) GetFromServer() *ValidateRequest_FromServer

+ func (x *ValidateRequest) GetNamespaceName() string

+ func (x *ValidateRequest) GetProjectName() string

+ func (x *ValidateRequest) ProtoReflect() protoreflect.Message

+ func (x *ValidateRequest) Reset()

+ func (x *ValidateRequest) String() string

+ type ValidateRequest_FromOutside struct

+ Jobs []*JobSpecification

+ func (*ValidateRequest_FromOutside) Descriptor() ([]byte, []int)

+ func (*ValidateRequest_FromOutside) ProtoMessage()

+ func (x *ValidateRequest_FromOutside) GetJobs() []*JobSpecification

+ func (x *ValidateRequest_FromOutside) ProtoReflect() protoreflect.Message

+ func (x *ValidateRequest_FromOutside) Reset()

+ func (x *ValidateRequest_FromOutside) String() string

+ type ValidateRequest_FromOutside_ struct

+ FromOutside *ValidateRequest_FromOutside

+ type ValidateRequest_FromServer struct

+ DeletionMode bool

+ JobNames []string

+ func (*ValidateRequest_FromServer) Descriptor() ([]byte, []int)

+ func (*ValidateRequest_FromServer) ProtoMessage()

+ func (x *ValidateRequest_FromServer) GetDeletionMode() bool

+ func (x *ValidateRequest_FromServer) GetJobNames() []string

+ func (x *ValidateRequest_FromServer) ProtoReflect() protoreflect.Message

+ func (x *ValidateRequest_FromServer) Reset()

+ func (x *ValidateRequest_FromServer) String() string

+ type ValidateRequest_FromServer_ struct

+ FromServer *ValidateRequest_FromServer

+ type ValidateResponse struct

+ ResultsByJobName map[string]*ValidateResponse_ResultList

+ func (*ValidateResponse) Descriptor() ([]byte, []int)

+ func (*ValidateResponse) ProtoMessage()

+ func (x *ValidateResponse) GetResultsByJobName() map[string]*ValidateResponse_ResultList

+ func (x *ValidateResponse) ProtoReflect() protoreflect.Message

+ func (x *ValidateResponse) Reset()

+ func (x *ValidateResponse) String() string

+ type ValidateResponse_Result struct

+ Messages []string

+ Name string

+ Success bool

+ func (*ValidateResponse_Result) Descriptor() ([]byte, []int)

+ func (*ValidateResponse_Result) ProtoMessage()

+ func (x *ValidateResponse_Result) GetMessages() []string

+ func (x *ValidateResponse_Result) GetName() string

+ func (x *ValidateResponse_Result) GetSuccess() bool

+ func (x *ValidateResponse_Result) ProtoReflect() protoreflect.Message

+ func (x *ValidateResponse_Result) Reset()

+ func (x *ValidateResponse_Result) String() string

+ type ValidateResponse_ResultList struct

+ Results []*ValidateResponse_Result

+ func (*ValidateResponse_ResultList) Descriptor() ([]byte, []int)

+ func (*ValidateResponse_ResultList) ProtoMessage()

+ func (x *ValidateResponse_ResultList) GetResults() []*ValidateResponse_Result

+ func (x *ValidateResponse_ResultList) ProtoReflect() protoreflect.Message

+ func (x *ValidateResponse_ResultList) Reset()

+ func (x *ValidateResponse_ResultList) String() string

v0.11.10

Apr 16, 2024

v0.11.9

Apr 4, 2024

v0.11.8

Apr 4, 2024

v0.11.7

Apr 3, 2024

v0.11.6

Mar 20, 2024

v0.11.5

Mar 14, 2024

v0.11.4

Mar 13, 2024

Changes in this version

type JobEvent_Type

+ const JobEvent_TYPE_SUCCESS

type JobSpecification_Behavior

+ Webhook []*JobSpecification_Behavior_Webhook

+ func (x *JobSpecification_Behavior) GetWebhook() []*JobSpecification_Behavior_Webhook

+ type JobSpecification_Behavior_Webhook struct

+ Endpoints []*JobSpecification_Behavior_Webhook_WebhookEndpoint

+ On JobEvent_Type

+ func (*JobSpecification_Behavior_Webhook) Descriptor() ([]byte, []int)

+ func (*JobSpecification_Behavior_Webhook) ProtoMessage()

+ func (x *JobSpecification_Behavior_Webhook) GetEndpoints() []*JobSpecification_Behavior_Webhook_WebhookEndpoint

+ func (x *JobSpecification_Behavior_Webhook) GetOn() JobEvent_Type

+ func (x *JobSpecification_Behavior_Webhook) ProtoReflect() protoreflect.Message

+ func (x *JobSpecification_Behavior_Webhook) Reset()

+ func (x *JobSpecification_Behavior_Webhook) String() string

+ type JobSpecification_Behavior_Webhook_WebhookEndpoint struct

+ Headers map[string]string

+ Url string

+ func (*JobSpecification_Behavior_Webhook_WebhookEndpoint) Descriptor() ([]byte, []int)

+ func (*JobSpecification_Behavior_Webhook_WebhookEndpoint) ProtoMessage()

+ func (x *JobSpecification_Behavior_Webhook_WebhookEndpoint) GetHeaders() map[string]string

+ func (x *JobSpecification_Behavior_Webhook_WebhookEndpoint) GetUrl() string

+ func (x *JobSpecification_Behavior_Webhook_WebhookEndpoint) ProtoReflect() protoreflect.Message

+ func (x *JobSpecification_Behavior_Webhook_WebhookEndpoint) Reset()

+ func (x *JobSpecification_Behavior_Webhook_WebhookEndpoint) String() string

v0.11.3

Mar 5, 2024

Changes in this version

+ type CancelReplayRequest struct

+ ProjectName string

+ ReplayId string

+ func (*CancelReplayRequest) Descriptor() ([]byte, []int)

+ func (*CancelReplayRequest) ProtoMessage()

+ func (x *CancelReplayRequest) GetProjectName() string

+ func (x *CancelReplayRequest) GetReplayId() string

+ func (x *CancelReplayRequest) ProtoReflect() protoreflect.Message

+ func (x *CancelReplayRequest) Reset()

+ func (x *CancelReplayRequest) String() string

+ type CancelReplayResponse struct

+ JobName string

+ ReplayRuns []*ReplayRun

+ func (*CancelReplayResponse) Descriptor() ([]byte, []int)

+ func (*CancelReplayResponse) ProtoMessage()

+ func (x *CancelReplayResponse) GetJobName() string

+ func (x *CancelReplayResponse) GetReplayRuns() []*ReplayRun

+ func (x *CancelReplayResponse) ProtoReflect() protoreflect.Message

+ func (x *CancelReplayResponse) Reset()

+ func (x *CancelReplayResponse) String() string

type GetReplayResponse

+ Message string

+ func (x *GetReplayResponse) GetMessage() string

type ReplayServiceClient

+ CancelReplay func(ctx context.Context, in *CancelReplayRequest, opts ...grpc.CallOption) (*CancelReplayResponse, error)

type ReplayServiceServer

+ CancelReplay func(context.Context, *CancelReplayRequest) (*CancelReplayResponse, error)

type UnimplementedReplayServiceServer

+ func (UnimplementedReplayServiceServer) CancelReplay(context.Context, *CancelReplayRequest) (*CancelReplayResponse, error)

v0.11.2

Jan 23, 2024

v0.11.1

Jan 23, 2024

v0.11.0

Dec 6, 2023

Changes in this version

type GetJobSpecificationsRequest

+ IgnoreAssets bool

+ func (x *GetJobSpecificationsRequest) GetIgnoreAssets() bool

type JobSpecification

+ Window *JobSpecification_Window

+ func (x *JobSpecification) GetWindow() *JobSpecification_Window

+ type JobSpecification_Window struct

+ Delay string

+ Location string

+ Preset string

+ Size string

+ TruncateTo string

+ func (*JobSpecification_Window) Descriptor() ([]byte, []int)

+ func (*JobSpecification_Window) ProtoMessage()

+ func (x *JobSpecification_Window) GetDelay() string

+ func (x *JobSpecification_Window) GetLocation() string

+ func (x *JobSpecification_Window) GetPreset() string

+ func (x *JobSpecification_Window) GetSize() string

+ func (x *JobSpecification_Window) GetTruncateTo() string

+ func (x *JobSpecification_Window) ProtoReflect() protoreflect.Message

+ func (x *JobSpecification_Window) Reset()

+ func (x *JobSpecification_Window) String() string

type ProjectSpecification_ProjectPreset

+ Delay string

+ Location string

+ func (x *ProjectSpecification_ProjectPreset) GetDelay() string

+ func (x *ProjectSpecification_ProjectPreset) GetLocation() string

v0.11.0-rc.1

Oct 18, 2023

v0.10.3-rc.1

Nov 28, 2023

v0.10.2

Nov 17, 2023

Changes in this version

type ListJobSpecificationRequest

+ IgnoreAssets bool

+ func (x *ListJobSpecificationRequest) GetIgnoreAssets() bool

v0.10.1

Oct 24, 2023

v0.10.0

Sep 14, 2023

Changes in this version

+ type GetIntervalRequest struct

+ JobName string

+ ProjectName string

+ ReferenceTime *timestamppb.Timestamp

+ func (*GetIntervalRequest) Descriptor() ([]byte, []int)

+ func (*GetIntervalRequest) ProtoMessage()

+ func (x *GetIntervalRequest) GetJobName() string

+ func (x *GetIntervalRequest) GetProjectName() string

+ func (x *GetIntervalRequest) GetReferenceTime() *timestamppb.Timestamp

+ func (x *GetIntervalRequest) ProtoReflect() protoreflect.Message

+ func (x *GetIntervalRequest) Reset()

+ func (x *GetIntervalRequest) String() string

+ type GetIntervalResponse struct

+ EndTime *timestamppb.Timestamp

+ StartTime *timestamppb.Timestamp

+ func (*GetIntervalResponse) Descriptor() ([]byte, []int)

+ func (*GetIntervalResponse) ProtoMessage()

+ func (x *GetIntervalResponse) GetEndTime() *timestamppb.Timestamp

+ func (x *GetIntervalResponse) GetStartTime() *timestamppb.Timestamp

+ func (x *GetIntervalResponse) ProtoReflect() protoreflect.Message

+ func (x *GetIntervalResponse) Reset()

+ func (x *GetIntervalResponse) String() string

type JobRunRequest

+ DownstreamJobName string

+ DownstreamProjectName string

+ func (x *JobRunRequest) GetDownstreamJobName() string

+ func (x *JobRunRequest) GetDownstreamProjectName() string

type JobRunServiceClient

+ GetInterval func(ctx context.Context, in *GetIntervalRequest, opts ...grpc.CallOption) (*GetIntervalResponse, error)

type JobRunServiceServer

+ GetInterval func(context.Context, *GetIntervalRequest) (*GetIntervalResponse, error)

type JobSpecification

+ WindowPreset string

+ func (x *JobSpecification) GetWindowPreset() string

type ProjectSpecification

+ Presets map[string]*ProjectSpecification_ProjectPreset

+ func (x *ProjectSpecification) GetPresets() map[string]*ProjectSpecification_ProjectPreset

+ type ProjectSpecification_ProjectPreset struct

+ Description string

+ Name string

+ Offset string

+ Size string

+ TruncateTo string

+ func (*ProjectSpecification_ProjectPreset) Descriptor() ([]byte, []int)

+ func (*ProjectSpecification_ProjectPreset) ProtoMessage()

+ func (x *ProjectSpecification_ProjectPreset) GetDescription() string

+ func (x *ProjectSpecification_ProjectPreset) GetName() string

+ func (x *ProjectSpecification_ProjectPreset) GetOffset() string

+ func (x *ProjectSpecification_ProjectPreset) GetSize() string

+ func (x *ProjectSpecification_ProjectPreset) GetTruncateTo() string

+ func (x *ProjectSpecification_ProjectPreset) ProtoReflect() protoreflect.Message

+ func (x *ProjectSpecification_ProjectPreset) Reset()

+ func (x *ProjectSpecification_ProjectPreset) String() string

type UnimplementedJobRunServiceServer

+ func (UnimplementedJobRunServiceServer) GetInterval(context.Context, *GetIntervalRequest) (*GetIntervalResponse, error)

v0.9.10

Oct 17, 2023

v0.9.9

Oct 6, 2023

v0.9.8

Sep 26, 2023

v0.9.7

Sep 11, 2023

v0.9.7-patch.1

Nov 7, 2023

v0.9.7-patch

Oct 30, 2023

v0.9.7-gtfn-patch-0.2

Nov 6, 2023

v0.9.7-gtfn-patch-0.1

Nov 6, 2023

v0.9.6

Sep 4, 2023

v0.9.5

Aug 24, 2023

v0.9.4

Aug 23, 2023

v0.9.3

Aug 14, 2023

v0.9.2

Aug 9, 2023

v0.9.1

Aug 4, 2023

v0.9.0

Aug 1, 2023

Changes in this version

+ var JobState_name = map[int32]string

+ var JobState_value = map[string]int32

+ type ApplyResourcesRequest struct

+ DatastoreName string

+ NamespaceName string

+ ProjectName string

+ ResourceNames []string

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

+ func (*ApplyResourcesRequest) ProtoMessage()

+ func (x *ApplyResourcesRequest) GetDatastoreName() string

+ func (x *ApplyResourcesRequest) GetNamespaceName() string

+ func (x *ApplyResourcesRequest) GetProjectName() string

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

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

+ func (x *ApplyResourcesRequest) Reset()

+ func (x *ApplyResourcesRequest) String() string

+ type ApplyResourcesResponse struct

+ Statuses []*ApplyResourcesResponse_ResourceStatus

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

+ func (*ApplyResourcesResponse) ProtoMessage()

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

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

+ func (x *ApplyResourcesResponse) Reset()

+ func (x *ApplyResourcesResponse) String() string

+ type ApplyResourcesResponse_ResourceStatus struct

+ Reason string

+ ResourceName string

+ Status string

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

+ func (*ApplyResourcesResponse_ResourceStatus) ProtoMessage()

+ func (x *ApplyResourcesResponse_ResourceStatus) GetReason() string

+ func (x *ApplyResourcesResponse_ResourceStatus) GetResourceName() string

+ func (x *ApplyResourcesResponse_ResourceStatus) GetStatus() string

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

+ func (x *ApplyResourcesResponse_ResourceStatus) Reset()

+ func (x *ApplyResourcesResponse_ResourceStatus) String() string

type JobSpecificationServiceClient

+ SyncJobsState func(ctx context.Context, in *SyncJobsStateRequest, opts ...grpc.CallOption) (*SyncJobsStateResponse, error)

+ UpdateJobsState func(ctx context.Context, in *UpdateJobsStateRequest, opts ...grpc.CallOption) (*UpdateJobsStateResponse, error)

type JobSpecificationServiceServer

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

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

+ type JobState int32

+ const JobState_JOB_STATE_DISABLED

+ const JobState_JOB_STATE_ENABLED

+ const JobState_JOB_STATE_UNSPECIFIED

+ func (JobState) Descriptor() protoreflect.EnumDescriptor

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

+ func (JobState) Type() protoreflect.EnumType

+ func (x JobState) Enum() *JobState

+ func (x JobState) Number() protoreflect.EnumNumber

+ func (x JobState) String() string

type ReplayDryRunRequest

+ Description string

+ EndTime *timestamppb.Timestamp

+ JobConfig string

+ Parallel bool

+ StartTime *timestamppb.Timestamp

+ func (x *ReplayDryRunRequest) GetDescription() string

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

+ func (x *ReplayDryRunRequest) GetJobConfig() string

+ func (x *ReplayDryRunRequest) GetParallel() bool

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

type ReplayDryRunResponse

+ ReplayRuns []*ReplayRun

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

type ResourceServiceClient

+ ApplyResources func(ctx context.Context, in *ApplyResourcesRequest, opts ...grpc.CallOption) (*ApplyResourcesResponse, error)

type ResourceServiceServer

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

+ type SyncJobsStateRequest struct

+ JobStates []*SyncJobsStateRequest_JobStatePair

+ NamespaceName string

+ ProjectName string

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

+ func (*SyncJobsStateRequest) ProtoMessage()

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

+ func (x *SyncJobsStateRequest) GetNamespaceName() string

+ func (x *SyncJobsStateRequest) GetProjectName() string

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

+ func (x *SyncJobsStateRequest) Reset()

+ func (x *SyncJobsStateRequest) String() string

+ type SyncJobsStateRequest_JobStatePair struct

+ JobName string

+ State JobState

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

+ func (*SyncJobsStateRequest_JobStatePair) ProtoMessage()

+ func (x *SyncJobsStateRequest_JobStatePair) GetJobName() string

+ func (x *SyncJobsStateRequest_JobStatePair) GetState() JobState

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

+ func (x *SyncJobsStateRequest_JobStatePair) Reset()

+ func (x *SyncJobsStateRequest_JobStatePair) String() string

+ type SyncJobsStateResponse struct

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

+ func (*SyncJobsStateResponse) ProtoMessage()

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

+ func (x *SyncJobsStateResponse) Reset()

+ func (x *SyncJobsStateResponse) String() string

type UnimplementedJobSpecificationServiceServer

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

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

type UnimplementedResourceServiceServer

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

+ type UpdateJobsStateRequest struct

+ JobNames []string

+ NamespaceName string

+ ProjectName string

+ Remark string

+ State JobState

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

+ func (*UpdateJobsStateRequest) ProtoMessage()

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

+ func (x *UpdateJobsStateRequest) GetNamespaceName() string

+ func (x *UpdateJobsStateRequest) GetProjectName() string

+ func (x *UpdateJobsStateRequest) GetRemark() string

+ func (x *UpdateJobsStateRequest) GetState() JobState

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

+ func (x *UpdateJobsStateRequest) Reset()

+ func (x *UpdateJobsStateRequest) String() string

+ type UpdateJobsStateResponse struct

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

+ func (*UpdateJobsStateResponse) ProtoMessage()

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

+ func (x *UpdateJobsStateResponse) Reset()

+ func (x *UpdateJobsStateResponse) String() string

v0.8.5

Aug 4, 2023

v0.8.4

Jul 19, 2023

v0.8.3

Jul 6, 2023

v0.8.2

Jun 27, 2023

v0.8.1

Jun 21, 2023

v0.8.0

Jun 13, 2023

Changes in this version

+ type ChangeJobNamespaceRequest struct

+ JobName string

+ NamespaceName string

+ NewNamespaceName string

+ ProjectName string

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

+ func (*ChangeJobNamespaceRequest) ProtoMessage()

+ func (x *ChangeJobNamespaceRequest) GetJobName() string

+ func (x *ChangeJobNamespaceRequest) GetNamespaceName() string

+ func (x *ChangeJobNamespaceRequest) GetNewNamespaceName() string

+ func (x *ChangeJobNamespaceRequest) GetProjectName() string

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

+ func (x *ChangeJobNamespaceRequest) Reset()

+ func (x *ChangeJobNamespaceRequest) String() string

+ type ChangeJobNamespaceResponse struct

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

+ func (*ChangeJobNamespaceResponse) ProtoMessage()

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

+ func (x *ChangeJobNamespaceResponse) Reset()

+ func (x *ChangeJobNamespaceResponse) String() string

+ type ChangeResourceNamespaceRequest struct

+ DatastoreName string

+ NamespaceName string

+ NewNamespaceName string

+ ProjectName string

+ ResourceName string

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

+ func (*ChangeResourceNamespaceRequest) ProtoMessage()

+ 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 (x *ChangeResourceNamespaceRequest) ProtoReflect() protoreflect.Message

+ func (x *ChangeResourceNamespaceRequest) Reset()

+ func (x *ChangeResourceNamespaceRequest) String() string

+ type ChangeResourceNamespaceResponse struct

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

+ func (*ChangeResourceNamespaceResponse) ProtoMessage()

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

+ func (x *ChangeResourceNamespaceResponse) Reset()

+ func (x *ChangeResourceNamespaceResponse) String() string

type JobSpecificationServiceClient

+ ChangeJobNamespace func(ctx context.Context, in *ChangeJobNamespaceRequest, opts ...grpc.CallOption) (*ChangeJobNamespaceResponse, error)

type JobSpecificationServiceServer

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

type ResourceServiceClient

+ ChangeResourceNamespace func(ctx context.Context, in *ChangeResourceNamespaceRequest, ...) (*ChangeResourceNamespaceResponse, error)

type ResourceServiceServer

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

type UnimplementedJobSpecificationServiceServer

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

type UnimplementedResourceServiceServer

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

v0.7.3-rc.1

Jun 10, 2023

v0.7.2

Jun 9, 2023

v0.7.2-rc.2

Jun 10, 2023

v0.7.1

May 14, 2023

v0.7.0

May 11, 2023

Changes in this version

+ type GetReplayRequest struct

+ ProjectName string

+ ReplayId string

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

+ func (*GetReplayRequest) ProtoMessage()

+ func (x *GetReplayRequest) GetProjectName() string

+ func (x *GetReplayRequest) GetReplayId() string

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

+ func (x *GetReplayRequest) Reset()

+ func (x *GetReplayRequest) String() string

+ type GetReplayResponse struct

+ Id string

+ JobName string

+ ReplayConfig *ReplayConfig

+ ReplayRuns []*ReplayRun

+ Status string

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

+ func (*GetReplayResponse) ProtoMessage()

+ 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 (x *GetReplayResponse) ProtoReflect() protoreflect.Message

+ func (x *GetReplayResponse) Reset()

+ func (x *GetReplayResponse) String() string

+ type ListReplayRequest struct

+ ProjectName string

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

+ func (*ListReplayRequest) ProtoMessage()

+ func (x *ListReplayRequest) GetProjectName() string

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

+ func (x *ListReplayRequest) Reset()

+ func (x *ListReplayRequest) String() string

+ type ListReplayResponse struct

+ Replays []*GetReplayResponse

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

+ func (*ListReplayResponse) ProtoMessage()

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

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

+ func (x *ListReplayResponse) Reset()

+ func (x *ListReplayResponse) String() string

+ type ReplayConfig struct

+ Description string

+ EndTime *timestamppb.Timestamp

+ JobConfig map[string]string

+ Parallel bool

+ StartTime *timestamppb.Timestamp

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

+ func (*ReplayConfig) ProtoMessage()

+ 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 (x *ReplayConfig) ProtoReflect() protoreflect.Message

+ func (x *ReplayConfig) Reset()

+ func (x *ReplayConfig) String() string

type ReplayRequest

+ Description string

+ EndTime *timestamppb.Timestamp

+ JobConfig string

+ Parallel bool

+ StartTime *timestamppb.Timestamp

+ func (x *ReplayRequest) GetDescription() string

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

+ func (x *ReplayRequest) GetJobConfig() string

+ func (x *ReplayRequest) GetParallel() bool

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

+ type ReplayRun struct

+ ScheduledAt *timestamppb.Timestamp

+ Status string

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

+ func (*ReplayRun) ProtoMessage()

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

+ func (x *ReplayRun) GetStatus() string

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

+ func (x *ReplayRun) Reset()

+ func (x *ReplayRun) String() string

type ReplayServiceClient

+ GetReplay func(ctx context.Context, in *GetReplayRequest, opts ...grpc.CallOption) (*GetReplayResponse, error)

+ ListReplay func(ctx context.Context, in *ListReplayRequest, opts ...grpc.CallOption) (*ListReplayResponse, error)

type ReplayServiceServer

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

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

type UnimplementedReplayServiceServer

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

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

v0.7.0-rc.2

May 2, 2023

v0.7.0-rc.1

Apr 28, 2023

v0.6.4

May 14, 2023

v0.6.3

May 12, 2023

v0.6.2

May 2, 2023

v0.6.1

Apr 11, 2023

v0.6.0

Mar 22, 2023

Changes in this version

+ var BackupService_ServiceDesc = grpc.ServiceDesc

+ 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 InstanceSpecData_Type_name = map[int32]string

+ var InstanceSpecData_Type_value = map[string]int32

+ var InstanceSpec_Type_name = map[int32]string

+ var InstanceSpec_Type_value = map[string]int32

+ var JobEvent_Type_name = map[int32]string

+ var JobEvent_Type_value = map[string]int32

+ var JobRunService_ServiceDesc = grpc.ServiceDesc

+ var JobSpecificationService_ServiceDesc = grpc.ServiceDesc

+ var Level_name = map[int32]string

+ var Level_value = map[string]int32

+ var NamespaceService_ServiceDesc = grpc.ServiceDesc

+ var ProjectService_ServiceDesc = grpc.ServiceDesc

+ var ReplayService_ServiceDesc = grpc.ServiceDesc

+ var ResourceService_ServiceDesc = grpc.ServiceDesc

+ var RuntimeService_ServiceDesc = grpc.ServiceDesc

+ var SecretService_ServiceDesc = grpc.ServiceDesc

+ 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 struct

+ NamespaceName string

+ ProjectName string

+ Specs []*JobSpecification

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

+ func (*AddJobSpecificationsRequest) ProtoMessage()

+ func (x *AddJobSpecificationsRequest) GetNamespaceName() string

+ func (x *AddJobSpecificationsRequest) GetProjectName() string

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

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

+ func (x *AddJobSpecificationsRequest) Reset()

+ func (x *AddJobSpecificationsRequest) String() string

+ type AddJobSpecificationsResponse struct

+ Log string

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

+ func (*AddJobSpecificationsResponse) ProtoMessage()

+ func (x *AddJobSpecificationsResponse) GetLog() string

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

+ func (x *AddJobSpecificationsResponse) Reset()

+ func (x *AddJobSpecificationsResponse) String() string

+ type BackupServiceClient interface

+ CreateBackup func(ctx context.Context, in *CreateBackupRequest, opts ...grpc.CallOption) (*CreateBackupResponse, error)

+ GetBackup func(ctx context.Context, in *GetBackupRequest, opts ...grpc.CallOption) (*GetBackupResponse, error)

+ ListBackups func(ctx context.Context, in *ListBackupsRequest, opts ...grpc.CallOption) (*ListBackupsResponse, error)

+ func NewBackupServiceClient(cc grpc.ClientConnInterface) BackupServiceClient

+ type BackupServiceServer interface

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

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

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

+ type BackupSpec struct

+ Config map[string]string

+ CreatedAt *timestamppb.Timestamp

+ Description string

+ Id string

+ ResourceNames []string

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

+ func (*BackupSpec) ProtoMessage()

+ 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 (x *BackupSpec) ProtoReflect() protoreflect.Message

+ func (x *BackupSpec) Reset()

+ func (x *BackupSpec) String() string

+ type CheckJobSpecificationRequest struct

+ Job *JobSpecification

+ NamespaceName string

+ ProjectName string

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

+ func (*CheckJobSpecificationRequest) ProtoMessage()

+ func (x *CheckJobSpecificationRequest) GetJob() *JobSpecification

+ func (x *CheckJobSpecificationRequest) GetNamespaceName() string

+ func (x *CheckJobSpecificationRequest) GetProjectName() string

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

+ func (x *CheckJobSpecificationRequest) Reset()

+ func (x *CheckJobSpecificationRequest) String() string

+ type CheckJobSpecificationResponse struct

+ Success bool

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

+ func (*CheckJobSpecificationResponse) ProtoMessage()

+ func (x *CheckJobSpecificationResponse) GetSuccess() bool

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

+ func (x *CheckJobSpecificationResponse) Reset()

+ func (x *CheckJobSpecificationResponse) String() string

+ type CheckJobSpecificationsRequest struct

+ Jobs []*JobSpecification

+ NamespaceName string

+ ProjectName string

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

+ func (*CheckJobSpecificationsRequest) ProtoMessage()

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

+ func (x *CheckJobSpecificationsRequest) GetNamespaceName() string

+ func (x *CheckJobSpecificationsRequest) GetProjectName() string

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

+ func (x *CheckJobSpecificationsRequest) Reset()

+ func (x *CheckJobSpecificationsRequest) String() string

+ type CheckJobSpecificationsResponse struct

+ LogStatus *Log

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

+ func (*CheckJobSpecificationsResponse) ProtoMessage()

+ func (x *CheckJobSpecificationsResponse) GetLogStatus() *Log

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

+ func (x *CheckJobSpecificationsResponse) Reset()

+ func (x *CheckJobSpecificationsResponse) String() string

+ type CreateBackupRequest struct

+ Config map[string]string

+ DatastoreName string

+ Description string

+ NamespaceName string

+ ProjectName string

+ ResourceNames []string

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

+ func (*CreateBackupRequest) ProtoMessage()

+ 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 (x *CreateBackupRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateBackupRequest) Reset()

+ func (x *CreateBackupRequest) String() string

+ type CreateBackupResponse struct

+ BackupId string

+ IgnoredResources []*IgnoredResource

+ ResourceNames []string

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

+ func (*CreateBackupResponse) ProtoMessage()

+ func (x *CreateBackupResponse) GetBackupId() string

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

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

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

+ func (x *CreateBackupResponse) Reset()

+ func (x *CreateBackupResponse) String() string

+ type CreateJobSpecificationRequest struct

+ NamespaceName string

+ ProjectName string

+ Spec *JobSpecification

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

+ func (*CreateJobSpecificationRequest) ProtoMessage()

+ func (x *CreateJobSpecificationRequest) GetNamespaceName() string

+ func (x *CreateJobSpecificationRequest) GetProjectName() string

+ func (x *CreateJobSpecificationRequest) GetSpec() *JobSpecification

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

+ func (x *CreateJobSpecificationRequest) Reset()

+ func (x *CreateJobSpecificationRequest) String() string

+ type CreateJobSpecificationResponse struct

+ Message string

+ Success bool

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

+ func (*CreateJobSpecificationResponse) ProtoMessage()

+ func (x *CreateJobSpecificationResponse) GetMessage() string

+ func (x *CreateJobSpecificationResponse) GetSuccess() bool

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

+ func (x *CreateJobSpecificationResponse) Reset()

+ func (x *CreateJobSpecificationResponse) String() string

+ type CreateResourceRequest struct

+ DatastoreName string

+ NamespaceName string

+ ProjectName string

+ Resource *ResourceSpecification

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

+ func (*CreateResourceRequest) ProtoMessage()

+ func (x *CreateResourceRequest) GetDatastoreName() string

+ func (x *CreateResourceRequest) GetNamespaceName() string

+ func (x *CreateResourceRequest) GetProjectName() string

+ func (x *CreateResourceRequest) GetResource() *ResourceSpecification

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

+ func (x *CreateResourceRequest) Reset()

+ func (x *CreateResourceRequest) String() string

+ type CreateResourceResponse struct

+ Message string

+ Success bool

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

+ func (*CreateResourceResponse) ProtoMessage()

+ func (x *CreateResourceResponse) GetMessage() string

+ func (x *CreateResourceResponse) GetSuccess() bool

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

+ func (x *CreateResourceResponse) Reset()

+ func (x *CreateResourceResponse) String() string

+ type DeleteJobSpecificationRequest struct

+ CleanHistory bool

+ Force bool

+ JobName string

+ NamespaceName string

+ ProjectName string

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

+ func (*DeleteJobSpecificationRequest) ProtoMessage()

+ 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 (x *DeleteJobSpecificationRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteJobSpecificationRequest) Reset()

+ func (x *DeleteJobSpecificationRequest) String() string

+ type DeleteJobSpecificationResponse struct

+ Message string

+ Success bool

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

+ func (*DeleteJobSpecificationResponse) ProtoMessage()

+ func (x *DeleteJobSpecificationResponse) GetMessage() string

+ func (x *DeleteJobSpecificationResponse) GetSuccess() bool

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

+ func (x *DeleteJobSpecificationResponse) Reset()

+ func (x *DeleteJobSpecificationResponse) String() string

+ type DeleteSecretRequest struct

+ NamespaceName string

+ ProjectName string

+ SecretName string

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

+ func (*DeleteSecretRequest) ProtoMessage()

+ func (x *DeleteSecretRequest) GetNamespaceName() string

+ func (x *DeleteSecretRequest) GetProjectName() string

+ func (x *DeleteSecretRequest) GetSecretName() string

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

+ func (x *DeleteSecretRequest) Reset()

+ func (x *DeleteSecretRequest) String() string

+ type DeleteSecretResponse struct

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

+ func (*DeleteSecretResponse) ProtoMessage()

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

+ func (x *DeleteSecretResponse) Reset()

+ func (x *DeleteSecretResponse) String() string

+ type DeployJobFailure struct

+ JobName string

+ Message string

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

+ func (*DeployJobFailure) ProtoMessage()

+ func (x *DeployJobFailure) GetJobName() string

+ func (x *DeployJobFailure) GetMessage() string

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

+ func (x *DeployJobFailure) Reset()

+ func (x *DeployJobFailure) String() string

+ type DeployJobSpecificationRequest struct

+ Jobs []*JobSpecification

+ NamespaceName string

+ ProjectName string

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

+ func (*DeployJobSpecificationRequest) ProtoMessage()

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

+ func (x *DeployJobSpecificationRequest) GetNamespaceName() string

+ func (x *DeployJobSpecificationRequest) GetProjectName() string

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

+ func (x *DeployJobSpecificationRequest) Reset()

+ func (x *DeployJobSpecificationRequest) String() string

+ type DeployJobSpecificationResponse struct

+ DeploymentId string

+ LogStatus *Log

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

+ func (*DeployJobSpecificationResponse) ProtoMessage()

+ func (x *DeployJobSpecificationResponse) GetDeploymentId() string

+ func (x *DeployJobSpecificationResponse) GetLogStatus() *Log

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

+ func (x *DeployJobSpecificationResponse) Reset()

+ func (x *DeployJobSpecificationResponse) String() string

+ type DeployResourceSpecificationRequest struct

+ DatastoreName string

+ NamespaceName string

+ ProjectName string

+ Resources []*ResourceSpecification

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

+ func (*DeployResourceSpecificationRequest) ProtoMessage()

+ func (x *DeployResourceSpecificationRequest) GetDatastoreName() string

+ func (x *DeployResourceSpecificationRequest) GetNamespaceName() string

+ func (x *DeployResourceSpecificationRequest) GetProjectName() string

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

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

+ func (x *DeployResourceSpecificationRequest) Reset()

+ func (x *DeployResourceSpecificationRequest) String() string

+ type DeployResourceSpecificationResponse struct

+ LogStatus *Log

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

+ func (*DeployResourceSpecificationResponse) ProtoMessage()

+ func (x *DeployResourceSpecificationResponse) GetLogStatus() *Log

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

+ func (x *DeployResourceSpecificationResponse) Reset()

+ func (x *DeployResourceSpecificationResponse) String() string

+ type GetBackupRequest struct

+ DatastoreName string

+ Id string

+ NamespaceName string

+ ProjectName string

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

+ func (*GetBackupRequest) ProtoMessage()

+ func (x *GetBackupRequest) GetDatastoreName() string

+ func (x *GetBackupRequest) GetId() string

+ func (x *GetBackupRequest) GetNamespaceName() string

+ func (x *GetBackupRequest) GetProjectName() string

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

+ func (x *GetBackupRequest) Reset()

+ func (x *GetBackupRequest) String() string

+ type GetBackupResponse struct

+ Spec *BackupSpec

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

+ func (*GetBackupResponse) ProtoMessage()

+ func (x *GetBackupResponse) GetSpec() *BackupSpec

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

+ func (x *GetBackupResponse) Reset()

+ func (x *GetBackupResponse) String() string

+ type GetDeployJobsStatusRequest struct

+ DeployId string

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

+ func (*GetDeployJobsStatusRequest) ProtoMessage()

+ func (x *GetDeployJobsStatusRequest) GetDeployId() string

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

+ func (x *GetDeployJobsStatusRequest) Reset()

+ func (x *GetDeployJobsStatusRequest) String() string

+ type GetDeployJobsStatusResponse struct

+ FailureCount int32

+ Failures []*DeployJobFailure

+ Status string

+ SuccessCount int32

+ UnknownDependencies map[string]string

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

+ func (*GetDeployJobsStatusResponse) ProtoMessage()

+ 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 (x *GetDeployJobsStatusResponse) ProtoReflect() protoreflect.Message

+ func (x *GetDeployJobsStatusResponse) Reset()

+ func (x *GetDeployJobsStatusResponse) String() string

+ type GetJobSpecificationRequest struct

+ JobName string

+ NamespaceName string

+ ProjectName string

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

+ func (*GetJobSpecificationRequest) ProtoMessage()

+ func (x *GetJobSpecificationRequest) GetJobName() string

+ func (x *GetJobSpecificationRequest) GetNamespaceName() string

+ func (x *GetJobSpecificationRequest) GetProjectName() string

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

+ func (x *GetJobSpecificationRequest) Reset()

+ func (x *GetJobSpecificationRequest) String() string

+ type GetJobSpecificationResponse struct

+ Spec *JobSpecification

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

+ func (*GetJobSpecificationResponse) ProtoMessage()

+ func (x *GetJobSpecificationResponse) GetSpec() *JobSpecification

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

+ func (x *GetJobSpecificationResponse) Reset()

+ func (x *GetJobSpecificationResponse) String() string

+ type GetJobSpecificationsRequest struct

+ JobName string

+ NamespaceName string

+ ProjectName string

+ ResourceDestination string

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

+ func (*GetJobSpecificationsRequest) ProtoMessage()

+ func (x *GetJobSpecificationsRequest) GetJobName() string

+ func (x *GetJobSpecificationsRequest) GetNamespaceName() string

+ func (x *GetJobSpecificationsRequest) GetProjectName() string

+ func (x *GetJobSpecificationsRequest) GetResourceDestination() string

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

+ func (x *GetJobSpecificationsRequest) Reset()

+ func (x *GetJobSpecificationsRequest) String() string

+ type GetJobSpecificationsResponse struct

+ JobSpecificationResponses []*JobSpecificationResponse

+ Jobs []*JobSpecification

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

+ func (*GetJobSpecificationsResponse) ProtoMessage()

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

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

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

+ func (x *GetJobSpecificationsResponse) Reset()

+ func (x *GetJobSpecificationsResponse) String() string

+ type GetJobTaskRequest struct

+ JobName string

+ NamespaceName string

+ ProjectName string

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

+ func (*GetJobTaskRequest) ProtoMessage()

+ func (x *GetJobTaskRequest) GetJobName() string

+ func (x *GetJobTaskRequest) GetNamespaceName() string

+ func (x *GetJobTaskRequest) GetProjectName() string

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

+ func (x *GetJobTaskRequest) Reset()

+ func (x *GetJobTaskRequest) String() string

+ type GetJobTaskResponse struct

+ Task *JobTask

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

+ func (*GetJobTaskResponse) ProtoMessage()

+ func (x *GetJobTaskResponse) GetTask() *JobTask

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

+ func (x *GetJobTaskResponse) Reset()

+ func (x *GetJobTaskResponse) String() string

+ type GetNamespaceRequest struct

+ NamespaceName string

+ ProjectName string

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

+ func (*GetNamespaceRequest) ProtoMessage()

+ func (x *GetNamespaceRequest) GetNamespaceName() string

+ func (x *GetNamespaceRequest) GetProjectName() string

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

+ func (x *GetNamespaceRequest) Reset()

+ func (x *GetNamespaceRequest) String() string

+ type GetNamespaceResponse struct

+ Namespace *NamespaceSpecification

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

+ func (*GetNamespaceResponse) ProtoMessage()

+ func (x *GetNamespaceResponse) GetNamespace() *NamespaceSpecification

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

+ func (x *GetNamespaceResponse) Reset()

+ func (x *GetNamespaceResponse) String() string

+ type GetProjectRequest struct

+ ProjectName string

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

+ func (*GetProjectRequest) ProtoMessage()

+ func (x *GetProjectRequest) GetProjectName() string

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

+ func (x *GetProjectRequest) Reset()

+ func (x *GetProjectRequest) String() string

+ type GetProjectResponse struct

+ Project *ProjectSpecification

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

+ func (*GetProjectResponse) ProtoMessage()

+ func (x *GetProjectResponse) GetProject() *ProjectSpecification

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

+ func (x *GetProjectResponse) Reset()

+ func (x *GetProjectResponse) String() string

+ type GetReplayStatusRequest struct

+ Id string

+ JobName string

+ ProjectName string

+ func (*GetReplayStatusRequest) Descriptor() ([]byte, []int)

+ func (*GetReplayStatusRequest) ProtoMessage()

+ func (x *GetReplayStatusRequest) GetId() string

+ func (x *GetReplayStatusRequest) GetJobName() string

+ func (x *GetReplayStatusRequest) GetProjectName() string

+ func (x *GetReplayStatusRequest) ProtoReflect() protoreflect.Message

+ func (x *GetReplayStatusRequest) Reset()

+ func (x *GetReplayStatusRequest) String() string

+ type GetReplayStatusResponse struct

+ Response *ReplayStatusTreeNode

+ State string

+ func (*GetReplayStatusResponse) Descriptor() ([]byte, []int)

+ func (*GetReplayStatusResponse) ProtoMessage()

+ func (x *GetReplayStatusResponse) GetResponse() *ReplayStatusTreeNode

+ func (x *GetReplayStatusResponse) GetState() string

+ func (x *GetReplayStatusResponse) ProtoReflect() protoreflect.Message

+ func (x *GetReplayStatusResponse) Reset()

+ func (x *GetReplayStatusResponse) String() string

+ type GetWindowRequest struct

+ Offset string

+ ScheduledAt *timestamppb.Timestamp

+ Size string

+ TruncateTo string

+ Version int32

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

+ func (*GetWindowRequest) ProtoMessage()

+ 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 (x *GetWindowRequest) ProtoReflect() protoreflect.Message

+ func (x *GetWindowRequest) Reset()

+ func (x *GetWindowRequest) String() string

+ type GetWindowResponse struct

+ End *timestamppb.Timestamp

+ Start *timestamppb.Timestamp

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

+ func (*GetWindowResponse) ProtoMessage()

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

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

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

+ func (x *GetWindowResponse) Reset()

+ func (x *GetWindowResponse) String() string

+ type HttpDependency struct

+ Headers map[string]string

+ Name string

+ Params map[string]string

+ Url string

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

+ func (*HttpDependency) ProtoMessage()

+ 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 (x *HttpDependency) ProtoReflect() protoreflect.Message

+ func (x *HttpDependency) Reset()

+ func (x *HttpDependency) String() string

+ type IgnoredResource struct

+ Name string

+ Reason string

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

+ func (*IgnoredResource) ProtoMessage()

+ func (x *IgnoredResource) GetName() string

+ func (x *IgnoredResource) GetReason() string

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

+ func (x *IgnoredResource) Reset()

+ func (x *IgnoredResource) String() string

+ type InstanceSpec struct

+ Data []*InstanceSpecData

+ ExecutedAt *timestamppb.Timestamp

+ Name string

+ State string

+ Type InstanceSpec_Type

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

+ func (*InstanceSpec) ProtoMessage()

+ 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 (x *InstanceSpec) ProtoReflect() protoreflect.Message

+ func (x *InstanceSpec) Reset()

+ func (x *InstanceSpec) String() string

+ type InstanceSpecData struct

+ Name string

+ Type InstanceSpecData_Type

+ Value string

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

+ func (*InstanceSpecData) ProtoMessage()

+ func (x *InstanceSpecData) GetName() string

+ func (x *InstanceSpecData) GetType() InstanceSpecData_Type

+ func (x *InstanceSpecData) GetValue() string

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

+ func (x *InstanceSpecData) Reset()

+ func (x *InstanceSpecData) String() string

+ type InstanceSpecData_Type int32

+ const InstanceSpecData_TYPE_ENV

+ const InstanceSpecData_TYPE_FILE

+ const InstanceSpecData_TYPE_UNSPECIFIED

+ func (InstanceSpecData_Type) Descriptor() protoreflect.EnumDescriptor

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

+ func (InstanceSpecData_Type) Type() protoreflect.EnumType

+ func (x InstanceSpecData_Type) Enum() *InstanceSpecData_Type

+ func (x InstanceSpecData_Type) Number() protoreflect.EnumNumber

+ func (x InstanceSpecData_Type) String() string

+ type InstanceSpec_Type int32

+ const InstanceSpec_TYPE_HOOK

+ const InstanceSpec_TYPE_TASK

+ const InstanceSpec_TYPE_UNSPECIFIED

+ func (InstanceSpec_Type) Descriptor() protoreflect.EnumDescriptor

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

+ func (InstanceSpec_Type) Type() protoreflect.EnumType

+ func (x InstanceSpec_Type) Enum() *InstanceSpec_Type

+ func (x InstanceSpec_Type) Number() protoreflect.EnumNumber

+ func (x InstanceSpec_Type) String() string

+ type JobConfigItem struct

+ Name string

+ Value string

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

+ func (*JobConfigItem) ProtoMessage()

+ func (x *JobConfigItem) GetName() string

+ func (x *JobConfigItem) GetValue() string

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

+ func (x *JobConfigItem) Reset()

+ func (x *JobConfigItem) String() string

+ type JobDependency struct

+ HttpDependency *HttpDependency

+ Name string

+ Type string

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

+ func (*JobDependency) ProtoMessage()

+ func (x *JobDependency) GetHttpDependency() *HttpDependency

+ func (x *JobDependency) GetName() string

+ func (x *JobDependency) GetType() string

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

+ func (x *JobDependency) Reset()

+ func (x *JobDependency) String() string

+ type JobEvent struct

+ Type JobEvent_Type

+ Value *structpb.Struct

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

+ func (*JobEvent) ProtoMessage()

+ func (x *JobEvent) GetType() JobEvent_Type

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

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

+ func (x *JobEvent) Reset()

+ func (x *JobEvent) String() string

+ type JobEvent_Type int32

+ const JobEvent_TYPE_FAILURE

+ const JobEvent_TYPE_HOOK_FAIL

+ const JobEvent_TYPE_HOOK_RETRY

+ const JobEvent_TYPE_HOOK_START

+ const JobEvent_TYPE_HOOK_SUCCESS

+ const JobEvent_TYPE_JOB_SUCCESS

+ const JobEvent_TYPE_SENSOR_FAIL

+ const JobEvent_TYPE_SENSOR_RETRY

+ const JobEvent_TYPE_SENSOR_START

+ const JobEvent_TYPE_SENSOR_SUCCESS

+ const JobEvent_TYPE_SLA_MISS

+ const JobEvent_TYPE_TASK_FAIL

+ const JobEvent_TYPE_TASK_RETRY

+ const JobEvent_TYPE_TASK_START

+ const JobEvent_TYPE_TASK_SUCCESS

+ const JobEvent_TYPE_UNSPECIFIED

+ func (JobEvent_Type) Descriptor() protoreflect.EnumDescriptor

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

+ func (JobEvent_Type) Type() protoreflect.EnumType

+ func (x JobEvent_Type) Enum() *JobEvent_Type

+ func (x JobEvent_Type) Number() protoreflect.EnumNumber

+ func (x JobEvent_Type) String() string

+ type JobInspectRequest struct

+ JobName string

+ NamespaceName string

+ ProjectName string

+ ScheduledAt *timestamppb.Timestamp

+ Spec *JobSpecification

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

+ func (*JobInspectRequest) ProtoMessage()

+ 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 (x *JobInspectRequest) ProtoReflect() protoreflect.Message

+ func (x *JobInspectRequest) Reset()

+ func (x *JobInspectRequest) String() string

+ type JobInspectResponse struct

+ BasicInfo *JobInspectResponse_BasicInfoSection

+ Downstreams *JobInspectResponse_DownstreamSection

+ Upstreams *JobInspectResponse_UpstreamSection

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

+ func (*JobInspectResponse) ProtoMessage()

+ func (x *JobInspectResponse) GetBasicInfo() *JobInspectResponse_BasicInfoSection

+ func (x *JobInspectResponse) GetDownstreams() *JobInspectResponse_DownstreamSection

+ func (x *JobInspectResponse) GetUpstreams() *JobInspectResponse_UpstreamSection

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

+ func (x *JobInspectResponse) Reset()

+ func (x *JobInspectResponse) String() string

+ type JobInspectResponse_BasicInfoSection struct

+ Destination string

+ Job *JobSpecification

+ Notice []*Log

+ Source []string

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

+ func (*JobInspectResponse_BasicInfoSection) ProtoMessage()

+ 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 (x *JobInspectResponse_BasicInfoSection) ProtoReflect() protoreflect.Message

+ func (x *JobInspectResponse_BasicInfoSection) Reset()

+ func (x *JobInspectResponse_BasicInfoSection) String() string

+ type JobInspectResponse_DownstreamSection struct

+ DownstreamJobs []*JobInspectResponse_JobDependency

+ Notice []*Log

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

+ func (*JobInspectResponse_DownstreamSection) ProtoMessage()

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

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

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

+ func (x *JobInspectResponse_DownstreamSection) Reset()

+ func (x *JobInspectResponse_DownstreamSection) String() string

+ type JobInspectResponse_JobDependency struct

+ Host string

+ Name string

+ NamespaceName string

+ ProjectName string

+ Runs []*JobRun

+ TaskName string

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

+ func (*JobInspectResponse_JobDependency) ProtoMessage()

+ 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 (x *JobInspectResponse_JobDependency) ProtoReflect() protoreflect.Message

+ func (x *JobInspectResponse_JobDependency) Reset()

+ func (x *JobInspectResponse_JobDependency) String() string

+ type JobInspectResponse_UpstreamSection struct

+ ExternalDependency []*JobInspectResponse_JobDependency

+ HttpDependency []*HttpDependency

+ InternalDependency []*JobInspectResponse_JobDependency

+ Notice []*Log

+ UnknownDependencies []*JobInspectResponse_UpstreamSection_UnknownDependencies

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

+ func (*JobInspectResponse_UpstreamSection) ProtoMessage()

+ 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 (x *JobInspectResponse_UpstreamSection) ProtoReflect() protoreflect.Message

+ func (x *JobInspectResponse_UpstreamSection) Reset()

+ func (x *JobInspectResponse_UpstreamSection) String() string

+ type JobInspectResponse_UpstreamSection_UnknownDependencies struct

+ JobName string

+ ProjectName string

+ ResourceDestination string

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

+ func (*JobInspectResponse_UpstreamSection_UnknownDependencies) ProtoMessage()

+ func (x *JobInspectResponse_UpstreamSection_UnknownDependencies) GetJobName() string

+ func (x *JobInspectResponse_UpstreamSection_UnknownDependencies) GetProjectName() string

+ func (x *JobInspectResponse_UpstreamSection_UnknownDependencies) GetResourceDestination() string

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

+ func (x *JobInspectResponse_UpstreamSection_UnknownDependencies) Reset()

+ func (x *JobInspectResponse_UpstreamSection_UnknownDependencies) String() string

+ type JobMetadata struct

+ Airflow *JobSpecMetadataAirflow

+ Resource *JobSpecMetadataResource

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

+ func (*JobMetadata) ProtoMessage()

+ func (x *JobMetadata) GetAirflow() *JobSpecMetadataAirflow

+ func (x *JobMetadata) GetResource() *JobSpecMetadataResource

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

+ func (x *JobMetadata) Reset()

+ func (x *JobMetadata) String() string

+ type JobRun struct

+ ScheduledAt *timestamppb.Timestamp

+ State string

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

+ func (*JobRun) ProtoMessage()

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

+ func (x *JobRun) GetState() string

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

+ func (x *JobRun) Reset()

+ func (x *JobRun) String() string

+ type JobRunInputRequest struct

+ InstanceName string

+ InstanceType InstanceSpec_Type

+ JobName string

+ JobrunId string

+ ProjectName string

+ ScheduledAt *timestamppb.Timestamp

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

+ func (*JobRunInputRequest) ProtoMessage()

+ 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 (x *JobRunInputRequest) ProtoReflect() protoreflect.Message

+ func (x *JobRunInputRequest) Reset()

+ func (x *JobRunInputRequest) String() string

+ type JobRunInputResponse struct

+ Envs map[string]string

+ Files map[string]string

+ Secrets map[string]string

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

+ func (*JobRunInputResponse) ProtoMessage()

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

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

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

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

+ func (x *JobRunInputResponse) Reset()

+ func (x *JobRunInputResponse) String() string

+ type JobRunRequest struct

+ EndDate *timestamppb.Timestamp

+ Filter []string

+ JobName string

+ ProjectName string

+ StartDate *timestamppb.Timestamp

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

+ func (*JobRunRequest) ProtoMessage()

+ 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 (x *JobRunRequest) ProtoReflect() protoreflect.Message

+ func (x *JobRunRequest) Reset()

+ func (x *JobRunRequest) String() string

+ type JobRunResponse struct

+ JobRuns []*JobRun

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

+ func (*JobRunResponse) ProtoMessage()

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

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

+ func (x *JobRunResponse) Reset()

+ func (x *JobRunResponse) String() string

+ type JobRunServiceClient interface

+ JobRun func(ctx context.Context, in *JobRunRequest, opts ...grpc.CallOption) (*JobRunResponse, error)

+ JobRunInput func(ctx context.Context, in *JobRunInputRequest, opts ...grpc.CallOption) (*JobRunInputResponse, error)

+ RegisterJobEvent func(ctx context.Context, in *RegisterJobEventRequest, opts ...grpc.CallOption) (*RegisterJobEventResponse, error)

+ UploadToScheduler func(ctx context.Context, in *UploadToSchedulerRequest, opts ...grpc.CallOption) (*UploadToSchedulerResponse, error)

+ func NewJobRunServiceClient(cc grpc.ClientConnInterface) JobRunServiceClient

+ type JobRunServiceServer interface

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

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

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

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

+ type JobSpecHook struct

+ Config []*JobConfigItem

+ Name string

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

+ func (*JobSpecHook) ProtoMessage()

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

+ func (x *JobSpecHook) GetName() string

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

+ func (x *JobSpecHook) Reset()

+ func (x *JobSpecHook) String() string

+ type JobSpecMetadataAirflow struct

+ Pool string

+ Queue string

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

+ func (*JobSpecMetadataAirflow) ProtoMessage()

+ func (x *JobSpecMetadataAirflow) GetPool() string

+ func (x *JobSpecMetadataAirflow) GetQueue() string

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

+ func (x *JobSpecMetadataAirflow) Reset()

+ func (x *JobSpecMetadataAirflow) String() string

+ type JobSpecMetadataResource struct

+ Limit *JobSpecMetadataResourceConfig

+ Request *JobSpecMetadataResourceConfig

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

+ func (*JobSpecMetadataResource) ProtoMessage()

+ func (x *JobSpecMetadataResource) GetLimit() *JobSpecMetadataResourceConfig

+ func (x *JobSpecMetadataResource) GetRequest() *JobSpecMetadataResourceConfig

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

+ func (x *JobSpecMetadataResource) Reset()

+ func (x *JobSpecMetadataResource) String() string

+ type JobSpecMetadataResourceConfig struct

+ Cpu string

+ Memory string

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

+ func (*JobSpecMetadataResourceConfig) ProtoMessage()

+ func (x *JobSpecMetadataResourceConfig) GetCpu() string

+ func (x *JobSpecMetadataResourceConfig) GetMemory() string

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

+ func (x *JobSpecMetadataResourceConfig) Reset()

+ func (x *JobSpecMetadataResourceConfig) String() string

+ type JobSpecification struct

+ Assets map[string]string

+ Behavior *JobSpecification_Behavior

+ CatchUp bool

+ Config []*JobConfigItem

+ Dependencies []*JobDependency

+ DependsOnPast bool

+ Description string

+ Destination string

+ EndDate string

+ Hooks []*JobSpecHook

+ Interval string

+ Labels map[string]string

+ Metadata *JobMetadata

+ Name string

+ Owner string

+ Sources []string

+ StartDate string

+ TaskName string

+ Version int32

+ WindowOffset string

+ WindowSize string

+ WindowTruncateTo string

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

+ func (*JobSpecification) ProtoMessage()

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

+ func (x *JobSpecification) GetBehavior() *JobSpecification_Behavior

+ func (x *JobSpecification) GetCatchUp() bool

+ 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 (x *JobSpecification) ProtoReflect() protoreflect.Message

+ func (x *JobSpecification) Reset()

+ func (x *JobSpecification) String() string

+ type JobSpecificationResponse struct

+ Job *JobSpecification

+ NamespaceName string

+ ProjectName string

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

+ func (*JobSpecificationResponse) ProtoMessage()

+ func (x *JobSpecificationResponse) GetJob() *JobSpecification

+ func (x *JobSpecificationResponse) GetNamespaceName() string

+ func (x *JobSpecificationResponse) GetProjectName() string

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

+ func (x *JobSpecificationResponse) Reset()

+ func (x *JobSpecificationResponse) String() string

+ type JobSpecificationServiceClient interface

+ AddJobSpecifications func(ctx context.Context, in *AddJobSpecificationsRequest, opts ...grpc.CallOption) (*AddJobSpecificationsResponse, error)

+ CheckJobSpecification func(ctx context.Context, in *CheckJobSpecificationRequest, opts ...grpc.CallOption) (*CheckJobSpecificationResponse, error)

+ CheckJobSpecifications func(ctx context.Context, in *CheckJobSpecificationsRequest, ...) (JobSpecificationService_CheckJobSpecificationsClient, error)

+ CreateJobSpecification func(ctx context.Context, in *CreateJobSpecificationRequest, ...) (*CreateJobSpecificationResponse, error)

+ DeleteJobSpecification func(ctx context.Context, in *DeleteJobSpecificationRequest, ...) (*DeleteJobSpecificationResponse, error)

+ DeployJobSpecification func(ctx context.Context, opts ...grpc.CallOption) (JobSpecificationService_DeployJobSpecificationClient, error)

+ GetDeployJobsStatus func(ctx context.Context, in *GetDeployJobsStatusRequest, opts ...grpc.CallOption) (*GetDeployJobsStatusResponse, error)

+ GetJobSpecification func(ctx context.Context, in *GetJobSpecificationRequest, opts ...grpc.CallOption) (*GetJobSpecificationResponse, error)

+ GetJobSpecifications func(ctx context.Context, in *GetJobSpecificationsRequest, opts ...grpc.CallOption) (*GetJobSpecificationsResponse, error)

+ GetJobTask func(ctx context.Context, in *GetJobTaskRequest, opts ...grpc.CallOption) (*GetJobTaskResponse, error)

+ GetWindow func(ctx context.Context, in *GetWindowRequest, opts ...grpc.CallOption) (*GetWindowResponse, error)

+ JobInspect func(ctx context.Context, in *JobInspectRequest, opts ...grpc.CallOption) (*JobInspectResponse, error)

+ ListJobSpecification func(ctx context.Context, in *ListJobSpecificationRequest, opts ...grpc.CallOption) (*ListJobSpecificationResponse, error)

+ RefreshJobs func(ctx context.Context, in *RefreshJobsRequest, opts ...grpc.CallOption) (JobSpecificationService_RefreshJobsClient, error)

+ ReplaceAllJobSpecifications func(ctx context.Context, opts ...grpc.CallOption) (JobSpecificationService_ReplaceAllJobSpecificationsClient, error)

+ UpdateJobSpecifications func(ctx context.Context, in *UpdateJobSpecificationsRequest, ...) (*UpdateJobSpecificationsResponse, error)

+ func NewJobSpecificationServiceClient(cc grpc.ClientConnInterface) JobSpecificationServiceClient

+ type JobSpecificationServiceServer interface

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

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

+ CheckJobSpecifications func(*CheckJobSpecificationsRequest, ...) error

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

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

+ DeployJobSpecification func(JobSpecificationService_DeployJobSpecificationServer) error

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

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

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

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

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

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

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

+ RefreshJobs func(*RefreshJobsRequest, JobSpecificationService_RefreshJobsServer) error

+ ReplaceAllJobSpecifications func(JobSpecificationService_ReplaceAllJobSpecificationsServer) error

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

+ type JobSpecificationService_CheckJobSpecificationsClient interface

+ Recv func() (*CheckJobSpecificationsResponse, error)

+ type JobSpecificationService_CheckJobSpecificationsServer interface

+ Send func(*CheckJobSpecificationsResponse) error

+ type JobSpecificationService_DeployJobSpecificationClient interface

+ Recv func() (*DeployJobSpecificationResponse, error)

+ Send func(*DeployJobSpecificationRequest) error

+ type JobSpecificationService_DeployJobSpecificationServer interface

+ Recv func() (*DeployJobSpecificationRequest, error)

+ Send func(*DeployJobSpecificationResponse) error

+ type JobSpecificationService_RefreshJobsClient interface

+ Recv func() (*RefreshJobsResponse, error)

+ type JobSpecificationService_RefreshJobsServer interface

+ Send func(*RefreshJobsResponse) error

+ type JobSpecificationService_ReplaceAllJobSpecificationsClient interface

+ Recv func() (*ReplaceAllJobSpecificationsResponse, error)

+ Send func(*ReplaceAllJobSpecificationsRequest) error

+ type JobSpecificationService_ReplaceAllJobSpecificationsServer interface

+ Recv func() (*ReplaceAllJobSpecificationsRequest, error)

+ Send func(*ReplaceAllJobSpecificationsResponse) error

+ type JobSpecification_Behavior struct

+ Notify []*JobSpecification_Behavior_Notifiers

+ Retry *JobSpecification_Behavior_Retry

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

+ func (*JobSpecification_Behavior) ProtoMessage()

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

+ func (x *JobSpecification_Behavior) GetRetry() *JobSpecification_Behavior_Retry

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

+ func (x *JobSpecification_Behavior) Reset()

+ func (x *JobSpecification_Behavior) String() string

+ type JobSpecification_Behavior_Notifiers struct

+ Channels []string

+ Config map[string]string

+ On JobEvent_Type

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

+ func (*JobSpecification_Behavior_Notifiers) ProtoMessage()

+ 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 (x *JobSpecification_Behavior_Notifiers) ProtoReflect() protoreflect.Message

+ func (x *JobSpecification_Behavior_Notifiers) Reset()

+ func (x *JobSpecification_Behavior_Notifiers) String() string

+ type JobSpecification_Behavior_Retry struct

+ Count int32

+ Delay *durationpb.Duration

+ ExponentialBackoff bool

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

+ func (*JobSpecification_Behavior_Retry) ProtoMessage()

+ func (x *JobSpecification_Behavior_Retry) GetCount() int32

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

+ func (x *JobSpecification_Behavior_Retry) GetExponentialBackoff() bool

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

+ func (x *JobSpecification_Behavior_Retry) Reset()

+ func (x *JobSpecification_Behavior_Retry) String() string

+ type JobTask struct

+ Dependencies []*JobTask_Dependency

+ Description string

+ Destination *JobTask_Destination

+ Image string

+ Name string

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

+ func (*JobTask) ProtoMessage()

+ 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 (x *JobTask) ProtoReflect() protoreflect.Message

+ func (x *JobTask) Reset()

+ func (x *JobTask) String() string

+ type JobTask_Dependency struct

+ Dependency string

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

+ func (*JobTask_Dependency) ProtoMessage()

+ func (x *JobTask_Dependency) GetDependency() string

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

+ func (x *JobTask_Dependency) Reset()

+ func (x *JobTask_Dependency) String() string

+ type JobTask_Destination struct

+ Destination string

+ Type string

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

+ func (*JobTask_Destination) ProtoMessage()

+ func (x *JobTask_Destination) GetDestination() string

+ func (x *JobTask_Destination) GetType() string

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

+ func (x *JobTask_Destination) Reset()

+ func (x *JobTask_Destination) String() string

+ type Level int32

+ const Level_LEVEL_DEBUG

+ const Level_LEVEL_ERROR

+ const Level_LEVEL_FATAL

+ const Level_LEVEL_INFO

+ const Level_LEVEL_TRACE

+ const Level_LEVEL_UNSPECIFIED

+ const Level_LEVEL_WARNING

+ func (Level) Descriptor() protoreflect.EnumDescriptor

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

+ func (Level) Type() protoreflect.EnumType

+ func (x Level) Enum() *Level

+ func (x Level) Number() protoreflect.EnumNumber

+ func (x Level) String() string

+ type ListBackupsRequest struct

+ DatastoreName string

+ NamespaceName string

+ ProjectName string

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

+ func (*ListBackupsRequest) ProtoMessage()

+ func (x *ListBackupsRequest) GetDatastoreName() string

+ func (x *ListBackupsRequest) GetNamespaceName() string

+ func (x *ListBackupsRequest) GetProjectName() string

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

+ func (x *ListBackupsRequest) Reset()

+ func (x *ListBackupsRequest) String() string

+ type ListBackupsResponse struct

+ Backups []*BackupSpec

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

+ func (*ListBackupsResponse) ProtoMessage()

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

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

+ func (x *ListBackupsResponse) Reset()

+ func (x *ListBackupsResponse) String() string

+ type ListJobSpecificationRequest struct

+ NamespaceName string

+ ProjectName string

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

+ func (*ListJobSpecificationRequest) ProtoMessage()

+ func (x *ListJobSpecificationRequest) GetNamespaceName() string

+ func (x *ListJobSpecificationRequest) GetProjectName() string

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

+ func (x *ListJobSpecificationRequest) Reset()

+ func (x *ListJobSpecificationRequest) String() string

+ type ListJobSpecificationResponse struct

+ Jobs []*JobSpecification

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

+ func (*ListJobSpecificationResponse) ProtoMessage()

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

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

+ func (x *ListJobSpecificationResponse) Reset()

+ func (x *ListJobSpecificationResponse) String() string

+ type ListProjectNamespacesRequest struct

+ ProjectName string

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

+ func (*ListProjectNamespacesRequest) ProtoMessage()

+ func (x *ListProjectNamespacesRequest) GetProjectName() string

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

+ func (x *ListProjectNamespacesRequest) Reset()

+ func (x *ListProjectNamespacesRequest) String() string

+ type ListProjectNamespacesResponse struct

+ Namespaces []*NamespaceSpecification

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

+ func (*ListProjectNamespacesResponse) ProtoMessage()

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

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

+ func (x *ListProjectNamespacesResponse) Reset()

+ func (x *ListProjectNamespacesResponse) String() string

+ type ListProjectsRequest struct

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

+ func (*ListProjectsRequest) ProtoMessage()

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

+ func (x *ListProjectsRequest) Reset()

+ func (x *ListProjectsRequest) String() string

+ type ListProjectsResponse struct

+ Projects []*ProjectSpecification

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

+ func (*ListProjectsResponse) ProtoMessage()

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

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

+ func (x *ListProjectsResponse) Reset()

+ func (x *ListProjectsResponse) String() string

+ type ListReplaysRequest struct

+ ProjectName string

+ func (*ListReplaysRequest) Descriptor() ([]byte, []int)

+ func (*ListReplaysRequest) ProtoMessage()

+ func (x *ListReplaysRequest) GetProjectName() string

+ func (x *ListReplaysRequest) ProtoReflect() protoreflect.Message

+ func (x *ListReplaysRequest) Reset()

+ func (x *ListReplaysRequest) String() string

+ type ListReplaysResponse struct

+ ReplayList []*ReplaySpec

+ func (*ListReplaysResponse) Descriptor() ([]byte, []int)

+ func (*ListReplaysResponse) ProtoMessage()

+ func (x *ListReplaysResponse) GetReplayList() []*ReplaySpec

+ func (x *ListReplaysResponse) ProtoReflect() protoreflect.Message

+ func (x *ListReplaysResponse) Reset()

+ func (x *ListReplaysResponse) String() string

+ type ListResourceSpecificationRequest struct

+ DatastoreName string

+ NamespaceName string

+ ProjectName string

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

+ func (*ListResourceSpecificationRequest) ProtoMessage()

+ func (x *ListResourceSpecificationRequest) GetDatastoreName() string

+ func (x *ListResourceSpecificationRequest) GetNamespaceName() string

+ func (x *ListResourceSpecificationRequest) GetProjectName() string

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

+ func (x *ListResourceSpecificationRequest) Reset()

+ func (x *ListResourceSpecificationRequest) String() string

+ type ListResourceSpecificationResponse struct

+ Resources []*ResourceSpecification

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

+ func (*ListResourceSpecificationResponse) ProtoMessage()

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

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

+ func (x *ListResourceSpecificationResponse) Reset()

+ func (x *ListResourceSpecificationResponse) String() string

+ type ListSecretsRequest struct

+ ProjectName string

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

+ func (*ListSecretsRequest) ProtoMessage()

+ func (x *ListSecretsRequest) GetProjectName() string

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

+ func (x *ListSecretsRequest) Reset()

+ func (x *ListSecretsRequest) String() string

+ type ListSecretsResponse struct

+ Secrets []*ListSecretsResponse_Secret

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

+ func (*ListSecretsResponse) ProtoMessage()

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

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

+ func (x *ListSecretsResponse) Reset()

+ func (x *ListSecretsResponse) String() string

+ type ListSecretsResponse_Secret struct

+ Digest string

+ Name string

+ Namespace string

+ UpdatedAt *timestamppb.Timestamp

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

+ func (*ListSecretsResponse_Secret) ProtoMessage()

+ 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 (x *ListSecretsResponse_Secret) ProtoReflect() protoreflect.Message

+ func (x *ListSecretsResponse_Secret) Reset()

+ func (x *ListSecretsResponse_Secret) String() string

+ type Log struct

+ Level Level

+ Message string

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

+ func (*Log) ProtoMessage()

+ func (x *Log) GetLevel() Level

+ func (x *Log) GetMessage() string

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

+ func (x *Log) Reset()

+ func (x *Log) String() string

+ type NamespaceServiceClient interface

+ GetNamespace func(ctx context.Context, in *GetNamespaceRequest, opts ...grpc.CallOption) (*GetNamespaceResponse, error)

+ ListProjectNamespaces func(ctx context.Context, in *ListProjectNamespacesRequest, opts ...grpc.CallOption) (*ListProjectNamespacesResponse, error)

+ RegisterProjectNamespace func(ctx context.Context, in *RegisterProjectNamespaceRequest, ...) (*RegisterProjectNamespaceResponse, error)

+ func NewNamespaceServiceClient(cc grpc.ClientConnInterface) NamespaceServiceClient

+ type NamespaceServiceServer interface

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

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

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

+ type NamespaceSpecification struct

+ Config map[string]string

+ Name string

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

+ func (*NamespaceSpecification) ProtoMessage()

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

+ func (x *NamespaceSpecification) GetName() string

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

+ func (x *NamespaceSpecification) Reset()

+ func (x *NamespaceSpecification) String() string

+ type ProjectServiceClient interface

+ GetProject func(ctx context.Context, in *GetProjectRequest, opts ...grpc.CallOption) (*GetProjectResponse, error)

+ ListProjects func(ctx context.Context, in *ListProjectsRequest, opts ...grpc.CallOption) (*ListProjectsResponse, error)

+ RegisterProject func(ctx context.Context, in *RegisterProjectRequest, opts ...grpc.CallOption) (*RegisterProjectResponse, error)

+ func NewProjectServiceClient(cc grpc.ClientConnInterface) ProjectServiceClient

+ type ProjectServiceServer interface

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

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

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

+ type ProjectSpecification struct

+ Config map[string]string

+ Name string

+ Secrets []*ProjectSpecification_ProjectSecret

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

+ func (*ProjectSpecification) ProtoMessage()

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

+ func (x *ProjectSpecification) GetName() string

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

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

+ func (x *ProjectSpecification) Reset()

+ func (x *ProjectSpecification) String() string

+ type ProjectSpecification_ProjectSecret struct

+ Name string

+ Value string

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

+ func (*ProjectSpecification_ProjectSecret) ProtoMessage()

+ func (x *ProjectSpecification_ProjectSecret) GetName() string

+ func (x *ProjectSpecification_ProjectSecret) GetValue() string

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

+ func (x *ProjectSpecification_ProjectSecret) Reset()

+ func (x *ProjectSpecification_ProjectSecret) String() string

+ type ReadResourceRequest struct

+ DatastoreName string

+ NamespaceName string

+ ProjectName string

+ ResourceName string

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

+ func (*ReadResourceRequest) ProtoMessage()

+ func (x *ReadResourceRequest) GetDatastoreName() string

+ func (x *ReadResourceRequest) GetNamespaceName() string

+ func (x *ReadResourceRequest) GetProjectName() string

+ func (x *ReadResourceRequest) GetResourceName() string

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

+ func (x *ReadResourceRequest) Reset()

+ func (x *ReadResourceRequest) String() string

+ type ReadResourceResponse struct

+ Message string

+ Resource *ResourceSpecification

+ Success bool

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

+ func (*ReadResourceResponse) ProtoMessage()

+ func (x *ReadResourceResponse) GetMessage() string

+ func (x *ReadResourceResponse) GetResource() *ResourceSpecification

+ func (x *ReadResourceResponse) GetSuccess() bool

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

+ func (x *ReadResourceResponse) Reset()

+ func (x *ReadResourceResponse) String() string

+ type RefreshJobsRequest struct

+ JobNames []string

+ NamespaceNames []string

+ ProjectName string

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

+ func (*RefreshJobsRequest) ProtoMessage()

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

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

+ func (x *RefreshJobsRequest) GetProjectName() string

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

+ func (x *RefreshJobsRequest) Reset()

+ func (x *RefreshJobsRequest) String() string

+ type RefreshJobsResponse struct

+ LogStatus *Log

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

+ func (*RefreshJobsResponse) ProtoMessage()

+ func (x *RefreshJobsResponse) GetLogStatus() *Log

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

+ func (x *RefreshJobsResponse) Reset()

+ func (x *RefreshJobsResponse) String() string

+ type RegisterJobEventRequest struct

+ Event *JobEvent

+ JobName string

+ NamespaceName string

+ ProjectName string

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

+ func (*RegisterJobEventRequest) ProtoMessage()

+ func (x *RegisterJobEventRequest) GetEvent() *JobEvent

+ func (x *RegisterJobEventRequest) GetJobName() string

+ func (x *RegisterJobEventRequest) GetNamespaceName() string

+ func (x *RegisterJobEventRequest) GetProjectName() string

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

+ func (x *RegisterJobEventRequest) Reset()

+ func (x *RegisterJobEventRequest) String() string

+ type RegisterJobEventResponse struct

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

+ func (*RegisterJobEventResponse) ProtoMessage()

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

+ func (x *RegisterJobEventResponse) Reset()

+ func (x *RegisterJobEventResponse) String() string

+ type RegisterProjectNamespaceRequest struct

+ Namespace *NamespaceSpecification

+ ProjectName string

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

+ func (*RegisterProjectNamespaceRequest) ProtoMessage()

+ func (x *RegisterProjectNamespaceRequest) GetNamespace() *NamespaceSpecification

+ func (x *RegisterProjectNamespaceRequest) GetProjectName() string

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

+ func (x *RegisterProjectNamespaceRequest) Reset()

+ func (x *RegisterProjectNamespaceRequest) String() string

+ type RegisterProjectNamespaceResponse struct

+ Message string

+ Success bool

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

+ func (*RegisterProjectNamespaceResponse) ProtoMessage()

+ func (x *RegisterProjectNamespaceResponse) GetMessage() string

+ func (x *RegisterProjectNamespaceResponse) GetSuccess() bool

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

+ func (x *RegisterProjectNamespaceResponse) Reset()

+ func (x *RegisterProjectNamespaceResponse) String() string

+ type RegisterProjectRequest struct

+ Project *ProjectSpecification

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

+ func (*RegisterProjectRequest) ProtoMessage()

+ func (x *RegisterProjectRequest) GetProject() *ProjectSpecification

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

+ func (x *RegisterProjectRequest) Reset()

+ func (x *RegisterProjectRequest) String() string

+ type RegisterProjectResponse struct

+ Message string

+ Success bool

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

+ func (*RegisterProjectResponse) ProtoMessage()

+ func (x *RegisterProjectResponse) GetMessage() string

+ func (x *RegisterProjectResponse) GetSuccess() bool

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

+ func (x *RegisterProjectResponse) Reset()

+ func (x *RegisterProjectResponse) String() string

+ type RegisterSecretRequest struct

+ NamespaceName string

+ ProjectName string

+ SecretName string

+ Value string

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

+ func (*RegisterSecretRequest) ProtoMessage()

+ func (x *RegisterSecretRequest) GetNamespaceName() string

+ func (x *RegisterSecretRequest) GetProjectName() string

+ func (x *RegisterSecretRequest) GetSecretName() string

+ func (x *RegisterSecretRequest) GetValue() string

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

+ func (x *RegisterSecretRequest) Reset()

+ func (x *RegisterSecretRequest) String() string

+ type RegisterSecretResponse struct

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

+ func (*RegisterSecretResponse) ProtoMessage()

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

+ func (x *RegisterSecretResponse) Reset()

+ func (x *RegisterSecretResponse) String() string

+ type ReplaceAllJobSpecificationsRequest struct

+ Jobs []*JobSpecification

+ NamespaceName string

+ ProjectName string

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

+ func (*ReplaceAllJobSpecificationsRequest) ProtoMessage()

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

+ func (x *ReplaceAllJobSpecificationsRequest) GetNamespaceName() string

+ func (x *ReplaceAllJobSpecificationsRequest) GetProjectName() string

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

+ func (x *ReplaceAllJobSpecificationsRequest) Reset()

+ func (x *ReplaceAllJobSpecificationsRequest) String() string

+ type ReplaceAllJobSpecificationsResponse struct

+ LogStatus *Log

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

+ func (*ReplaceAllJobSpecificationsResponse) ProtoMessage()

+ func (x *ReplaceAllJobSpecificationsResponse) GetLogStatus() *Log

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

+ func (x *ReplaceAllJobSpecificationsResponse) Reset()

+ func (x *ReplaceAllJobSpecificationsResponse) String() string

+ type ReplayDryRunRequest struct

+ AllowedDownstreamNamespaces []string

+ EndDate string

+ JobName string

+ NamespaceName string

+ ProjectName string

+ StartDate string

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

+ func (*ReplayDryRunRequest) ProtoMessage()

+ func (x *ReplayDryRunRequest) GetAllowedDownstreamNamespaces() []string

+ func (x *ReplayDryRunRequest) GetEndDate() string

+ func (x *ReplayDryRunRequest) GetJobName() string

+ func (x *ReplayDryRunRequest) GetNamespaceName() string

+ func (x *ReplayDryRunRequest) GetProjectName() string

+ func (x *ReplayDryRunRequest) GetStartDate() string

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

+ func (x *ReplayDryRunRequest) Reset()

+ func (x *ReplayDryRunRequest) String() string

+ type ReplayDryRunResponse struct

+ ExecutionTree *ReplayExecutionTreeNode

+ IgnoredJobs []string

+ Response *ReplayExecutionTreeNode

+ Success bool

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

+ func (*ReplayDryRunResponse) ProtoMessage()

+ func (x *ReplayDryRunResponse) GetExecutionTree() *ReplayExecutionTreeNode

+ func (x *ReplayDryRunResponse) GetIgnoredJobs() []string

+ func (x *ReplayDryRunResponse) GetResponse() *ReplayExecutionTreeNode

+ func (x *ReplayDryRunResponse) GetSuccess() bool

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

+ func (x *ReplayDryRunResponse) Reset()

+ func (x *ReplayDryRunResponse) String() string

+ type ReplayExecutionTreeNode struct

+ Dependents []*ReplayExecutionTreeNode

+ JobName string

+ Runs []*timestamppb.Timestamp

+ func (*ReplayExecutionTreeNode) Descriptor() ([]byte, []int)

+ func (*ReplayExecutionTreeNode) ProtoMessage()

+ func (x *ReplayExecutionTreeNode) GetDependents() []*ReplayExecutionTreeNode

+ func (x *ReplayExecutionTreeNode) GetJobName() string

+ func (x *ReplayExecutionTreeNode) GetRuns() []*timestamppb.Timestamp

+ func (x *ReplayExecutionTreeNode) ProtoReflect() protoreflect.Message

+ func (x *ReplayExecutionTreeNode) Reset()

+ func (x *ReplayExecutionTreeNode) String() string

+ type ReplayRequest struct

+ AllowedDownstreamNamespaces []string

+ EndDate string

+ Force bool

+ JobName string

+ NamespaceName string

+ ProjectName string

+ StartDate string

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

+ func (*ReplayRequest) ProtoMessage()

+ func (x *ReplayRequest) GetAllowedDownstreamNamespaces() []string

+ func (x *ReplayRequest) GetEndDate() string

+ func (x *ReplayRequest) GetForce() bool

+ func (x *ReplayRequest) GetJobName() string

+ func (x *ReplayRequest) GetNamespaceName() string

+ func (x *ReplayRequest) GetProjectName() string

+ func (x *ReplayRequest) GetStartDate() string

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

+ func (x *ReplayRequest) Reset()

+ func (x *ReplayRequest) String() string

+ type ReplayResponse struct

+ Id string

+ IgnoredJobs []string

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

+ func (*ReplayResponse) ProtoMessage()

+ func (x *ReplayResponse) GetId() string

+ func (x *ReplayResponse) GetIgnoredJobs() []string

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

+ func (x *ReplayResponse) Reset()

+ func (x *ReplayResponse) String() string

+ type ReplayServiceClient interface

+ GetReplayStatus func(ctx context.Context, in *GetReplayStatusRequest, opts ...grpc.CallOption) (*GetReplayStatusResponse, error)

+ ListReplays func(ctx context.Context, in *ListReplaysRequest, opts ...grpc.CallOption) (*ListReplaysResponse, error)

+ Replay func(ctx context.Context, in *ReplayRequest, opts ...grpc.CallOption) (*ReplayResponse, error)

+ ReplayDryRun func(ctx context.Context, in *ReplayDryRunRequest, opts ...grpc.CallOption) (*ReplayDryRunResponse, error)

+ func NewReplayServiceClient(cc grpc.ClientConnInterface) ReplayServiceClient

+ type ReplayServiceServer interface

+ GetReplayStatus func(context.Context, *GetReplayStatusRequest) (*GetReplayStatusResponse, error)

+ ListReplays func(context.Context, *ListReplaysRequest) (*ListReplaysResponse, error)

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

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

+ type ReplaySpec struct

+ Config map[string]string

+ CreatedAt *timestamppb.Timestamp

+ EndDate *timestamppb.Timestamp

+ Id string

+ JobName string

+ StartDate *timestamppb.Timestamp

+ State string

+ func (*ReplaySpec) Descriptor() ([]byte, []int)

+ func (*ReplaySpec) ProtoMessage()

+ func (x *ReplaySpec) GetConfig() map[string]string

+ func (x *ReplaySpec) GetCreatedAt() *timestamppb.Timestamp

+ func (x *ReplaySpec) GetEndDate() *timestamppb.Timestamp

+ func (x *ReplaySpec) GetId() string

+ func (x *ReplaySpec) GetJobName() string

+ func (x *ReplaySpec) GetStartDate() *timestamppb.Timestamp

+ func (x *ReplaySpec) GetState() string

+ func (x *ReplaySpec) ProtoReflect() protoreflect.Message

+ func (x *ReplaySpec) Reset()

+ func (x *ReplaySpec) String() string

+ type ReplayStatusRun struct

+ Run *timestamppb.Timestamp

+ State string

+ func (*ReplayStatusRun) Descriptor() ([]byte, []int)

+ func (*ReplayStatusRun) ProtoMessage()

+ func (x *ReplayStatusRun) GetRun() *timestamppb.Timestamp

+ func (x *ReplayStatusRun) GetState() string

+ func (x *ReplayStatusRun) ProtoReflect() protoreflect.Message

+ func (x *ReplayStatusRun) Reset()

+ func (x *ReplayStatusRun) String() string

+ type ReplayStatusTreeNode struct

+ Dependents []*ReplayStatusTreeNode

+ JobName string

+ Runs []*ReplayStatusRun

+ State string

+ func (*ReplayStatusTreeNode) Descriptor() ([]byte, []int)

+ func (*ReplayStatusTreeNode) ProtoMessage()

+ func (x *ReplayStatusTreeNode) GetDependents() []*ReplayStatusTreeNode

+ func (x *ReplayStatusTreeNode) GetJobName() string

+ func (x *ReplayStatusTreeNode) GetRuns() []*ReplayStatusRun

+ func (x *ReplayStatusTreeNode) GetState() string

+ func (x *ReplayStatusTreeNode) ProtoReflect() protoreflect.Message

+ func (x *ReplayStatusTreeNode) Reset()

+ func (x *ReplayStatusTreeNode) String() string

+ type ResourceServiceClient interface

+ CreateResource func(ctx context.Context, in *CreateResourceRequest, opts ...grpc.CallOption) (*CreateResourceResponse, error)

+ DeployResourceSpecification func(ctx context.Context, opts ...grpc.CallOption) (ResourceService_DeployResourceSpecificationClient, error)

+ ListResourceSpecification func(ctx context.Context, in *ListResourceSpecificationRequest, ...) (*ListResourceSpecificationResponse, error)

+ ReadResource func(ctx context.Context, in *ReadResourceRequest, opts ...grpc.CallOption) (*ReadResourceResponse, error)

+ UpdateResource func(ctx context.Context, in *UpdateResourceRequest, opts ...grpc.CallOption) (*UpdateResourceResponse, error)

+ func NewResourceServiceClient(cc grpc.ClientConnInterface) ResourceServiceClient

+ type ResourceServiceServer interface

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

+ DeployResourceSpecification func(ResourceService_DeployResourceSpecificationServer) error

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

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

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

+ type ResourceService_DeployResourceSpecificationClient interface

+ Recv func() (*DeployResourceSpecificationResponse, error)

+ Send func(*DeployResourceSpecificationRequest) error

+ type ResourceService_DeployResourceSpecificationServer interface

+ Recv func() (*DeployResourceSpecificationRequest, error)

+ Send func(*DeployResourceSpecificationResponse) error

+ type ResourceSpecification struct

+ Assets map[string]string

+ Labels map[string]string

+ Name string

+ Spec *structpb.Struct

+ Type string

+ Version int32

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

+ func (*ResourceSpecification) ProtoMessage()

+ 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 (x *ResourceSpecification) ProtoReflect() protoreflect.Message

+ func (x *ResourceSpecification) Reset()

+ func (x *ResourceSpecification) String() string

+ type RuntimeServiceClient interface

+ Version func(ctx context.Context, in *VersionRequest, opts ...grpc.CallOption) (*VersionResponse, error)

+ func NewRuntimeServiceClient(cc grpc.ClientConnInterface) RuntimeServiceClient

+ type RuntimeServiceServer interface

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

+ type SecretServiceClient interface

+ DeleteSecret func(ctx context.Context, in *DeleteSecretRequest, opts ...grpc.CallOption) (*DeleteSecretResponse, error)

+ ListSecrets func(ctx context.Context, in *ListSecretsRequest, opts ...grpc.CallOption) (*ListSecretsResponse, error)

+ RegisterSecret func(ctx context.Context, in *RegisterSecretRequest, opts ...grpc.CallOption) (*RegisterSecretResponse, error)

+ UpdateSecret func(ctx context.Context, in *UpdateSecretRequest, opts ...grpc.CallOption) (*UpdateSecretResponse, error)

+ func NewSecretServiceClient(cc grpc.ClientConnInterface) SecretServiceClient

+ type SecretServiceServer interface

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

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

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

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

+ type TaskWindow struct

+ Offset *durationpb.Duration

+ Size *durationpb.Duration

+ TruncateTo string

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

+ func (*TaskWindow) ProtoMessage()

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

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

+ func (x *TaskWindow) GetTruncateTo() string

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

+ func (x *TaskWindow) Reset()

+ func (x *TaskWindow) String() string

+ type UnimplementedBackupServiceServer struct

+ 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 struct

+ 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 struct

+ func (UnimplementedJobSpecificationServiceServer) AddJobSpecifications(context.Context, *AddJobSpecificationsRequest) (*AddJobSpecificationsResponse, 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 struct

+ 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 struct

+ 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 struct

+ func (UnimplementedReplayServiceServer) GetReplayStatus(context.Context, *GetReplayStatusRequest) (*GetReplayStatusResponse, error)

+ func (UnimplementedReplayServiceServer) ListReplays(context.Context, *ListReplaysRequest) (*ListReplaysResponse, error)

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

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

+ type UnimplementedResourceServiceServer struct

+ 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 struct

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

+ type UnimplementedSecretServiceServer struct

+ 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 interface

+ type UnsafeJobRunServiceServer interface

+ type UnsafeJobSpecificationServiceServer interface

+ type UnsafeNamespaceServiceServer interface

+ type UnsafeProjectServiceServer interface

+ type UnsafeReplayServiceServer interface

+ type UnsafeResourceServiceServer interface

+ type UnsafeRuntimeServiceServer interface

+ type UnsafeSecretServiceServer interface

+ type UpdateJobSpecificationsRequest struct

+ NamespaceName string

+ ProjectName string

+ Specs []*JobSpecification

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

+ func (*UpdateJobSpecificationsRequest) ProtoMessage()

+ func (x *UpdateJobSpecificationsRequest) GetNamespaceName() string

+ func (x *UpdateJobSpecificationsRequest) GetProjectName() string

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

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

+ func (x *UpdateJobSpecificationsRequest) Reset()

+ func (x *UpdateJobSpecificationsRequest) String() string

+ type UpdateJobSpecificationsResponse struct

+ Log string

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

+ func (*UpdateJobSpecificationsResponse) ProtoMessage()

+ func (x *UpdateJobSpecificationsResponse) GetLog() string

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

+ func (x *UpdateJobSpecificationsResponse) Reset()

+ func (x *UpdateJobSpecificationsResponse) String() string

+ type UpdateResourceRequest struct

+ DatastoreName string

+ NamespaceName string

+ ProjectName string

+ Resource *ResourceSpecification

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

+ func (*UpdateResourceRequest) ProtoMessage()

+ func (x *UpdateResourceRequest) GetDatastoreName() string

+ func (x *UpdateResourceRequest) GetNamespaceName() string

+ func (x *UpdateResourceRequest) GetProjectName() string

+ func (x *UpdateResourceRequest) GetResource() *ResourceSpecification

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

+ func (x *UpdateResourceRequest) Reset()

+ func (x *UpdateResourceRequest) String() string

+ type UpdateResourceResponse struct

+ Message string

+ Success bool

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

+ func (*UpdateResourceResponse) ProtoMessage()

+ func (x *UpdateResourceResponse) GetMessage() string

+ func (x *UpdateResourceResponse) GetSuccess() bool

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

+ func (x *UpdateResourceResponse) Reset()

+ func (x *UpdateResourceResponse) String() string

+ type UpdateSecretRequest struct

+ NamespaceName string

+ ProjectName string

+ SecretName string

+ Value string

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

+ func (*UpdateSecretRequest) ProtoMessage()

+ func (x *UpdateSecretRequest) GetNamespaceName() string

+ func (x *UpdateSecretRequest) GetProjectName() string

+ func (x *UpdateSecretRequest) GetSecretName() string

+ func (x *UpdateSecretRequest) GetValue() string

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

+ func (x *UpdateSecretRequest) Reset()

+ func (x *UpdateSecretRequest) String() string

+ type UpdateSecretResponse struct

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

+ func (*UpdateSecretResponse) ProtoMessage()

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

+ func (x *UpdateSecretResponse) Reset()

+ func (x *UpdateSecretResponse) String() string

+ type UploadToSchedulerRequest struct

+ NamespaceName *string

+ ProjectName string

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

+ func (*UploadToSchedulerRequest) ProtoMessage()

+ func (x *UploadToSchedulerRequest) GetNamespaceName() string

+ func (x *UploadToSchedulerRequest) GetProjectName() string

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

+ func (x *UploadToSchedulerRequest) Reset()

+ func (x *UploadToSchedulerRequest) String() string

+ type UploadToSchedulerResponse struct

+ ErrorMessage string

+ Status bool

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

+ func (*UploadToSchedulerResponse) ProtoMessage()

+ func (x *UploadToSchedulerResponse) GetErrorMessage() string

+ func (x *UploadToSchedulerResponse) GetStatus() bool

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

+ func (x *UploadToSchedulerResponse) Reset()

+ func (x *UploadToSchedulerResponse) String() string

+ type VersionRequest struct

+ Client string

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

+ func (*VersionRequest) ProtoMessage()

+ func (x *VersionRequest) GetClient() string

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

+ func (x *VersionRequest) Reset()

+ func (x *VersionRequest) String() string

+ type VersionResponse struct

+ Server string

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

+ func (*VersionResponse) ProtoMessage()

+ func (x *VersionResponse) GetServer() string

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

+ func (x *VersionResponse) Reset()

+ func (x *VersionResponse) String() string

v0.6.0-rc.16

Mar 20, 2023

v0.6.0-rc.15

Mar 20, 2023

v0.6.0-rc.14

Mar 20, 2023

v0.6.0-rc.13

Mar 20, 2023

v0.6.0-rc.12

Mar 20, 2023

v0.6.0-rc.11

Mar 17, 2023

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