jobs

package
v0.0.0-...-be3d2a3 Latest Latest
Warning

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

 Go to latest Published: Jun 13, 2022 License: Apache-2.0 Imports: 14 Imported by: 0

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.

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

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthJobs        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowJobs          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupJobs = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var JobPriority_name = map[int32]string{
	0: "NORMAL",
	1: "URGENT",
	2: "LOW",
}
View Source 
var JobPriority_value = map[string]int32{
	"NORMAL": 0,
	"URGENT": 1,
	"LOW":    2,
}
View Source 
var JobStatus_name = map[int32]string{
	0: "QUEUED",
	1: "RENDERING",
	2: "ERROR",
	3: "FINISHED",
}
View Source 
var JobStatus_value = map[string]int32{
	"QUEUED":    0,
	"RENDERING": 1,
	"ERROR":     2,
	"FINISHED":  3,
}
View Source 
var RenderEngine_name = map[int32]string{
	0: "UNKNOWN",
	1: "CYCLES",
	2: "BLENDER_EEVEE",
}
View Source 
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) MarshalTo 

func (m *DeleteJobRequest) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*FrameJob) GetFinishedAt 

func (m *FrameJob) GetFinishedAt() time.Time

func (*FrameJob) GetID 

func (m *FrameJob) GetID() string

func (*FrameJob) GetJobSource 

func (m *FrameJob) GetJobSource() string

func (*FrameJob) GetQueuedAt 

func (m *FrameJob) GetQueuedAt() time.Time

func (*FrameJob) GetRenderFrame 

func (m *FrameJob) GetRenderFrame() int64

func (*FrameJob) GetRequest 

func (m *FrameJob) GetRequest() *JobRequest

func (*FrameJob) GetSequenceID 

func (m *FrameJob) GetSequenceID() uint64

func (*FrameJob) GetSliceJobs 

func (m *FrameJob) GetSliceJobs() []*SliceJob

func (*FrameJob) GetStartedAt 

func (m *FrameJob) GetStartedAt() time.Time

func (*FrameJob) GetStatus 

func (m *FrameJob) GetStatus() JobStatus

func (*FrameJob) GetWorker 

func (m *FrameJob) GetWorker() *v1.Worker

func (*FrameJob) Marshal 

func (m *FrameJob) Marshal() (dAtA []byte, err error)

func (*FrameJob) MarshalTo 

func (m *FrameJob) MarshalTo(dAtA []byte) (int, error)

func (*FrameJob) MarshalToSizedBuffer 

func (m *FrameJob) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FrameJob) ProtoMessage 

func (*FrameJob) ProtoMessage()

func (*FrameJob) Reset 

func (m *FrameJob) Reset()

func (*FrameJob) Size 

func (m *FrameJob) Size() (n int)

func (*FrameJob) String 

func (m *FrameJob) String() string

func (*FrameJob) Unmarshal 

func (m *FrameJob) Unmarshal(dAtA []byte) error

func (*FrameJob) XXX_DiscardUnknown 

func (m *FrameJob) XXX_DiscardUnknown()

func (*FrameJob) XXX_Marshal 

func (m *FrameJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FrameJob) XXX_Merge 

func (m *FrameJob) XXX_Merge(src proto.Message)

func (*FrameJob) XXX_Size 

func (m *FrameJob) XXX_Size() int

func (*FrameJob) XXX_Unmarshal 

func (m *FrameJob) XXX_Unmarshal(b []byte) error

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) MarshalTo 

func (m *GetJobRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *GetJobResponse) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*Job) GetCreatedAt 

func (m *Job) GetCreatedAt() time.Time

func (*Job) GetDuration 

func (m *Job) GetDuration() time.Duration

func (*Job) GetFinishedAt 

func (m *Job) GetFinishedAt() time.Time

func (*Job) GetFrameJobs 

func (m *Job) GetFrameJobs() []*FrameJob

func (*Job) GetID 

func (m *Job) GetID() string

