server

Documentation

Index

• type Server
  • func New() *Server
  • func (s *Server) CreateJob(name string, functions []*function.Function, data map[string]interface{}) (*job.Job, error)
  • func (s *Server) RegisterWorker(ctx context.Context, in *pb.RegisterWorkerRequest) (*pb.RegisterWorkerReply, error)
  • func (s *Server) Run() error

Types

type Server

type Server struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func New

func New() *Server

func (*Server) CreateJob

func (s *Server) CreateJob(name string, functions []*function.Function, data map[string]interface{}) (*job.Job, error)

func (*Server) RegisterWorker

func (s *Server) RegisterWorker(ctx context.Context, in *pb.RegisterWorkerRequest) (*pb.RegisterWorkerReply, error)

func (*Server) Run

func (s *Server) Run() error