helloservice

helloservice.go

package helloservice

//HelloService is the Service with its public API
type HelloService struct {
	HelloEndpoint chan *HelloReq //Endpoint on which the service listens
}

//NewHelloService returns a new Service
func NewHelloService() *HelloService {
	return &HelloService{
		HelloEndpoint1: make(chan *HelloReq),
	}
}

//Run spins up an go routine in which the Service processes its requests
func (s *HelloService) Run() {
	go func() {
		for {
			select {
			case req := <-s.HelloEndpoint:
				go s.ProcessHelloReq(req)
			}
		}
	}()
}

//ProcessHelloReq processes request HelloReq and returns an response
func (s *HelloService) ProcessHelloReq(req *HelloReq) {
	req.Resp <- &HelloResp{
		Result: "Hello " + req.Query,
	}
}

//HelloReq used to send request to the HelloEndpoint of Service
type HelloReq struct {
	Query string
	Resp  chan *HelloResp
}

//HelloResp used as an response from the HelloEndpoint of Service
type HelloResp struct {
	Result string
}