add sysctls to yaml

vendor/github.com/cncd/pipeline/pipeline/backend/docker/convert.go

@@ -49,6 +49,7 @@ func toHostConfig(proc *backend.Step) *container.HostConfig {
 		},
 		Privileged: proc.Privileged,
 		ShmSize:    proc.ShmSize,
+		Sysctls:    proc.Sysctls,
 	}
 
 	// if len(proc.VolumesFrom) != 0 {

vendor/github.com/cncd/pipeline/pipeline/backend/types.go

@@ -47,6 +47,7 @@ type (
 		AuthConfig   Auth              `json:"auth_config,omitempty"`
 		NetworkMode  string            `json:"network_mode,omitempty"`
 		IpcMode      string            `json:"ipc_mode,omitempty"`
+		Sysctls      map[string]string `json:"sysctls,omitempty"`
 	}
 
 	// Auth defines registry authentication credentials.

vendor/github.com/cncd/pipeline/pipeline/frontend/metadata.go

@@ -33,6 +33,7 @@ type (
 		Remote  string   `json:"remote,omitempty"`
 		Private bool     `json:"private,omitempty"`
 		Secrets []Secret `json:"secrets,omitempty"`
+		Branch  string   `json:"default_branch,omitempty"`
 	}
 
 	// Build defines runtime metadata for a build.
