service

Documentation

Index

• type Option
  • func APIOption(api *api.API) Option
• type Server
  • func NewServer(options ...Option) (*Server, error)
  • 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)

Types

type Option

type Option func(*Server)

Option is a configuration func for Server.

func APIOption

func APIOption(api *api.API) Option

APIOption sets underlying mesg API.

type Server

type Server struct {
	// contains filtered or unexported fields
}

Server binds all api functions.

func NewServer

func NewServer(options ...Option) (*Server, error)

NewServer creates a new Server with given options.

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.