protofiles

Documentation

Index

• Variables
• func RegisterSchedulerServer(s grpc.ServiceRegistrar, srv SchedulerServer)
• type Job
  • func (*Job) Descriptor() ([]byte, []int)
  • func (x *Job) GetJobId() string
  • func (x *Job) GetTaskName() string
  • func (*Job) ProtoMessage()
  • func (x *Job) ProtoReflect() protoreflect.Message
  • func (x *Job) Reset()
  • func (x *Job) String() string
• type RegisterWorker
  • func (*RegisterWorker) Descriptor() ([]byte, []int)
  • func (x *RegisterWorker) GetWorkerName() string
  • func (*RegisterWorker) ProtoMessage()
  • func (x *RegisterWorker) ProtoReflect() protoreflect.Message
  • func (x *RegisterWorker) Reset()
  • func (x *RegisterWorker) String() string
• type SchedulerClient
  • func NewSchedulerClient(cc grpc.ClientConnInterface) SchedulerClient
• type SchedulerServer
• type Scheduler_GetJobsClient
• type Scheduler_GetJobsServer
• type UnimplementedSchedulerServer
  • func (UnimplementedSchedulerServer) GetJobs(*RegisterWorker, Scheduler_GetJobsServer) error
• type UnsafeSchedulerServer

Variables

var File_protofiles_deikstra_proto protoreflect.FileDescriptor

var Scheduler_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "protofiles.Scheduler",
	HandlerType: (*SchedulerServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetJobs",
			Handler:       _Scheduler_GetJobs_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "protofiles/deikstra.proto",
}

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

Functions

func RegisterSchedulerServer

func RegisterSchedulerServer(s grpc.ServiceRegistrar, srv SchedulerServer)

Types

type Job

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

func (*Job) Descriptor

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

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetJobId

func (x *Job) GetJobId() string

func (*Job) GetTaskName

func (x *Job) GetTaskName() string

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 RegisterWorker

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

func (*RegisterWorker) Descriptor

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

Deprecated: Use RegisterWorker.ProtoReflect.Descriptor instead.

func (*RegisterWorker) GetWorkerName

func (x *RegisterWorker) GetWorkerName() string

func (*RegisterWorker) ProtoMessage

func (*RegisterWorker) ProtoMessage()

func (*RegisterWorker) ProtoReflect

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

func (*RegisterWorker) Reset

func (x *RegisterWorker) Reset()

func (*RegisterWorker) String

func (x *RegisterWorker) String() string

type SchedulerClient

type SchedulerClient interface {
	GetJobs(ctx context.Context, in *RegisterWorker, opts ...grpc.CallOption) (Scheduler_GetJobsClient, error)
}

SchedulerClient is the client API for Scheduler 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 NewSchedulerClient

func NewSchedulerClient(cc grpc.ClientConnInterface) SchedulerClient

type SchedulerServer

type SchedulerServer interface {
	GetJobs(*RegisterWorker, Scheduler_GetJobsServer) error
	// contains filtered or unexported methods
}

SchedulerServer is the server API for Scheduler service. All implementations must embed UnimplementedSchedulerServer for forward compatibility

type Scheduler_GetJobsClient

type Scheduler_GetJobsClient interface {
	Recv() (*Job, error)
	grpc.ClientStream
}

type Scheduler_GetJobsServer

type Scheduler_GetJobsServer interface {
	Send(*Job) error
	grpc.ServerStream
}

type UnimplementedSchedulerServer

type UnimplementedSchedulerServer struct {
}

UnimplementedSchedulerServer must be embedded to have forward compatible implementations.

func (UnimplementedSchedulerServer) GetJobs

func (UnimplementedSchedulerServer) GetJobs(*RegisterWorker, Scheduler_GetJobsServer) error

type UnsafeSchedulerServer

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

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