Versions in this module Expand all Collapse all v0 v0.6.0 Nov 8, 2019 v0.5.0 Jun 15, 2018 Changes in this version + type GrpcServer struct + func NewGRPCServer(ib builder.ImageBuildPusher, dl datalayer.DataLayer, ep kafka.EventBusProducer, ...) *GrpcServer + func (gr *GrpcServer) CancelBuild(ctx context.Context, req *lib.BuildCancelRequest) (_ *lib.BuildCancelResponse, err error) + func (gr *GrpcServer) GetBuildStatus(ctx context.Context, req *lib.BuildStatusRequest) (_ *lib.BuildStatusResponse, err error) + func (gr *GrpcServer) ListenRPC(addr string, port uint) error + func (gr *GrpcServer) MonitorBuild(req *lib.BuildStatusRequest, stream lib.FuranExecutor_MonitorBuildServer) (err error) + func (gr *GrpcServer) Shutdown() + func (gr *GrpcServer) StartBuild(ctx context.Context, req *lib.BuildRequest) (_ *lib.BuildRequestResponse, err error) + func (gr *GrpcServer) WorkerChan() chan *workerRequest
Go to main page