models

package
v0.2.0 Latest Latest
Warning

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

 Go to latest Published: Apr 14, 2021 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	JobType_name = map[int32]string{
		0: "InvalidJobType",
		1: "CopyDir",
		2: "CopyFile",
		3: "CopySingleFile",
		4: "CopyMultipartFile",
		5: "CopyMultipart",
	}
	JobType_value = map[string]int32{
		"InvalidJobType":    0,
		"CopyDir":           1,
		"CopyFile":          2,
		"CopySingleFile":    3,
		"CopyMultipartFile": 4,
		"CopyMultipart":     5,
	}
)

Enum value maps for JobType.

View Source 
var (
	JobStatus_name = map[int32]string{
		0: "InvalidJobStatus",
		1: "Succeed",
		2: "Failed",
	}
	JobStatus_value = map[string]int32{
		"InvalidJobStatus": 0,
		"Succeed":          1,
		"Failed":           2,
	}
)

Enum value maps for JobStatus.

View Source 
var (
	TaskPrefix  = []byte{taskPrefix, ':'}
	StaffPrefix = []byte{staffPrefix, ':'}
	JobPrefix   = []byte{jobPrefix, ':'}
)
View Source 
var (
	PollStatus_name = map[int32]string{
		0:   "InvalidPollStatus",
		1:   "Valid",
		2:   "Empty",
		100: "Terminated",
	}
	PollStatus_value = map[string]int32{
		"InvalidPollStatus": 0,
		"Valid":             1,
		"Empty":             2,
		"Terminated":        100,
	}
)

Enum value maps for PollStatus.

View Source 
var (
	TaskType_name = map[int32]string{
		0: "InvalidTaskType",
		1: "CopyDir",
	}
	TaskType_value = map[string]int32{
		"InvalidTaskType": 0,
		"CopyDir":         1,
	}
)

Enum value maps for TaskType.

View Source 
var (
	TaskStatus_name = map[int32]string{
		0: "InvalidTaskStatus",
		1: "Created",
		2: "Ready",
		3: "Running",
		4: "Finished",
		5: "Stopped",
		6: "Error",
	}
	TaskStatus_value = map[string]int32{
		"InvalidTaskStatus": 0,
		"Created":           1,
		"Ready":             2,
		"Running":           3,
		"Finished":          4,
		"Stopped":           5,
		"Error":             6,
	}
)

Enum value maps for TaskStatus.

View Source 
var (
	StorageType_name = map[int32]string{
		0: "InvalidStorageType",
		1: "Fs",
		2: "Qingstor",
	}
	StorageType_value = map[string]int32{
		"InvalidStorageType": 0,
		"Fs":                 1,
		"Qingstor":           2,
	}
)

Enum value maps for StorageType.

View Source 
var (
	PollJobStatus_name = map[int32]string{
		0:   "InvalidPollJobStatus",
		1:   "Valid",
		100: "Terminated",
	}
	PollJobStatus_value = map[string]int32{
		"InvalidPollJobStatus": 0,
		"Valid":                1,
		"Terminated":           100,
	}
)

Enum value maps for PollJobStatus.

View Source 
var (
	// ErrNotFound returns when request record not found in db
	ErrNotFound = errors.New("record not found")
)
View Source 
var File_job_proto protoreflect.FileDescriptor
View Source 
var File_staff_proto protoreflect.FileDescriptor
View Source 
var File_task_proto protoreflect.FileDescriptor
View Source 
var File_worker_proto protoreflect.FileDescriptor
View Source 
var JobDone = errors.New("job done")
View Source 
var Staff_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "staff.Staff",
	HandlerType: (*StaffServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Register",
			Handler:    _Staff_Register_Handler,
		},
		{
			MethodName: "Elect",
			Handler:    _Staff_Elect_Handler,
		},
		{
			MethodName: "Finish",
			Handler:    _Staff_Finish_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Poll",
			Handler:       _Staff_Poll_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "staff.proto",
}

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

View Source 
var TaskDone = errors.New("task done")
View Source 
var Worker_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "worker.Worker",
	HandlerType: (*WorkerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateJob",
			Handler:    _Worker_CreateJob_Handler,
		},
		{
			MethodName: "WaitJob",
			Handler:    _Worker_WaitJob_Handler,
		},
		{
			MethodName: "FinishJob",
			Handler:    _Worker_FinishJob_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "PollJob",
			Handler:       _Worker_PollJob_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "worker.proto",
}

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

Functions

func FormatPair added in v0.2.0 

func FormatPair(p *Pair) types.Pair

func FormatStorage added in v0.2.0 

func FormatStorage(st *Storage) (types.Storager, error)

func JobKey added in v0.2.0 

func JobKey(jobId string) []byte

func NewNotFoundErr 

func NewNotFoundErr(key string) error

NewNotFoundErr wrap not found error with specific msg

func RegisterStaffServer added in v0.2.0 

func RegisterStaffServer(s grpc.ServiceRegistrar, srv StaffServer)

func RegisterWorkerServer added in v0.2.0 

func RegisterWorkerServer(s grpc.ServiceRegistrar, srv WorkerServer)

func StaffKey added in v0.2.0 

func StaffKey(staffId string) []byte

Style: s:<staff_id>

func StaffTaskKey added in v0.2.0 

func StaffTaskKey(staffId, taskId string) []byte

Style: st:<staff_id>:<task_id>

func StaffTaskPrefix added in v0.2.0 

func StaffTaskPrefix(staffId string) []byte

Style: s_t:<staff_id>:<task_id>

func TaskKey added in v0.2.0 

func TaskKey(taskId string) []byte

Style: t:<task_id>

func TaskLeaderKey added in v0.2.0 

func TaskLeaderKey(taskId string) []byte

Style: t_leader:<task_id>

Types

type CopyDirJob added in v0.2.0 

type CopyDirJob struct {
	Src       uint32 `protobuf:"varint,1,opt,name=src,proto3" json:"src,omitempty"`
	Dst       uint32 `protobuf:"varint,2,opt,name=dst,proto3" json:"dst,omitempty"`
	SrcPath   string `protobuf:"bytes,3,opt,name=src_path,json=srcPath,proto3" json:"src_path,omitempty"`
	DstPath   string `protobuf:"bytes,4,opt,name=dst_path,json=dstPath,proto3" json:"dst_path,omitempty"`
	Recursive bool   `protobuf:"varint,5,opt,name=recursive,proto3" json:"recursive,omitempty"`
	// contains filtered or unexported fields
}

func (*CopyDirJob) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use CopyDirJob.ProtoReflect.Descriptor instead.

