Documentation
¶
Index ¶
- func MakeQueueServer() (*handler.H, chan struct{}, error)
- type QueueServer
- func (qs *QueueServer) GetCancel(ctx context.Context, id *gtypes.IntID) (*gtypes.Status, error)
- func (qs *QueueServer) NextQueueItem(ctx context.Context, qr *gtypes.QueueRequest) (*gtypes.QueueItem, error)
- func (qs *QueueServer) PutStatus(ctx context.Context, s *gtypes.Status) (*empty.Empty, error)
- func (qs *QueueServer) SetCancel(ctx context.Context, id *gtypes.IntID) (*empty.Empty, error)
- func (qs *QueueServer) Submit(ctx context.Context, sub *queue.Submission) (*empty.Empty, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MakeQueueServer ¶
MakeQueueServer makes an instance of the queuesvc on port 6001. It returns a chan which can be closed to terminate it, and any boot-time errors.
Types ¶
type QueueServer ¶
QueueServer encapsulates a GRPC server for the queuesvc.
func (*QueueServer) GetCancel ¶
GetCancel mirrors the GetCancel in datasvc -- just easier to access by runners.
func (*QueueServer) NextQueueItem ¶
func (qs *QueueServer) NextQueueItem(ctx context.Context, qr *gtypes.QueueRequest) (*gtypes.QueueItem, error)
NextQueueItem gathers the next available item from the queue, if any, and returns it. If there is any failure, the queue could not be read and there is a need to retry after a wait.
func (*QueueServer) PutStatus ¶
PutStatus pushes the finished run's status out to github and back into the datasvc.
func (*QueueServer) SetCancel ¶
SetCancel mirrors the cancel in datasvc -- just easier to access by runners.
func (*QueueServer) Submit ¶
func (qs *QueueServer) Submit(ctx context.Context, sub *queue.Submission) (*empty.Empty, error)
Submit is the submission endpoint for the queue; all items gathered from the submission are automatically injected into the queue.
Source Files