Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewWerkerServer ¶
func NewWerkerServer(werkerCtx *WerkerContext) pb.BuildServer
func ServeMe ¶
func ServeMe(transportChan chan *models.Transport, conf *models.WerkerFacts, store storage.OcelotStorage, killValet *valet.ContextValet)
ServeMe will start HTTP Server as needed for streaming build output by hash
Types ¶
type WerkerContext ¶
type WerkerContext struct {
*models.WerkerFacts
// contains filtered or unexported fields
}
type WerkerServer ¶
type WerkerServer struct {
*WerkerContext
cleaner.Cleaner
}
WerkerServer embeds the werkerappcontext so we can stream + access active builds
func (*WerkerServer) BuildInfo ¶
func (w *WerkerServer) BuildInfo(request *pb.Request, stream pb.Build_BuildInfoServer) error
BuildInfo streams logs for an active build
func (*WerkerServer) KillHash ¶
func (w *WerkerServer) KillHash(request *pb.Request, stream pb.Build_KillHashServer) error
KillHash handles build kills
Source Files
Click to show internal directories.
Click to hide internal directories.