proto

package
v0.0.0-...-0f35d45 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

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 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,
		},
	},
	Streams:  []grpc.StreamDesc{},
	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)

Functions

func RegisterStaffServer 

func RegisterStaffServer(s grpc.ServiceRegistrar, srv StaffServer)

Types

type Acknowledgement 

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

func (*Acknowledgement) Descriptor deprecated 

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

Deprecated: Use Acknowledgement.ProtoReflect.Descriptor instead.

func (*Acknowledgement) ProtoMessage 

func (*Acknowledgement) ProtoMessage()

func (*Acknowledgement) ProtoReflect 

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

func (*Acknowledgement) Reset 

func (x *Acknowledgement) Reset()

func (*Acknowledgement) String 

func (x *Acknowledgement) String() string

type ClockinReply 

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

func (*ClockinReply) Descriptor deprecated 

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

Deprecated: Use ClockinReply.ProtoReflect.Descriptor instead.

func (*ClockinReply) ProtoMessage 

func (*ClockinReply) ProtoMessage()

func (*ClockinReply) ProtoReflect 

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

func (*ClockinReply) Reset 

func (x *ClockinReply) Reset()

func (*ClockinReply) String 

func (x *ClockinReply) String() string

type ClockinRequest 

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

func (*ClockinRequest) Descriptor deprecated 

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

Deprecated: Use ClockinRequest.ProtoReflect.Descriptor instead.

func (*ClockinRequest) GetStaffId 

func (x *ClockinRequest) GetStaffId() string

func (*ClockinRequest) GetTaskId 

func (x *ClockinRequest) GetTaskId() string

func (*ClockinRequest) ProtoMessage 

func (*ClockinRequest) ProtoMessage()

func (*ClockinRequest) ProtoReflect 

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

func (*ClockinRequest) Reset 

func (x *ClockinRequest) Reset()

func (*ClockinRequest) String 

func (x *ClockinRequest) String() string

type ClockoutReply 

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

func (*ClockoutReply) Descriptor deprecated 

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

Deprecated: Use ClockoutReply.ProtoReflect.Descriptor instead.

func (*ClockoutReply) ProtoMessage 

func (*ClockoutReply) ProtoMessage()

func (*ClockoutReply) ProtoReflect 

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

func (*ClockoutReply) Reset 

func (x *ClockoutReply) Reset()

func (*ClockoutReply) String 

func (x *ClockoutReply) String() string

type ClockoutRequest 

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

func (*ClockoutRequest) Descriptor deprecated 

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

Deprecated: Use ClockoutRequest.ProtoReflect.Descriptor instead.

func (*ClockoutRequest) GetStaffId 

func (x *ClockoutRequest) GetStaffId() string

func (*ClockoutRequest) GetTaskId 

func (x *ClockoutRequest) GetTaskId() string

func (*ClockoutRequest) ProtoMessage 

func (*ClockoutRequest) ProtoMessage()

func (*ClockoutRequest) ProtoReflect 

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

func (*ClockoutRequest) Reset 

func (x *ClockoutRequest) Reset()

func (*ClockoutRequest) String 

func (x *ClockoutRequest) String() string

type CopyDir 

type CopyDir 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 (*CopyDir) Descriptor deprecated 

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

Deprecated: Use CopyDir.ProtoReflect.Descriptor instead.

func (*CopyDir) GetDst 

func (x *CopyDir) GetDst() uint32

func (*CopyDir) GetDstPath 

func (x *CopyDir) GetDstPath() string

func (*CopyDir) GetRecursive 

func (x *CopyDir) GetRecursive() bool

func (*CopyDir) GetSrc 

func (x *CopyDir) GetSrc() uint32

func (*CopyDir) GetSrcPath 

func (x *CopyDir) GetSrcPath() string

func (*CopyDir) ProtoMessage 

func (*CopyDir) ProtoMessage()

func (*CopyDir) ProtoReflect 

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

func (*CopyDir) Reset 

func (x *CopyDir) Reset()

func (*CopyDir) String 

func (x *CopyDir) String() string

type CopyFile 