@@ -181,7 +182,7 @@ func (m *Metadata) EnvironDrone() map[string]string {
 		"DRONE_REPO_OWNER":           owner,
 		"DRONE_REPO_NAME":            name,
 		"DRONE_REPO_LINK":            m.Repo.Link,
-		"DRONE_REPO_BRANCH":          m.Curr.Commit.Branch,
+		"DRONE_REPO_BRANCH":          m.Repo.Branch,
 		"DRONE_REPO_PRIVATE":         fmt.Sprintf("%v", m.Repo.Private),
 		"DRONE_REPO_TRUSTED":         "false", // TODO should this be added?
 		"DRONE_REMOTE_URL":           m.Repo.Remote,

vendor/github.com/cncd/pipeline/pipeline/frontend/yaml/compiler/convert.go

@@ -166,6 +166,7 @@ func (c *Compiler) createProcess(name string, container *yaml.Container, section
 		MemSwapLimit: memSwapLimit,
 		MemLimit:     memLimit,
 		ShmSize:      shmSize,
+		Sysctls:      container.Sysctls,
 		CPUQuota:     cpuQuota,
 		CPUShares:    cpuShares,
 		CPUSet:       cpuSet,

vendor/github.com/cncd/pipeline/pipeline/frontend/yaml/container.go

@@ -55,6 +55,7 @@ type (
 		Ulimits       libcompose.Ulimits        `yaml:"ulimits,omitempty"`
 		Volumes       libcompose.Volumes        `yaml:"volumes,omitempty"`
 		Secrets       Secrets                   `yaml:"secrets,omitempty"`
+		Sysctls       libcompose.SliceorMap     `yaml:"sysctls,omitempty"`
 		Constraints   Constraints               `yaml:"when,omitempty"`
 		Vargs         map[string]interface{}    `yaml:",inline"`
 	}

vendor/github.com/cncd/pipeline/pipeline/frontend/yaml/linter/linter.go

@@ -127,6 +127,9 @@ func (l *Linter) lintTrusted(c *yaml.Container) error {
 	if len(c.IpcMode) != 0 {
 		return fmt.Errorf("Insufficient privileges to use ipc_mode")
 	}
+	if len(c.Sysctls) != 0 {
+		return fmt.Errorf("Insufficient privileges to use sysctls")
+	}
 	if c.Networks.Networks != nil && len(c.Networks.Networks) != 0 {
 		return fmt.Errorf("Insufficient privileges to use networks")
 	}

vendor/github.com/cncd/pipeline/pipeline/rpc/client_grpc_health.go

@@ -0,0 +1,63 @@
+package rpc
+
+import (
+	"context"
+	// "encoding/json"
+	"time"
+
+	// "github.com/cncd/pipeline/pipeline/backend"
+	"github.com/cncd/pipeline/pipeline/rpc/proto"
+
+	"google.golang.org/grpc"
+	"google.golang.org/grpc/codes"
+)
+
+// generate protobuffs
+//   protoc --go_out=plugins=grpc,import_path=proto:. *.proto
+
+type healthClient struct {
+	client proto.HealthClient
+	conn   *grpc.ClientConn
+}
+
+// NewGrpcHealthClient returns a new grpc Client.
+func NewGrpcHealthClient(conn *grpc.ClientConn) Health {
+	client := new(healthClient)
+	client.client = proto.NewHealthClient(conn)
+	client.conn = conn
+	return client
+}
+
+func (c *healthClient) Close() error {
+	return c.conn.Close()
+}
+
+func (c *healthClient) Check(ctx context.Context) (bool, error) {
+	var res *proto.HealthCheckResponse
+	var err error
+	req := new(proto.HealthCheckRequest)
+
+	for {
+		res, err = c.client.Check(ctx, req)
+		if err == nil {
+			if res.GetStatus() == proto.HealthCheckResponse_SERVING {
+				return true, nil
+			}
+			return false, nil
+		}
+		switch grpc.Code(err) {
+		case
+			codes.Aborted,
+			codes.DataLoss,
+			codes.DeadlineExceeded,
+			codes.Internal,
+			codes.Unavailable:
+			// non-fatal errors
+		default:
+			return false, err
+		}
+		<-time.After(backoff)
+	}
+
+	return true, nil
+}

vendor/github.com/cncd/pipeline/pipeline/rpc/health.go

@@ -0,0 +1,11 @@
+package rpc
+
+import (
+	"context"
+)
+
+// Health defines a health-check connection.
+type Health interface {
+  // Check returns if server is healthy or not
+	Check(c context.Context) (bool, error)
+}

vendor/github.com/cncd/pipeline/pipeline/rpc/proto/drone.pb.go

@@ -13,6 +13,8 @@ It has these top-level messages:
 	Line
 	Filter
 	Pipeline
+	HealthCheckRequest
+	HealthCheckResponse
 	NextRequest
 	NextReply
 	InitRequest
@@ -46,6 +48,32 @@ var _ = math.Inf
 // proto package needs to be updated.
 const _ = proto1.ProtoPackageIsVersion2 // please upgrade the proto package
 
+type HealthCheckResponse_ServingStatus int32
+
+const (
+	HealthCheckResponse_UNKNOWN     HealthCheckResponse_ServingStatus = 0
+	HealthCheckResponse_SERVING     HealthCheckResponse_ServingStatus = 1
+	HealthCheckResponse_NOT_SERVING HealthCheckResponse_ServingStatus = 2
+)
+
+var HealthCheckResponse_ServingStatus_name = map[int32]string{
+	0: "UNKNOWN",
+	1: "SERVING",
+	2: "NOT_SERVING",
+}
+var HealthCheckResponse_ServingStatus_value = map[string]int32{
+	"UNKNOWN":     0,
+	"SERVING":     1,
+	"NOT_SERVING": 2,
+}
+
+func (x HealthCheckResponse_ServingStatus) String() string {
+	return proto1.EnumName(HealthCheckResponse_ServingStatus_name, int32(x))
+}
+func (HealthCheckResponse_ServingStatus) EnumDescriptor() ([]byte, []int) {
+	return fileDescriptor0, []int{6, 0}
+}
+
 type File struct {
 	Name string            `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
 	Proc string            `protobuf:"bytes,2,opt,name=proc" json:"proc,omitempty"`
@@ -262,6 +290,38 @@ func (m *Pipeline) GetPayload() []byte {
 	return nil
 }
 
+type HealthCheckRequest struct {
+	Service string `protobuf:"bytes,1,opt,name=service" json:"service,omitempty"`
+}
+
+func (m *HealthCheckRequest) Reset()                    { *m = HealthCheckRequest{} }
+func (m *HealthCheckRequest) String() string            { return proto1.CompactTextString(m) }
+func (*HealthCheckRequest) ProtoMessage()               {}
+func (*HealthCheckRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{5} }
+
+func (m *HealthCheckRequest) GetService() string {
+	if m != nil {
+		return m.Service
+	}
+	return ""
+}
+
+type HealthCheckResponse struct {
+	Status HealthCheckResponse_ServingStatus `protobuf:"varint,1,opt,name=status,enum=proto.HealthCheckResponse_ServingStatus" json:"status,omitempty"`
+}
+
+func (m *HealthCheckResponse) Reset()                    { *m = HealthCheckResponse{} }
+func (m *HealthCheckResponse) String() string            { return proto1.CompactTextString(m) }
+func (*HealthCheckResponse) ProtoMessage()               {}
+func (*HealthCheckResponse) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{6} }
+
+func (m *HealthCheckResponse) GetStatus() HealthCheckResponse_ServingStatus {
+	if m != nil {
+		return m.Status
+	}
+	return HealthCheckResponse_UNKNOWN
+}
+
 type NextRequest struct {
 	Filter *Filter `protobuf:"bytes,1,opt,name=filter" json:"filter,omitempty"`
 }
@@ -269,7 +329,7 @@ type NextRequest struct {
 func (m *NextRequest) Reset()                    { *m = NextRequest{} }
 func (m *NextRequest) String() string            { return proto1.CompactTextString(m) }
 func (*NextRequest) ProtoMessage()               {}
-func (*NextRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{5} }
+func (*NextRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{7} }
 
 func (m *NextRequest) GetFilter() *Filter {
 	if m != nil {
@@ -285,7 +345,7 @@ type NextReply struct {
 func (m *NextReply) Reset()                    { *m = NextReply{} }
 func (m *NextReply) String() string            { return proto1.CompactTextString(m) }
 func (*NextReply) ProtoMessage()               {}
-func (*NextReply) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{6} }
+func (*NextReply) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{8} }
 
 func (m *NextReply) GetPipeline() *Pipeline {
 	if m != nil {
@@ -302,7 +362,7 @@ type InitRequest struct {
 func (m *InitRequest) Reset()                    { *m = InitRequest{} }
 func (m *InitRequest) String() string            { return proto1.CompactTextString(m) }
 func (*InitRequest) ProtoMessage()               {}
-func (*InitRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{7} }
+func (*InitRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{9} }
 
 func (m *InitRequest) GetId() string {
 	if m != nil {
@@ -325,7 +385,7 @@ type WaitRequest struct {
 func (m *WaitRequest) Reset()                    { *m = WaitRequest{} }
 func (m *WaitRequest) String() string            { return proto1.CompactTextString(m) }
 func (*WaitRequest) ProtoMessage()               {}
-func (*WaitRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{8} }
+func (*WaitRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{10} }
 
 func (m *WaitRequest) GetId() string {
 	if m != nil {
@@ -342,7 +402,7 @@ type DoneRequest struct {
 func (m *DoneRequest) Reset()                    { *m = DoneRequest{} }
 func (m *DoneRequest) String() string            { return proto1.CompactTextString(m) }
 func (*DoneRequest) ProtoMessage()               {}
-func (*DoneRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{9} }
+func (*DoneRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{11} }
 
 func (m *DoneRequest) GetId() string {
 	if m != nil {
@@ -365,7 +425,7 @@ type ExtendRequest struct {
 func (m *ExtendRequest) Reset()                    { *m = ExtendRequest{} }
 func (m *ExtendRequest) String() string            { return proto1.CompactTextString(m) }
 func (*ExtendRequest) ProtoMessage()               {}
-func (*ExtendRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{10} }
+func (*ExtendRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{12} }
 
 func (m *ExtendRequest) GetId() string {
 	if m != nil {
@@ -382,7 +442,7 @@ type UploadRequest struct {
 func (m *UploadRequest) Reset()                    { *m = UploadRequest{} }
 func (m *UploadRequest) String() string            { return proto1.CompactTextString(m) }
 func (*UploadRequest) ProtoMessage()               {}
-func (*UploadRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{11} }
+func (*UploadRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{13} }
 
 func (m *UploadRequest) GetId() string {
 	if m != nil {
@@ -406,7 +466,7 @@ type UpdateRequest struct {
 func (m *UpdateRequest) Reset()                    { *m = UpdateRequest{} }
 func (m *UpdateRequest) String() string            { return proto1.CompactTextString(m) }
 func (*UpdateRequest) ProtoMessage()               {}
-func (*UpdateRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{12} }
+func (*UpdateRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{14} }
 
 func (m *UpdateRequest) GetId() string {
 	if m != nil {
@@ -430,7 +490,7 @@ type LogRequest struct {
 func (m *LogRequest) Reset()                    { *m = LogRequest{} }
 func (m *LogRequest) String() string            { return proto1.CompactTextString(m) }
 func (*LogRequest) ProtoMessage()               {}
-func (*LogRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{13} }
+func (*LogRequest) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{15} }
 
 func (m *LogRequest) GetId() string {
 	if m != nil {
@@ -452,7 +512,7 @@ type Empty struct {
 func (m *Empty) Reset()                    { *m = Empty{} }
 func (m *Empty) String() string            { return proto1.CompactTextString(m) }
 func (*Empty) ProtoMessage()               {}
-func (*Empty) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{14} }
+func (*Empty) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{16} }
 
 func init() {
 	proto1.RegisterType((*File)(nil), "proto.File")
@@ -460,6 +520,8 @@ func init() {
 	proto1.RegisterType((*Line)(nil), "proto.Line")
 	proto1.RegisterType((*Filter)(nil), "proto.Filter")
 	proto1.RegisterType((*Pipeline)(nil), "proto.Pipeline")
+	proto1.RegisterType((*HealthCheckRequest)(nil), "proto.HealthCheckRequest")
+	proto1.RegisterType((*HealthCheckResponse)(nil), "proto.HealthCheckResponse")
 	proto1.RegisterType((*NextRequest)(nil), "proto.NextRequest")
 	proto1.RegisterType((*NextReply)(nil), "proto.NextReply")
 	proto1.RegisterType((*InitRequest)(nil), "proto.InitRequest")
@@ -470,6 +532,7 @@ func init() {
 	proto1.RegisterType((*UpdateRequest)(nil), "proto.UpdateRequest")
 	proto1.RegisterType((*LogRequest)(nil), "proto.LogRequest")
 	proto1.RegisterType((*Empty)(nil), "proto.Empty")
+	proto1.RegisterEnum("proto.HealthCheckResponse_ServingStatus", HealthCheckResponse_ServingStatus_name, HealthCheckResponse_ServingStatus_value)
 }
 
 // Reference imports to suppress errors if they are not otherwise used.
@@ -775,50 +838,121 @@ var _Drone_serviceDesc = grpc.ServiceDesc{
 	Metadata: "drone.proto",
 }
 
+// Client API for Health service
+
+type HealthClient interface {
+	Check(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error)
+}
+
+type healthClient struct {
+	cc *grpc.ClientConn
+}
+
+func NewHealthClient(cc *grpc.ClientConn) HealthClient {
+	return &healthClient{cc}
+}
+
+func (c *healthClient) Check(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error) {
+	out := new(HealthCheckResponse)
+	err := grpc.Invoke(ctx, "/proto.Health/Check", in, out, c.cc, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+// Server API for Health service
+
+type HealthServer interface {
+	Check(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
+}
+
+func RegisterHealthServer(s *grpc.Server, srv HealthServer) {
+	s.RegisterService(&_Health_serviceDesc, srv)
+}
+
+func _Health_Check_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(HealthCheckRequest)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(HealthServer).Check(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: "/proto.Health/Check",
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(HealthServer).Check(ctx, req.(*HealthCheckRequest))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+var _Health_serviceDesc = grpc.ServiceDesc{
+	ServiceName: "proto.Health",
+	HandlerType: (*HealthServer)(nil),
+	Methods: []grpc.MethodDesc{
+		{
+			MethodName: "Check",
+			Handler:    _Health_Check_Handler,
+		},
+	},
+	Streams:  []grpc.StreamDesc{},
+	Metadata: "drone.proto",
+}
+
 func init() { proto1.RegisterFile("drone.proto", fileDescriptor0) }
 
 var fileDescriptor0 = []byte{
-	// 661 bytes of a gzipped FileDescriptorProto
+	// 780 bytes of a gzipped FileDescriptorProto
-	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xa4, 0x54, 0xed, 0x6a, 0xd4, 0x4c,
+	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xa4, 0x54, 0x5f, 0x4f, 0xd3, 0x50,
-	0x14, 0x7e, 0xb3, 0xf9, 0xe8, 0xee, 0x49, 0xfb, 0x5a, 0x87, 0x2a, 0x71, 0x45, 0xba, 0x04, 0x84,
+	0x14, 0xa7, 0x5b, 0xdb, 0x6d, 0xa7, 0x0c, 0xe6, 0x15, 0x4d, 0x99, 0x31, 0x2c, 0x4d, 0x4c, 0xa6,
-	0x55, 0x61, 0xc1, 0x55, 0xb0, 0x0a, 0x82, 0xd2, 0x0f, 0x10, 0xd6, 0x22, 0x23, 0xe2, 0x4f, 0x49,
+	0x26, 0x4d, 0x9c, 0x26, 0x22, 0x89, 0x06, 0x03, 0x43, 0x88, 0x73, 0x98, 0x3b, 0x91, 0x47, 0x52,
-	0x9b, 0xd3, 0x3a, 0x98, 0xcd, 0xc4, 0x64, 0x2a, 0x1b, 0x2f, 0xc1, 0x6b, 0xf0, 0xea, 0xbc, 0x07,
+	0xd6, 0x0b, 0x34, 0x74, 0x6d, 0x6d, 0xef, 0xc8, 0xe6, 0x47, 0xf0, 0xd5, 0x57, 0x3f, 0x9d, 0xdf,
-	0xff, 0xcb, 0x99, 0x99, 0xa4, 0xd9, 0x76, 0x2b, 0x48, 0x7f, 0xed, 0xf9, 0x78, 0x66, 0xce, 0x73,
+	0xc1, 0x77, 0x73, 0xee, 0x6d, 0x4b, 0x07, 0x9b, 0x89, 0xe1, 0xa9, 0xe7, 0xcf, 0xef, 0xdc, 0x73,
-	0x9e, 0x67, 0xb2, 0x10, 0xa6, 0xa5, 0xcc, 0x71, 0x52, 0x94, 0x52, 0x49, 0xe6, 0xeb, 0x9f, 0xf8,
+	0xce, 0xef, 0xd7, 0x7b, 0xc1, 0x70, 0xe3, 0x30, 0x60, 0x76, 0x14, 0x87, 0x3c, 0x24, 0x9a, 0xf8,
-	0x97, 0x03, 0xde, 0x81, 0xc8, 0x90, 0x31, 0xf0, 0xf2, 0x64, 0x8e, 0x91, 0x33, 0x72, 0xc6, 0x03,
+	0x58, 0xbf, 0x15, 0x50, 0xf7, 0x3c, 0x9f, 0x11, 0x02, 0x6a, 0xe0, 0x8c, 0x98, 0xa9, 0xb4, 0x94,
-	0xae, 0x63, 0xaa, 0x15, 0xa5, 0x3c, 0x8e, 0x7a, 0xa6, 0x46, 0x31, 0xd5, 0xe6, 0x62, 0x8e, 0x91,
+	0x76, 0x8d, 0x0a, 0x1b, 0x63, 0x51, 0x1c, 0x0e, 0xcd, 0x92, 0x8c, 0xa1, 0x8d, 0xb1, 0x91, 0x37,
-	0x6b, 0x6a, 0x14, 0x53, 0x4d, 0x51, 0xcd, 0x1b, 0x39, 0x63, 0x97, 0xeb, 0x98, 0x6a, 0x95, 0xf8,
+	0x62, 0x66, 0x59, 0xc6, 0xd0, 0xc6, 0x18, 0xc7, 0x98, 0xda, 0x52, 0xda, 0x65, 0x2a, 0x6c, 0x8c,
-	0x8e, 0x91, 0x3f, 0x72, 0xc6, 0x3e, 0xd7, 0x31, 0xd5, 0xd2, 0x44, 0x25, 0x51, 0x30, 0x72, 0xc6,
+	0x25, 0xde, 0x77, 0x66, 0x6a, 0x2d, 0xa5, 0xad, 0x51, 0x61, 0x63, 0xcc, 0x75, 0xb8, 0x63, 0xea,
-	0xeb, 0x5c, 0xc7, 0xec, 0x01, 0x78, 0x73, 0x54, 0x49, 0xb4, 0x36, 0x72, 0xc7, 0xe1, 0xf4, 0x96,
+	0x2d, 0xa5, 0xbd, 0x4c, 0x85, 0x4d, 0x9e, 0x82, 0x3a, 0x62, 0xdc, 0x31, 0x2b, 0xad, 0x72, 0xdb,
-	0x61, 0x37, 0x21, 0x4a, 0x93, 0xb7, 0xa8, 0x92, 0xfd, 0x5c, 0x95, 0x35, 0xd7, 0x90, 0xe1, 0x33,
+	0xe8, 0x3c, 0x90, 0xd3, 0xd9, 0x38, 0x92, 0xfd, 0x89, 0x71, 0xa7, 0x1b, 0xf0, 0x78, 0x4a, 0x05,
-	0x18, 0xb4, 0x25, 0xb6, 0x09, 0xee, 0x17, 0xac, 0x2d, 0x5d, 0x0a, 0xd9, 0x16, 0xf8, 0xdf, 0x92,
+	0xa4, 0xf9, 0x1a, 0x6a, 0x79, 0x88, 0x34, 0xa0, 0x7c, 0xc9, 0xa6, 0xe9, 0xb8, 0x68, 0x92, 0x35,
-	0xec, 0x0c, 0x2d, 0x5d, 0x93, 0xbc, 0xe8, 0xed, 0x38, 0xf1, 0x4f, 0x07, 0xfc, 0xf7, 0x2a, 0x51,
+	0xd0, 0xae, 0x1c, 0x7f, 0xcc, 0xd2, 0x71, 0xa5, 0xb3, 0x55, 0xda, 0x54, 0xac, 0x5f, 0x0a, 0x68,
-	0xab, 0xb7, 0xbc, 0x0d, 0x01, 0x2e, 0x84, 0xc2, 0x54, 0x1f, 0xec, 0x73, 0x9b, 0xb1, 0xbb, 0x30,
+	0x03, 0xee, 0xf0, 0xf9, 0x5b, 0x3e, 0x04, 0x9d, 0x4d, 0x3c, 0xce, 0x5c, 0x51, 0x58, 0xa5, 0xa9,
-	0xa0, 0xe8, 0xd3, 0xb1, 0x4c, 0xcd, 0xba, 0x3e, 0xef, 0x53, 0x61, 0x57, 0xa6, 0xc8, 0x22, 0x58,
+	0x47, 0x1e, 0x41, 0x0d, 0xad, 0x93, 0x61, 0xe8, 0xca, 0x75, 0x35, 0x5a, 0xc5, 0xc0, 0x4e, 0xe8,
-	0xab, 0x54, 0x52, 0xd2, 0x29, 0xb3, 0x75, 0x93, 0xb2, 0x21, 0xf4, 0x4f, 0x44, 0x2e, 0xaa, 0xcf,
+	0x32, 0x62, 0x42, 0x25, 0xe1, 0x4e, 0x8c, 0x55, 0x72, 0xeb, 0xcc, 0x25, 0x4d, 0xa8, 0x9e, 0x79,
-	0x98, 0xea, 0xe5, 0x5d, 0xde, 0xe6, 0x44, 0x11, 0xcb, 0x52, 0x96, 0x5a, 0x81, 0x01, 0x37, 0x49,
+	0x81, 0x97, 0x5c, 0x30, 0x57, 0x2c, 0x5f, 0xa6, 0xb9, 0x8f, 0x23, 0xb2, 0x38, 0x0e, 0x63, 0xc1,
-	0xcc, 0xc1, 0x9b, 0x89, 0xfc, 0x5c, 0x6e, 0x67, 0x59, 0x6e, 0x2d, 0x6d, 0xaf, 0x23, 0xed, 0x26,
+	0x40, 0x8d, 0x4a, 0xc7, 0xa2, 0xa0, 0xf6, 0xbc, 0xe0, 0x9a, 0x6e, 0x65, 0x96, 0x6e, 0x41, 0x6d,
-	0xb8, 0x85, 0xac, 0x2c, 0x25, 0x0a, 0xa9, 0x22, 0xcf, 0x94, 0x66, 0x32, 0xe0, 0x14, 0xc6, 0x3f,
+	0xa9, 0x40, 0x6d, 0x03, 0xca, 0x51, 0x98, 0xa4, 0x23, 0xa1, 0x89, 0x91, 0x70, 0xcc, 0xc5, 0x24,
-	0x1c, 0x08, 0x0e, 0x44, 0xa6, 0xb0, 0x64, 0x8f, 0x21, 0xc8, 0x92, 0x23, 0xcc, 0xaa, 0xc8, 0xd1,
+	0x35, 0x8a, 0xa6, 0xf5, 0x43, 0x01, 0x7d, 0xcf, 0xf3, 0x39, 0x8b, 0xc9, 0x0b, 0xd0, 0x7d, 0xe7,
-	0x1a, 0xdf, 0x39, 0xd7, 0x58, 0x61, 0x39, 0x99, 0xe9, 0x9e, 0xd1, 0xd9, 0x02, 0x69, 0x2a, 0x2e,
+	0x94, 0xf9, 0x89, 0xa9, 0x08, 0x8e, 0xd7, 0xaf, 0x39, 0xe6, 0x2c, 0xb6, 0x7b, 0x22, 0x27, 0x79,
-	0x8a, 0xb2, 0x31, 0x9e, 0xe2, 0xe1, 0x73, 0x08, 0x3b, 0xd0, 0x7f, 0xd2, 0xff, 0x10, 0xfa, 0xef,
+	0x4e, 0x81, 0xd8, 0x95, 0x4d, 0xa2, 0x38, 0x13, 0x1e, 0xed, 0xe6, 0x1b, 0x30, 0x0a, 0xd0, 0xff,
-	0x44, 0x81, 0x19, 0x2d, 0xf9, 0x3f, 0xf4, 0x44, 0x6a, 0x8f, 0xf5, 0x44, 0x4a, 0x42, 0xd2, 0x52,
+	0xe2, 0xbf, 0x0f, 0xd5, 0xcf, 0x5e, 0xc4, 0x7c, 0x5c, 0x72, 0x05, 0x4a, 0x9e, 0x9b, 0x96, 0x95,
-	0x44, 0xdf, 0xec, 0xd8, 0xa4, 0xd4, 0x29, 0x92, 0x3a, 0x93, 0x49, 0xaa, 0x57, 0x5d, 0xe7, 0x4d,
+	0x3c, 0x17, 0x89, 0xc4, 0xa5, 0x70, 0x7c, 0xb9, 0x63, 0xe6, 0x62, 0x26, 0x72, 0xa6, 0x7e, 0xe8,
-	0x1a, 0x3f, 0x85, 0xf0, 0x10, 0x17, 0x8a, 0xe3, 0xd7, 0x33, 0xac, 0x14, 0xbb, 0x0f, 0xc1, 0x89,
+	0xb8, 0x62, 0xd5, 0x65, 0x9a, 0xb9, 0x96, 0x0d, 0x64, 0x9f, 0x39, 0x3e, 0xbf, 0xd8, 0xb9, 0x60,
-	0xde, 0x45, 0x5f, 0x1b, 0x4e, 0x37, 0x96, 0x16, 0xe4, 0xb6, 0x19, 0xef, 0xc0, 0xc0, 0x9c, 0x2a,
+	0xc3, 0x4b, 0xca, 0xbe, 0x8d, 0x59, 0x22, 0xf0, 0x09, 0x8b, 0xaf, 0xbc, 0x61, 0x26, 0x6f, 0xe6,
-	0xb2, 0x9a, 0x3d, 0x82, 0x7e, 0x61, 0x29, 0xd9, 0x53, 0x37, 0xec, 0xa9, 0x86, 0x29, 0x6f, 0x01,
+	0x5a, 0x3f, 0x15, 0xb8, 0x3f, 0x53, 0x90, 0x44, 0x61, 0x90, 0x30, 0xb2, 0x0d, 0x7a, 0xc2, 0x1d,
-	0xf1, 0x6b, 0x08, 0xdf, 0xe4, 0xa2, 0x9d, 0x77, 0x71, 0x85, 0x18, 0xfc, 0x8a, 0x5e, 0x97, 0x5e,
+	0x3e, 0x4e, 0x44, 0xc1, 0x4a, 0xa7, 0x9d, 0x32, 0x33, 0x07, 0x6b, 0x0f, 0xf0, 0xac, 0xe0, 0x7c,
-	0x20, 0x9c, 0xae, 0xdb, 0x8b, 0xf4, 0x8b, 0xe3, 0xa6, 0x15, 0xdf, 0x83, 0xf0, 0x63, 0x72, 0xe5,
+	0x20, 0xf0, 0x34, 0xad, 0xb3, 0xb6, 0xa0, 0x3e, 0x93, 0x20, 0x06, 0x54, 0x8e, 0xfa, 0x1f, 0xfb,
-	0x15, 0x34, 0x61, 0x4f, 0xe6, 0x78, 0x9d, 0x09, 0xdb, 0xb0, 0xb1, 0xbf, 0x50, 0x98, 0xa7, 0x57,
+	0x87, 0xc7, 0xfd, 0xc6, 0x12, 0x3a, 0x83, 0x2e, 0xfd, 0x7a, 0xd0, 0xff, 0xd0, 0x50, 0xc8, 0x2a,
-	0xcd, 0x78, 0x05, 0x1b, 0x1f, 0x0a, 0xd2, 0xef, 0xaa, 0x29, 0xdb, 0xe0, 0x9d, 0x88, 0xac, 0x19,
+	0x18, 0xfd, 0xc3, 0x2f, 0x27, 0x59, 0xa0, 0x64, 0xbd, 0x02, 0xa3, 0xcf, 0x26, 0x3c, 0x1b, 0xff,
-	0x12, 0x76, 0x3e, 0x45, 0xae, 0x1b, 0xf1, 0x2e, 0xdd, 0x90, 0xd2, 0xcc, 0x6b, 0xf0, 0x7c, 0x09,
+	0x09, 0xe8, 0x67, 0x42, 0x11, 0x31, 0x8c, 0xd1, 0xa9, 0xcf, 0xc8, 0x44, 0xd3, 0xa4, 0xb5, 0x09,
-	0x30, 0x93, 0xa7, 0x7f, 0xe1, 0xa0, 0x3d, 0x59, 0xe6, 0x40, 0x9f, 0x07, 0xd7, 0x8d, 0x78, 0x0d,
+	0x35, 0x59, 0x15, 0xf9, 0x53, 0xf2, 0x1c, 0xaa, 0x51, 0x4a, 0x6c, 0x5a, 0xb5, 0x9a, 0x56, 0x65,
-	0xfc, 0xfd, 0x79, 0xa1, 0xea, 0xe9, 0xef, 0x1e, 0xf8, 0x7b, 0xf4, 0x87, 0xc6, 0x26, 0xe0, 0x91,
+	0x7c, 0xd3, 0x1c, 0x60, 0xbd, 0x07, 0xe3, 0x20, 0xf0, 0xf2, 0x7e, 0x37, 0x85, 0xb0, 0x40, 0xc3,
-	0xb1, 0x8c, 0x59, 0x74, 0xe7, 0x6d, 0x0c, 0x37, 0x97, 0x6a, 0x45, 0x56, 0xc7, 0xff, 0xb1, 0x87,
+	0xa5, 0xa4, 0x7c, 0x46, 0x67, 0x39, 0x3d, 0x48, 0xdc, 0x1b, 0x2a, 0x53, 0xd6, 0x63, 0x30, 0x8e,
-	0xe0, 0x91, 0x9d, 0x2d, 0xbe, 0xe3, 0xed, 0xb0, 0xa1, 0xac, 0x67, 0x18, 0x2c, 0xf9, 0xd6, 0x62,
+	0x9d, 0x85, 0x47, 0x60, 0x87, 0xdd, 0x30, 0x60, 0x77, 0xe9, 0xb0, 0x01, 0xf5, 0xee, 0x84, 0xb3,
-	0x3b, 0x26, 0xae, 0xc2, 0x92, 0x89, 0x2d, 0xb6, 0xe3, 0xe8, 0x25, 0xec, 0x04, 0x02, 0xe3, 0x16,
+	0xc0, 0x5d, 0xd4, 0x63, 0x1b, 0xea, 0x47, 0x11, 0xfe, 0x05, 0x8b, 0xba, 0x6c, 0x80, 0x7a, 0xe6,
-	0xdb, 0x6a, 0x3a, 0x5d, 0xf3, 0x56, 0xe1, 0x8d, 0xf4, 0x2d, 0x7e, 0xc9, 0x89, 0xd5, 0x78, 0x32,
+	0xf9, 0x59, 0x13, 0xa3, 0xf0, 0xa0, 0x50, 0x91, 0xb0, 0x76, 0xf0, 0x04, 0x17, 0x7b, 0xde, 0x61,
-	0xbb, 0x83, 0xef, 0x78, 0x7f, 0x09, 0x3f, 0x06, 0x77, 0x26, 0x4f, 0xd9, 0xcd, 0x46, 0xf0, 0xd6,
+	0xce, 0xb7, 0x00, 0xbd, 0xf0, 0xfc, 0x1f, 0x33, 0x08, 0x4d, 0x66, 0x67, 0xc0, 0x4b, 0x4e, 0x45,
-	0xa1, 0x8b, 0xc8, 0xa3, 0x40, 0xa7, 0x4f, 0xfe, 0x04, 0x00, 0x00, 0xff, 0xff, 0xe9, 0x21, 0xb6,
+	0xc2, 0xaa, 0x80, 0xd6, 0x1d, 0x45, 0x7c, 0xda, 0xf9, 0x53, 0x02, 0x6d, 0x17, 0x9f, 0x65, 0x62,
-	0xce, 0x4e, 0x06, 0x00, 0x00,
+	0x83, 0x8a, 0xc2, 0x12, 0x92, 0xa2, 0x0b, 0xff, 0x46, 0xb3, 0x31, 0x13, 0x8b, 0xfc, 0xa9, 0xb5,
+	0x44, 0x9e, 0x81, 0x8a, 0x72, 0xe6, 0xf8, 0x82, 0xb6, 0xcd, 0x6c, 0x64, 0xd1, 0x43, 0x62, 0x51,
+	0xb7, 0x1c, 0x5b, 0x10, 0x71, 0x1e, 0x16, 0x45, 0xcc, 0xb1, 0x05, 0x45, 0x6f, 0x61, 0x6d, 0xd0,
+	0xa5, 0x5a, 0x64, 0x2d, 0xcb, 0x14, 0xc5, 0x9b, 0x87, 0x97, 0xd4, 0xe7, 0xf8, 0x19, 0x25, 0xe6,
+	0xe3, 0x51, 0xec, 0x02, 0xbe, 0xa0, 0xfd, 0x2d, 0x7c, 0x1b, 0xca, 0xbd, 0xf0, 0x9c, 0xdc, 0xcb,
+	0x08, 0xcf, 0x15, 0xba, 0x89, 0xec, 0xec, 0x83, 0x2e, 0x6f, 0x39, 0x79, 0x07, 0x9a, 0xb8, 0xe9,
+	0x64, 0x7d, 0xde, 0xed, 0x97, 0xd5, 0xcd, 0xc5, 0x0f, 0xc3, 0xa9, 0x2e, 0x52, 0x2f, 0xff, 0x06,
+	0x00, 0x00, 0xff, 0xff, 0x59, 0x78, 0xda, 0x5d, 0x5e, 0x07, 0x00, 0x00,
 }

vendor/github.com/cncd/pipeline/pipeline/rpc/proto/drone.proto

@@ -39,6 +39,19 @@ message Pipeline {
   bytes payload = 3;
 }
 
+message HealthCheckRequest {
+  string service = 1;
+}
+
+message HealthCheckResponse {
+  enum ServingStatus {
+    UNKNOWN = 0;
+    SERVING = 1;
+    NOT_SERVING = 2;
+  }
+  ServingStatus status = 1;
+}
+
 service Drone {
   rpc Next   (NextRequest)   returns (NextReply) {}
   rpc Init   (InitRequest)   returns (Empty) {}
@@ -50,6 +63,10 @@ service Drone {
   rpc Log    (LogRequest)    returns (Empty) {}
 }
 
+service Health {
+  rpc Check(HealthCheckRequest) returns (HealthCheckResponse);
+}
+
 //
 // next
 //

vendor/vendor.json

@@ -195,80 +195,80 @@
 		{
 			"checksumSHA1": "W3AuK8ocqHwlUajGmQLFvnRhTZE=",
 			"path": "github.com/cncd/pipeline/pipeline",
-			"revision": "b7427ae1fb86bb04e2997e5f3a1eec75c4b056ef",
+			"revision": "82706703c87f88a632674484e095e494c0e30e34",
-			"revisionTime": "2017-09-14T17:45:32Z"
+			"revisionTime": "2017-11-17T22:46:28Z"
 		},
 		{
-			"checksumSHA1": "gc+efbEPGdecp6I2ezd6J3+UL3o=",
+			"checksumSHA1": "iRKdpheRPBTP0DKTQH7zmE2PI34=",
 			"path": "github.com/cncd/pipeline/pipeline/backend",
-			"revision": "b7427ae1fb86bb04e2997e5f3a1eec75c4b056ef",
+			"revision": "82706703c87f88a632674484e095e494c0e30e34",
-			"revisionTime": "2017-09-14T17:45:32Z"
+			"revisionTime": "2017-11-17T22:46:28Z"
 		},
 		{
-			"checksumSHA1": "IIuOItGMhYP6kLtlZWYBO+liSx4=",
+			"checksumSHA1": "EHJGG1USUliP8nzNWV/axO5KLzw=",
 			"path": "github.com/cncd/pipeline/pipeline/backend/docker",
-			"revision": "b7427ae1fb86bb04e2997e5f3a1eec75c4b056ef",
+			"revision": "82706703c87f88a632674484e095e494c0e30e34",
-			"revisionTime": "2017-09-14T17:45:32Z"
+			"revisionTime": "2017-11-17T22:46:28Z"
 		},
 		{
-			"checksumSHA1": "2A3+CnkMfvvO4oRkjQKqi44no0g=",
+			"checksumSHA1": "HWV2BBLXS4gY5eLJeNIg7Z6nAOA=",
 			"path": "github.com/cncd/pipeline/pipeline/frontend",
-			"revision": "b7427ae1fb86bb04e2997e5f3a1eec75c4b056ef",
+			"revision": "82706703c87f88a632674484e095e494c0e30e34",
-			"revisionTime": "2017-09-14T17:45:32Z"
+			"revisionTime": "2017-11-17T22:46:28Z"
 		},
 		{
-			"checksumSHA1": "VZEf4sUe0jVi3TPXE+gfjpKtXFA=",
+			"checksumSHA1": "a31aG4R3OK0t87whuZ5IWbSD1uc=",
 			"path": "github.com/cncd/pipeline/pipeline/frontend/yaml",
-			"revision": "b7427ae1fb86bb04e2997e5f3a1eec75c4b056ef",
+			"revision": "82706703c87f88a632674484e095e494c0e30e34",
-			"revisionTime": "2017-09-14T17:45:32Z"
+			"revisionTime": "2017-11-17T22:46:28Z"
 		},
 		{
-			"checksumSHA1": "Bso8L5AC/YA4k+YVfIg+m2bMLmU=",
+			"checksumSHA1": "cdjOSSSS5Gzx7gRLNvObQvNJWYg=",
 			"path": "github.com/cncd/pipeline/pipeline/frontend/yaml/compiler",
-			"revision": "b7427ae1fb86bb04e2997e5f3a1eec75c4b056ef",
+			"revision": "82706703c87f88a632674484e095e494c0e30e34",
-			"revisionTime": "2017-09-14T17:45:32Z"
+			"revisionTime": "2017-11-17T22:46:28Z"
 		},
 		{
-			"checksumSHA1": "tExCYtVZoTnfEkEQL7r/megor8I=",
+			"checksumSHA1": "Sj2VYU+asWToYriIqcinav5MJZo=",
 			"path": "github.com/cncd/pipeline/pipeline/frontend/yaml/linter",
-			"revision": "b7427ae1fb86bb04e2997e5f3a1eec75c4b056ef",
+			"revision": "82706703c87f88a632674484e095e494c0e30e34",
-			"revisionTime": "2017-09-14T17:45:32Z"
+			"revisionTime": "2017-11-17T22:46:28Z"
 		},
 		{
 			"checksumSHA1": "kx2sPUIMozPC/g6E4w48h3FfH3k=",
 			"path": "github.com/cncd/pipeline/pipeline/frontend/yaml/matrix",
-			"revision": "b7427ae1fb86bb04e2997e5f3a1eec75c4b056ef",
+			"revision": "82706703c87f88a632674484e095e494c0e30e34",
-			"revisionTime": "2017-09-14T17:45:32Z"
+			"revisionTime": "2017-11-17T22:46:28Z"
 		},
 		{
 			"checksumSHA1": "L7Q5qJmPITNmvFEEaj5MPwCWFRk=",
 			"path": "github.com/cncd/pipeline/pipeline/frontend/yaml/types",
-			"revision": "b7427ae1fb86bb04e2997e5f3a1eec75c4b056ef",
+			"revision": "82706703c87f88a632674484e095e494c0e30e34",
-			"revisionTime": "2017-09-14T17:45:32Z"
+			"revisionTime": "2017-11-17T22:46:28Z"
 		},
 		{
 			"checksumSHA1": "2/3f3oNmxXy5kcrRLCFa24Oc9O4=",
 			"path": "github.com/cncd/pipeline/pipeline/interrupt",
-			"revision": "b7427ae1fb86bb04e2997e5f3a1eec75c4b056ef",
+			"revision": "82706703c87f88a632674484e095e494c0e30e34",
-			"revisionTime": "2017-09-14T17:45:32Z"
+			"revisionTime": "2017-11-17T22:46:28Z"
 		},
 		{
 			"checksumSHA1": "uOjTfke7Qxosrivgz/nVTHeIP5g=",
 			"path": "github.com/cncd/pipeline/pipeline/multipart",
-			"revision": "b7427ae1fb86bb04e2997e5f3a1eec75c4b056ef",
+			"revision": "82706703c87f88a632674484e095e494c0e30e34",
-			"revisionTime": "2017-09-14T17:45:32Z"
+			"revisionTime": "2017-11-17T22:46:28Z"
 		},
 		{
-			"checksumSHA1": "pyaqbQRdFkOGTE0mSNou27ikvfs=",
+			"checksumSHA1": "5oiGroE8hLXcj9hcZ+GGoBEm3o0=",
 			"path": "github.com/cncd/pipeline/pipeline/rpc",
-			"revision": "b7427ae1fb86bb04e2997e5f3a1eec75c4b056ef",
+			"revision": "82706703c87f88a632674484e095e494c0e30e34",
-			"revisionTime": "2017-09-14T17:45:32Z"
+			"revisionTime": "2017-11-17T22:46:28Z"
 		},
 		{
-			"checksumSHA1": "huYd+DhpBP/0kHMAC0mPZAZBmnw=",
+			"checksumSHA1": "N+3wNQ8hc/6yrh3FxbaxkEVwrkY=",
 			"path": "github.com/cncd/pipeline/pipeline/rpc/proto",
-			"revision": "b7427ae1fb86bb04e2997e5f3a1eec75c4b056ef",
+			"revision": "82706703c87f88a632674484e095e494c0e30e34",
-			"revisionTime": "2017-09-14T17:45:32Z"
+			"revisionTime": "2017-11-17T22:46:28Z"
 		},
 		{
 			"checksumSHA1": "7Qj1DK0ceAXkYztW0l3+L6sn+V8=",