Documentation ¶
Overview ¶
Copyright 2022 Evan Hazlett
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Copyright 2022 Evan Hazlett ¶
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Index ¶
- Variables
- func RegisterJobsServer(s *grpc.Server, srv JobsServer)
- type DeleteJobRequest
- func (*DeleteJobRequest) Descriptor() ([]byte, []int)
- func (m *DeleteJobRequest) GetID() string
- func (m *DeleteJobRequest) Marshal() (dAtA []byte, err error)
- func (m *DeleteJobRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *DeleteJobRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DeleteJobRequest) ProtoMessage()
- func (m *DeleteJobRequest) Reset()
- func (m *DeleteJobRequest) Size() (n int)
- func (m *DeleteJobRequest) String() string
- func (m *DeleteJobRequest) Unmarshal(dAtA []byte) error
- func (m *DeleteJobRequest) XXX_DiscardUnknown()
- func (m *DeleteJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteJobRequest) XXX_Merge(src proto.Message)
- func (m *DeleteJobRequest) XXX_Size() int
- func (m *DeleteJobRequest) XXX_Unmarshal(b []byte) error
- type FrameJob
- func (*FrameJob) Descriptor() ([]byte, []int)
- func (m *FrameJob) GetFinishedAt() time.Time
- func (m *FrameJob) GetID() string
- func (m *FrameJob) GetJobSource() string
- func (m *FrameJob) GetQueuedAt() time.Time
- func (m *FrameJob) GetRenderFrame() int64
- func (m *FrameJob) GetRequest() *JobRequest
- func (m *FrameJob) GetSequenceID() uint64
- func (m *FrameJob) GetSliceJobs() []*SliceJob
- func (m *FrameJob) GetStartedAt() time.Time
- func (m *FrameJob) GetStatus() JobStatus
- func (m *FrameJob) GetWorker() *v1.Worker
- func (m *FrameJob) Marshal() (dAtA []byte, err error)
- func (m *FrameJob) MarshalTo(dAtA []byte) (int, error)
- func (m *FrameJob) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*FrameJob) ProtoMessage()
- func (m *FrameJob) Reset()
- func (m *FrameJob) Size() (n int)
- func (m *FrameJob) String() string
- func (m *FrameJob) Unmarshal(dAtA []byte) error
- func (m *FrameJob) XXX_DiscardUnknown()
- func (m *FrameJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FrameJob) XXX_Merge(src proto.Message)
- func (m *FrameJob) XXX_Size() int
- func (m *FrameJob) XXX_Unmarshal(b []byte) error
- type GetJobArchiveRequest
- func (*GetJobArchiveRequest) Descriptor() ([]byte, []int)
- func (m *GetJobArchiveRequest) GetID() string
- func (m *GetJobArchiveRequest) Marshal() (dAtA []byte, err error)
- func (m *GetJobArchiveRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetJobArchiveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetJobArchiveRequest) ProtoMessage()
- func (m *GetJobArchiveRequest) Reset()
- func (m *GetJobArchiveRequest) Size() (n int)
- func (m *GetJobArchiveRequest) String() string
- func (m *GetJobArchiveRequest) Unmarshal(dAtA []byte) error
- func (m *GetJobArchiveRequest) XXX_DiscardUnknown()
- func (m *GetJobArchiveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetJobArchiveRequest) XXX_Merge(src proto.Message)
- func (m *GetJobArchiveRequest) XXX_Size() int
- func (m *GetJobArchiveRequest) XXX_Unmarshal(b []byte) error
- type GetJobArchiveResponse
- func (*GetJobArchiveResponse) Descriptor() ([]byte, []int)
- func (m *GetJobArchiveResponse) GetID() string
- func (m *GetJobArchiveResponse) GetJobArchive() *JobArchive
- func (m *GetJobArchiveResponse) Marshal() (dAtA []byte, err error)
- func (m *GetJobArchiveResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetJobArchiveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetJobArchiveResponse) ProtoMessage()
- func (m *GetJobArchiveResponse) Reset()
- func (m *GetJobArchiveResponse) Size() (n int)
- func (m *GetJobArchiveResponse) String() string
- func (m *GetJobArchiveResponse) Unmarshal(dAtA []byte) error
- func (m *GetJobArchiveResponse) XXX_DiscardUnknown()
- func (m *GetJobArchiveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetJobArchiveResponse) XXX_Merge(src proto.Message)
- func (m *GetJobArchiveResponse) XXX_Size() int
- func (m *GetJobArchiveResponse) XXX_Unmarshal(b []byte) error
- type GetJobRequest
- func (*GetJobRequest) Descriptor() ([]byte, []int)
- func (m *GetJobRequest) GetID() string
- func (m *GetJobRequest) Marshal() (dAtA []byte, err error)
- func (m *GetJobRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetJobRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetJobRequest) ProtoMessage()
- func (m *GetJobRequest) Reset()
- func (m *GetJobRequest) Size() (n int)
- func (m *GetJobRequest) String() string
- func (m *GetJobRequest) Unmarshal(dAtA []byte) error
- func (m *GetJobRequest) XXX_DiscardUnknown()
- func (m *GetJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetJobRequest) XXX_Merge(src proto.Message)
- func (m *GetJobRequest) XXX_Size() int
- func (m *GetJobRequest) XXX_Unmarshal(b []byte) error
- type GetJobResponse
- func (*GetJobResponse) Descriptor() ([]byte, []int)
- func (m *GetJobResponse) GetJob() *Job
- func (m *GetJobResponse) Marshal() (dAtA []byte, err error)
- func (m *GetJobResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetJobResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetJobResponse) ProtoMessage()
- func (m *GetJobResponse) Reset()
- func (m *GetJobResponse) Size() (n int)
- func (m *GetJobResponse) String() string
- func (m *GetJobResponse) Unmarshal(dAtA []byte) error
- func (m *GetJobResponse) XXX_DiscardUnknown()
- func (m *GetJobResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetJobResponse) XXX_Merge(src proto.Message)
- func (m *GetJobResponse) XXX_Size() int
- func (m *GetJobResponse) XXX_Unmarshal(b []byte) error
- type GetLatestRenderRequest
- func (*GetLatestRenderRequest) Descriptor() ([]byte, []int)
- func (m *GetLatestRenderRequest) GetFrame() int64
- func (m *GetLatestRenderRequest) GetID() string
- func (m *GetLatestRenderRequest) GetTTL() time.Duration
- func (m *GetLatestRenderRequest) Marshal() (dAtA []byte, err error)
- func (m *GetLatestRenderRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetLatestRenderRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetLatestRenderRequest) ProtoMessage()
- func (m *GetLatestRenderRequest) Reset()
- func (m *GetLatestRenderRequest) Size() (n int)
- func (m *GetLatestRenderRequest) String() string
- func (m *GetLatestRenderRequest) Unmarshal(dAtA []byte) error
- func (m *GetLatestRenderRequest) XXX_DiscardUnknown()
- func (m *GetLatestRenderRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetLatestRenderRequest) XXX_Merge(src proto.Message)
- func (m *GetLatestRenderRequest) XXX_Size() int
- func (m *GetLatestRenderRequest) XXX_Unmarshal(b []byte) error
- type GetLatestRenderResponse
- func (*GetLatestRenderResponse) Descriptor() ([]byte, []int)
- func (m *GetLatestRenderResponse) GetFrame() int64
- func (m *GetLatestRenderResponse) GetUrl() string
- func (m *GetLatestRenderResponse) Marshal() (dAtA []byte, err error)
- func (m *GetLatestRenderResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetLatestRenderResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetLatestRenderResponse) ProtoMessage()
- func (m *GetLatestRenderResponse) Reset()
- func (m *GetLatestRenderResponse) Size() (n int)
- func (m *GetLatestRenderResponse) String() string
- func (m *GetLatestRenderResponse) Unmarshal(dAtA []byte) error
- func (m *GetLatestRenderResponse) XXX_DiscardUnknown()
- func (m *GetLatestRenderResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetLatestRenderResponse) XXX_Merge(src proto.Message)
- func (m *GetLatestRenderResponse) XXX_Size() int
- func (m *GetLatestRenderResponse) XXX_Unmarshal(b []byte) error
- type Job
- func (*Job) Descriptor() ([]byte, []int)
- func (m *Job) GetCreatedAt() time.Time
- func (m *Job) GetDuration() time.Duration
- func (m *Job) GetFinishedAt() time.Time
- func (m *Job) GetFrameJobs() []*FrameJob
- func (m *Job) GetID() string
- func (m *Job) GetJobSource() string
- func (m *Job) GetOutputDir() string
- func (m *Job) GetQueuedAt() time.Time
- func (m *Job) GetRequest() *JobRequest
- func (m *Job) GetStartedAt() time.Time
- func (m *Job) GetStatus() JobStatus
- func (m *Job) Marshal() (dAtA []byte, err error)
- func (m *Job) MarshalTo(dAtA []byte) (int, error)
- func (m *Job) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Job) ProtoMessage()
- func (m *Job) Reset()
- func (m *Job) Size() (n int)
- func (m *Job) String() string
- func (m *Job) Unmarshal(dAtA []byte) error
- func (m *Job) XXX_DiscardUnknown()
- func (m *Job) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Job) XXX_Merge(src proto.Message)
- func (m *Job) XXX_Size() int
- func (m *Job) XXX_Unmarshal(b []byte) error
- type JobArchive
- func (*JobArchive) Descriptor() ([]byte, []int)
- func (m *JobArchive) GetArchiveUrl() string
- func (m *JobArchive) Marshal() (dAtA []byte, err error)
- func (m *JobArchive) MarshalTo(dAtA []byte) (int, error)
- func (m *JobArchive) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobArchive) ProtoMessage()
- func (m *JobArchive) Reset()
- func (m *JobArchive) Size() (n int)
- func (m *JobArchive) String() string
- func (m *JobArchive) Unmarshal(dAtA []byte) error
- func (m *JobArchive) XXX_DiscardUnknown()
- func (m *JobArchive) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobArchive) XXX_Merge(src proto.Message)
- func (m *JobArchive) XXX_Size() int
- func (m *JobArchive) XXX_Unmarshal(b []byte) error
- type JobLog
- func (*JobLog) Descriptor() ([]byte, []int)
- func (m *JobLog) GetID() string
- func (m *JobLog) GetLog() string
- func (m *JobLog) GetNamespace() string
- func (m *JobLog) Marshal() (dAtA []byte, err error)
- func (m *JobLog) MarshalTo(dAtA []byte) (int, error)
- func (m *JobLog) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobLog) ProtoMessage()
- func (m *JobLog) Reset()
- func (m *JobLog) Size() (n int)
- func (m *JobLog) String() string
- func (m *JobLog) Unmarshal(dAtA []byte) error
- func (m *JobLog) XXX_DiscardUnknown()
- func (m *JobLog) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobLog) XXX_Merge(src proto.Message)
- func (m *JobLog) XXX_Size() int
- func (m *JobLog) XXX_Unmarshal(b []byte) error
- type JobLogRequest
- func (*JobLogRequest) Descriptor() ([]byte, []int)
- func (m *JobLogRequest) GetID() string
- func (m *JobLogRequest) Marshal() (dAtA []byte, err error)
- func (m *JobLogRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *JobLogRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobLogRequest) ProtoMessage()
- func (m *JobLogRequest) Reset()
- func (m *JobLogRequest) Size() (n int)
- func (m *JobLogRequest) String() string
- func (m *JobLogRequest) Unmarshal(dAtA []byte) error
- func (m *JobLogRequest) XXX_DiscardUnknown()
- func (m *JobLogRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobLogRequest) XXX_Merge(src proto.Message)
- func (m *JobLogRequest) XXX_Size() int
- func (m *JobLogRequest) XXX_Unmarshal(b []byte) error
- type JobLogResponse
- func (*JobLogResponse) Descriptor() ([]byte, []int)
- func (m *JobLogResponse) GetJobLog() *JobLog
- func (m *JobLogResponse) Marshal() (dAtA []byte, err error)
- func (m *JobLogResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *JobLogResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobLogResponse) ProtoMessage()
- func (m *JobLogResponse) Reset()
- func (m *JobLogResponse) Size() (n int)
- func (m *JobLogResponse) String() string
- func (m *JobLogResponse) Unmarshal(dAtA []byte) error
- func (m *JobLogResponse) XXX_DiscardUnknown()
- func (m *JobLogResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobLogResponse) XXX_Merge(src proto.Message)
- func (m *JobLogResponse) XXX_Size() int
- func (m *JobLogResponse) XXX_Unmarshal(b []byte) error
- type JobPriority
- type JobRequest
- func (*JobRequest) Descriptor() ([]byte, []int)
- func (m *JobRequest) GetCPU() int64
- func (m *JobRequest) GetContentType() string
- func (m *JobRequest) GetMemory() int64
- func (m *JobRequest) GetName() string
- func (m *JobRequest) GetNamespace() string
- func (m *JobRequest) GetPriority() JobPriority
- func (m *JobRequest) GetRenderEndFrame() int64
- func (m *JobRequest) GetRenderEngine() RenderEngine
- func (m *JobRequest) GetRenderPriority() int64
- func (m *JobRequest) GetRenderSamples() int64
- func (m *JobRequest) GetRenderSlices() int64
- func (m *JobRequest) GetRenderStartFrame() int64
- func (m *JobRequest) GetRenderUseGPU() bool
- func (m *JobRequest) GetResolutionScale() int64
- func (m *JobRequest) GetResolutionX() int64
- func (m *JobRequest) GetResolutionY() int64
- func (m *JobRequest) Marshal() (dAtA []byte, err error)
- func (m *JobRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *JobRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobRequest) ProtoMessage()
- func (m *JobRequest) Reset()
- func (m *JobRequest) Size() (n int)
- func (m *JobRequest) String() string
- func (m *JobRequest) Unmarshal(dAtA []byte) error
- func (m *JobRequest) XXX_DiscardUnknown()
- func (m *JobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobRequest) XXX_Merge(src proto.Message)
- func (m *JobRequest) XXX_Size() int
- func (m *JobRequest) XXX_Unmarshal(b []byte) error
- type JobResult
- func (*JobResult) Descriptor() ([]byte, []int)
- func (m *JobResult) GetDuration() time.Duration
- func (m *JobResult) GetError() string
- func (m *JobResult) GetFrameJob() *FrameJob
- func (m *JobResult) GetNamespace() string
- func (m *JobResult) GetRenderFrame() int64
- func (m *JobResult) GetResult() isJobResult_Result
- func (m *JobResult) GetSliceJob() *SliceJob
- func (m *JobResult) GetStatus() JobStatus
- func (m *JobResult) Marshal() (dAtA []byte, err error)
- func (m *JobResult) MarshalTo(dAtA []byte) (int, error)
- func (m *JobResult) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*JobResult) ProtoMessage()
- func (m *JobResult) Reset()
- func (m *JobResult) Size() (n int)
- func (m *JobResult) String() string
- func (m *JobResult) Unmarshal(dAtA []byte) error
- func (m *JobResult) XXX_DiscardUnknown()
- func (m *JobResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JobResult) XXX_Merge(src proto.Message)
- func (*JobResult) XXX_OneofWrappers() []interface{}
- func (m *JobResult) XXX_Size() int
- func (m *JobResult) XXX_Unmarshal(b []byte) error
- type JobResult_FrameJob
- type JobResult_SliceJob
- type JobStatus
- type JobsClient
- type JobsServer
- type Jobs_QueueJobClient
- type Jobs_QueueJobServer
- type ListJobsRequest
- func (*ListJobsRequest) Descriptor() ([]byte, []int)
- func (m *ListJobsRequest) Marshal() (dAtA []byte, err error)
- func (m *ListJobsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ListJobsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ListJobsRequest) ProtoMessage()
- func (m *ListJobsRequest) Reset()
- func (m *ListJobsRequest) Size() (n int)
- func (m *ListJobsRequest) String() string
- func (m *ListJobsRequest) Unmarshal(dAtA []byte) error
- func (m *ListJobsRequest) XXX_DiscardUnknown()
- func (m *ListJobsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListJobsRequest) XXX_Merge(src proto.Message)
- func (m *ListJobsRequest) XXX_Size() int
- func (m *ListJobsRequest) XXX_Unmarshal(b []byte) error
- type ListJobsResponse
- func (*ListJobsResponse) Descriptor() ([]byte, []int)
- func (m *ListJobsResponse) GetJobs() []*Job
- func (m *ListJobsResponse) Marshal() (dAtA []byte, err error)
- func (m *ListJobsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ListJobsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ListJobsResponse) ProtoMessage()
- func (m *ListJobsResponse) Reset()
- func (m *ListJobsResponse) Size() (n int)
- func (m *ListJobsResponse) String() string
- func (m *ListJobsResponse) Unmarshal(dAtA []byte) error
- func (m *ListJobsResponse) XXX_DiscardUnknown()
- func (m *ListJobsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListJobsResponse) XXX_Merge(src proto.Message)
- func (m *ListJobsResponse) XXX_Size() int
- func (m *ListJobsResponse) XXX_Unmarshal(b []byte) error
- type QueueJobRequest
- func (*QueueJobRequest) Descriptor() ([]byte, []int)
- func (m *QueueJobRequest) GetChunkData() []byte
- func (m *QueueJobRequest) GetData() isQueueJobRequest_Data
- func (m *QueueJobRequest) GetRequest() *JobRequest
- func (m *QueueJobRequest) Marshal() (dAtA []byte, err error)
- func (m *QueueJobRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueueJobRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueueJobRequest) ProtoMessage()
- func (m *QueueJobRequest) Reset()
- func (m *QueueJobRequest) Size() (n int)
- func (m *QueueJobRequest) String() string
- func (m *QueueJobRequest) Unmarshal(dAtA []byte) error
- func (m *QueueJobRequest) XXX_DiscardUnknown()
- func (m *QueueJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueueJobRequest) XXX_Merge(src proto.Message)
- func (*QueueJobRequest) XXX_OneofWrappers() []interface{}
- func (m *QueueJobRequest) XXX_Size() int
- func (m *QueueJobRequest) XXX_Unmarshal(b []byte) error
- type QueueJobRequest_ChunkData
- type QueueJobRequest_Request
- type QueueJobResponse
- func (*QueueJobResponse) Descriptor() ([]byte, []int)
- func (m *QueueJobResponse) GetUUID() string
- func (m *QueueJobResponse) Marshal() (dAtA []byte, err error)
- func (m *QueueJobResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueueJobResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueueJobResponse) ProtoMessage()
- func (m *QueueJobResponse) Reset()
- func (m *QueueJobResponse) Size() (n int)
- func (m *QueueJobResponse) String() string
- func (m *QueueJobResponse) Unmarshal(dAtA []byte) error
- func (m *QueueJobResponse) XXX_DiscardUnknown()
- func (m *QueueJobResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueueJobResponse) XXX_Merge(src proto.Message)
- func (m *QueueJobResponse) XXX_Size() int
- func (m *QueueJobResponse) XXX_Unmarshal(b []byte) error
- type RenderEngine
- type RenderJob
- type RenderLog
- func (*RenderLog) Descriptor() ([]byte, []int)
- func (m *RenderLog) GetFrame() int64
- func (m *RenderLog) GetLog() string
- func (m *RenderLog) GetSlice() int64
- func (m *RenderLog) Marshal() (dAtA []byte, err error)
- func (m *RenderLog) MarshalTo(dAtA []byte) (int, error)
- func (m *RenderLog) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RenderLog) ProtoMessage()
- func (m *RenderLog) Reset()
- func (m *RenderLog) Size() (n int)
- func (m *RenderLog) String() string
- func (m *RenderLog) Unmarshal(dAtA []byte) error
- func (m *RenderLog) XXX_DiscardUnknown()
- func (m *RenderLog) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RenderLog) XXX_Merge(src proto.Message)
- func (m *RenderLog) XXX_Size() int
- func (m *RenderLog) XXX_Unmarshal(b []byte) error
- type RenderLogRequest
- func (*RenderLogRequest) Descriptor() ([]byte, []int)
- func (m *RenderLogRequest) GetFrame() int64
- func (m *RenderLogRequest) GetID() string
- func (m *RenderLogRequest) GetSlice() int64
- func (m *RenderLogRequest) Marshal() (dAtA []byte, err error)
- func (m *RenderLogRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *RenderLogRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RenderLogRequest) ProtoMessage()
- func (m *RenderLogRequest) Reset()
- func (m *RenderLogRequest) Size() (n int)
- func (m *RenderLogRequest) String() string
- func (m *RenderLogRequest) Unmarshal(dAtA []byte) error
- func (m *RenderLogRequest) XXX_DiscardUnknown()
- func (m *RenderLogRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RenderLogRequest) XXX_Merge(src proto.Message)
- func (m *RenderLogRequest) XXX_Size() int
- func (m *RenderLogRequest) XXX_Unmarshal(b []byte) error
- type RenderLogResponse
- func (*RenderLogResponse) Descriptor() ([]byte, []int)
- func (m *RenderLogResponse) GetRenderLog() *RenderLog
- func (m *RenderLogResponse) Marshal() (dAtA []byte, err error)
- func (m *RenderLogResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *RenderLogResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RenderLogResponse) ProtoMessage()
- func (m *RenderLogResponse) Reset()
- func (m *RenderLogResponse) Size() (n int)
- func (m *RenderLogResponse) String() string
- func (m *RenderLogResponse) Unmarshal(dAtA []byte) error
- func (m *RenderLogResponse) XXX_DiscardUnknown()
- func (m *RenderLogResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RenderLogResponse) XXX_Merge(src proto.Message)
- func (m *RenderLogResponse) XXX_Size() int
- func (m *RenderLogResponse) XXX_Unmarshal(b []byte) error
- type SliceJob
- func (*SliceJob) Descriptor() ([]byte, []int)
- func (m *SliceJob) GetFinishedAt() time.Time
- func (m *SliceJob) GetID() string
- func (m *SliceJob) GetJobSource() string
- func (m *SliceJob) GetQueuedAt() time.Time
- func (m *SliceJob) GetRenderFrame() int64
- func (m *SliceJob) GetRenderSliceIndex() int64
- func (m *SliceJob) GetRenderSliceMaxX() float32
- func (m *SliceJob) GetRenderSliceMaxY() float32
- func (m *SliceJob) GetRenderSliceMinX() float32
- func (m *SliceJob) GetRenderSliceMinY() float32
- func (m *SliceJob) GetRequest() *JobRequest
- func (m *SliceJob) GetSequenceID() uint64
- func (m *SliceJob) GetStartedAt() time.Time
- func (m *SliceJob) GetStatus() JobStatus
- func (m *SliceJob) GetWorker() *v1.Worker
- func (m *SliceJob) Marshal() (dAtA []byte, err error)
- func (m *SliceJob) MarshalTo(dAtA []byte) (int, error)
- func (m *SliceJob) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SliceJob) ProtoMessage()
- func (m *SliceJob) Reset()
- func (m *SliceJob) Size() (n int)
- func (m *SliceJob) String() string
- func (m *SliceJob) Unmarshal(dAtA []byte) error
- func (m *SliceJob) XXX_DiscardUnknown()
- func (m *SliceJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SliceJob) XXX_Merge(src proto.Message)
- func (m *SliceJob) XXX_Size() int
- func (m *SliceJob) XXX_Unmarshal(b []byte) error
- type UnimplementedJobsServer
- func (*UnimplementedJobsServer) DeleteJob(ctx context.Context, req *DeleteJobRequest) (*types.Empty, error)
- func (*UnimplementedJobsServer) GetJob(ctx context.Context, req *GetJobRequest) (*GetJobResponse, error)
- func (*UnimplementedJobsServer) GetJobArchive(ctx context.Context, req *GetJobArchiveRequest) (*GetJobArchiveResponse, error)
- func (*UnimplementedJobsServer) GetLatestRender(ctx context.Context, req *GetLatestRenderRequest) (*GetLatestRenderResponse, error)
- func (*UnimplementedJobsServer) JobLog(ctx context.Context, req *JobLogRequest) (*JobLogResponse, error)
- func (*UnimplementedJobsServer) ListJobs(ctx context.Context, req *ListJobsRequest) (*ListJobsResponse, error)
- func (*UnimplementedJobsServer) QueueJob(srv Jobs_QueueJobServer) error
- func (*UnimplementedJobsServer) RenderLog(ctx context.Context, req *RenderLogRequest) (*RenderLogResponse, error)
- func (*UnimplementedJobsServer) Version(ctx context.Context, req *VersionRequest) (*VersionResponse, error)
- type VersionRequest
- func (*VersionRequest) Descriptor() ([]byte, []int)
- func (m *VersionRequest) Marshal() (dAtA []byte, err error)
- func (m *VersionRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *VersionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*VersionRequest) ProtoMessage()
- func (m *VersionRequest) Reset()
- func (m *VersionRequest) Size() (n int)
- func (m *VersionRequest) String() string
- func (m *VersionRequest) Unmarshal(dAtA []byte) error
- func (m *VersionRequest) XXX_DiscardUnknown()
- func (m *VersionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *VersionRequest) XXX_Merge(src proto.Message)
- func (m *VersionRequest) XXX_Size() int
- func (m *VersionRequest) XXX_Unmarshal(b []byte) error
- type VersionResponse
- func (*VersionResponse) Descriptor() ([]byte, []int)
- func (m *VersionResponse) GetAuthenticator() string
- func (m *VersionResponse) GetBuild() string
- func (m *VersionResponse) GetCommit() string
- func (m *VersionResponse) GetName() string
- func (m *VersionResponse) GetVersion() string
- func (m *VersionResponse) Marshal() (dAtA []byte, err error)
- func (m *VersionResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *VersionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*VersionResponse) ProtoMessage()
- func (m *VersionResponse) Reset()
- func (m *VersionResponse) Size() (n int)
- func (m *VersionResponse) String() string
- func (m *VersionResponse) Unmarshal(dAtA []byte) error
- func (m *VersionResponse) XXX_DiscardUnknown()
- func (m *VersionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *VersionResponse) XXX_Merge(src proto.Message)
- func (m *VersionResponse) XXX_Size() int
- func (m *VersionResponse) XXX_Unmarshal(b []byte) error
- type WorkerJob
- func (*WorkerJob) Descriptor() ([]byte, []int)
- func (m *WorkerJob) GetFrameJob() *FrameJob
- func (m *WorkerJob) GetID() string
- func (m *WorkerJob) GetJob() isWorkerJob_Job
- func (m *WorkerJob) GetSliceJob() *SliceJob
- func (m *WorkerJob) Marshal() (dAtA []byte, err error)
- func (m *WorkerJob) MarshalTo(dAtA []byte) (int, error)
- func (m *WorkerJob) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WorkerJob) ProtoMessage()
- func (m *WorkerJob) Reset()
- func (m *WorkerJob) Size() (n int)
- func (m *WorkerJob) String() string
- func (m *WorkerJob) Unmarshal(dAtA []byte) error
- func (m *WorkerJob) XXX_DiscardUnknown()
- func (m *WorkerJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WorkerJob) XXX_Merge(src proto.Message)
- func (*WorkerJob) XXX_OneofWrappers() []interface{}
- func (m *WorkerJob) XXX_Size() int
- func (m *WorkerJob) XXX_Unmarshal(b []byte) error
- type WorkerJob_FrameJob
- type WorkerJob_SliceJob
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthJobs = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowJobs = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupJobs = fmt.Errorf("proto: unexpected end of group") )
var JobPriority_name = map[int32]string{
0: "NORMAL",
1: "URGENT",
2: "LOW",
}
var JobPriority_value = map[string]int32{
"NORMAL": 0,
"URGENT": 1,
"LOW": 2,
}
var JobStatus_name = map[int32]string{
0: "QUEUED",
1: "RENDERING",
2: "ERROR",
3: "FINISHED",
}
var JobStatus_value = map[string]int32{
"QUEUED": 0,
"RENDERING": 1,
"ERROR": 2,
"FINISHED": 3,
}
var RenderEngine_name = map[int32]string{
0: "UNKNOWN",
1: "CYCLES",
2: "BLENDER_EEVEE",
}
var RenderEngine_value = map[string]int32{
"UNKNOWN": 0,
"CYCLES": 1,
"BLENDER_EEVEE": 2,
}
Functions ¶
func RegisterJobsServer ¶
func RegisterJobsServer(s *grpc.Server, srv JobsServer)
Types ¶
type DeleteJobRequest ¶
type DeleteJobRequest struct { ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeleteJobRequest) Descriptor ¶
func (*DeleteJobRequest) Descriptor() ([]byte, []int)
func (*DeleteJobRequest) GetID ¶
func (m *DeleteJobRequest) GetID() string
func (*DeleteJobRequest) Marshal ¶
func (m *DeleteJobRequest) Marshal() (dAtA []byte, err error)
func (*DeleteJobRequest) MarshalToSizedBuffer ¶
func (m *DeleteJobRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DeleteJobRequest) ProtoMessage ¶
func (*DeleteJobRequest) ProtoMessage()
func (*DeleteJobRequest) Reset ¶
func (m *DeleteJobRequest) Reset()
func (*DeleteJobRequest) Size ¶
func (m *DeleteJobRequest) Size() (n int)
func (*DeleteJobRequest) String ¶
func (m *DeleteJobRequest) String() string
func (*DeleteJobRequest) Unmarshal ¶
func (m *DeleteJobRequest) Unmarshal(dAtA []byte) error
func (*DeleteJobRequest) XXX_DiscardUnknown ¶
func (m *DeleteJobRequest) XXX_DiscardUnknown()
func (*DeleteJobRequest) XXX_Marshal ¶
func (m *DeleteJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteJobRequest) XXX_Merge ¶
func (m *DeleteJobRequest) XXX_Merge(src proto.Message)
func (*DeleteJobRequest) XXX_Size ¶
func (m *DeleteJobRequest) XXX_Size() int
func (*DeleteJobRequest) XXX_Unmarshal ¶
func (m *DeleteJobRequest) XXX_Unmarshal(b []byte) error
type FrameJob ¶
type FrameJob struct { ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Request *JobRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"` JobSource string `protobuf:"bytes,3,opt,name=job_source,json=jobSource,proto3" json:"job_source,omitempty"` RenderFrame int64 `protobuf:"varint,4,opt,name=render_frame,json=renderFrame,proto3" json:"render_frame,omitempty"` SequenceID uint64 `protobuf:"varint,5,opt,name=sequence_id,json=sequenceId,proto3" json:"sequence_id,omitempty"` Worker *v1.Worker `protobuf:"bytes,6,opt,name=worker,proto3" json:"worker,omitempty"` SliceJobs []*SliceJob `protobuf:"bytes,7,rep,name=slice_jobs,json=sliceJobs,proto3" json:"slice_jobs,omitempty"` QueuedAt time.Time `protobuf:"bytes,8,opt,name=queued_at,json=queuedAt,proto3,stdtime" json:"queued_at"` StartedAt time.Time `protobuf:"bytes,9,opt,name=started_at,json=startedAt,proto3,stdtime" json:"started_at"` FinishedAt time.Time `protobuf:"bytes,10,opt,name=finished_at,json=finishedAt,proto3,stdtime" json:"finished_at"` Status JobStatus `protobuf:"varint,11,opt,name=status,proto3,enum=fynca.services.jobs.v1.JobStatus" json:"status,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*FrameJob) Descriptor ¶
func (*FrameJob) GetFinishedAt ¶
func (*FrameJob) GetJobSource ¶
func (*FrameJob) GetQueuedAt ¶
func (*FrameJob) GetRenderFrame ¶
func (*FrameJob) GetRequest ¶
func (m *FrameJob) GetRequest() *JobRequest
func (*FrameJob) GetSequenceID ¶
func (*FrameJob) GetSliceJobs ¶
func (*FrameJob) GetStartedAt ¶
func (*FrameJob) MarshalToSizedBuffer ¶
func (*FrameJob) ProtoMessage ¶
func (*FrameJob) ProtoMessage()
func (*FrameJob) XXX_DiscardUnknown ¶
func (m *FrameJob) XXX_DiscardUnknown()
func (*FrameJob) XXX_Marshal ¶
func (*FrameJob) XXX_Unmarshal ¶
type GetJobArchiveRequest ¶
type GetJobArchiveRequest struct { ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetJobArchiveRequest) Descriptor ¶
func (*GetJobArchiveRequest) Descriptor() ([]byte, []int)
func (*GetJobArchiveRequest) GetID ¶
func (m *GetJobArchiveRequest) GetID() string
func (*GetJobArchiveRequest) Marshal ¶
func (m *GetJobArchiveRequest) Marshal() (dAtA []byte, err error)
func (*GetJobArchiveRequest) MarshalTo ¶
func (m *GetJobArchiveRequest) MarshalTo(dAtA []byte) (int, error)
func (*GetJobArchiveRequest) MarshalToSizedBuffer ¶
func (m *GetJobArchiveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetJobArchiveRequest) ProtoMessage ¶
func (*GetJobArchiveRequest) ProtoMessage()
func (*GetJobArchiveRequest) Reset ¶
func (m *GetJobArchiveRequest) Reset()
func (*GetJobArchiveRequest) Size ¶
func (m *GetJobArchiveRequest) Size() (n int)
func (*GetJobArchiveRequest) String ¶
func (m *GetJobArchiveRequest) String() string
func (*GetJobArchiveRequest) Unmarshal ¶
func (m *GetJobArchiveRequest) Unmarshal(dAtA []byte) error
func (*GetJobArchiveRequest) XXX_DiscardUnknown ¶
func (m *GetJobArchiveRequest) XXX_DiscardUnknown()
func (*GetJobArchiveRequest) XXX_Marshal ¶
func (m *GetJobArchiveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetJobArchiveRequest) XXX_Merge ¶
func (m *GetJobArchiveRequest) XXX_Merge(src proto.Message)
func (*GetJobArchiveRequest) XXX_Size ¶
func (m *GetJobArchiveRequest) XXX_Size() int
func (*GetJobArchiveRequest) XXX_Unmarshal ¶
func (m *GetJobArchiveRequest) XXX_Unmarshal(b []byte) error
type GetJobArchiveResponse ¶
type GetJobArchiveResponse struct { ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` JobArchive *JobArchive `protobuf:"bytes,2,opt,name=job_archive,json=jobArchive,proto3" json:"job_archive,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetJobArchiveResponse) Descriptor ¶
func (*GetJobArchiveResponse) Descriptor() ([]byte, []int)
func (*GetJobArchiveResponse) GetID ¶
func (m *GetJobArchiveResponse) GetID() string
func (*GetJobArchiveResponse) GetJobArchive ¶
func (m *GetJobArchiveResponse) GetJobArchive() *JobArchive
func (*GetJobArchiveResponse) Marshal ¶
func (m *GetJobArchiveResponse) Marshal() (dAtA []byte, err error)
func (*GetJobArchiveResponse) MarshalTo ¶
func (m *GetJobArchiveResponse) MarshalTo(dAtA []byte) (int, error)
func (*GetJobArchiveResponse) MarshalToSizedBuffer ¶
func (m *GetJobArchiveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetJobArchiveResponse) ProtoMessage ¶
func (*GetJobArchiveResponse) ProtoMessage()
func (*GetJobArchiveResponse) Reset ¶
func (m *GetJobArchiveResponse) Reset()
func (*GetJobArchiveResponse) Size ¶
func (m *GetJobArchiveResponse) Size() (n int)
func (*GetJobArchiveResponse) String ¶
func (m *GetJobArchiveResponse) String() string
func (*GetJobArchiveResponse) Unmarshal ¶
func (m *GetJobArchiveResponse) Unmarshal(dAtA []byte) error
func (*GetJobArchiveResponse) XXX_DiscardUnknown ¶
func (m *GetJobArchiveResponse) XXX_DiscardUnknown()
func (*GetJobArchiveResponse) XXX_Marshal ¶
func (m *GetJobArchiveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetJobArchiveResponse) XXX_Merge ¶
func (m *GetJobArchiveResponse) XXX_Merge(src proto.Message)
func (*GetJobArchiveResponse) XXX_Size ¶
func (m *GetJobArchiveResponse) XXX_Size() int
func (*GetJobArchiveResponse) XXX_Unmarshal ¶
func (m *GetJobArchiveResponse) XXX_Unmarshal(b []byte) error
type GetJobRequest ¶
type GetJobRequest struct { ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetJobRequest) Descriptor ¶
func (*GetJobRequest) Descriptor() ([]byte, []int)
func (*GetJobRequest) GetID ¶
func (m *GetJobRequest) GetID() string
func (*GetJobRequest) Marshal ¶
func (m *GetJobRequest) Marshal() (dAtA []byte, err error)
func (*GetJobRequest) MarshalToSizedBuffer ¶
func (m *GetJobRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetJobRequest) ProtoMessage ¶
func (*GetJobRequest) ProtoMessage()
func (*GetJobRequest) Reset ¶
func (m *GetJobRequest) Reset()
func (*GetJobRequest) Size ¶
func (m *GetJobRequest) Size() (n int)
func (*GetJobRequest) String ¶
func (m *GetJobRequest) String() string
func (*GetJobRequest) Unmarshal ¶
func (m *GetJobRequest) Unmarshal(dAtA []byte) error
func (*GetJobRequest) XXX_DiscardUnknown ¶
func (m *GetJobRequest) XXX_DiscardUnknown()
func (*GetJobRequest) XXX_Marshal ¶
func (m *GetJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetJobRequest) XXX_Merge ¶
func (m *GetJobRequest) XXX_Merge(src proto.Message)
func (*GetJobRequest) XXX_Size ¶
func (m *GetJobRequest) XXX_Size() int
func (*GetJobRequest) XXX_Unmarshal ¶
func (m *GetJobRequest) XXX_Unmarshal(b []byte) error
type GetJobResponse ¶
type GetJobResponse struct { Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetJobResponse) Descriptor ¶
func (*GetJobResponse) Descriptor() ([]byte, []int)
func (*GetJobResponse) GetJob ¶
func (m *GetJobResponse) GetJob() *Job
func (*GetJobResponse) Marshal ¶
func (m *GetJobResponse) Marshal() (dAtA []byte, err error)
func (*GetJobResponse) MarshalToSizedBuffer ¶
func (m *GetJobResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetJobResponse) ProtoMessage ¶
func (*GetJobResponse) ProtoMessage()
func (*GetJobResponse) Reset ¶
func (m *GetJobResponse) Reset()
func (*GetJobResponse) Size ¶
func (m *GetJobResponse) Size() (n int)
func (*GetJobResponse) String ¶
func (m *GetJobResponse) String() string
func (*GetJobResponse) Unmarshal ¶
func (m *GetJobResponse) Unmarshal(dAtA []byte) error
func (*GetJobResponse) XXX_DiscardUnknown ¶
func (m *GetJobResponse) XXX_DiscardUnknown()
func (*GetJobResponse) XXX_Marshal ¶
func (m *GetJobResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetJobResponse) XXX_Merge ¶
func (m *GetJobResponse) XXX_Merge(src proto.Message)
func (*GetJobResponse) XXX_Size ¶
func (m *GetJobResponse) XXX_Size() int
func (*GetJobResponse) XXX_Unmarshal ¶
func (m *GetJobResponse) XXX_Unmarshal(b []byte) error
type GetLatestRenderRequest ¶
type GetLatestRenderRequest struct { ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Frame int64 `protobuf:"varint,2,opt,name=frame,proto3" json:"frame,omitempty"` TTL time.Duration `protobuf:"bytes,3,opt,name=ttl,proto3,stdduration" json:"ttl"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetLatestRenderRequest) Descriptor ¶
func (*GetLatestRenderRequest) Descriptor() ([]byte, []int)
func (*GetLatestRenderRequest) GetFrame ¶
func (m *GetLatestRenderRequest) GetFrame() int64
func (*GetLatestRenderRequest) GetID ¶
func (m *GetLatestRenderRequest) GetID() string
func (*GetLatestRenderRequest) GetTTL ¶
func (m *GetLatestRenderRequest) GetTTL() time.Duration
func (*GetLatestRenderRequest) Marshal ¶
func (m *GetLatestRenderRequest) Marshal() (dAtA []byte, err error)
func (*GetLatestRenderRequest) MarshalTo ¶
func (m *GetLatestRenderRequest) MarshalTo(dAtA []byte) (int, error)
func (*GetLatestRenderRequest) MarshalToSizedBuffer ¶
func (m *GetLatestRenderRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetLatestRenderRequest) ProtoMessage ¶
func (*GetLatestRenderRequest) ProtoMessage()
func (*GetLatestRenderRequest) Reset ¶
func (m *GetLatestRenderRequest) Reset()
func (*GetLatestRenderRequest) Size ¶
func (m *GetLatestRenderRequest) Size() (n int)
func (*GetLatestRenderRequest) String ¶
func (m *GetLatestRenderRequest) String() string
func (*GetLatestRenderRequest) Unmarshal ¶
func (m *GetLatestRenderRequest) Unmarshal(dAtA []byte) error
func (*GetLatestRenderRequest) XXX_DiscardUnknown ¶
func (m *GetLatestRenderRequest) XXX_DiscardUnknown()
func (*GetLatestRenderRequest) XXX_Marshal ¶
func (m *GetLatestRenderRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetLatestRenderRequest) XXX_Merge ¶
func (m *GetLatestRenderRequest) XXX_Merge(src proto.Message)
func (*GetLatestRenderRequest) XXX_Size ¶
func (m *GetLatestRenderRequest) XXX_Size() int
func (*GetLatestRenderRequest) XXX_Unmarshal ¶
func (m *GetLatestRenderRequest) XXX_Unmarshal(b []byte) error
type GetLatestRenderResponse ¶
type GetLatestRenderResponse struct { Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"` Frame int64 `protobuf:"varint,2,opt,name=frame,proto3" json:"frame,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetLatestRenderResponse) Descriptor ¶
func (*GetLatestRenderResponse) Descriptor() ([]byte, []int)
func (*GetLatestRenderResponse) GetFrame ¶
func (m *GetLatestRenderResponse) GetFrame() int64
func (*GetLatestRenderResponse) GetUrl ¶
func (m *GetLatestRenderResponse) GetUrl() string
func (*GetLatestRenderResponse) Marshal ¶
func (m *GetLatestRenderResponse) Marshal() (dAtA []byte, err error)
func (*GetLatestRenderResponse) MarshalTo ¶
func (m *GetLatestRenderResponse) MarshalTo(dAtA []byte) (int, error)
func (*GetLatestRenderResponse) MarshalToSizedBuffer ¶
func (m *GetLatestRenderResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetLatestRenderResponse) ProtoMessage ¶
func (*GetLatestRenderResponse) ProtoMessage()
func (*GetLatestRenderResponse) Reset ¶
func (m *GetLatestRenderResponse) Reset()
func (*GetLatestRenderResponse) Size ¶
func (m *GetLatestRenderResponse) Size() (n int)
func (*GetLatestRenderResponse) String ¶
func (m *GetLatestRenderResponse) String() string
func (*GetLatestRenderResponse) Unmarshal ¶
func (m *GetLatestRenderResponse) Unmarshal(dAtA []byte) error
func (*GetLatestRenderResponse) XXX_DiscardUnknown ¶
func (m *GetLatestRenderResponse) XXX_DiscardUnknown()
func (*GetLatestRenderResponse) XXX_Marshal ¶
func (m *GetLatestRenderResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetLatestRenderResponse) XXX_Merge ¶
func (m *GetLatestRenderResponse) XXX_Merge(src proto.Message)
func (*GetLatestRenderResponse) XXX_Size ¶
func (m *GetLatestRenderResponse) XXX_Size() int
func (*GetLatestRenderResponse) XXX_Unmarshal ¶
func (m *GetLatestRenderResponse) XXX_Unmarshal(b []byte) error
type Job ¶
type Job struct { ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Request *JobRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"` JobSource string `protobuf:"bytes,3,opt,name=job_source,json=jobSource,proto3" json:"job_source,omitempty"` OutputDir string `protobuf:"bytes,4,opt,name=output_dir,json=outputDir,proto3" json:"output_dir,omitempty"` Status JobStatus `protobuf:"varint,5,opt,name=status,proto3,enum=fynca.services.jobs.v1.JobStatus" json:"status,omitempty"` FrameJobs []*FrameJob `protobuf:"bytes,6,rep,name=frame_jobs,json=frameJobs,proto3" json:"frame_jobs,omitempty"` CreatedAt time.Time `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3,stdtime" json:"created_at"` QueuedAt time.Time `protobuf:"bytes,8,opt,name=queued_at,json=queuedAt,proto3,stdtime" json:"queued_at"` StartedAt time.Time `protobuf:"bytes,9,opt,name=started_at,json=startedAt,proto3,stdtime" json:"started_at"` FinishedAt time.Time `protobuf:"bytes,10,opt,name=finished_at,json=finishedAt,proto3,stdtime" json:"finished_at"` Duration time.Duration `protobuf:"bytes,11,opt,name=duration,proto3,stdduration" json:"duration"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Job) Descriptor ¶
func (*Job) GetCreatedAt ¶
func (*Job) GetDuration ¶
func (*Job) GetFinishedAt ¶
func (*Job) GetFrameJobs ¶
func (*Job) GetJobSource ¶
func (*Job) GetOutputDir ¶
func (*Job) GetQueuedAt ¶
func (*Job) GetRequest ¶
func (m *Job) GetRequest() *JobRequest
func (*Job) GetStartedAt ¶
func (*Job) ProtoMessage ¶
func (*Job) ProtoMessage()
func (*Job) XXX_DiscardUnknown ¶
func (m *Job) XXX_DiscardUnknown()
func (*Job) XXX_Unmarshal ¶
type JobArchive ¶
type JobArchive struct { ArchiveUrl string `protobuf:"bytes,1,opt,name=archive_url,json=archiveUrl,proto3" json:"archive_url,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*JobArchive) Descriptor ¶
func (*JobArchive) Descriptor() ([]byte, []int)
func (*JobArchive) GetArchiveUrl ¶
func (m *JobArchive) GetArchiveUrl() string
func (*JobArchive) Marshal ¶
func (m *JobArchive) Marshal() (dAtA []byte, err error)
func (*JobArchive) MarshalToSizedBuffer ¶
func (m *JobArchive) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobArchive) ProtoMessage ¶
func (*JobArchive) ProtoMessage()
func (*JobArchive) Reset ¶
func (m *JobArchive) Reset()
func (*JobArchive) Size ¶
func (m *JobArchive) Size() (n int)
func (*JobArchive) String ¶
func (m *JobArchive) String() string
func (*JobArchive) Unmarshal ¶
func (m *JobArchive) Unmarshal(dAtA []byte) error
func (*JobArchive) XXX_DiscardUnknown ¶
func (m *JobArchive) XXX_DiscardUnknown()
func (*JobArchive) XXX_Marshal ¶
func (m *JobArchive) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobArchive) XXX_Merge ¶
func (m *JobArchive) XXX_Merge(src proto.Message)
func (*JobArchive) XXX_Size ¶
func (m *JobArchive) XXX_Size() int
func (*JobArchive) XXX_Unmarshal ¶
func (m *JobArchive) XXX_Unmarshal(b []byte) error
type JobLog ¶
type JobLog struct { ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` Log string `protobuf:"bytes,3,opt,name=log,proto3" json:"log,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*JobLog) Descriptor ¶
func (*JobLog) GetNamespace ¶
func (*JobLog) MarshalToSizedBuffer ¶
func (*JobLog) ProtoMessage ¶
func (*JobLog) ProtoMessage()
func (*JobLog) XXX_DiscardUnknown ¶
func (m *JobLog) XXX_DiscardUnknown()
func (*JobLog) XXX_Marshal ¶
func (*JobLog) XXX_Unmarshal ¶
type JobLogRequest ¶
type JobLogRequest struct { ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*JobLogRequest) Descriptor ¶
func (*JobLogRequest) Descriptor() ([]byte, []int)
func (*JobLogRequest) GetID ¶
func (m *JobLogRequest) GetID() string
func (*JobLogRequest) Marshal ¶
func (m *JobLogRequest) Marshal() (dAtA []byte, err error)
func (*JobLogRequest) MarshalToSizedBuffer ¶
func (m *JobLogRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobLogRequest) ProtoMessage ¶
func (*JobLogRequest) ProtoMessage()
func (*JobLogRequest) Reset ¶
func (m *JobLogRequest) Reset()
func (*JobLogRequest) Size ¶
func (m *JobLogRequest) Size() (n int)
func (*JobLogRequest) String ¶
func (m *JobLogRequest) String() string
func (*JobLogRequest) Unmarshal ¶
func (m *JobLogRequest) Unmarshal(dAtA []byte) error
func (*JobLogRequest) XXX_DiscardUnknown ¶
func (m *JobLogRequest) XXX_DiscardUnknown()
func (*JobLogRequest) XXX_Marshal ¶
func (m *JobLogRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobLogRequest) XXX_Merge ¶
func (m *JobLogRequest) XXX_Merge(src proto.Message)
func (*JobLogRequest) XXX_Size ¶
func (m *JobLogRequest) XXX_Size() int
func (*JobLogRequest) XXX_Unmarshal ¶
func (m *JobLogRequest) XXX_Unmarshal(b []byte) error
type JobLogResponse ¶
type JobLogResponse struct { JobLog *JobLog `protobuf:"bytes,1,opt,name=job_log,json=jobLog,proto3" json:"job_log,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*JobLogResponse) Descriptor ¶
func (*JobLogResponse) Descriptor() ([]byte, []int)
func (*JobLogResponse) GetJobLog ¶
func (m *JobLogResponse) GetJobLog() *JobLog
func (*JobLogResponse) Marshal ¶
func (m *JobLogResponse) Marshal() (dAtA []byte, err error)
func (*JobLogResponse) MarshalToSizedBuffer ¶
func (m *JobLogResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobLogResponse) ProtoMessage ¶
func (*JobLogResponse) ProtoMessage()
func (*JobLogResponse) Reset ¶
func (m *JobLogResponse) Reset()
func (*JobLogResponse) Size ¶
func (m *JobLogResponse) Size() (n int)
func (*JobLogResponse) String ¶
func (m *JobLogResponse) String() string
func (*JobLogResponse) Unmarshal ¶
func (m *JobLogResponse) Unmarshal(dAtA []byte) error
func (*JobLogResponse) XXX_DiscardUnknown ¶
func (m *JobLogResponse) XXX_DiscardUnknown()
func (*JobLogResponse) XXX_Marshal ¶
func (m *JobLogResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobLogResponse) XXX_Merge ¶
func (m *JobLogResponse) XXX_Merge(src proto.Message)
func (*JobLogResponse) XXX_Size ¶
func (m *JobLogResponse) XXX_Size() int
func (*JobLogResponse) XXX_Unmarshal ¶
func (m *JobLogResponse) XXX_Unmarshal(b []byte) error
type JobPriority ¶
type JobPriority int32
const ( JobPriority_NORMAL JobPriority = 0 JobPriority_URGENT JobPriority = 1 JobPriority_LOW JobPriority = 2 )
func (JobPriority) EnumDescriptor ¶
func (JobPriority) EnumDescriptor() ([]byte, []int)
func (JobPriority) String ¶
func (x JobPriority) String() string
type JobRequest ¶
type JobRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` ResolutionX int64 `protobuf:"varint,2,opt,name=resolution_x,json=resolutionX,proto3" json:"resolution_x,omitempty"` ResolutionY int64 `protobuf:"varint,3,opt,name=resolution_y,json=resolutionY,proto3" json:"resolution_y,omitempty"` ResolutionScale int64 `protobuf:"varint,4,opt,name=resolution_scale,json=resolutionScale,proto3" json:"resolution_scale,omitempty"` RenderSamples int64 `protobuf:"varint,5,opt,name=render_samples,json=renderSamples,proto3" json:"render_samples,omitempty"` RenderStartFrame int64 `protobuf:"varint,6,opt,name=render_start_frame,json=renderStartFrame,proto3" json:"render_start_frame,omitempty"` RenderEndFrame int64 `protobuf:"varint,7,opt,name=render_end_frame,json=renderEndFrame,proto3" json:"render_end_frame,omitempty"` RenderUseGPU bool `protobuf:"varint,8,opt,name=render_use_gpu,json=renderUseGpu,proto3" json:"render_use_gpu,omitempty"` RenderPriority int64 `protobuf:"varint,9,opt,name=render_priority,json=renderPriority,proto3" json:"render_priority,omitempty"` CPU int64 `protobuf:"varint,10,opt,name=cpu,proto3" json:"cpu,omitempty"` Memory int64 `protobuf:"varint,11,opt,name=memory,proto3" json:"memory,omitempty"` RenderSlices int64 `protobuf:"varint,12,opt,name=render_slices,json=renderSlices,proto3" json:"render_slices,omitempty"` ContentType string `protobuf:"bytes,13,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"` Namespace string `protobuf:"bytes,14,opt,name=namespace,proto3" json:"namespace,omitempty"` RenderEngine RenderEngine `` /* 140-byte string literal not displayed */ Priority JobPriority `protobuf:"varint,16,opt,name=priority,proto3,enum=fynca.services.jobs.v1.JobPriority" json:"priority,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*JobRequest) Descriptor ¶
func (*JobRequest) Descriptor() ([]byte, []int)
func (*JobRequest) GetCPU ¶
func (m *JobRequest) GetCPU() int64
func (*JobRequest) GetContentType ¶
func (m *JobRequest) GetContentType() string
func (*JobRequest) GetMemory ¶
func (m *JobRequest) GetMemory() int64
func (*JobRequest) GetName ¶
func (m *JobRequest) GetName() string
func (*JobRequest) GetNamespace ¶
func (m *JobRequest) GetNamespace() string
func (*JobRequest) GetPriority ¶
func (m *JobRequest) GetPriority() JobPriority
func (*JobRequest) GetRenderEndFrame ¶
func (m *JobRequest) GetRenderEndFrame() int64
func (*JobRequest) GetRenderEngine ¶
func (m *JobRequest) GetRenderEngine() RenderEngine
func (*JobRequest) GetRenderPriority ¶
func (m *JobRequest) GetRenderPriority() int64
func (*JobRequest) GetRenderSamples ¶
func (m *JobRequest) GetRenderSamples() int64
func (*JobRequest) GetRenderSlices ¶
func (m *JobRequest) GetRenderSlices() int64
func (*JobRequest) GetRenderStartFrame ¶
func (m *JobRequest) GetRenderStartFrame() int64
func (*JobRequest) GetRenderUseGPU ¶
func (m *JobRequest) GetRenderUseGPU() bool
func (*JobRequest) GetResolutionScale ¶
func (m *JobRequest) GetResolutionScale() int64
func (*JobRequest) GetResolutionX ¶
func (m *JobRequest) GetResolutionX() int64
func (*JobRequest) GetResolutionY ¶
func (m *JobRequest) GetResolutionY() int64
func (*JobRequest) Marshal ¶
func (m *JobRequest) Marshal() (dAtA []byte, err error)
func (*JobRequest) MarshalToSizedBuffer ¶
func (m *JobRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobRequest) ProtoMessage ¶
func (*JobRequest) ProtoMessage()
func (*JobRequest) Reset ¶
func (m *JobRequest) Reset()
func (*JobRequest) Size ¶
func (m *JobRequest) Size() (n int)
func (*JobRequest) String ¶
func (m *JobRequest) String() string
func (*JobRequest) Unmarshal ¶
func (m *JobRequest) Unmarshal(dAtA []byte) error
func (*JobRequest) XXX_DiscardUnknown ¶
func (m *JobRequest) XXX_DiscardUnknown()
func (*JobRequest) XXX_Marshal ¶
func (m *JobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JobRequest) XXX_Merge ¶
func (m *JobRequest) XXX_Merge(src proto.Message)
func (*JobRequest) XXX_Size ¶
func (m *JobRequest) XXX_Size() int
func (*JobRequest) XXX_Unmarshal ¶
func (m *JobRequest) XXX_Unmarshal(b []byte) error
type JobResult ¶
type JobResult struct { Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` // Types that are valid to be assigned to Result: // *JobResult_FrameJob // *JobResult_SliceJob Result isJobResult_Result `protobuf_oneof:"result"` Duration time.Duration `protobuf:"bytes,4,opt,name=duration,proto3,stdduration" json:"duration"` RenderFrame int64 `protobuf:"varint,5,opt,name=render_frame,json=renderFrame,proto3" json:"render_frame,omitempty"` Status JobStatus `protobuf:"varint,6,opt,name=status,proto3,enum=fynca.services.jobs.v1.JobStatus" json:"status,omitempty"` Error string `protobuf:"bytes,7,opt,name=error,proto3" json:"error,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*JobResult) Descriptor ¶
func (*JobResult) GetDuration ¶
func (*JobResult) GetFrameJob ¶
func (*JobResult) GetNamespace ¶
func (*JobResult) GetRenderFrame ¶
func (*JobResult) GetSliceJob ¶
func (*JobResult) MarshalToSizedBuffer ¶
func (*JobResult) ProtoMessage ¶
func (*JobResult) ProtoMessage()
func (*JobResult) XXX_DiscardUnknown ¶
func (m *JobResult) XXX_DiscardUnknown()
func (*JobResult) XXX_Marshal ¶
func (*JobResult) XXX_OneofWrappers ¶
func (*JobResult) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*JobResult) XXX_Unmarshal ¶
type JobResult_FrameJob ¶
type JobResult_FrameJob struct {
FrameJob *FrameJob `protobuf:"bytes,2,opt,name=frame_job,json=frameJob,proto3,oneof" json:"frame_job,omitempty"`
}
func (*JobResult_FrameJob) MarshalTo ¶
func (m *JobResult_FrameJob) MarshalTo(dAtA []byte) (int, error)
func (*JobResult_FrameJob) MarshalToSizedBuffer ¶
func (m *JobResult_FrameJob) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobResult_FrameJob) Size ¶
func (m *JobResult_FrameJob) Size() (n int)
type JobResult_SliceJob ¶
type JobResult_SliceJob struct {
SliceJob *SliceJob `protobuf:"bytes,3,opt,name=slice_job,json=sliceJob,proto3,oneof" json:"slice_job,omitempty"`
}
func (*JobResult_SliceJob) MarshalTo ¶
func (m *JobResult_SliceJob) MarshalTo(dAtA []byte) (int, error)
func (*JobResult_SliceJob) MarshalToSizedBuffer ¶
func (m *JobResult_SliceJob) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*JobResult_SliceJob) Size ¶
func (m *JobResult_SliceJob) Size() (n int)
type JobsClient ¶
type JobsClient interface { QueueJob(ctx context.Context, opts ...grpc.CallOption) (Jobs_QueueJobClient, error) ListJobs(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error) GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*GetJobResponse, error) DeleteJob(ctx context.Context, in *DeleteJobRequest, opts ...grpc.CallOption) (*types.Empty, error) GetLatestRender(ctx context.Context, in *GetLatestRenderRequest, opts ...grpc.CallOption) (*GetLatestRenderResponse, error) Version(ctx context.Context, in *VersionRequest, opts ...grpc.CallOption) (*VersionResponse, error) JobLog(ctx context.Context, in *JobLogRequest, opts ...grpc.CallOption) (*JobLogResponse, error) RenderLog(ctx context.Context, in *RenderLogRequest, opts ...grpc.CallOption) (*RenderLogResponse, error) GetJobArchive(ctx context.Context, in *GetJobArchiveRequest, opts ...grpc.CallOption) (*GetJobArchiveResponse, error) }
JobsClient is the client API for Jobs service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewJobsClient ¶
func NewJobsClient(cc *grpc.ClientConn) JobsClient
type JobsServer ¶
type JobsServer interface { QueueJob(Jobs_QueueJobServer) error ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error) GetJob(context.Context, *GetJobRequest) (*GetJobResponse, error) DeleteJob(context.Context, *DeleteJobRequest) (*types.Empty, error) GetLatestRender(context.Context, *GetLatestRenderRequest) (*GetLatestRenderResponse, error) Version(context.Context, *VersionRequest) (*VersionResponse, error) JobLog(context.Context, *JobLogRequest) (*JobLogResponse, error) RenderLog(context.Context, *RenderLogRequest) (*RenderLogResponse, error) GetJobArchive(context.Context, *GetJobArchiveRequest) (*GetJobArchiveResponse, error) }
JobsServer is the server API for Jobs service.
type Jobs_QueueJobClient ¶
type Jobs_QueueJobClient interface { Send(*QueueJobRequest) error CloseAndRecv() (*QueueJobResponse, error) grpc.ClientStream }
type Jobs_QueueJobServer ¶
type Jobs_QueueJobServer interface { SendAndClose(*QueueJobResponse) error Recv() (*QueueJobRequest, error) grpc.ServerStream }
type ListJobsRequest ¶
type ListJobsRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListJobsRequest) Descriptor ¶
func (*ListJobsRequest) Descriptor() ([]byte, []int)
func (*ListJobsRequest) Marshal ¶
func (m *ListJobsRequest) Marshal() (dAtA []byte, err error)
func (*ListJobsRequest) MarshalToSizedBuffer ¶
func (m *ListJobsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ListJobsRequest) ProtoMessage ¶
func (*ListJobsRequest) ProtoMessage()
func (*ListJobsRequest) Reset ¶
func (m *ListJobsRequest) Reset()
func (*ListJobsRequest) Size ¶
func (m *ListJobsRequest) Size() (n int)
func (*ListJobsRequest) String ¶
func (m *ListJobsRequest) String() string
func (*ListJobsRequest) Unmarshal ¶
func (m *ListJobsRequest) Unmarshal(dAtA []byte) error
func (*ListJobsRequest) XXX_DiscardUnknown ¶
func (m *ListJobsRequest) XXX_DiscardUnknown()
func (*ListJobsRequest) XXX_Marshal ¶
func (m *ListJobsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListJobsRequest) XXX_Merge ¶
func (m *ListJobsRequest) XXX_Merge(src proto.Message)
func (*ListJobsRequest) XXX_Size ¶
func (m *ListJobsRequest) XXX_Size() int
func (*ListJobsRequest) XXX_Unmarshal ¶
func (m *ListJobsRequest) XXX_Unmarshal(b []byte) error
type ListJobsResponse ¶
type ListJobsResponse struct { Jobs []*Job `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListJobsResponse) Descriptor ¶
func (*ListJobsResponse) Descriptor() ([]byte, []int)
func (*ListJobsResponse) GetJobs ¶
func (m *ListJobsResponse) GetJobs() []*Job
func (*ListJobsResponse) Marshal ¶
func (m *ListJobsResponse) Marshal() (dAtA []byte, err error)
func (*ListJobsResponse) MarshalToSizedBuffer ¶
func (m *ListJobsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ListJobsResponse) ProtoMessage ¶
func (*ListJobsResponse) ProtoMessage()
func (*ListJobsResponse) Reset ¶
func (m *ListJobsResponse) Reset()
func (*ListJobsResponse) Size ¶
func (m *ListJobsResponse) Size() (n int)
func (*ListJobsResponse) String ¶
func (m *ListJobsResponse) String() string
func (*ListJobsResponse) Unmarshal ¶
func (m *ListJobsResponse) Unmarshal(dAtA []byte) error
func (*ListJobsResponse) XXX_DiscardUnknown ¶
func (m *ListJobsResponse) XXX_DiscardUnknown()
func (*ListJobsResponse) XXX_Marshal ¶
func (m *ListJobsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListJobsResponse) XXX_Merge ¶
func (m *ListJobsResponse) XXX_Merge(src proto.Message)
func (*ListJobsResponse) XXX_Size ¶
func (m *ListJobsResponse) XXX_Size() int
func (*ListJobsResponse) XXX_Unmarshal ¶
func (m *ListJobsResponse) XXX_Unmarshal(b []byte) error
type QueueJobRequest ¶
type QueueJobRequest struct { // Types that are valid to be assigned to Data: // *QueueJobRequest_Request // *QueueJobRequest_ChunkData Data isQueueJobRequest_Data `protobuf_oneof:"data"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*QueueJobRequest) Descriptor ¶
func (*QueueJobRequest) Descriptor() ([]byte, []int)
func (*QueueJobRequest) GetChunkData ¶
func (m *QueueJobRequest) GetChunkData() []byte
func (*QueueJobRequest) GetData ¶
func (m *QueueJobRequest) GetData() isQueueJobRequest_Data
func (*QueueJobRequest) GetRequest ¶
func (m *QueueJobRequest) GetRequest() *JobRequest
func (*QueueJobRequest) Marshal ¶
func (m *QueueJobRequest) Marshal() (dAtA []byte, err error)
func (*QueueJobRequest) MarshalToSizedBuffer ¶
func (m *QueueJobRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueueJobRequest) ProtoMessage ¶
func (*QueueJobRequest) ProtoMessage()
func (*QueueJobRequest) Reset ¶
func (m *QueueJobRequest) Reset()
func (*QueueJobRequest) Size ¶
func (m *QueueJobRequest) Size() (n int)
func (*QueueJobRequest) String ¶
func (m *QueueJobRequest) String() string
func (*QueueJobRequest) Unmarshal ¶
func (m *QueueJobRequest) Unmarshal(dAtA []byte) error
func (*QueueJobRequest) XXX_DiscardUnknown ¶
func (m *QueueJobRequest) XXX_DiscardUnknown()
func (*QueueJobRequest) XXX_Marshal ¶
func (m *QueueJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueueJobRequest) XXX_Merge ¶
func (m *QueueJobRequest) XXX_Merge(src proto.Message)
func (*QueueJobRequest) XXX_OneofWrappers ¶
func (*QueueJobRequest) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*QueueJobRequest) XXX_Size ¶
func (m *QueueJobRequest) XXX_Size() int
func (*QueueJobRequest) XXX_Unmarshal ¶
func (m *QueueJobRequest) XXX_Unmarshal(b []byte) error
type QueueJobRequest_ChunkData ¶
type QueueJobRequest_ChunkData struct {
ChunkData []byte `protobuf:"bytes,2,opt,name=chunk_data,json=chunkData,proto3,oneof" json:"chunk_data,omitempty"`
}
func (*QueueJobRequest_ChunkData) MarshalTo ¶
func (m *QueueJobRequest_ChunkData) MarshalTo(dAtA []byte) (int, error)
func (*QueueJobRequest_ChunkData) MarshalToSizedBuffer ¶
func (m *QueueJobRequest_ChunkData) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueueJobRequest_ChunkData) Size ¶
func (m *QueueJobRequest_ChunkData) Size() (n int)
type QueueJobRequest_Request ¶
type QueueJobRequest_Request struct {
Request *JobRequest `protobuf:"bytes,1,opt,name=request,proto3,oneof" json:"request,omitempty"`
}
func (*QueueJobRequest_Request) MarshalTo ¶
func (m *QueueJobRequest_Request) MarshalTo(dAtA []byte) (int, error)
func (*QueueJobRequest_Request) MarshalToSizedBuffer ¶
func (m *QueueJobRequest_Request) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueueJobRequest_Request) Size ¶
func (m *QueueJobRequest_Request) Size() (n int)
type QueueJobResponse ¶
type QueueJobResponse struct { UUID string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*QueueJobResponse) Descriptor ¶
func (*QueueJobResponse) Descriptor() ([]byte, []int)
func (*QueueJobResponse) GetUUID ¶
func (m *QueueJobResponse) GetUUID() string
func (*QueueJobResponse) Marshal ¶
func (m *QueueJobResponse) Marshal() (dAtA []byte, err error)
func (*QueueJobResponse) MarshalToSizedBuffer ¶
func (m *QueueJobResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueueJobResponse) ProtoMessage ¶
func (*QueueJobResponse) ProtoMessage()
func (*QueueJobResponse) Reset ¶
func (m *QueueJobResponse) Reset()
func (*QueueJobResponse) Size ¶
func (m *QueueJobResponse) Size() (n int)
func (*QueueJobResponse) String ¶
func (m *QueueJobResponse) String() string
func (*QueueJobResponse) Unmarshal ¶
func (m *QueueJobResponse) Unmarshal(dAtA []byte) error
func (*QueueJobResponse) XXX_DiscardUnknown ¶
func (m *QueueJobResponse) XXX_DiscardUnknown()
func (*QueueJobResponse) XXX_Marshal ¶
func (m *QueueJobResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueueJobResponse) XXX_Merge ¶
func (m *QueueJobResponse) XXX_Merge(src proto.Message)
func (*QueueJobResponse) XXX_Size ¶
func (m *QueueJobResponse) XXX_Size() int
func (*QueueJobResponse) XXX_Unmarshal ¶
func (m *QueueJobResponse) XXX_Unmarshal(b []byte) error
type RenderEngine ¶
type RenderEngine int32
const ( RenderEngine_UNKNOWN RenderEngine = 0 RenderEngine_CYCLES RenderEngine = 1 RenderEngine_BLENDER_EEVEE RenderEngine = 2 )
func (RenderEngine) EnumDescriptor ¶
func (RenderEngine) EnumDescriptor() ([]byte, []int)
func (RenderEngine) String ¶
func (x RenderEngine) String() string
type RenderJob ¶
type RenderJob interface { GetID() string GetJobSource() string GetRequest() *JobRequest GetRenderFrame() int64 }
type RenderLog ¶
type RenderLog struct { Log string `protobuf:"bytes,1,opt,name=log,proto3" json:"log,omitempty"` Frame int64 `protobuf:"varint,2,opt,name=frame,proto3" json:"frame,omitempty"` Slice int64 `protobuf:"varint,3,opt,name=slice,proto3" json:"slice,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RenderLog) Descriptor ¶
func (*RenderLog) MarshalToSizedBuffer ¶
func (*RenderLog) ProtoMessage ¶
func (*RenderLog) ProtoMessage()
func (*RenderLog) XXX_DiscardUnknown ¶
func (m *RenderLog) XXX_DiscardUnknown()
func (*RenderLog) XXX_Marshal ¶
func (*RenderLog) XXX_Unmarshal ¶
type RenderLogRequest ¶
type RenderLogRequest struct { ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Frame int64 `protobuf:"varint,2,opt,name=frame,proto3" json:"frame,omitempty"` Slice int64 `protobuf:"varint,3,opt,name=slice,proto3" json:"slice,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RenderLogRequest) Descriptor ¶
func (*RenderLogRequest) Descriptor() ([]byte, []int)
func (*RenderLogRequest) GetFrame ¶
func (m *RenderLogRequest) GetFrame() int64
func (*RenderLogRequest) GetID ¶
func (m *RenderLogRequest) GetID() string
func (*RenderLogRequest) GetSlice ¶
func (m *RenderLogRequest) GetSlice() int64
func (*RenderLogRequest) Marshal ¶
func (m *RenderLogRequest) Marshal() (dAtA []byte, err error)
func (*RenderLogRequest) MarshalToSizedBuffer ¶
func (m *RenderLogRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RenderLogRequest) ProtoMessage ¶
func (*RenderLogRequest) ProtoMessage()
func (*RenderLogRequest) Reset ¶
func (m *RenderLogRequest) Reset()
func (*RenderLogRequest) Size ¶
func (m *RenderLogRequest) Size() (n int)
func (*RenderLogRequest) String ¶
func (m *RenderLogRequest) String() string
func (*RenderLogRequest) Unmarshal ¶
func (m *RenderLogRequest) Unmarshal(dAtA []byte) error
func (*RenderLogRequest) XXX_DiscardUnknown ¶
func (m *RenderLogRequest) XXX_DiscardUnknown()
func (*RenderLogRequest) XXX_Marshal ¶
func (m *RenderLogRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RenderLogRequest) XXX_Merge ¶
func (m *RenderLogRequest) XXX_Merge(src proto.Message)
func (*RenderLogRequest) XXX_Size ¶
func (m *RenderLogRequest) XXX_Size() int
func (*RenderLogRequest) XXX_Unmarshal ¶
func (m *RenderLogRequest) XXX_Unmarshal(b []byte) error
type RenderLogResponse ¶
type RenderLogResponse struct { RenderLog *RenderLog `protobuf:"bytes,1,opt,name=render_log,json=renderLog,proto3" json:"render_log,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RenderLogResponse) Descriptor ¶
func (*RenderLogResponse) Descriptor() ([]byte, []int)
func (*RenderLogResponse) GetRenderLog ¶
func (m *RenderLogResponse) GetRenderLog() *RenderLog
func (*RenderLogResponse) Marshal ¶
func (m *RenderLogResponse) Marshal() (dAtA []byte, err error)
func (*RenderLogResponse) MarshalTo ¶
func (m *RenderLogResponse) MarshalTo(dAtA []byte) (int, error)
func (*RenderLogResponse) MarshalToSizedBuffer ¶
func (m *RenderLogResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RenderLogResponse) ProtoMessage ¶
func (*RenderLogResponse) ProtoMessage()
func (*RenderLogResponse) Reset ¶
func (m *RenderLogResponse) Reset()
func (*RenderLogResponse) Size ¶
func (m *RenderLogResponse) Size() (n int)
func (*RenderLogResponse) String ¶
func (m *RenderLogResponse) String() string
func (*RenderLogResponse) Unmarshal ¶
func (m *RenderLogResponse) Unmarshal(dAtA []byte) error
func (*RenderLogResponse) XXX_DiscardUnknown ¶
func (m *RenderLogResponse) XXX_DiscardUnknown()
func (*RenderLogResponse) XXX_Marshal ¶
func (m *RenderLogResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RenderLogResponse) XXX_Merge ¶
func (m *RenderLogResponse) XXX_Merge(src proto.Message)
func (*RenderLogResponse) XXX_Size ¶
func (m *RenderLogResponse) XXX_Size() int
func (*RenderLogResponse) XXX_Unmarshal ¶
func (m *RenderLogResponse) XXX_Unmarshal(b []byte) error
type SliceJob ¶
type SliceJob struct { ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Request *JobRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"` JobSource string `protobuf:"bytes,3,opt,name=job_source,json=jobSource,proto3" json:"job_source,omitempty"` SequenceID uint64 `protobuf:"varint,4,opt,name=sequence_id,json=sequenceId,proto3" json:"sequence_id,omitempty"` RenderSliceIndex int64 `protobuf:"varint,5,opt,name=render_slice_index,json=renderSliceIndex,proto3" json:"render_slice_index,omitempty"` RenderSliceMinX float32 `protobuf:"fixed32,6,opt,name=render_slice_min_x,json=renderSliceMinX,proto3" json:"render_slice_min_x,omitempty"` RenderSliceMaxX float32 `protobuf:"fixed32,7,opt,name=render_slice_max_x,json=renderSliceMaxX,proto3" json:"render_slice_max_x,omitempty"` RenderSliceMinY float32 `protobuf:"fixed32,8,opt,name=render_slice_min_y,json=renderSliceMinY,proto3" json:"render_slice_min_y,omitempty"` RenderSliceMaxY float32 `protobuf:"fixed32,9,opt,name=render_slice_max_y,json=renderSliceMaxY,proto3" json:"render_slice_max_y,omitempty"` RenderFrame int64 `protobuf:"varint,10,opt,name=render_frame,json=renderFrame,proto3" json:"render_frame,omitempty"` Worker *v1.Worker `protobuf:"bytes,11,opt,name=worker,proto3" json:"worker,omitempty"` QueuedAt time.Time `protobuf:"bytes,12,opt,name=queued_at,json=queuedAt,proto3,stdtime" json:"queued_at"` StartedAt time.Time `protobuf:"bytes,13,opt,name=started_at,json=startedAt,proto3,stdtime" json:"started_at"` FinishedAt time.Time `protobuf:"bytes,14,opt,name=finished_at,json=finishedAt,proto3,stdtime" json:"finished_at"` Status JobStatus `protobuf:"varint,15,opt,name=status,proto3,enum=fynca.services.jobs.v1.JobStatus" json:"status,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SliceJob) Descriptor ¶
func (*SliceJob) GetFinishedAt ¶
func (*SliceJob) GetJobSource ¶
func (*SliceJob) GetQueuedAt ¶
func (*SliceJob) GetRenderFrame ¶
func (*SliceJob) GetRenderSliceIndex ¶
func (*SliceJob) GetRenderSliceMaxX ¶
func (*SliceJob) GetRenderSliceMaxY ¶
func (*SliceJob) GetRenderSliceMinX ¶
func (*SliceJob) GetRenderSliceMinY ¶
func (*SliceJob) GetRequest ¶
func (m *SliceJob) GetRequest() *JobRequest
func (*SliceJob) GetSequenceID ¶
func (*SliceJob) GetStartedAt ¶
func (*SliceJob) MarshalToSizedBuffer ¶
func (*SliceJob) ProtoMessage ¶
func (*SliceJob) ProtoMessage()
func (*SliceJob) XXX_DiscardUnknown ¶
func (m *SliceJob) XXX_DiscardUnknown()
func (*SliceJob) XXX_Marshal ¶
func (*SliceJob) XXX_Unmarshal ¶
type UnimplementedJobsServer ¶
type UnimplementedJobsServer struct { }
UnimplementedJobsServer can be embedded to have forward compatible implementations.
func (*UnimplementedJobsServer) DeleteJob ¶
func (*UnimplementedJobsServer) DeleteJob(ctx context.Context, req *DeleteJobRequest) (*types.Empty, error)
func (*UnimplementedJobsServer) GetJob ¶
func (*UnimplementedJobsServer) GetJob(ctx context.Context, req *GetJobRequest) (*GetJobResponse, error)
func (*UnimplementedJobsServer) GetJobArchive ¶
func (*UnimplementedJobsServer) GetJobArchive(ctx context.Context, req *GetJobArchiveRequest) (*GetJobArchiveResponse, error)
func (*UnimplementedJobsServer) GetLatestRender ¶
func (*UnimplementedJobsServer) GetLatestRender(ctx context.Context, req *GetLatestRenderRequest) (*GetLatestRenderResponse, error)
func (*UnimplementedJobsServer) JobLog ¶
func (*UnimplementedJobsServer) JobLog(ctx context.Context, req *JobLogRequest) (*JobLogResponse, error)
func (*UnimplementedJobsServer) ListJobs ¶
func (*UnimplementedJobsServer) ListJobs(ctx context.Context, req *ListJobsRequest) (*ListJobsResponse, error)
func (*UnimplementedJobsServer) QueueJob ¶
func (*UnimplementedJobsServer) QueueJob(srv Jobs_QueueJobServer) error
func (*UnimplementedJobsServer) RenderLog ¶
func (*UnimplementedJobsServer) RenderLog(ctx context.Context, req *RenderLogRequest) (*RenderLogResponse, error)
func (*UnimplementedJobsServer) Version ¶
func (*UnimplementedJobsServer) Version(ctx context.Context, req *VersionRequest) (*VersionResponse, error)
type VersionRequest ¶
type VersionRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*VersionRequest) Descriptor ¶
func (*VersionRequest) Descriptor() ([]byte, []int)
func (*VersionRequest) Marshal ¶
func (m *VersionRequest) Marshal() (dAtA []byte, err error)
func (*VersionRequest) MarshalToSizedBuffer ¶
func (m *VersionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*VersionRequest) ProtoMessage ¶
func (*VersionRequest) ProtoMessage()
func (*VersionRequest) Reset ¶
func (m *VersionRequest) Reset()
func (*VersionRequest) Size ¶
func (m *VersionRequest) Size() (n int)
func (*VersionRequest) String ¶
func (m *VersionRequest) String() string
func (*VersionRequest) Unmarshal ¶
func (m *VersionRequest) Unmarshal(dAtA []byte) error
func (*VersionRequest) XXX_DiscardUnknown ¶
func (m *VersionRequest) XXX_DiscardUnknown()
func (*VersionRequest) XXX_Marshal ¶
func (m *VersionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*VersionRequest) XXX_Merge ¶
func (m *VersionRequest) XXX_Merge(src proto.Message)
func (*VersionRequest) XXX_Size ¶
func (m *VersionRequest) XXX_Size() int
func (*VersionRequest) XXX_Unmarshal ¶
func (m *VersionRequest) XXX_Unmarshal(b []byte) error
type VersionResponse ¶
type VersionResponse struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` Build string `protobuf:"bytes,3,opt,name=build,proto3" json:"build,omitempty"` Commit string `protobuf:"bytes,4,opt,name=commit,proto3" json:"commit,omitempty"` Authenticator string `protobuf:"bytes,5,opt,name=authenticator,proto3" json:"authenticator,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*VersionResponse) Descriptor ¶
func (*VersionResponse) Descriptor() ([]byte, []int)
func (*VersionResponse) GetAuthenticator ¶
func (m *VersionResponse) GetAuthenticator() string
func (*VersionResponse) GetBuild ¶
func (m *VersionResponse) GetBuild() string
func (*VersionResponse) GetCommit ¶
func (m *VersionResponse) GetCommit() string
func (*VersionResponse) GetName ¶
func (m *VersionResponse) GetName() string
func (*VersionResponse) GetVersion ¶
func (m *VersionResponse) GetVersion() string
func (*VersionResponse) Marshal ¶
func (m *VersionResponse) Marshal() (dAtA []byte, err error)
func (*VersionResponse) MarshalToSizedBuffer ¶
func (m *VersionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*VersionResponse) ProtoMessage ¶
func (*VersionResponse) ProtoMessage()
func (*VersionResponse) Reset ¶
func (m *VersionResponse) Reset()
func (*VersionResponse) Size ¶
func (m *VersionResponse) Size() (n int)
func (*VersionResponse) String ¶
func (m *VersionResponse) String() string
func (*VersionResponse) Unmarshal ¶
func (m *VersionResponse) Unmarshal(dAtA []byte) error
func (*VersionResponse) XXX_DiscardUnknown ¶
func (m *VersionResponse) XXX_DiscardUnknown()
func (*VersionResponse) XXX_Marshal ¶
func (m *VersionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*VersionResponse) XXX_Merge ¶
func (m *VersionResponse) XXX_Merge(src proto.Message)
func (*VersionResponse) XXX_Size ¶
func (m *VersionResponse) XXX_Size() int
func (*VersionResponse) XXX_Unmarshal ¶
func (m *VersionResponse) XXX_Unmarshal(b []byte) error
type WorkerJob ¶
type WorkerJob struct { // Types that are valid to be assigned to Job: // *WorkerJob_FrameJob // *WorkerJob_SliceJob Job isWorkerJob_Job `protobuf_oneof:"job"` ID string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*WorkerJob) Descriptor ¶
func (*WorkerJob) GetFrameJob ¶
func (*WorkerJob) GetSliceJob ¶
func (*WorkerJob) MarshalToSizedBuffer ¶
func (*WorkerJob) ProtoMessage ¶
func (*WorkerJob) ProtoMessage()
func (*WorkerJob) XXX_DiscardUnknown ¶
func (m *WorkerJob) XXX_DiscardUnknown()
func (*WorkerJob) XXX_Marshal ¶
func (*WorkerJob) XXX_OneofWrappers ¶
func (*WorkerJob) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*WorkerJob) XXX_Unmarshal ¶
type WorkerJob_FrameJob ¶
type WorkerJob_FrameJob struct {
FrameJob *FrameJob `protobuf:"bytes,1,opt,name=frame_job,json=frameJob,proto3,oneof" json:"frame_job,omitempty"`
}
func (*WorkerJob_FrameJob) MarshalTo ¶
func (m *WorkerJob_FrameJob) MarshalTo(dAtA []byte) (int, error)
func (*WorkerJob_FrameJob) MarshalToSizedBuffer ¶
func (m *WorkerJob_FrameJob) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*WorkerJob_FrameJob) Size ¶
func (m *WorkerJob_FrameJob) Size() (n int)
type WorkerJob_SliceJob ¶
type WorkerJob_SliceJob struct {
SliceJob *SliceJob `protobuf:"bytes,2,opt,name=slice_job,json=sliceJob,proto3,oneof" json:"slice_job,omitempty"`
}
func (*WorkerJob_SliceJob) MarshalTo ¶
func (m *WorkerJob_SliceJob) MarshalTo(dAtA []byte) (int, error)
func (*WorkerJob_SliceJob) MarshalToSizedBuffer ¶
func (m *WorkerJob_SliceJob) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*WorkerJob_SliceJob) Size ¶
func (m *WorkerJob_SliceJob) Size() (n int)