buildevent

Documentation

Index

• type Service
  • func NewService(besTopic sender) (*Service, error)
  • func (s *Service) PublishBuildToolEventStream(stream bpb.PublishBuildEvent_PublishBuildToolEventStreamServer) (retErr error)
  • func (s *Service) PublishLifecycleEvent(ctx context.Context, req *bpb.PublishLifecycleEventRequest) (*emptypb.Empty, error)
• type Topic
  • func NewTopic(t *pubsub.Topic) *Topic
  • func (t *Topic) Publish(ctx context.Context, msg *pubsub.Message) fetcher

Types

type Service

type Service struct {
	// contains filtered or unexported fields
}

Service implements the Build Event Protocol service.

func NewService

func NewService(besTopic sender) (*Service, error)

func (*Service) PublishBuildToolEventStream

func (s *Service) PublishBuildToolEventStream(stream bpb.PublishBuildEvent_PublishBuildToolEventStreamServer) (retErr error)

PublishBuildToolEventStream handles all the Bazel BES messages seen.

func (*Service) PublishLifecycleEvent

func (s *Service) PublishLifecycleEvent(ctx context.Context, req *bpb.PublishLifecycleEventRequest) (*emptypb.Empty, error)

PublishLifecycleEvent records the BEP lifecycle events seen in a metric, and not much else.

type Topic

type Topic struct {
	*pubsub.Topic
}

Topic wraps a pubsub.Topic so that it can expose the proper return type for Publish().

func NewTopic

func NewTopic(t *pubsub.Topic) *Topic

NewTopic wraps a pubsub.Topic with a *Topic so it can be used as a `sender`.

func (*Topic) Publish

func (t *Topic) Publish(ctx context.Context, msg *pubsub.Message) fetcher

Publish effectively casts a pubsub.MessageResult into a fetcher.