scheduler

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

type GetJobResp struct {
	Job *v2.Action `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

type HeartBeatReq struct {
	ExecutorInfo *Property `protobuf:"bytes,1,opt,name=executor_info,json=executorInfo,proto3" json:"executor_info,omitempty"`
	ExecutorId   string    `protobuf:"bytes,2,opt,name=executor_id,json=executorId,proto3" json:"executor_id,omitempty"`
	// contains filtered or unexported fields
}

type HeartBeatResp struct {
	Status *status.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type Property struct {
	Cpu    int32 `protobuf:"varint,1,opt,name=Cpu,proto3" json:"Cpu,omitempty"`
	Memory int64 `protobuf:"varint,2,opt,name=Memory,proto3" json:"Memory,omitempty"`
	// contains filtered or unexported fields
}

type SchedulerClient interface {
	HeartBeat(ctx context.Context, in *HeartBeatReq, opts ...grpc.CallOption) (*HeartBeatResp, error)
	GetJob(ctx context.Context, in *GetJobReq, opts ...grpc.CallOption) (*GetJobResp, error)
}

type SchedulerServer interface {
	HeartBeat(context.Context, *HeartBeatReq) (*HeartBeatResp, error)
	GetJob(context.Context, *GetJobReq) (*GetJobResp, error)
}

type UnimplementedSchedulerServer struct {
}