Documentation
¶
Index ¶
- type Server
- func (s *Server) EmitEvent(context context.Context, request *serviceapi.EmitEventRequest) (*serviceapi.EmitEventReply, error)
- func (s *Server) ListenTask(request *serviceapi.ListenTaskRequest, ...) error
- func (s *Server) SubmitResult(context context.Context, request *serviceapi.SubmitResultRequest) (*serviceapi.SubmitResultReply, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
Server binds all api functions.
func (*Server) EmitEvent ¶
func (s *Server) EmitEvent(context context.Context, request *serviceapi.EmitEventRequest) (*serviceapi.EmitEventReply, error)
EmitEvent permits to send and event to anyone who subscribed to it.
func (*Server) ListenTask ¶
func (s *Server) ListenTask(request *serviceapi.ListenTaskRequest, stream serviceapi.Service_ListenTaskServer) error
ListenTask creates a stream that will send data for every task to execute.
func (*Server) SubmitResult ¶
func (s *Server) SubmitResult(context context.Context, request *serviceapi.SubmitResultRequest) (*serviceapi.SubmitResultReply, error)
SubmitResult submits results of an execution.
Source Files
Click to show internal directories.
Click to hide internal directories.