func (*Job) GetJobSource 

func (m *Job) GetJobSource() string

func (*Job) GetOutputDir 

func (m *Job) GetOutputDir() string

func (*Job) GetQueuedAt 

func (m *Job) GetQueuedAt() time.Time

func (*Job) GetRequest 

func (m *Job) GetRequest() *JobRequest

func (*Job) GetStartedAt 

func (m *Job) GetStartedAt() time.Time

func (*Job) GetStatus 

func (m *Job) GetStatus() JobStatus

func (*Job) Marshal 

func (m *Job) Marshal() (dAtA []byte, err error)

func (*Job) MarshalTo 

func (m *Job) MarshalTo(dAtA []byte) (int, error)

func (*Job) MarshalToSizedBuffer 

func (m *Job) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) Reset 

func (m *Job) Reset()

func (*Job) Size 

func (m *Job) Size() (n int)

func (*Job) String 

func (m *Job) String() string

func (*Job) Unmarshal 

func (m *Job) Unmarshal(dAtA []byte) error

func (*Job) XXX_DiscardUnknown 

func (m *Job) XXX_DiscardUnknown()

func (*Job) XXX_Marshal 

func (m *Job) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Job) XXX_Merge 

func (m *Job) XXX_Merge(src proto.Message)

func (*Job) XXX_Size 

func (m *Job) XXX_Size() int

func (*Job) XXX_Unmarshal 

func (m *Job) XXX_Unmarshal(b []byte) error

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) MarshalTo 

func (m *JobArchive) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*JobLog) GetID 

func (m *JobLog) GetID() string

func (*JobLog) GetLog 

func (m *JobLog) GetLog() string

func (*JobLog) GetNamespace 

func (m *JobLog) GetNamespace() string

func (*JobLog) Marshal 

func (m *JobLog) Marshal() (dAtA []byte, err error)

func (*JobLog) MarshalTo 

func (m *JobLog) MarshalTo(dAtA []byte) (int, error)

func (*JobLog) MarshalToSizedBuffer 

func (m *JobLog) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobLog) ProtoMessage 

func (*JobLog) ProtoMessage()

func (*JobLog) Reset 

func (m *JobLog) Reset()

func (*JobLog) Size 

func (m *JobLog) Size() (n int)

func (*JobLog) String 

func (m *JobLog) String() string

func (*JobLog) Unmarshal 

func (m *JobLog) Unmarshal(dAtA []byte) error

func (*JobLog) XXX_DiscardUnknown 

func (m *JobLog) XXX_DiscardUnknown()

func (*JobLog) XXX_Marshal 

func (m *JobLog) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobLog) XXX_Merge 

func (m *JobLog) XXX_Merge(src proto.Message)

func (*JobLog) XXX_Size 

func (m *JobLog) XXX_Size() int

func (*JobLog) XXX_Unmarshal 

func (m *JobLog) XXX_Unmarshal(b []byte) error

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) MarshalTo 

func (m *JobLogRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *JobLogResponse) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *JobRequest) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*JobResult) GetDuration 

func (m *JobResult) GetDuration() time.Duration

func (*JobResult) GetError 

func (m *JobResult) GetError() string

func (*JobResult) GetFrameJob 

func (m *JobResult) GetFrameJob() *FrameJob

func (*JobResult) GetNamespace 

func (m *JobResult) GetNamespace() string

func (*JobResult) GetRenderFrame 

func (m *JobResult) GetRenderFrame() int64

func (*JobResult) GetResult 

func (m *JobResult) GetResult() isJobResult_Result

func (*JobResult) GetSliceJob 

func (m *JobResult) GetSliceJob() *SliceJob

func (*JobResult) GetStatus 

func (m *JobResult) GetStatus() JobStatus

func (*JobResult) Marshal 

func (m *JobResult) Marshal() (dAtA []byte, err error)

func (*JobResult) MarshalTo 

func (m *JobResult) MarshalTo(dAtA []byte) (int, error)

