setup /v2/skaffoldLogs endpoint (#5951)

pkg/skaffold/event/v2/event.go

@@ -68,6 +68,8 @@ type eventHandler struct {
 	logLock             sync.Mutex
 	applicationLogs     []proto.Event
 	applicationLogsLock sync.Mutex
+	skaffoldLogs        []proto.Event
+	skaffoldLogsLock    sync.Mutex
 	cfg                 Config
 
 	iteration               int
@@ -76,6 +78,7 @@ type eventHandler struct {
 	eventChan               chan *proto.Event
 	eventListeners          []*listener
 	applicationLogListeners []*listener
+	skaffoldLogListeners    []*listener
 }
 
 type listener struct {
@@ -101,6 +104,10 @@ func ForEachApplicationLog(callback func(*proto.Event) error) error {
 	return handler.forEachApplicationLog(callback)
 }
 
+func ForEachSkaffoldLog(callback func(*proto.Event) error) error {
+	return handler.forEachSkaffoldLog(callback)
+}
+
 func Handle(event *proto.Event) error {
 	if event != nil {
 		handler.handle(event)
@@ -178,6 +185,10 @@ func (ev *eventHandler) forEachApplicationLog(callback func(*proto.Event) error)
 	return ev.forEach(&ev.applicationLogListeners, &ev.applicationLogs, &ev.applicationLogsLock, callback)
 }
 
+func (ev *eventHandler) forEachSkaffoldLog(callback func(*proto.Event) error) error {
+	return ev.forEach(&ev.skaffoldLogListeners, &ev.skaffoldLogs, &ev.skaffoldLogsLock, callback)
+}
+
 func emptyState(cfg Config) proto.State {
 	builds := map[string]string{}
 	for _, p := range cfg.GetPipelines() {

pkg/skaffold/server/v2/endpoints.go

@@ -46,6 +46,10 @@ func (s *Server) ApplicationLogs(_ *empty.Empty, stream proto.SkaffoldV2Service_
 	return event.ForEachApplicationLog(stream.Send)
 }
 
+func (s *Server) SkaffoldLogs(_ *empty.Empty, stream proto.SkaffoldV2Service_SkaffoldLogsServer) error {
+	return event.ForEachSkaffoldLog(stream.Send)
+}
+
 func (s *Server) Handle(ctx context.Context, e *proto.Event) (*empty.Empty, error) {
 	return &empty.Empty{}, event.Handle(e)
 }