type CopyFile 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 (*CopyFile) Descriptor deprecated 

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

Deprecated: Use CopyFile.ProtoReflect.Descriptor instead.

func (*CopyFile) GetDst 

func (x *CopyFile) GetDst() uint32

func (*CopyFile) GetDstPath 

func (x *CopyFile) GetDstPath() string

func (*CopyFile) GetSrc 

func (x *CopyFile) GetSrc() uint32

func (*CopyFile) GetSrcPath 

func (x *CopyFile) GetSrcPath() string

func (*CopyFile) ProtoMessage 

func (*CopyFile) ProtoMessage()

func (*CopyFile) ProtoReflect 

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

func (*CopyFile) Reset 

func (x *CopyFile) Reset()

func (*CopyFile) String 

func (x *CopyFile) String() string

type CopyMultipart 

type CopyMultipart 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 (*CopyMultipart) Descriptor deprecated 

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

Deprecated: Use CopyMultipart.ProtoReflect.Descriptor instead.

func (*CopyMultipart) GetDst 

func (x *CopyMultipart) GetDst() uint32

func (*CopyMultipart) GetDstPath 

func (x *CopyMultipart) GetDstPath() string

func (*CopyMultipart) GetIndex 

func (x *CopyMultipart) GetIndex() uint32

func (*CopyMultipart) GetMultipartId 

func (x *CopyMultipart) GetMultipartId() string

func (*CopyMultipart) GetOffset 

func (x *CopyMultipart) GetOffset() int64

func (*CopyMultipart) GetSize 

func (x *CopyMultipart) GetSize() int64

func (*CopyMultipart) GetSrc 

func (x *CopyMultipart) GetSrc() uint32

func (*CopyMultipart) GetSrcPath 

func (x *CopyMultipart) GetSrcPath() string

func (*CopyMultipart) ProtoMessage 

func (*CopyMultipart) ProtoMessage()

func (*CopyMultipart) ProtoReflect 

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

func (*CopyMultipart) Reset 

func (x *CopyMultipart) Reset()

func (*CopyMultipart) String 

func (x *CopyMultipart) String() string

type CopyMultipartFile 

type CopyMultipartFile 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 (*CopyMultipartFile) Descriptor deprecated 

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

Deprecated: Use CopyMultipartFile.ProtoReflect.Descriptor instead.

func (*CopyMultipartFile) GetDst 

func (x *CopyMultipartFile) GetDst() uint32

func (*CopyMultipartFile) GetDstPath 

func (x *CopyMultipartFile) GetDstPath() string

func (*CopyMultipartFile) GetSize 

func (x *CopyMultipartFile) GetSize() int64

func (*CopyMultipartFile) GetSrc 

func (x *CopyMultipartFile) GetSrc() uint32

func (*CopyMultipartFile) GetSrcPath 

func (x *CopyMultipartFile) GetSrcPath() string

func (*CopyMultipartFile) ProtoMessage 

func (*CopyMultipartFile) ProtoMessage()

func (*CopyMultipartFile) ProtoReflect 

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

func (*CopyMultipartFile) Reset 

func (x *CopyMultipartFile) Reset()

func (*CopyMultipartFile) String 

func (x *CopyMultipartFile) String() string

type CopySingleFile 

type CopySingleFile 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 (*CopySingleFile) Descriptor deprecated 

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

Deprecated: Use CopySingleFile.ProtoReflect.Descriptor instead.

func (*CopySingleFile) GetDst 

func (x *CopySingleFile) GetDst() uint32

func (*CopySingleFile) GetDstPath 

func (x *CopySingleFile) GetDstPath() string

func (*CopySingleFile) GetSize 

func (x *CopySingleFile) GetSize() int64

func (*CopySingleFile) GetSrc 

func (x *CopySingleFile) GetSrc() uint32

func (*CopySingleFile) GetSrcPath 

func (x *CopySingleFile) GetSrcPath() string

func (*CopySingleFile) ProtoMessage 

func (*CopySingleFile) ProtoMessage()

func (*CopySingleFile) ProtoReflect 

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