func (*JobResult) MarshalToSizedBuffer 

func (m *JobResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobResult) ProtoMessage 

func (*JobResult) ProtoMessage()

func (*JobResult) Reset 

func (m *JobResult) Reset()

func (*JobResult) Size 

func (m *JobResult) Size() (n int)

func (*JobResult) String 

func (m *JobResult) String() string

func (*JobResult) Unmarshal 

func (m *JobResult) Unmarshal(dAtA []byte) error

func (*JobResult) XXX_DiscardUnknown 

func (m *JobResult) XXX_DiscardUnknown()

func (*JobResult) XXX_Marshal 

func (m *JobResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JobResult) XXX_Merge 

func (m *JobResult) XXX_Merge(src proto.Message)

func (*JobResult) XXX_OneofWrappers 

func (*JobResult) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*JobResult) XXX_Size 

func (m *JobResult) XXX_Size() int

func (*JobResult) XXX_Unmarshal 

func (m *JobResult) XXX_Unmarshal(b []byte) error

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 JobStatus 

type JobStatus int32
const (
	JobStatus_QUEUED    JobStatus = 0
	JobStatus_RENDERING JobStatus = 1
	JobStatus_ERROR     JobStatus = 2
	JobStatus_FINISHED  JobStatus = 3
)

func (JobStatus) EnumDescriptor 

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

func (JobStatus) String 

func (x JobStatus) String() string

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) MarshalTo 

func (m *ListJobsRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *ListJobsResponse) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *QueueJobRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *QueueJobResponse) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*RenderLog) GetFrame 

func (m *RenderLog) GetFrame() int64

func (*RenderLog) GetLog 

func (m *RenderLog) GetLog() string

func (*RenderLog) GetSlice 

func (m *RenderLog) GetSlice() int64

func (*RenderLog) Marshal 

func (m *RenderLog) Marshal() (dAtA []byte, err error)

func (*RenderLog) MarshalTo 

func (m *RenderLog) MarshalTo(dAtA []byte) (int, error)

func (*RenderLog) MarshalToSizedBuffer 

func (m *RenderLog) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RenderLog) ProtoMessage 

func (*RenderLog) ProtoMessage()

func (*RenderLog) Reset 

func (m *RenderLog) Reset()

func (*RenderLog) Size 

func (m *RenderLog) Size() (n int)

func (*RenderLog) String 

func (m *RenderLog) String() string

func (*RenderLog) Unmarshal 

func (m *RenderLog) Unmarshal(dAtA []byte) error

func (*RenderLog) XXX_DiscardUnknown 

func (m *RenderLog) XXX_DiscardUnknown()

func (*RenderLog) XXX_Marshal 

func (m *RenderLog) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RenderLog) XXX_Merge 

func (m *RenderLog) XXX_Merge(src proto.Message)

func (*RenderLog) XXX_Size 

func (m *RenderLog) XXX_Size() int

func (*RenderLog) XXX_Unmarshal 

func (m *RenderLog) XXX_Unmarshal(b []byte) error

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) MarshalTo 

func (m *RenderLogRequest) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*SliceJob) GetFinishedAt 

func (m *SliceJob) GetFinishedAt() time.Time

func (*SliceJob) GetID 

func (m *SliceJob) GetID() string

func (*SliceJob) GetJobSource 

func (m *SliceJob) GetJobSource() string

func (*SliceJob) GetQueuedAt 

func (m *SliceJob) GetQueuedAt() time.Time

func (*SliceJob) GetRenderFrame 

func (m *SliceJob) GetRenderFrame() int64

func (*SliceJob) GetRenderSliceIndex 

func (m *SliceJob) GetRenderSliceIndex() int64

func (*SliceJob) GetRenderSliceMaxX 

func (m *SliceJob) GetRenderSliceMaxX() float32

func (*SliceJob) GetRenderSliceMaxY 

func (m *SliceJob) GetRenderSliceMaxY() float32