func (*CopyDirJob) GetDst added in v0.2.0 

func (x *CopyDirJob) GetDst() uint32

func (*CopyDirJob) GetDstPath added in v0.2.0 

func (x *CopyDirJob) GetDstPath() string

func (*CopyDirJob) GetRecursive added in v0.2.0 

func (x *CopyDirJob) GetRecursive() bool

func (*CopyDirJob) GetSrc added in v0.2.0 

func (x *CopyDirJob) GetSrc() uint32

func (*CopyDirJob) GetSrcPath added in v0.2.0 

func (x *CopyDirJob) GetSrcPath() string

func (*CopyDirJob) ProtoMessage added in v0.2.0 

func (*CopyDirJob) ProtoMessage()

func (*CopyDirJob) ProtoReflect added in v0.2.0 

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

func (*CopyDirJob) Reset added in v0.2.0 

func (x *CopyDirJob) Reset()

func (*CopyDirJob) String added in v0.2.0 

func (x *CopyDirJob) String() string

type CopyFileJob added in v0.2.0 

type CopyFileJob struct {
	Src     uint32 `protobuf:"varint,1,opt,name=src,proto3" json:"src,omitempty"`
	Dst     uint32 `protobuf:"varint,2,opt,name=dst,proto3" json:"dst,omitempty"`
	SrcPath string `protobuf:"bytes,3,opt,name=src_path,json=srcPath,proto3" json:"src_path,omitempty"`
	DstPath string `protobuf:"bytes,4,opt,name=dst_path,json=dstPath,proto3" json:"dst_path,omitempty"`
	// contains filtered or unexported fields
}

func (*CopyFileJob) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use CopyFileJob.ProtoReflect.Descriptor instead.

func (*CopyFileJob) GetDst added in v0.2.0 

func (x *CopyFileJob) GetDst() uint32

func (*CopyFileJob) GetDstPath added in v0.2.0 

func (x *CopyFileJob) GetDstPath() string

func (*CopyFileJob) GetSrc added in v0.2.0 

func (x *CopyFileJob) GetSrc() uint32

func (*CopyFileJob) GetSrcPath added in v0.2.0 

func (x *CopyFileJob) GetSrcPath() string

func (*CopyFileJob) ProtoMessage added in v0.2.0 

func (*CopyFileJob) ProtoMessage()

func (*CopyFileJob) ProtoReflect added in v0.2.0 

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

func (*CopyFileJob) Reset added in v0.2.0 

func (x *CopyFileJob) Reset()

func (*CopyFileJob) String added in v0.2.0 

func (x *CopyFileJob) String() string

type CopyMultipartFileJob added in v0.2.0 

