Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewBuildEventServer ¶
func NewBuildEventServer(db *ent.Client, blobArchiver processing.BlobMultiArchiver) build.PublishBuildEventServer
NewBuildEventServer creates a new BuildEventServer
Types ¶
type BuildEventChannel ¶
type BuildEventChannel interface {
// HandleBuildEvent processes a single BuildEvent
// This method should be called for each received event.
HandleBuildEvent(event *build.BuildEvent) error
// Finalize does post-processing of a stream of BuildEvents.
// This method should be called after receiving the EOF event.
Finalize() error
}
BuildEventChannel handles a single BuildEvent stream
type BuildEventHandler ¶
type BuildEventHandler struct {
// contains filtered or unexported fields
}
BuildEventHandler orchestrates the handling of incoming Build Event streams. For each incoming stream, and BuildEventChannel is created, which handles that stream. BuildEventHandler is responsible for managing the things that are common to these event streams.
func NewBuildEventHandler ¶
func NewBuildEventHandler(workflow *processing.Workflow) *BuildEventHandler
NewBuildEventHandler constructs a new BuildEventHandler TODO: Ensure we allow processing to complete before shutdown TODO: Cancel previous processing for an invocation if the client retries TODO: Write metrics
func (*BuildEventHandler) CreateEventChannel ¶
func (h *BuildEventHandler) CreateEventChannel(ctx context.Context, initialEvent *build.OrderedBuildEvent) BuildEventChannel
CreateEventChannel creates a new BuildEventChannel
type BuildEventServer ¶
type BuildEventServer struct {
// contains filtered or unexported fields
}
BuildEventServer implements the Build Event Service. It receives events and forwards them to a BuildEventChannel. TODO: Should this support forwarding events? Users might want to create their own tooling that reacts to build events, and it would be useful if this service could forward events to those.
func (BuildEventServer) PublishBuildToolEventStream ¶
func (s BuildEventServer) PublishBuildToolEventStream(stream build.PublishBuildEvent_PublishBuildToolEventStreamServer) error
PublishBuildToolEventStream handles a build tool event stream.
func (BuildEventServer) PublishLifecycleEvent ¶
func (s BuildEventServer) PublishLifecycleEvent(ctx context.Context, request *build.PublishLifecycleEventRequest) (*emptypb.Empty, error)
PublishLifecycleEvent handles life cycle events.
Source Files