func (*SliceJob) GetRenderSliceMinX 

func (m *SliceJob) GetRenderSliceMinX() float32

func (*SliceJob) GetRenderSliceMinY 

func (m *SliceJob) GetRenderSliceMinY() float32

func (*SliceJob) GetRequest 

func (m *SliceJob) GetRequest() *JobRequest

func (*SliceJob) GetSequenceID 

func (m *SliceJob) GetSequenceID() uint64

func (*SliceJob) GetStartedAt 

func (m *SliceJob) GetStartedAt() time.Time

func (*SliceJob) GetStatus 

func (m *SliceJob) GetStatus() JobStatus

func (*SliceJob) GetWorker 

func (m *SliceJob) GetWorker() *v1.Worker

func (*SliceJob) Marshal 

func (m *SliceJob) Marshal() (dAtA []byte, err error)

func (*SliceJob) MarshalTo 

func (m *SliceJob) MarshalTo(dAtA []byte) (int, error)

func (*SliceJob) MarshalToSizedBuffer 

func (m *SliceJob) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SliceJob) ProtoMessage 

func (*SliceJob) ProtoMessage()

func (*SliceJob) Reset 

func (m *SliceJob) Reset()

func (*SliceJob) Size 

func (m *SliceJob) Size() (n int)

func (*SliceJob) String 

func (m *SliceJob) String() string

func (*SliceJob) Unmarshal 

func (m *SliceJob) Unmarshal(dAtA []byte) error

func (*SliceJob) XXX_DiscardUnknown 

func (m *SliceJob) XXX_DiscardUnknown()

func (*SliceJob) XXX_Marshal 

func (m *SliceJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SliceJob) XXX_Merge 

func (m *SliceJob) XXX_Merge(src proto.Message)

func (*SliceJob) XXX_Size 

func (m *SliceJob) XXX_Size() int

func (*SliceJob) XXX_Unmarshal 

func (m *SliceJob) XXX_Unmarshal(b []byte) error

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) MarshalTo 

func (m *VersionRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *VersionResponse) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*WorkerJob) GetFrameJob 

func (m *WorkerJob) GetFrameJob() *FrameJob

func (*WorkerJob) GetID 

func (m *WorkerJob) GetID() string

func (*WorkerJob) GetJob 

func (m *WorkerJob) GetJob() isWorkerJob_Job

func (*WorkerJob) GetSliceJob 

func (m *WorkerJob) GetSliceJob() *SliceJob

func (*WorkerJob) Marshal 

func (m *WorkerJob) Marshal() (dAtA []byte, err error)

func (*WorkerJob) MarshalTo 

func (m *WorkerJob) MarshalTo(dAtA []byte) (int, error)

func (*WorkerJob) MarshalToSizedBuffer 

func (m *WorkerJob) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkerJob) ProtoMessage 

func (*WorkerJob) ProtoMessage()

func (*WorkerJob) Reset 

func (m *WorkerJob) Reset()

func (*WorkerJob) Size 

func (m *WorkerJob) Size() (n int)

func (*WorkerJob) String 

func (m *WorkerJob) String() string

func (*WorkerJob) Unmarshal 

func (m *WorkerJob) Unmarshal(dAtA []byte) error

func (*WorkerJob) XXX_DiscardUnknown 

func (m *WorkerJob) XXX_DiscardUnknown()

func (*WorkerJob) XXX_Marshal 

func (m *WorkerJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkerJob) XXX_Merge 

func (m *WorkerJob) XXX_Merge(src proto.Message)

func (*WorkerJob) XXX_OneofWrappers 

func (*WorkerJob) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*WorkerJob) XXX_Size 

func (m *WorkerJob) XXX_Size() int

func (*WorkerJob) XXX_Unmarshal 

func (m *WorkerJob) XXX_Unmarshal(b []byte) error

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)

Source Files

View all Source files

Jump to

Keyboard shortcuts

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