type CopyMultipartFileJob struct {
	Src     uint32 `protobuf:"varint,1,opt,name=src,proto3" json:"src,omitempty"`
	Dst     uint32 `protobuf:"varint,2,opt,name=dst,proto3" json:"dst,omitempty"`
	SrcPath string `protobuf:"bytes,3,opt,name=src_path,json=srcPath,proto3" json:"src_path,omitempty"`
	DstPath string `protobuf:"bytes,4,opt,name=dst_path,json=dstPath,proto3" json:"dst_path,omitempty"`
	Size    int64  `protobuf:"varint,5,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*CopyMultipartFileJob) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use CopyMultipartFileJob.ProtoReflect.Descriptor instead.

func (*CopyMultipartFileJob) GetDst added in v0.2.0 

func (x *CopyMultipartFileJob) GetDst() uint32

func (*CopyMultipartFileJob) GetDstPath added in v0.2.0 

func (x *CopyMultipartFileJob) GetDstPath() string

func (*CopyMultipartFileJob) GetSize added in v0.2.0 

func (x *CopyMultipartFileJob) GetSize() int64

func (*CopyMultipartFileJob) GetSrc added in v0.2.0 

func (x *CopyMultipartFileJob) GetSrc() uint32

func (*CopyMultipartFileJob) GetSrcPath added in v0.2.0 

func (x *CopyMultipartFileJob) GetSrcPath() string

func (*CopyMultipartFileJob) ProtoMessage added in v0.2.0 

func (*CopyMultipartFileJob) ProtoMessage()

func (*CopyMultipartFileJob) ProtoReflect added in v0.2.0 

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

func (*CopyMultipartFileJob) Reset added in v0.2.0 

func (x *CopyMultipartFileJob) Reset()

func (*CopyMultipartFileJob) String added in v0.2.0 

func (x *CopyMultipartFileJob) String() string

type CopyMultipartJob added in v0.2.0 

type CopyMultipartJob struct {
	Src         uint32 `protobuf:"varint,1,opt,name=src,proto3" json:"src,omitempty"`
	Dst         uint32 `protobuf:"varint,2,opt,name=dst,proto3" json:"dst,omitempty"`
	SrcPath     string `protobuf:"bytes,3,opt,name=src_path,json=srcPath,proto3" json:"src_path,omitempty"`
	DstPath     string `protobuf:"bytes,4,opt,name=dst_path,json=dstPath,proto3" json:"dst_path,omitempty"`
	MultipartId string `protobuf:"bytes,5,opt,name=multipart_id,json=multipartId,proto3" json:"multipart_id,omitempty"`
	Size        int64  `protobuf:"varint,6,opt,name=size,proto3" json:"size,omitempty"`
	Index       uint32 `protobuf:"varint,7,opt,name=index,proto3" json:"index,omitempty"`
	Offset      int64  `protobuf:"varint,8,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*CopyMultipartJob) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use CopyMultipartJob.ProtoReflect.Descriptor instead.

func (*CopyMultipartJob) GetDst added in v0.2.0 

func (x *CopyMultipartJob) GetDst() uint32

func (*CopyMultipartJob) GetDstPath added in v0.2.0 

func (x *CopyMultipartJob) GetDstPath() string

func (*CopyMultipartJob) GetIndex added in v0.2.0 

func (x *CopyMultipartJob) GetIndex() uint32

func (*CopyMultipartJob) GetMultipartId added in v0.2.0 

func (x *CopyMultipartJob) GetMultipartId() string

func (*CopyMultipartJob) GetOffset added in v0.2.0 

func (x *CopyMultipartJob) GetOffset() int64

func (*CopyMultipartJob) GetSize added in v0.2.0 

func (x *CopyMultipartJob) GetSize() int64

func (*CopyMultipartJob) GetSrc added in v0.2.0 

func (x *CopyMultipartJob) GetSrc() uint32

func (*CopyMultipartJob) GetSrcPath added in v0.2.0 

func (x *CopyMultipartJob) GetSrcPath() string

func (*CopyMultipartJob) ProtoMessage added in v0.2.0 

func (*CopyMultipartJob) ProtoMessage()

func (*CopyMultipartJob) ProtoReflect added in v0.2.0 

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

func (*CopyMultipartJob) Reset added in v0.2.0 

func (x *CopyMultipartJob) Reset()

func (*CopyMultipartJob) String added in v0.2.0 

func (x *CopyMultipartJob) String() string

type CopySingleFileJob added in v0.2.0 

type CopySingleFileJob struct {
	Src     uint32 `protobuf:"varint,1,opt,name=src,proto3" json:"src,omitempty"`
	Dst     uint32 `protobuf:"varint,2,opt,name=dst,proto3" json:"dst,omitempty"`
	SrcPath string `protobuf:"bytes,3,opt,name=src_path,json=srcPath,proto3" json:"src_path,omitempty"`
	DstPath string `protobuf:"bytes,4,opt,name=dst_path,json=dstPath,proto3" json:"dst_path,omitempty"`
	Size    int64  `protobuf:"varint,5,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*CopySingleFileJob) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use CopySingleFileJob.ProtoReflect.Descriptor instead.

func (*CopySingleFileJob) GetDst added in v0.2.0 

func (x *CopySingleFileJob) GetDst() uint32

func (*CopySingleFileJob) GetDstPath added in v0.2.0 

func (x *CopySingleFileJob) GetDstPath() string

func (*CopySingleFileJob) GetSize added in v0.2.0 

func (x *CopySingleFileJob) GetSize() int64

func (*CopySingleFileJob) GetSrc added in v0.2.0 

func (x *CopySingleFileJob) GetSrc() uint32

func (*CopySingleFileJob) GetSrcPath added in v0.2.0 

func (x *CopySingleFileJob) GetSrcPath() string

func (*CopySingleFileJob) ProtoMessage added in v0.2.0 

func (*CopySingleFileJob) ProtoMessage()

func (*CopySingleFileJob) ProtoReflect added in v0.2.0 

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

func (*CopySingleFileJob) Reset added in v0.2.0 

func (x *CopySingleFileJob) Reset()

func (*CopySingleFileJob) String added in v0.2.0 

func (x *CopySingleFileJob) String() string

type CreateJobReply added in v0.2.0 

type CreateJobReply struct {
	Status uint32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateJobReply) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use CreateJobReply.ProtoReflect.Descriptor instead.

func (*CreateJobReply) GetStatus added in v0.2.0 

func (x *CreateJobReply) GetStatus() uint32

func (*CreateJobReply) ProtoMessage added in v0.2.0 

func (*CreateJobReply) ProtoMessage()

func (*CreateJobReply) ProtoReflect added in v0.2.0 

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

func (*CreateJobReply) Reset added in v0.2.0 

func (x *CreateJobReply) Reset()

func (*CreateJobReply) String added in v0.2.0 

func (x *CreateJobReply) String() string

type CreateJobRequest added in v0.2.0 

type CreateJobRequest struct {
	StaffId string `protobuf:"bytes,1,opt,name=staff_id,json=staffId,proto3" json:"staff_id,omitempty"`
	Job     *Job   `protobuf:"bytes,2,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateJobRequest) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use CreateJobRequest.ProtoReflect.Descriptor instead.

func (*CreateJobRequest) GetJob added in v0.2.0 

func (x *CreateJobRequest) GetJob() *Job

func (*CreateJobRequest) GetStaffId added in v0.2.0 

func (x *CreateJobRequest) GetStaffId() string

func (*CreateJobRequest) ProtoMessage added in v0.2.0 

func (*CreateJobRequest) ProtoMessage()

func (*CreateJobRequest) ProtoReflect added in v0.2.0 

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

func (*CreateJobRequest) Reset added in v0.2.0 

func (x *CreateJobRequest) Reset()

func (*CreateJobRequest) String added in v0.2.0 

func (x *CreateJobRequest) String() string

type DB 

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

func NewDB 

func NewDB(path string, logger *zap.Logger) (*DB, error)

func (*DB) Close added in v0.2.0 

func (d *DB) Close() (err error)

func (*DB) CloseTxn added in v0.2.0 

func (d *DB) CloseTxn(txn *badger.Txn, err error) error

func (*DB) CreateStaff added in v0.2.0 

func (d *DB) CreateStaff(id string) (s *Staff, err error)

func (*DB) DeleteJob added in v0.2.0 

func (d *DB) DeleteJob(ctx context.Context, jobId string) (err error)

func (*DB) DeleteStaffTask added in v0.2.0 

func (d *DB) DeleteStaffTask(txn *badger.Txn, staffId, taskId string) (err error)

func (*DB) DeleteTask 

func (d *DB) DeleteTask(id string) error

DeleteTask delete a task by given ID from DB

func (*DB) ElectTaskLeader added in v0.2.0 

func (d *DB) ElectTaskLeader(taskId, staffId, staffAddr string) (electedStaffId, electedStaffAddr string, err error)

This function will be used to elect task leader. If there is no leader here, we will use input staff as leader. TODO: This logic could be changed.

func (*DB) GetJob added in v0.2.0 

func (d *DB) GetJob(ctx context.Context, jobId string) (j *Job, err error)

func (*DB) GetStaff added in v0.2.0 

func (d *DB) GetStaff(id string) (s *Staff, err error)

func (*DB) GetTask 

func (d *DB) GetTask(id string) (t *Task, err error)

GetTask get task from db and parsed into struct with specific ID

func (*DB) InsertJob added in v0.2.0 

func (d *DB) InsertJob(j *Job) error

func (*DB) InsertStaffTask added in v0.2.0 

func (d *DB) InsertStaffTask(txn *badger.Txn, staffId, taskId string) (err error)

func (*DB) InsertTask added in v0.2.0 

func (d *DB) InsertTask(txn *badger.Txn, t *Task) (err error)

Insert will insert task and update all staffs task queue.

func (*DB) ListJobs added in v0.2.0 

func (d *DB) ListJobs()

func (*DB) ListStaffTasks added in v0.2.0 

func (d *DB) ListStaffTasks(txn *badger.Txn, staffId string) (taskIds []string, err error)

func (*DB) ListStaffs added in v0.2.0 

func (d *DB) ListStaffs() ([]*Staff, error)

func (*DB) ListTasks 

func (d *DB) ListTasks() ([]*Task, error)

ListTasks create a db iterator and conduct result tasks

func (*DB) NextStaffTask added in v0.2.0 

func (d *DB) NextStaffTask(txn *badger.Txn, staffId string) (taskId string, err error)

func (*DB) SubscribeJob added in v0.2.0 

func (d *DB) SubscribeJob(ctx context.Context, fn func(j *Job)) (err error)

func (*DB) SubscribeTask added in v0.2.0 

func (d *DB) SubscribeTask(ctx context.Context, fn func(t *Task)) (err error)

func (*DB) UpdateTask added in v0.2.0 

func (d *DB) UpdateTask(t *Task) error

func (*DB) WaitJob added in v0.2.0 

func (d *DB) WaitJob(ctx context.Context, jobId string) (err error)

func (*DB) WaitTask added in v0.2.0 

func (d *DB) WaitTask(ctx context.Context, taskId string) (err error)

type ElectReply added in v0.2.0 

type ElectReply struct {
	LeaderId   string `protobuf:"bytes,1,opt,name=leader_id,json=leaderId,proto3" json:"leader_id,omitempty"`
	LeaderAddr string `protobuf:"bytes,2,opt,name=leader_addr,json=leaderAddr,proto3" json:"leader_addr,omitempty"`
	// contains filtered or unexported fields
}

func (*ElectReply) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use ElectReply.ProtoReflect.Descriptor instead.

func (*ElectReply) GetLeaderAddr added in v0.2.0 

func (x *ElectReply) GetLeaderAddr() string

func (*ElectReply) GetLeaderId added in v0.2.0 

func (x *ElectReply) GetLeaderId() string

func (*ElectReply) ProtoMessage added in v0.2.0 

func (*ElectReply) ProtoMessage()

func (*ElectReply) ProtoReflect added in v0.2.0 

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

func (*ElectReply) Reset added in v0.2.0 

func (x *ElectReply) Reset()

func (*ElectReply) String added in v0.2.0 

func (x *ElectReply) String() string

type ElectRequest added in v0.2.0 

type ElectRequest struct {
	TaskId    string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	StaffId   string `protobuf:"bytes,2,opt,name=staff_id,json=staffId,proto3" json:"staff_id,omitempty"`
	StaffAddr string `protobuf:"bytes,3,opt,name=staff_addr,json=staffAddr,proto3" json:"staff_addr,omitempty"`
	// contains filtered or unexported fields
}

func (*ElectRequest) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use ElectRequest.ProtoReflect.Descriptor instead.

func (*ElectRequest) GetStaffAddr added in v0.2.0 

func (x *ElectRequest) GetStaffAddr() string

func (*ElectRequest) GetStaffId added in v0.2.0 

func (x *ElectRequest) GetStaffId() string

func (*ElectRequest) GetTaskId added in v0.2.0 

func (x *ElectRequest) GetTaskId() string

func (*ElectRequest) ProtoMessage added in v0.2.0 

func (*ElectRequest) ProtoMessage()

func (*ElectRequest) ProtoReflect added in v0.2.0 

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

func (*ElectRequest) Reset added in v0.2.0 

func (x *ElectRequest) Reset()

func (*ElectRequest) String added in v0.2.0 

func (x *ElectRequest) String() string

type Error added in v0.2.0 

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

func (Error) Error added in v0.2.0 

func (e Error) Error() string

func (Error) Unwrap added in v0.2.0 

func (e Error) Unwrap() error

type FinishJobReply added in v0.2.0 

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

func (*FinishJobReply) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use FinishJobReply.ProtoReflect.Descriptor instead.

func (*FinishJobReply) ProtoMessage added in v0.2.0 

func (*FinishJobReply) ProtoMessage()

func (*FinishJobReply) ProtoReflect added in v0.2.0 

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

func (*FinishJobReply) Reset added in v0.2.0 

func (x *FinishJobReply) Reset()

func (*FinishJobReply) String added in v0.2.0 

func (x *FinishJobReply) String() string

type FinishJobRequest added in v0.2.0 

type FinishJobRequest struct {
	JobId   string    `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	Status  JobStatus `protobuf:"varint,2,opt,name=status,proto3,enum=job.JobStatus" json:"status,omitempty"`
	Message string    `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*FinishJobRequest) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use FinishJobRequest.ProtoReflect.Descriptor instead.

func (*FinishJobRequest) GetJobId added in v0.2.0 

func (x *FinishJobRequest) GetJobId() string

func (*FinishJobRequest) GetMessage added in v0.2.0 

func (x *FinishJobRequest) GetMessage() string

func (*FinishJobRequest) GetStatus added in v0.2.0 

func (x *FinishJobRequest) GetStatus() JobStatus

func (*FinishJobRequest) ProtoMessage added in v0.2.0 

func (*FinishJobRequest) ProtoMessage()

func (*FinishJobRequest) ProtoReflect added in v0.2.0 

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

func (*FinishJobRequest) Reset added in v0.2.0 

func (x *FinishJobRequest) Reset()

func (*FinishJobRequest) String added in v0.2.0 

func (x *FinishJobRequest) String() string

type FinishReply added in v0.2.0 

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

func (*FinishReply) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use FinishReply.ProtoReflect.Descriptor instead.

func (*FinishReply) ProtoMessage added in v0.2.0 

func (*FinishReply) ProtoMessage()

func (*FinishReply) ProtoReflect added in v0.2.0 

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

func (*FinishReply) Reset added in v0.2.0 

func (x *FinishReply) Reset()

func (*FinishReply) String added in v0.2.0 

func (x *FinishReply) String() string

type FinishRequest added in v0.2.0 

type FinishRequest struct {
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// contains filtered or unexported fields
}

func (*FinishRequest) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use FinishRequest.ProtoReflect.Descriptor instead.

func (*FinishRequest) GetTaskId added in v0.2.0 

func (x *FinishRequest) GetTaskId() string

func (*FinishRequest) ProtoMessage added in v0.2.0 

func (*FinishRequest) ProtoMessage()

func (*FinishRequest) ProtoReflect added in v0.2.0 

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

func (*FinishRequest) Reset added in v0.2.0 

func (x *FinishRequest) Reset()

func (*FinishRequest) String added in v0.2.0 

func (x *FinishRequest) String() string

type Job added in v0.2.0 

type Job struct {
	Id      string  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Type    JobType `protobuf:"varint,2,opt,name=type,proto3,enum=job.JobType" json:"type,omitempty"`
	Content []byte  `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

func NewJob added in v0.2.0 

func NewJob(ty JobType, pb protobuf.Message) *Job

func NewJobFromBytes added in v0.2.0 

func NewJobFromBytes(bs []byte) *Job

func (*Job) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetContent added in v0.2.0 

func (x *Job) GetContent() []byte

func (*Job) GetId added in v0.2.0 

func (x *Job) GetId() string

func (*Job) GetType added in v0.2.0 

func (x *Job) GetType() JobType

func (*Job) ProtoMessage added in v0.2.0 

func (*Job) ProtoMessage()

func (*Job) ProtoReflect added in v0.2.0 

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

func (*Job) Reset added in v0.2.0 

func (x *Job) Reset()

func (*Job) String added in v0.2.0 

func (x *Job) String() string

type JobStatus added in v0.2.0 

type JobStatus int32
const (
	JobStatus_InvalidJobStatus JobStatus = 0
	JobStatus_Succeed          JobStatus = 1
	JobStatus_Failed           JobStatus = 2
)

func (JobStatus) Descriptor added in v0.2.0 

func (JobStatus) Descriptor() protoreflect.EnumDescriptor

func (JobStatus) Enum added in v0.2.0 

func (x JobStatus) Enum() *JobStatus

func (JobStatus) EnumDescriptor deprecated added in v0.2.0 

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

Deprecated: Use JobStatus.Descriptor instead.

func (JobStatus) Number added in v0.2.0 

func (x JobStatus) Number() protoreflect.EnumNumber

func (JobStatus) String added in v0.2.0 

func (x JobStatus) String() string

func (JobStatus) Type added in v0.2.0 

func (JobStatus) Type() protoreflect.EnumType

type JobType added in v0.2.0 

type JobType int32
const (
	JobType_InvalidJobType    JobType = 0
	JobType_CopyDir           JobType = 1
	JobType_CopyFile          JobType = 2
	JobType_CopySingleFile    JobType = 3
	JobType_CopyMultipartFile JobType = 4
	JobType_CopyMultipart     JobType = 5
)

func (JobType) Descriptor added in v0.2.0 

func (JobType) Descriptor() protoreflect.EnumDescriptor

func (JobType) Enum added in v0.2.0 

func (x JobType) Enum() *JobType

func (JobType) EnumDescriptor deprecated added in v0.2.0 

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

Deprecated: Use JobType.Descriptor instead.

func (JobType) Number added in v0.2.0 

func (x JobType) Number() protoreflect.EnumNumber

func (JobType) String added in v0.2.0 

func (x JobType) String() string

func (JobType) Type added in v0.2.0 

func (JobType) Type() protoreflect.EnumType

type Pair added in v0.2.0 

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

func (*Pair) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use Pair.ProtoReflect.Descriptor instead.

func (*Pair) GetKey added in v0.2.0 

func (x *Pair) GetKey() string

func (*Pair) GetValue added in v0.2.0 

func (x *Pair) GetValue() string

func (*Pair) MarshalGQL added in v0.2.0 

func (x *Pair) MarshalGQL(w io.Writer)

func (*Pair) ProtoMessage added in v0.2.0 

func (*Pair) ProtoMessage()

func (*Pair) ProtoReflect added in v0.2.0 

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

func (*Pair) Reset added in v0.2.0 

func (x *Pair) Reset()

func (*Pair) String added in v0.2.0 

func (x *Pair) String() string

func (*Pair) UnmarshalGQL added in v0.2.0 

func (x *Pair) UnmarshalGQL(v interface{}) error

type PollJobReply added in v0.2.0 

type PollJobReply struct {
	Status PollJobStatus `protobuf:"varint,1,opt,name=status,proto3,enum=worker.PollJobStatus" json:"status,omitempty"`
	Job    *Job          `protobuf:"bytes,2,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

func (*PollJobReply) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use PollJobReply.ProtoReflect.Descriptor instead.

func (*PollJobReply) GetJob added in v0.2.0 

func (x *PollJobReply) GetJob() *Job

func (*PollJobReply) GetStatus added in v0.2.0 

func (x *PollJobReply) GetStatus() PollJobStatus

func (*PollJobReply) ProtoMessage added in v0.2.0 

func (*PollJobReply) ProtoMessage()

func (*PollJobReply) ProtoReflect added in v0.2.0 

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

func (*PollJobReply) Reset added in v0.2.0 

func (x *PollJobReply) Reset()

func (*PollJobReply) String added in v0.2.0 

func (x *PollJobReply) String() string

type PollJobRequest added in v0.2.0 

type PollJobRequest struct {
	StaffId string `protobuf:"bytes,1,opt,name=staff_id,json=staffId,proto3" json:"staff_id,omitempty"`
	// contains filtered or unexported fields
}

func (*PollJobRequest) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use PollJobRequest.ProtoReflect.Descriptor instead.

func (*PollJobRequest) GetStaffId added in v0.2.0 

func (x *PollJobRequest) GetStaffId() string

func (*PollJobRequest) ProtoMessage added in v0.2.0 

func (*PollJobRequest) ProtoMessage()

func (*PollJobRequest) ProtoReflect added in v0.2.0 

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

func (*PollJobRequest) Reset added in v0.2.0 

func (x *PollJobRequest) Reset()

func (*PollJobRequest) String added in v0.2.0 

func (x *PollJobRequest) String() string

type PollJobStatus added in v0.2.0 

type PollJobStatus int32
const (
	PollJobStatus_InvalidPollJobStatus PollJobStatus = 0
	PollJobStatus_Valid                PollJobStatus = 1
	PollJobStatus_Terminated           PollJobStatus = 100
)

func (PollJobStatus) Descriptor added in v0.2.0 

func (PollJobStatus) Descriptor() protoreflect.EnumDescriptor

func (PollJobStatus) Enum added in v0.2.0 

func (x PollJobStatus) Enum() *PollJobStatus

func (PollJobStatus) EnumDescriptor deprecated added in v0.2.0 

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

Deprecated: Use PollJobStatus.Descriptor instead.

func (PollJobStatus) Number added in v0.2.0 

func (x PollJobStatus) Number() protoreflect.EnumNumber

func (PollJobStatus) String added in v0.2.0 

func (x PollJobStatus) String() string

func (PollJobStatus) Type added in v0.2.0 

func (PollJobStatus) Type() protoreflect.EnumType

type PollReply added in v0.2.0 

type PollReply struct {
	Status PollStatus `protobuf:"varint,1,opt,name=status,proto3,enum=staff.PollStatus" json:"status,omitempty"`
	Task   *Task      `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

func (*PollReply) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use PollReply.ProtoReflect.Descriptor instead.

func (*PollReply) GetStatus added in v0.2.0 

func (x *PollReply) GetStatus() PollStatus

func (*PollReply) GetTask added in v0.2.0 

func (x *PollReply) GetTask() *Task

func (*PollReply) ProtoMessage added in v0.2.0 

func (*PollReply) ProtoMessage()

func (*PollReply) ProtoReflect added in v0.2.0 

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

func (*PollReply) Reset added in v0.2.0 

func (x *PollReply) Reset()

func (*PollReply) String added in v0.2.0 

func (x *PollReply) String() string

type PollRequest added in v0.2.0 

type PollRequest struct {
	StaffId string `protobuf:"bytes,1,opt,name=staff_id,json=staffId,proto3" json:"staff_id,omitempty"`
	// contains filtered or unexported fields
}

func (*PollRequest) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use PollRequest.ProtoReflect.Descriptor instead.

func (*PollRequest) GetStaffId added in v0.2.0 

func (x *PollRequest) GetStaffId() string

func (*PollRequest) ProtoMessage added in v0.2.0 

func (*PollRequest) ProtoMessage()

func (*PollRequest) ProtoReflect added in v0.2.0 

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

func (*PollRequest) Reset added in v0.2.0 

func (x *PollRequest) Reset()

func (*PollRequest) String added in v0.2.0 

func (x *PollRequest) String() string

type PollStatus added in v0.2.0 

type PollStatus int32
const (
	PollStatus_InvalidPollStatus PollStatus = 0
	PollStatus_Valid             PollStatus = 1
	PollStatus_Empty             PollStatus = 2
	PollStatus_Terminated        PollStatus = 100
)

func (PollStatus) Descriptor added in v0.2.0 

func (PollStatus) Descriptor() protoreflect.EnumDescriptor

func (PollStatus) Enum added in v0.2.0 

func (x PollStatus) Enum() *PollStatus

func (PollStatus) EnumDescriptor deprecated added in v0.2.0 

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

Deprecated: Use PollStatus.Descriptor instead.

func (PollStatus) Number added in v0.2.0 

func (x PollStatus) Number() protoreflect.EnumNumber

func (PollStatus) String added in v0.2.0 

func (x PollStatus) String() string

func (PollStatus) Type added in v0.2.0 

func (PollStatus) Type() protoreflect.EnumType

type RegisterReply added in v0.2.0 

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

func (*RegisterReply) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use RegisterReply.ProtoReflect.Descriptor instead.

func (*RegisterReply) ProtoMessage added in v0.2.0 

func (*RegisterReply) ProtoMessage()

func (*RegisterReply) ProtoReflect added in v0.2.0 

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

func (*RegisterReply) Reset added in v0.2.0 

func (x *RegisterReply) Reset()

func (*RegisterReply) String added in v0.2.0 

func (x *RegisterReply) String() string

type RegisterRequest added in v0.2.0 

type RegisterRequest struct {
	StaffId string `protobuf:"bytes,1,opt,name=staff_id,json=staffId,proto3" json:"staff_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterRequest) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use RegisterRequest.ProtoReflect.Descriptor instead.

func (*RegisterRequest) GetStaffId added in v0.2.0 

func (x *RegisterRequest) GetStaffId() string

func (*RegisterRequest) ProtoMessage added in v0.2.0 

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) ProtoReflect added in v0.2.0 

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

func (*RegisterRequest) Reset added in v0.2.0 

func (x *RegisterRequest) Reset()

func (*RegisterRequest) String added in v0.2.0 

func (x *RegisterRequest) String() string

type Staff added in v0.2.0 

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

func NewStaff added in v0.2.0 

func NewStaff(id string) *Staff

func NewStaffFromBytes added in v0.2.0 

func NewStaffFromBytes(bs []byte) *Staff

func (*Staff) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use Staff.ProtoReflect.Descriptor instead.

func (*Staff) GetId added in v0.2.0 

func (x *Staff) GetId() string

func (*Staff) ProtoMessage added in v0.2.0 

func (*Staff) ProtoMessage()

func (*Staff) ProtoReflect added in v0.2.0 

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

func (*Staff) Reset added in v0.2.0 

func (x *Staff) Reset()

func (*Staff) String added in v0.2.0 

func (x *Staff) String() string

type StaffClient added in v0.2.0 

type StaffClient interface {
	Register(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*RegisterReply, error)
	Elect(ctx context.Context, in *ElectRequest, opts ...grpc.CallOption) (*ElectReply, error)
	Poll(ctx context.Context, in *PollRequest, opts ...grpc.CallOption) (Staff_PollClient, error)
	Finish(ctx context.Context, in *FinishRequest, opts ...grpc.CallOption) (*FinishReply, error)
}

StaffClient is the client API for Staff service.

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

func NewStaffClient added in v0.2.0 

func NewStaffClient(cc grpc.ClientConnInterface) StaffClient

type StaffServer added in v0.2.0 

type StaffServer interface {
	Register(context.Context, *RegisterRequest) (*RegisterReply, error)
	Elect(context.Context, *ElectRequest) (*ElectReply, error)
	Poll(*PollRequest, Staff_PollServer) error
	Finish(context.Context, *FinishRequest) (*FinishReply, error)
	// contains filtered or unexported methods
}

StaffServer is the server API for Staff service. All implementations must embed UnimplementedStaffServer for forward compatibility

type Staff_PollClient added in v0.2.0 

type Staff_PollClient interface {
	Recv() (*PollReply, error)
	grpc.ClientStream
}

type Staff_PollServer added in v0.2.0 

type Staff_PollServer interface {
	Send(*PollReply) error
	grpc.ServerStream
}

type Storage added in v0.2.0 

type Storage struct {
	Type    StorageType `protobuf:"varint,1,opt,name=type,proto3,enum=task.StorageType" json:"type,omitempty"`
	Options []*Pair     `protobuf:"bytes,2,rep,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*Storage) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use Storage.ProtoReflect.Descriptor instead.

func (*Storage) GetOptions added in v0.2.0 

func (x *Storage) GetOptions() []*Pair

func (*Storage) GetType added in v0.2.0 

func (x *Storage) GetType() StorageType

func (*Storage) MarshalGQL added in v0.2.0 

func (x *Storage) MarshalGQL(w io.Writer)

func (*Storage) ProtoMessage added in v0.2.0 

func (*Storage) ProtoMessage()

func (*Storage) ProtoReflect added in v0.2.0 

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

func (*Storage) Reset added in v0.2.0 

func (x *Storage) Reset()

func (*Storage) String added in v0.2.0 

func (x *Storage) String() string

type StorageType added in v0.2.0 

type StorageType int32
const (
	StorageType_InvalidStorageType StorageType = 0
	StorageType_Fs                 StorageType = 1
	StorageType_Qingstor           StorageType = 2
)

func (StorageType) Descriptor added in v0.2.0 

func (StorageType) Descriptor() protoreflect.EnumDescriptor

func (StorageType) Enum added in v0.2.0 

func (x StorageType) Enum() *StorageType

func (StorageType) EnumDescriptor deprecated added in v0.2.0 

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

Deprecated: Use StorageType.Descriptor instead.

func (StorageType) MarshalGQL added in v0.2.0 

func (x StorageType) MarshalGQL(w io.Writer)

func (StorageType) Number added in v0.2.0 

func (x StorageType) Number() protoreflect.EnumNumber

func (StorageType) String added in v0.2.0 

func (x StorageType) String() string

func (StorageType) Type added in v0.2.0 

func (StorageType) Type() protoreflect.EnumType

func (*StorageType) UnmarshalGQL added in v0.2.0 

func (x *StorageType) UnmarshalGQL(v interface{}) error

type Task 

type Task struct {

	// Task related metadata
	Id        string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name      string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Type      TaskType               `protobuf:"varint,3,opt,name=type,proto3,enum=task.TaskType" json:"type,omitempty"`
	Status    TaskStatus             `protobuf:"varint,4,opt,name=status,proto3,enum=task.TaskStatus" json:"status,omitempty"`
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	Storages  []*Storage             `protobuf:"bytes,101,rep,name=storages,proto3" json:"storages,omitempty"`
	Options   []*Pair                `protobuf:"bytes,102,rep,name=options,proto3" json:"options,omitempty"`
	StaffIds  []string               `protobuf:"bytes,201,rep,name=staff_ids,json=staffIds,proto3" json:"staff_ids,omitempty"`
	// contains filtered or unexported fields
}

func NewTask 

func NewTask(name string, ty TaskType) *Task

NewTask created a task with default value

func NewTaskFromBytes added in v0.2.0 

func NewTaskFromBytes(bs []byte) *Task

func (*Task) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetCreatedAt added in v0.2.0 

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

func (*Task) GetId added in v0.2.0 

func (x *Task) GetId() string

func (*Task) GetName added in v0.2.0 

func (x *Task) GetName() string

func (*Task) GetOptions added in v0.2.0 

func (x *Task) GetOptions() []*Pair

func (*Task) GetStaffIds added in v0.2.0 

func (x *Task) GetStaffIds() []string

func (*Task) GetStatus added in v0.2.0 

func (x *Task) GetStatus() TaskStatus

func (*Task) GetStorages added in v0.2.0 

func (x *Task) GetStorages() []*Storage

func (*Task) GetType added in v0.2.0 

func (x *Task) GetType() TaskType

func (*Task) GetUpdatedAt added in v0.2.0 

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

func (*Task) ProtoMessage added in v0.2.0 

func (*Task) ProtoMessage()

func (*Task) ProtoReflect added in v0.2.0 

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

func (*Task) Reset added in v0.2.0 

func (x *Task) Reset()

func (*Task) String added in v0.2.0 

func (x *Task) String() string

type TaskLeader added in v0.2.0 

type TaskLeader struct {
	TaskId    string `protobuf:"bytes,1,opt,name=TaskId,proto3" json:"TaskId,omitempty"`
	StaffId   string `protobuf:"bytes,2,opt,name=StaffId,proto3" json:"StaffId,omitempty"`
	StaffAddr string `protobuf:"bytes,3,opt,name=StaffAddr,proto3" json:"StaffAddr,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskLeader) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use TaskLeader.ProtoReflect.Descriptor instead.

func (*TaskLeader) GetStaffAddr added in v0.2.0 

func (x *TaskLeader) GetStaffAddr() string

func (*TaskLeader) GetStaffId added in v0.2.0 

func (x *TaskLeader) GetStaffId() string

func (*TaskLeader) GetTaskId added in v0.2.0 

func (x *TaskLeader) GetTaskId() string

func (*TaskLeader) ProtoMessage added in v0.2.0 

func (*TaskLeader) ProtoMessage()

func (*TaskLeader) ProtoReflect added in v0.2.0 

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

func (*TaskLeader) Reset added in v0.2.0 

func (x *TaskLeader) Reset()

func (*TaskLeader) String added in v0.2.0 

func (x *TaskLeader) String() string

type TaskReply added in v0.2.0 

type TaskReply struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	StaffId string `protobuf:"bytes,2,opt,name=staff_id,json=staffId,proto3" json:"staff_id,omitempty"`
	Status  uint32 `protobuf:"varint,3,opt,name=status,proto3" json:"status,omitempty"`
	Message string `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskReply) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use TaskReply.ProtoReflect.Descriptor instead.

func (*TaskReply) GetId added in v0.2.0 

func (x *TaskReply) GetId() string

func (*TaskReply) GetMessage added in v0.2.0 

func (x *TaskReply) GetMessage() string

func (*TaskReply) GetStaffId added in v0.2.0 

func (x *TaskReply) GetStaffId() string

func (*TaskReply) GetStatus added in v0.2.0 

func (x *TaskReply) GetStatus() uint32

func (*TaskReply) ProtoMessage added in v0.2.0 

func (*TaskReply) ProtoMessage()

func (*TaskReply) ProtoReflect added in v0.2.0 

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

func (*TaskReply) Reset added in v0.2.0 

func (x *TaskReply) Reset()

func (*TaskReply) String added in v0.2.0 

func (x *TaskReply) String() string

type TaskStatus 

type TaskStatus int32
const (
	TaskStatus_InvalidTaskStatus TaskStatus = 0
	TaskStatus_Created           TaskStatus = 1
	TaskStatus_Ready             TaskStatus = 2
	TaskStatus_Running           TaskStatus = 3
	TaskStatus_Finished          TaskStatus = 4
	TaskStatus_Stopped           TaskStatus = 5
	TaskStatus_Error             TaskStatus = 6
)

func (TaskStatus) Descriptor added in v0.2.0 

func (TaskStatus) Descriptor() protoreflect.EnumDescriptor

func (TaskStatus) Enum added in v0.2.0 

func (x TaskStatus) Enum() *TaskStatus

func (TaskStatus) EnumDescriptor deprecated added in v0.2.0 

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

Deprecated: Use TaskStatus.Descriptor instead.

func (TaskStatus) MarshalGQL 

func (x TaskStatus) MarshalGQL(w io.Writer)

func (TaskStatus) Number added in v0.2.0 

func (x TaskStatus) Number() protoreflect.EnumNumber

func (TaskStatus) String 

func (x TaskStatus) String() string

func (TaskStatus) Type added in v0.2.0 

func (TaskStatus) Type() protoreflect.EnumType

func (*TaskStatus) UnmarshalGQL 

func (x *TaskStatus) UnmarshalGQL(v interface{}) error

type TaskType 

type TaskType int32
const (
	TaskType_InvalidTaskType TaskType = 0
	TaskType_CopyDir         TaskType = 1
)

func (TaskType) Descriptor added in v0.2.0 

func (TaskType) Descriptor() protoreflect.EnumDescriptor

func (TaskType) Enum added in v0.2.0 

func (x TaskType) Enum() *TaskType

func (TaskType) EnumDescriptor deprecated added in v0.2.0 

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

Deprecated: Use TaskType.Descriptor instead.

func (TaskType) MarshalGQL 

func (x TaskType) MarshalGQL(w io.Writer)

func (TaskType) Number added in v0.2.0 

func (x TaskType) Number() protoreflect.EnumNumber

func (TaskType) String 

func (x TaskType) String() string

func (TaskType) Type added in v0.2.0 

func (TaskType) Type() protoreflect.EnumType

func (*TaskType) UnmarshalGQL 

func (x *TaskType) UnmarshalGQL(v interface{}) error

type UnimplementedStaffServer added in v0.2.0 

type UnimplementedStaffServer struct {
}

UnimplementedStaffServer must be embedded to have forward compatible implementations.

func (UnimplementedStaffServer) Elect added in v0.2.0 

func (UnimplementedStaffServer) Elect(context.Context, *ElectRequest) (*ElectReply, error)

func (UnimplementedStaffServer) Finish added in v0.2.0 

func (UnimplementedStaffServer) Finish(context.Context, *FinishRequest) (*FinishReply, error)

func (UnimplementedStaffServer) Poll added in v0.2.0 

func (UnimplementedStaffServer) Poll(*PollRequest, Staff_PollServer) error

func (UnimplementedStaffServer) Register added in v0.2.0 

func (UnimplementedStaffServer) Register(context.Context, *RegisterRequest) (*RegisterReply, error)

type UnimplementedWorkerServer added in v0.2.0 

type UnimplementedWorkerServer struct {
}

UnimplementedWorkerServer must be embedded to have forward compatible implementations.

func (UnimplementedWorkerServer) CreateJob added in v0.2.0 

func (UnimplementedWorkerServer) CreateJob(context.Context, *CreateJobRequest) (*CreateJobReply, error)

func (UnimplementedWorkerServer) FinishJob added in v0.2.0 

func (UnimplementedWorkerServer) FinishJob(context.Context, *FinishJobRequest) (*FinishJobReply, error)

func (UnimplementedWorkerServer) PollJob added in v0.2.0 

func (UnimplementedWorkerServer) PollJob(*PollJobRequest, Worker_PollJobServer) error

func (UnimplementedWorkerServer) WaitJob added in v0.2.0 

func (UnimplementedWorkerServer) WaitJob(context.Context, *WaitJobRequest) (*WaitJobReply, error)

type UnsafeStaffServer added in v0.2.0 

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

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

type UnsafeWorkerServer added in v0.2.0 

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

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

type WaitJobReply added in v0.2.0 

type WaitJobReply struct {
	Status  uint32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*WaitJobReply) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use WaitJobReply.ProtoReflect.Descriptor instead.

func (*WaitJobReply) GetMessage added in v0.2.0 

func (x *WaitJobReply) GetMessage() string

func (*WaitJobReply) GetStatus added in v0.2.0 

func (x *WaitJobReply) GetStatus() uint32

func (*WaitJobReply) ProtoMessage added in v0.2.0 

func (*WaitJobReply) ProtoMessage()

func (*WaitJobReply) ProtoReflect added in v0.2.0 

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

func (*WaitJobReply) Reset added in v0.2.0 

func (x *WaitJobReply) Reset()

func (*WaitJobReply) String added in v0.2.0 

func (x *WaitJobReply) String() string

type WaitJobRequest added in v0.2.0 

type WaitJobRequest struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*WaitJobRequest) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use WaitJobRequest.ProtoReflect.Descriptor instead.

func (*WaitJobRequest) GetJobId added in v0.2.0 

func (x *WaitJobRequest) GetJobId() string

func (*WaitJobRequest) ProtoMessage added in v0.2.0 

func (*WaitJobRequest) ProtoMessage()

func (*WaitJobRequest) ProtoReflect added in v0.2.0 

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

func (*WaitJobRequest) Reset added in v0.2.0 

func (x *WaitJobRequest) Reset()

func (*WaitJobRequest) String added in v0.2.0 

func (x *WaitJobRequest) String() string

type WorkerClient added in v0.2.0 

type WorkerClient interface {
	PollJob(ctx context.Context, in *PollJobRequest, opts ...grpc.CallOption) (Worker_PollJobClient, error)
	CreateJob(ctx context.Context, in *CreateJobRequest, opts ...grpc.CallOption) (*CreateJobReply, error)
	WaitJob(ctx context.Context, in *WaitJobRequest, opts ...grpc.CallOption) (*WaitJobReply, error)
	FinishJob(ctx context.Context, in *FinishJobRequest, opts ...grpc.CallOption) (*FinishJobReply, error)
}

WorkerClient is the client API for Worker service.

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

func NewWorkerClient added in v0.2.0 

func NewWorkerClient(cc grpc.ClientConnInterface) WorkerClient

type WorkerServer added in v0.2.0 

type WorkerServer interface {
	PollJob(*PollJobRequest, Worker_PollJobServer) error
	CreateJob(context.Context, *CreateJobRequest) (*CreateJobReply, error)
	WaitJob(context.Context, *WaitJobRequest) (*WaitJobReply, error)
	FinishJob(context.Context, *FinishJobRequest) (*FinishJobReply, error)
	// contains filtered or unexported methods
}

WorkerServer is the server API for Worker service. All implementations must embed UnimplementedWorkerServer for forward compatibility

type Worker_PollJobClient added in v0.2.0 

type Worker_PollJobClient interface {
	Recv() (*PollJobReply, error)
	grpc.ClientStream
}

type Worker_PollJobServer added in v0.2.0 

type Worker_PollJobServer interface {
	Send(*PollJobReply) error
	grpc.ServerStream
}

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.