func (*CopySingleFile) Reset 

func (x *CopySingleFile) Reset()

func (*CopySingleFile) String 

func (x *CopySingleFile) String() string

type ElectReply 

type ElectReply struct {
	Addr      string   `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	Subject   string   `protobuf:"bytes,2,opt,name=subject,proto3" json:"subject,omitempty"`
	LeaderId  string   `protobuf:"bytes,3,opt,name=leader_id,json=leaderId,proto3" json:"leader_id,omitempty"`
	WorkerIds []string `protobuf:"bytes,4,rep,name=worker_ids,json=workerIds,proto3" json:"worker_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*ElectReply) Descriptor deprecated 

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

Deprecated: Use ElectReply.ProtoReflect.Descriptor instead.

func (*ElectReply) GetAddr 

func (x *ElectReply) GetAddr() string

func (*ElectReply) GetLeaderId 

func (x *ElectReply) GetLeaderId() string

func (*ElectReply) GetSubject 

func (x *ElectReply) GetSubject() string

func (*ElectReply) GetWorkerIds 

func (x *ElectReply) GetWorkerIds() []string

func (*ElectReply) ProtoMessage 

func (*ElectReply) ProtoMessage()

func (*ElectReply) ProtoReflect 

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

func (*ElectReply) Reset 

func (x *ElectReply) Reset()

func (*ElectReply) String 

func (x *ElectReply) String() string

type ElectRequest 

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

func (*ElectRequest) Descriptor deprecated 

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

Deprecated: Use ElectRequest.ProtoReflect.Descriptor instead.

func (*ElectRequest) GetStaffId 

func (x *ElectRequest) GetStaffId() string

func (*ElectRequest) GetTaskId 

func (x *ElectRequest) GetTaskId() string

func (*ElectRequest) ProtoMessage 

func (*ElectRequest) ProtoMessage()

func (*ElectRequest) ProtoReflect 

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

func (*ElectRequest) Reset 

func (x *ElectRequest) Reset()

func (*ElectRequest) String 

func (x *ElectRequest) String() string

type Endpoint 

type Endpoint struct {
	Type  string  `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Pairs []*Pair `protobuf:"bytes,2,rep,name=pairs,proto3" json:"pairs,omitempty"`
	// contains filtered or unexported fields
}

func (*Endpoint) Descriptor deprecated 

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

Deprecated: Use Endpoint.ProtoReflect.Descriptor instead.

func (*Endpoint) GetPairs 

func (x *Endpoint) GetPairs() []*Pair

func (*Endpoint) GetType 

func (x *Endpoint) GetType() string

func (*Endpoint) ParseStorager 

func (x *Endpoint) ParseStorager() (types.Storager, error)

ParseStorager parse endpoint into

func (*Endpoint) ProtoMessage 

func (*Endpoint) ProtoMessage()

func (*Endpoint) ProtoReflect 

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

func (*Endpoint) Reset 

func (x *Endpoint) Reset()

func (*Endpoint) String 

func (x *Endpoint) String() string

type Job 

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

func NewJob 

func NewJob() Job

func (*Job) Descriptor deprecated 

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

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetContent 

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

func (*Job) GetId 

func (x *Job) GetId() string

func (*Job) GetType 

func (x *Job) GetType() uint32

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) ProtoReflect 

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

func (*Job) Reset 

func (x *Job) Reset()

func (*Job) String 

func (x *Job) String() string

type JobReply 

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

func (*JobReply) Descriptor deprecated 

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

Deprecated: Use JobReply.ProtoReflect.Descriptor instead.

func (*JobReply) GetId 

func (x *JobReply) GetId() string

func (*JobReply) GetMessage 

func (x *JobReply) GetMessage() string

func (*JobReply) GetStatus 

func (x *JobReply) GetStatus() uint32

func (*JobReply) ProtoMessage 

func (*JobReply) ProtoMessage()

func (*JobReply) ProtoReflect 

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

func (*JobReply) Reset 

func (x *JobReply) Reset()

func (*JobReply) String 

func (x *JobReply) String() string

type Pair 

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 

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

Deprecated: Use Pair.ProtoReflect.Descriptor instead.

func (*Pair) GetKey 

func (x *Pair) GetKey() string

func (*Pair) GetValue 

func (x *Pair) GetValue() string

func (*Pair) ProtoMessage 

func (*Pair) ProtoMessage()

func (*Pair) ProtoReflect 

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

func (*Pair) Reset 

func (x *Pair) Reset()

func (*Pair) String 

func (x *Pair) String() string

type RegisterReply 

type RegisterReply struct {
	Addr    string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	Subject string `protobuf:"bytes,2,opt,name=subject,proto3" json:"subject,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterReply) Descriptor deprecated 

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

Deprecated: Use RegisterReply.ProtoReflect.Descriptor instead.

func (*RegisterReply) GetAddr 

func (x *RegisterReply) GetAddr() string

func (*RegisterReply) GetSubject 

func (x *RegisterReply) GetSubject() string

func (*RegisterReply) ProtoMessage 

func (*RegisterReply) ProtoMessage()

func (*RegisterReply) ProtoReflect 

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

func (*RegisterReply) Reset 

func (x *RegisterReply) Reset()

func (*RegisterReply) String 

func (x *RegisterReply) String() string

type RegisterRequest 

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

func (*RegisterRequest) Descriptor deprecated 

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

Deprecated: Use RegisterRequest.ProtoReflect.Descriptor instead.

func (*RegisterRequest) GetAddr 

func (x *RegisterRequest) GetAddr() string

func (*RegisterRequest) GetId 

func (x *RegisterRequest) GetId() string

func (*RegisterRequest) ProtoMessage 

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) ProtoReflect 

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

func (*RegisterRequest) Reset 

func (x *RegisterRequest) Reset()

func (*RegisterRequest) String 

func (x *RegisterRequest) String() string

type StaffClient 

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

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 

func NewStaffClient(cc grpc.ClientConnInterface) StaffClient

type StaffServer 

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

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

type Task 

type Task struct {
	Id        string      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Endpoints []*Endpoint `protobuf:"bytes,2,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
	Job       *Job        `protobuf:"bytes,3,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

func (*Task) Descriptor deprecated 

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetEndpoints 

func (x *Task) GetEndpoints() []*Endpoint

func (*Task) GetId 

func (x *Task) GetId() string

func (*Task) GetJob 

func (x *Task) GetJob() *Job

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) ProtoReflect 

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

func (*Task) Reset 

func (x *Task) Reset()

func (*Task) String 

func (x *Task) String() string

type TaskFinish 

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

func (*TaskFinish) Descriptor deprecated 

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

Deprecated: Use TaskFinish.ProtoReflect.Descriptor instead.

func (*TaskFinish) ProtoMessage 

func (*TaskFinish) ProtoMessage()

func (*TaskFinish) ProtoReflect 

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

func (*TaskFinish) Reset 

func (x *TaskFinish) Reset()

func (*TaskFinish) String 

func (x *TaskFinish) String() string

type TaskReply 

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 

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

Deprecated: Use TaskReply.ProtoReflect.Descriptor instead.

func (*TaskReply) GetId 

func (x *TaskReply) GetId() string

func (*TaskReply) GetMessage 

func (x *TaskReply) GetMessage() string

func (*TaskReply) GetStaffId 

func (x *TaskReply) GetStaffId() string

func (*TaskReply) GetStatus 

func (x *TaskReply) GetStatus() uint32

func (*TaskReply) ProtoMessage 

func (*TaskReply) ProtoMessage()

func (*TaskReply) ProtoReflect 

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

func (*TaskReply) Reset 

func (x *TaskReply) Reset()

func (*TaskReply) String 

func (x *TaskReply) String() string

type UnimplementedStaffServer 

type UnimplementedStaffServer struct {
}

UnimplementedStaffServer must be embedded to have forward compatible implementations.

func (UnimplementedStaffServer) Elect 

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

func (UnimplementedStaffServer) Register 

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

type UnsafeStaffServer 

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.

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.