queuesvc

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, status *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)

Functions

func MakeQueueServer

func MakeQueueServer() (*handler.H, chan struct{}, error)

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

type QueueServer struct {
	H *handler.H
}

QueueServer encapsulates a GRPC server for the queuesvc.

func (*QueueServer) GetCancel

func (qs *QueueServer) GetCancel(ctx context.Context, id *gtypes.IntID) (*gtypes.Status, error)

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

func (qs *QueueServer) PutStatus(ctx context.Context, status *gtypes.Status) (*empty.Empty, error)

PutStatus pushes the finished run's status out to github and back into the datasvc.

func (*QueueServer) SetCancel

func (qs *QueueServer) SetCancel(ctx context.Context, id *gtypes.IntID) (*empty.Empty, error)

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.