TestMu Conference is Back! Future of Testing + AI LambdaTest G2 Announcement

How to use Publish method of event Package

Best Testkube code snippet using event.Publish

publish_build_event.pb.go

Source:publish_build_event.pb.go

...42const _ = proto.ProtoPackageIsVersion443// The service level of the build request. Backends only uses this value when44// the BuildEnqueued event is published to determine what level of service45// this build should receive.46type PublishLifecycleEventRequest_ServiceLevel int3247const (48	// Non-interactive builds can tolerate longer event latencies. This is the49	// default ServiceLevel if callers do not specify one.50	PublishLifecycleEventRequest_NONINTERACTIVE PublishLifecycleEventRequest_ServiceLevel = 051	// The events of an interactive build should be delivered with low latency.52	PublishLifecycleEventRequest_INTERACTIVE PublishLifecycleEventRequest_ServiceLevel = 153)54// Enum value maps for PublishLifecycleEventRequest_ServiceLevel.55var (56	PublishLifecycleEventRequest_ServiceLevel_name = map[int32]string{57		0: "NONINTERACTIVE",58		1: "INTERACTIVE",59	}60	PublishLifecycleEventRequest_ServiceLevel_value = map[string]int32{61		"NONINTERACTIVE": 0,62		"INTERACTIVE":    1,63	}64)65func (x PublishLifecycleEventRequest_ServiceLevel) Enum() *PublishLifecycleEventRequest_ServiceLevel {66	p := new(PublishLifecycleEventRequest_ServiceLevel)67	*p = x68	return p69}70func (x PublishLifecycleEventRequest_ServiceLevel) String() string {71	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))72}73func (PublishLifecycleEventRequest_ServiceLevel) Descriptor() protoreflect.EnumDescriptor {74	return file_google_devtools_build_v1_publish_build_event_proto_enumTypes[0].Descriptor()75}76func (PublishLifecycleEventRequest_ServiceLevel) Type() protoreflect.EnumType {77	return &file_google_devtools_build_v1_publish_build_event_proto_enumTypes[0]78}79func (x PublishLifecycleEventRequest_ServiceLevel) Number() protoreflect.EnumNumber {80	return protoreflect.EnumNumber(x)81}82// Deprecated: Use PublishLifecycleEventRequest_ServiceLevel.Descriptor instead.83func (PublishLifecycleEventRequest_ServiceLevel) EnumDescriptor() ([]byte, []int) {84	return file_google_devtools_build_v1_publish_build_event_proto_rawDescGZIP(), []int{0, 0}85}86// Publishes 'lifecycle events' that update the high-level state of a build:87// - BuildEnqueued: When a build is scheduled.88// - InvocationAttemptStarted: When work for a build starts; there can be89//     multiple invocations for a build (e.g. retries).90// - InvocationAttemptCompleted: When work for a build finishes.91// - BuildFinished: When a build is finished.92type PublishLifecycleEventRequest struct {93	state         protoimpl.MessageState94	sizeCache     protoimpl.SizeCache95	unknownFields protoimpl.UnknownFields96	// The interactivity of this build.97	ServiceLevel PublishLifecycleEventRequest_ServiceLevel `protobuf:"varint,1,opt,name=service_level,json=serviceLevel,proto3,enum=google.devtools.build.v1.PublishLifecycleEventRequest_ServiceLevel" json:"service_level,omitempty"`98	// Required. The lifecycle build event. If this is a build tool event, the RPC99	// will fail with INVALID_REQUEST.100	BuildEvent *OrderedBuildEvent `protobuf:"bytes,2,opt,name=build_event,json=buildEvent,proto3" json:"build_event,omitempty"`101	// If the next event for this build or invocation (depending on the event102	// type) hasn't been published after this duration from when {build_event}103	// is written to BES, consider this stream expired. If this field is not set,104	// BES backend will use its own default value.105	StreamTimeout *durationpb.Duration `protobuf:"bytes,3,opt,name=stream_timeout,json=streamTimeout,proto3" json:"stream_timeout,omitempty"`106	// Additional information about a build request. These are define by the event107	// publishers, and the Build Event Service does not validate or interpret108	// them. They are used while notifying internal systems of new builds and109	// invocations if the OrderedBuildEvent.event type is110	// BuildEnqueued/InvocationAttemptStarted.111	NotificationKeywords []string `protobuf:"bytes,4,rep,name=notification_keywords,json=notificationKeywords,proto3" json:"notification_keywords,omitempty"`112	// Required. The project this build is associated with.113	// This should match the project used for the initial call to114	// PublishLifecycleEvent (containing a BuildEnqueued message).115	ProjectId string `protobuf:"bytes,6,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`116}117func (x *PublishLifecycleEventRequest) Reset() {118	*x = PublishLifecycleEventRequest{}119	if protoimpl.UnsafeEnabled {120		mi := &file_google_devtools_build_v1_publish_build_event_proto_msgTypes[0]121		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))122		ms.StoreMessageInfo(mi)123	}124}125func (x *PublishLifecycleEventRequest) String() string {126	return protoimpl.X.MessageStringOf(x)127}128func (*PublishLifecycleEventRequest) ProtoMessage() {}129func (x *PublishLifecycleEventRequest) ProtoReflect() protoreflect.Message {130	mi := &file_google_devtools_build_v1_publish_build_event_proto_msgTypes[0]131	if protoimpl.UnsafeEnabled && x != nil {132		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))133		if ms.LoadMessageInfo() == nil {134			ms.StoreMessageInfo(mi)135		}136		return ms137	}138	return mi.MessageOf(x)139}140// Deprecated: Use PublishLifecycleEventRequest.ProtoReflect.Descriptor instead.141func (*PublishLifecycleEventRequest) Descriptor() ([]byte, []int) {142	return file_google_devtools_build_v1_publish_build_event_proto_rawDescGZIP(), []int{0}143}144func (x *PublishLifecycleEventRequest) GetServiceLevel() PublishLifecycleEventRequest_ServiceLevel {145	if x != nil {146		return x.ServiceLevel147	}148	return PublishLifecycleEventRequest_NONINTERACTIVE149}150func (x *PublishLifecycleEventRequest) GetBuildEvent() *OrderedBuildEvent {151	if x != nil {152		return x.BuildEvent153	}154	return nil155}156func (x *PublishLifecycleEventRequest) GetStreamTimeout() *durationpb.Duration {157	if x != nil {158		return x.StreamTimeout159	}160	return nil161}162func (x *PublishLifecycleEventRequest) GetNotificationKeywords() []string {163	if x != nil {164		return x.NotificationKeywords165	}166	return nil167}168func (x *PublishLifecycleEventRequest) GetProjectId() string {169	if x != nil {170		return x.ProjectId171	}172	return ""173}174// States which event has been committed. Any failure to commit will cause175// RPC errors, hence not recorded by this proto.176type PublishBuildToolEventStreamResponse struct {177	state         protoimpl.MessageState178	sizeCache     protoimpl.SizeCache179	unknownFields protoimpl.UnknownFields180	// The stream that contains this event.181	StreamId *StreamId `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`182	// The sequence number of this event that has been committed.183	SequenceNumber int64 `protobuf:"varint,2,opt,name=sequence_number,json=sequenceNumber,proto3" json:"sequence_number,omitempty"`184}185func (x *PublishBuildToolEventStreamResponse) Reset() {186	*x = PublishBuildToolEventStreamResponse{}187	if protoimpl.UnsafeEnabled {188		mi := &file_google_devtools_build_v1_publish_build_event_proto_msgTypes[1]189		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))190		ms.StoreMessageInfo(mi)191	}192}193func (x *PublishBuildToolEventStreamResponse) String() string {194	return protoimpl.X.MessageStringOf(x)195}196func (*PublishBuildToolEventStreamResponse) ProtoMessage() {}197func (x *PublishBuildToolEventStreamResponse) ProtoReflect() protoreflect.Message {198	mi := &file_google_devtools_build_v1_publish_build_event_proto_msgTypes[1]199	if protoimpl.UnsafeEnabled && x != nil {200		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))201		if ms.LoadMessageInfo() == nil {202			ms.StoreMessageInfo(mi)203		}204		return ms205	}206	return mi.MessageOf(x)207}208// Deprecated: Use PublishBuildToolEventStreamResponse.ProtoReflect.Descriptor instead.209func (*PublishBuildToolEventStreamResponse) Descriptor() ([]byte, []int) {210	return file_google_devtools_build_v1_publish_build_event_proto_rawDescGZIP(), []int{1}211}212func (x *PublishBuildToolEventStreamResponse) GetStreamId() *StreamId {213	if x != nil {214		return x.StreamId215	}216	return nil217}218func (x *PublishBuildToolEventStreamResponse) GetSequenceNumber() int64 {219	if x != nil {220		return x.SequenceNumber221	}222	return 0223}224// Build event with contextual information about the stream it belongs to and225// its position in that stream.226type OrderedBuildEvent struct {227	state         protoimpl.MessageState228	sizeCache     protoimpl.SizeCache229	unknownFields protoimpl.UnknownFields230	// Which build event stream this event belongs to.231	StreamId *StreamId `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`232	// The position of this event in the stream. The sequence numbers for a build233	// event stream should be a sequence of consecutive natural numbers starting234	// from one. (1, 2, 3, ...)235	SequenceNumber int64 `protobuf:"varint,2,opt,name=sequence_number,json=sequenceNumber,proto3" json:"sequence_number,omitempty"`236	// The actual event.237	Event *BuildEvent `protobuf:"bytes,3,opt,name=event,proto3" json:"event,omitempty"`238}239func (x *OrderedBuildEvent) Reset() {240	*x = OrderedBuildEvent{}241	if protoimpl.UnsafeEnabled {242		mi := &file_google_devtools_build_v1_publish_build_event_proto_msgTypes[2]243		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))244		ms.StoreMessageInfo(mi)245	}246}247func (x *OrderedBuildEvent) String() string {248	return protoimpl.X.MessageStringOf(x)249}250func (*OrderedBuildEvent) ProtoMessage() {}251func (x *OrderedBuildEvent) ProtoReflect() protoreflect.Message {252	mi := &file_google_devtools_build_v1_publish_build_event_proto_msgTypes[2]253	if protoimpl.UnsafeEnabled && x != nil {254		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))255		if ms.LoadMessageInfo() == nil {256			ms.StoreMessageInfo(mi)257		}258		return ms259	}260	return mi.MessageOf(x)261}262// Deprecated: Use OrderedBuildEvent.ProtoReflect.Descriptor instead.263func (*OrderedBuildEvent) Descriptor() ([]byte, []int) {264	return file_google_devtools_build_v1_publish_build_event_proto_rawDescGZIP(), []int{2}265}266func (x *OrderedBuildEvent) GetStreamId() *StreamId {267	if x != nil {268		return x.StreamId269	}270	return nil271}272func (x *OrderedBuildEvent) GetSequenceNumber() int64 {273	if x != nil {274		return x.SequenceNumber275	}276	return 0277}278func (x *OrderedBuildEvent) GetEvent() *BuildEvent {279	if x != nil {280		return x.Event281	}282	return nil283}284// Streaming request message for PublishBuildToolEventStream.285type PublishBuildToolEventStreamRequest struct {286	state         protoimpl.MessageState287	sizeCache     protoimpl.SizeCache288	unknownFields protoimpl.UnknownFields289	// Required. The build event with position info.290	// New publishing clients should use this field rather than the 3 above.291	OrderedBuildEvent *OrderedBuildEvent `protobuf:"bytes,4,opt,name=ordered_build_event,json=orderedBuildEvent,proto3" json:"ordered_build_event,omitempty"`292	// The keywords to be attached to the notification which notifies the start293	// of a new build event stream. BES only reads this field when sequence_number294	// or ordered_build_event.sequence_number is 1 in this message. If this field295	// is empty, BES will not publish notification messages for this stream.296	NotificationKeywords []string `protobuf:"bytes,5,rep,name=notification_keywords,json=notificationKeywords,proto3" json:"notification_keywords,omitempty"`297	// Required. The project this build is associated with.298	// This should match the project used for the initial call to299	// PublishLifecycleEvent (containing a BuildEnqueued message).300	ProjectId string `protobuf:"bytes,6,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`301}302func (x *PublishBuildToolEventStreamRequest) Reset() {303	*x = PublishBuildToolEventStreamRequest{}304	if protoimpl.UnsafeEnabled {305		mi := &file_google_devtools_build_v1_publish_build_event_proto_msgTypes[3]306		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))307		ms.StoreMessageInfo(mi)308	}309}310func (x *PublishBuildToolEventStreamRequest) String() string {311	return protoimpl.X.MessageStringOf(x)312}313func (*PublishBuildToolEventStreamRequest) ProtoMessage() {}314func (x *PublishBuildToolEventStreamRequest) ProtoReflect() protoreflect.Message {315	mi := &file_google_devtools_build_v1_publish_build_event_proto_msgTypes[3]316	if protoimpl.UnsafeEnabled && x != nil {317		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))318		if ms.LoadMessageInfo() == nil {319			ms.StoreMessageInfo(mi)320		}321		return ms322	}323	return mi.MessageOf(x)324}325// Deprecated: Use PublishBuildToolEventStreamRequest.ProtoReflect.Descriptor instead.326func (*PublishBuildToolEventStreamRequest) Descriptor() ([]byte, []int) {327	return file_google_devtools_build_v1_publish_build_event_proto_rawDescGZIP(), []int{3}328}329func (x *PublishBuildToolEventStreamRequest) GetOrderedBuildEvent() *OrderedBuildEvent {330	if x != nil {331		return x.OrderedBuildEvent332	}333	return nil334}335func (x *PublishBuildToolEventStreamRequest) GetNotificationKeywords() []string {336	if x != nil {337		return x.NotificationKeywords338	}339	return nil340}341func (x *PublishBuildToolEventStreamRequest) GetProjectId() string {342	if x != nil {343		return x.ProjectId344	}345	return ""346}347var File_google_devtools_build_v1_publish_build_event_proto protoreflect.FileDescriptor348var file_google_devtools_build_v1_publish_build_event_proto_rawDesc = []byte{349	0x0a, 0x32, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x64, 0x65, 0x76, 0x74, 0x6f, 0x6f, 0x6c,350	0x73, 0x2f, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x2f, 0x76, 0x31, 0x2f, 0x70, 0x75, 0x62, 0x6c, 0x69,351	0x73, 0x68, 0x5f, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x5f, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x2e, 0x70,352	0x72, 0x6f, 0x74, 0x6f, 0x12, 0x18, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x65, 0x76,353	0x74, 0x6f, 0x6f, 0x6c, 0x73, 0x2e, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x2e, 0x76, 0x31, 0x1a, 0x1c,354	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74,355	0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x17, 0x67, 0x6f,356	0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x2e,357	0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70,358	0x69, 0x2f, 0x66, 0x69, 0x65, 0x6c, 0x64, 0x5f, 0x62, 0x65, 0x68, 0x61, 0x76, 0x69, 0x6f, 0x72,359	0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x2b, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x64,360	0x65, 0x76, 0x74, 0x6f, 0x6f, 0x6c, 0x73, 0x2f, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x2f, 0x76, 0x31,361	0x2f, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x5f, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x2e, 0x70, 0x72,362	0x6f, 0x74, 0x6f, 0x1a, 0x1e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74,363	0x6f, 0x62, 0x75, 0x66, 0x2f, 0x64, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x70, 0x72,364	0x6f, 0x74, 0x6f, 0x1a, 0x1b, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74,365	0x6f, 0x62, 0x75, 0x66, 0x2f, 0x65, 0x6d, 0x70, 0x74, 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f,366	0x22, 0xab, 0x03, 0x0a, 0x1c, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x4c, 0x69, 0x66, 0x65,367	0x63, 0x79, 0x63, 0x6c, 0x65, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73,368	0x74, 0x12, 0x68, 0x0a, 0x0d, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x5f, 0x6c, 0x65, 0x76,369	0x65, 0x6c, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x43, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,370	0x65, 0x2e, 0x64, 0x65, 0x76, 0x74, 0x6f, 0x6f, 0x6c, 0x73, 0x2e, 0x62, 0x75, 0x69, 0x6c, 0x64,371	0x2e, 0x76, 0x31, 0x2e, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x4c, 0x69, 0x66, 0x65, 0x63,372	0x79, 0x63, 0x6c, 0x65, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,373	0x2e, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x4c, 0x65, 0x76, 0x65, 0x6c, 0x52, 0x0c, 0x73,374	0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x4c, 0x65, 0x76, 0x65, 0x6c, 0x12, 0x51, 0x0a, 0x0b, 0x62,375	0x75, 0x69, 0x6c, 0x64, 0x5f, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b,376	0x32, 0x2b, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x65, 0x76, 0x74, 0x6f, 0x6f,377	0x6c, 0x73, 0x2e, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x2e, 0x76, 0x31, 0x2e, 0x4f, 0x72, 0x64, 0x65,378	0x72, 0x65, 0x64, 0x42, 0x75, 0x69, 0x6c, 0x64, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x42, 0x03, 0xe0,379	0x41, 0x02, 0x52, 0x0a, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x12, 0x40,380	0x0a, 0x0e, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x6f, 0x75, 0x74,381	0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,382	0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x44, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f,383	0x6e, 0x52, 0x0d, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x54, 0x69, 0x6d, 0x65, 0x6f, 0x75, 0x74,384	0x12, 0x33, 0x0a, 0x15, 0x6e, 0x6f, 0x74, 0x69, 0x66, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e,385	0x5f, 0x6b, 0x65, 0x79, 0x77, 0x6f, 0x72, 0x64, 0x73, 0x18, 0x04, 0x20, 0x03, 0x28, 0x09, 0x52,386	0x14, 0x6e, 0x6f, 0x74, 0x69, 0x66, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x4b, 0x65, 0x79,387	0x77, 0x6f, 0x72, 0x64, 0x73, 0x12, 0x22, 0x0a, 0x0a, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74,388	0x5f, 0x69, 0x64, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x09,389	0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x49, 0x64, 0x22, 0x33, 0x0a, 0x0c, 0x53, 0x65, 0x72,390	0x76, 0x69, 0x63, 0x65, 0x4c, 0x65, 0x76, 0x65, 0x6c, 0x12, 0x12, 0x0a, 0x0e, 0x4e, 0x4f, 0x4e,391	0x49, 0x4e, 0x54, 0x45, 0x52, 0x41, 0x43, 0x54, 0x49, 0x56, 0x45, 0x10, 0x00, 0x12, 0x0f, 0x0a,392	0x0b, 0x49, 0x4e, 0x54, 0x45, 0x52, 0x41, 0x43, 0x54, 0x49, 0x56, 0x45, 0x10, 0x01, 0x22, 0x8f,393	0x01, 0x0a, 0x23, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x42, 0x75, 0x69, 0x6c, 0x64, 0x54,394	0x6f, 0x6f, 0x6c, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x65,395	0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x3f, 0x0a, 0x09, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d,396	0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x22, 0x2e, 0x67, 0x6f, 0x6f, 0x67,397	0x6c, 0x65, 0x2e, 0x64, 0x65, 0x76, 0x74, 0x6f, 0x6f, 0x6c, 0x73, 0x2e, 0x62, 0x75, 0x69, 0x6c,398	0x64, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x49, 0x64, 0x52, 0x08, 0x73,399	0x74, 0x72, 0x65, 0x61, 0x6d, 0x49, 0x64, 0x12, 0x27, 0x0a, 0x0f, 0x73, 0x65, 0x71, 0x75, 0x65,400	0x6e, 0x63, 0x65, 0x5f, 0x6e, 0x75, 0x6d, 0x62, 0x65, 0x72, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03,401	0x52, 0x0e, 0x73, 0x65, 0x71, 0x75, 0x65, 0x6e, 0x63, 0x65, 0x4e, 0x75, 0x6d, 0x62, 0x65, 0x72,402	0x22, 0xb9, 0x01, 0x0a, 0x11, 0x4f, 0x72, 0x64, 0x65, 0x72, 0x65, 0x64, 0x42, 0x75, 0x69, 0x6c,403	0x64, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x12, 0x3f, 0x0a, 0x09, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d,404	0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x22, 0x2e, 0x67, 0x6f, 0x6f, 0x67,405	0x6c, 0x65, 0x2e, 0x64, 0x65, 0x76, 0x74, 0x6f, 0x6f, 0x6c, 0x73, 0x2e, 0x62, 0x75, 0x69, 0x6c,406	0x64, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x49, 0x64, 0x52, 0x08, 0x73,407	0x74, 0x72, 0x65, 0x61, 0x6d, 0x49, 0x64, 0x12, 0x27, 0x0a, 0x0f, 0x73, 0x65, 0x71, 0x75, 0x65,408	0x6e, 0x63, 0x65, 0x5f, 0x6e, 0x75, 0x6d, 0x62, 0x65, 0x72, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03,409	0x52, 0x0e, 0x73, 0x65, 0x71, 0x75, 0x65, 0x6e, 0x63, 0x65, 0x4e, 0x75, 0x6d, 0x62, 0x65, 0x72,410	0x12, 0x3a, 0x0a, 0x05, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32,411	0x24, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x65, 0x76, 0x74, 0x6f, 0x6f, 0x6c,412	0x73, 0x2e, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x2e, 0x76, 0x31, 0x2e, 0x42, 0x75, 0x69, 0x6c, 0x64,413	0x45, 0x76, 0x65, 0x6e, 0x74, 0x52, 0x05, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x22, 0xdf, 0x01, 0x0a,414	0x22, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x42, 0x75, 0x69, 0x6c, 0x64, 0x54, 0x6f, 0x6f,415	0x6c, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x65, 0x71, 0x75,416	0x65, 0x73, 0x74, 0x12, 0x60, 0x0a, 0x13, 0x6f, 0x72, 0x64, 0x65, 0x72, 0x65, 0x64, 0x5f, 0x62,417	0x75, 0x69, 0x6c, 0x64, 0x5f, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b,418	0x32, 0x2b, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x65, 0x76, 0x74, 0x6f, 0x6f,419	0x6c, 0x73, 0x2e, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x2e, 0x76, 0x31, 0x2e, 0x4f, 0x72, 0x64, 0x65,420	0x72, 0x65, 0x64, 0x42, 0x75, 0x69, 0x6c, 0x64, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x42, 0x03, 0xe0,421	0x41, 0x02, 0x52, 0x11, 0x6f, 0x72, 0x64, 0x65, 0x72, 0x65, 0x64, 0x42, 0x75, 0x69, 0x6c, 0x64,422	0x45, 0x76, 0x65, 0x6e, 0x74, 0x12, 0x33, 0x0a, 0x15, 0x6e, 0x6f, 0x74, 0x69, 0x66, 0x69, 0x63,423	0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x6b, 0x65, 0x79, 0x77, 0x6f, 0x72, 0x64, 0x73, 0x18, 0x05,424	0x20, 0x03, 0x28, 0x09, 0x52, 0x14, 0x6e, 0x6f, 0x74, 0x69, 0x66, 0x69, 0x63, 0x61, 0x74, 0x69,425	0x6f, 0x6e, 0x4b, 0x65, 0x79, 0x77, 0x6f, 0x72, 0x64, 0x73, 0x12, 0x22, 0x0a, 0x0a, 0x70, 0x72,426	0x6f, 0x6a, 0x65, 0x63, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03,427	0xe0, 0x41, 0x02, 0x52, 0x09, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x49, 0x64, 0x32, 0xde,428	0x04, 0x0a, 0x11, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x42, 0x75, 0x69, 0x6c, 0x64, 0x45,429	0x76, 0x65, 0x6e, 0x74, 0x12, 0xc9, 0x01, 0x0a, 0x15, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68,430	0x4c, 0x69, 0x66, 0x65, 0x63, 0x79, 0x63, 0x6c, 0x65, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x12, 0x36,431	0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x65, 0x76, 0x74, 0x6f, 0x6f, 0x6c, 0x73,432	0x2e, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x2e, 0x76, 0x31, 0x2e, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73,433	0x68, 0x4c, 0x69, 0x66, 0x65, 0x63, 0x79, 0x63, 0x6c, 0x65, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x52,434	0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,435	0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x22, 0x60,436	0x82, 0xd3, 0xe4, 0x93, 0x02, 0x5a, 0x22, 0x33, 0x2f, 0x76, 0x31, 0x2f, 0x70, 0x72, 0x6f, 0x6a,437	0x65, 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x5f, 0x69, 0x64,438	0x3d, 0x2a, 0x7d, 0x2f, 0x6c, 0x69, 0x66, 0x65, 0x63, 0x79, 0x63, 0x6c, 0x65, 0x45, 0x76, 0x65,439	0x6e, 0x74, 0x73, 0x3a, 0x70, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x3a, 0x01, 0x2a, 0x5a, 0x20,440	0x22, 0x1b, 0x2f, 0x76, 0x31, 0x2f, 0x6c, 0x69, 0x66, 0x65, 0x63, 0x79, 0x63, 0x6c, 0x65, 0x45,441	0x76, 0x65, 0x6e, 0x74, 0x73, 0x3a, 0x70, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x3a, 0x01, 0x2a,442	0x12, 0xa6, 0x02, 0x0a, 0x1b, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x42, 0x75, 0x69, 0x6c,443	0x64, 0x54, 0x6f, 0x6f, 0x6c, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d,444	0x12, 0x3c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x65, 0x76, 0x74, 0x6f, 0x6f,445	0x6c, 0x73, 0x2e, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x2e, 0x76, 0x31, 0x2e, 0x50, 0x75, 0x62, 0x6c,446	0x69, 0x73, 0x68, 0x42, 0x75, 0x69, 0x6c, 0x64, 0x54, 0x6f, 0x6f, 0x6c, 0x45, 0x76, 0x65, 0x6e,447	0x74, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x3d,448	0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64, 0x65, 0x76, 0x74, 0x6f, 0x6f, 0x6c, 0x73,449	0x2e, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x2e, 0x76, 0x31, 0x2e, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73,450	0x68, 0x42, 0x75, 0x69, 0x6c, 0x64, 0x54, 0x6f, 0x6f, 0x6c, 0x45, 0x76, 0x65, 0x6e, 0x74, 0x53,451	0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x85, 0x01,452	0x82, 0xd3, 0xe4, 0x93, 0x02, 0x48, 0x22, 0x2a, 0x2f, 0x76, 0x31, 0x2f, 0x70, 0x72, 0x6f, 0x6a,453	0x65, 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x5f, 0x69, 0x64,454	0x3d, 0x2a, 0x7d, 0x2f, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x3a, 0x70, 0x75, 0x62, 0x6c, 0x69,455	0x73, 0x68, 0x3a, 0x01, 0x2a, 0x5a, 0x17, 0x22, 0x12, 0x2f, 0x76, 0x31, 0x2f, 0x65, 0x76, 0x65,456	0x6e, 0x74, 0x73, 0x3a, 0x70, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x3a, 0x01, 0x2a, 0xda, 0x41,457	0x34, 0x6f, 0x72, 0x64, 0x65, 0x72, 0x65, 0x64, 0x5f, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x5f, 0x65,458	0x76, 0x65, 0x6e, 0x74, 0x2c, 0x6e, 0x6f, 0x74, 0x69, 0x66, 0x69, 0x63, 0x61, 0x74, 0x69, 0x6f,459	0x6e, 0x5f, 0x6b, 0x65, 0x79, 0x77, 0x6f, 0x72, 0x64, 0x73, 0x2c, 0x70, 0x72, 0x6f, 0x6a, 0x65,460	0x63, 0x74, 0x5f, 0x69, 0x64, 0x28, 0x01, 0x30, 0x01, 0x1a, 0x54, 0xca, 0x41, 0x20, 0x62, 0x75,461	0x69, 0x6c, 0x64, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e,462	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0xd2, 0x41,463	0x2e, 0x68, 0x74, 0x74, 0x70, 0x73, 0x3a, 0x2f, 0x2f, 0x77, 0x77, 0x77, 0x2e, 0x67, 0x6f, 0x6f,464	0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x61, 0x75, 0x74, 0x68,465	0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2d, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x42,466	0x88, 0x01, 0x0a, 0x1c, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x64,467	0x65, 0x76, 0x74, 0x6f, 0x6f, 0x6c, 0x73, 0x2e, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x2e, 0x76, 0x31,468	0x42, 0x0c, 0x42, 0x61, 0x63, 0x6b, 0x65, 0x6e, 0x64, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01,469	0x5a, 0x3d, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x6f, 0x6c, 0x61, 0x6e, 0x67, 0x2e,470	0x6f, 0x72, 0x67, 0x2f, 0x67, 0x65, 0x6e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x6f,471	0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2f, 0x64, 0x65, 0x76, 0x74, 0x6f, 0x6f, 0x6c, 0x73,472	0x2f, 0x62, 0x75, 0x69, 0x6c, 0x64, 0x2f, 0x76, 0x31, 0x3b, 0x62, 0x75, 0x69, 0x6c, 0x64, 0xf8,473	0x01, 0x01, 0xca, 0x02, 0x15, 0x47, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x5c, 0x43, 0x6c, 0x6f, 0x75,474	0x64, 0x5c, 0x42, 0x75, 0x69, 0x6c, 0x64, 0x5c, 0x56, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74,475	0x6f, 0x33,476}477var (478	file_google_devtools_build_v1_publish_build_event_proto_rawDescOnce sync.Once479	file_google_devtools_build_v1_publish_build_event_proto_rawDescData = file_google_devtools_build_v1_publish_build_event_proto_rawDesc480)481func file_google_devtools_build_v1_publish_build_event_proto_rawDescGZIP() []byte {482	file_google_devtools_build_v1_publish_build_event_proto_rawDescOnce.Do(func() {483		file_google_devtools_build_v1_publish_build_event_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_devtools_build_v1_publish_build_event_proto_rawDescData)484	})485	return file_google_devtools_build_v1_publish_build_event_proto_rawDescData486}487var file_google_devtools_build_v1_publish_build_event_proto_enumTypes = make([]protoimpl.EnumInfo, 1)488var file_google_devtools_build_v1_publish_build_event_proto_msgTypes = make([]protoimpl.MessageInfo, 4)489var file_google_devtools_build_v1_publish_build_event_proto_goTypes = []interface{}{490	(PublishLifecycleEventRequest_ServiceLevel)(0), // 0: google.devtools.build.v1.PublishLifecycleEventRequest.ServiceLevel491	(*PublishLifecycleEventRequest)(nil),           // 1: google.devtools.build.v1.PublishLifecycleEventRequest492	(*PublishBuildToolEventStreamResponse)(nil),    // 2: google.devtools.build.v1.PublishBuildToolEventStreamResponse493	(*OrderedBuildEvent)(nil),                      // 3: google.devtools.build.v1.OrderedBuildEvent494	(*PublishBuildToolEventStreamRequest)(nil),     // 4: google.devtools.build.v1.PublishBuildToolEventStreamRequest495	(*durationpb.Duration)(nil),                    // 5: google.protobuf.Duration496	(*StreamId)(nil),                               // 6: google.devtools.build.v1.StreamId497	(*BuildEvent)(nil),                             // 7: google.devtools.build.v1.BuildEvent498	(*emptypb.Empty)(nil),                          // 8: google.protobuf.Empty499}500var file_google_devtools_build_v1_publish_build_event_proto_depIdxs = []int32{501	0, // 0: google.devtools.build.v1.PublishLifecycleEventRequest.service_level:type_name -> google.devtools.build.v1.PublishLifecycleEventRequest.ServiceLevel502	3, // 1: google.devtools.build.v1.PublishLifecycleEventRequest.build_event:type_name -> google.devtools.build.v1.OrderedBuildEvent503	5, // 2: google.devtools.build.v1.PublishLifecycleEventRequest.stream_timeout:type_name -> google.protobuf.Duration504	6, // 3: google.devtools.build.v1.PublishBuildToolEventStreamResponse.stream_id:type_name -> google.devtools.build.v1.StreamId505	6, // 4: google.devtools.build.v1.OrderedBuildEvent.stream_id:type_name -> google.devtools.build.v1.StreamId506	7, // 5: google.devtools.build.v1.OrderedBuildEvent.event:type_name -> google.devtools.build.v1.BuildEvent507	3, // 6: google.devtools.build.v1.PublishBuildToolEventStreamRequest.ordered_build_event:type_name -> google.devtools.build.v1.OrderedBuildEvent508	1, // 7: google.devtools.build.v1.PublishBuildEvent.PublishLifecycleEvent:input_type -> google.devtools.build.v1.PublishLifecycleEventRequest509	4, // 8: google.devtools.build.v1.PublishBuildEvent.PublishBuildToolEventStream:input_type -> google.devtools.build.v1.PublishBuildToolEventStreamRequest510	8, // 9: google.devtools.build.v1.PublishBuildEvent.PublishLifecycleEvent:output_type -> google.protobuf.Empty511	2, // 10: google.devtools.build.v1.PublishBuildEvent.PublishBuildToolEventStream:output_type -> google.devtools.build.v1.PublishBuildToolEventStreamResponse512	9, // [9:11] is the sub-list for method output_type513	7, // [7:9] is the sub-list for method input_type514	7, // [7:7] is the sub-list for extension type_name515	7, // [7:7] is the sub-list for extension extendee516	0, // [0:7] is the sub-list for field type_name517}518func init() { file_google_devtools_build_v1_publish_build_event_proto_init() }519func file_google_devtools_build_v1_publish_build_event_proto_init() {520	if File_google_devtools_build_v1_publish_build_event_proto != nil {521		return522	}523	file_google_devtools_build_v1_build_events_proto_init()524	if !protoimpl.UnsafeEnabled {525		file_google_devtools_build_v1_publish_build_event_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {526			switch v := v.(*PublishLifecycleEventRequest); i {527			case 0:528				return &v.state529			case 1:530				return &v.sizeCache531			case 2:532				return &v.unknownFields533			default:534				return nil535			}536		}537		file_google_devtools_build_v1_publish_build_event_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {538			switch v := v.(*PublishBuildToolEventStreamResponse); i {539			case 0:540				return &v.state541			case 1:542				return &v.sizeCache543			case 2:544				return &v.unknownFields545			default:546				return nil547			}548		}549		file_google_devtools_build_v1_publish_build_event_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {550			switch v := v.(*OrderedBuildEvent); i {551			case 0:552				return &v.state553			case 1:554				return &v.sizeCache555			case 2:556				return &v.unknownFields557			default:558				return nil559			}560		}561		file_google_devtools_build_v1_publish_build_event_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {562			switch v := v.(*PublishBuildToolEventStreamRequest); i {563			case 0:564				return &v.state565			case 1:566				return &v.sizeCache567			case 2:568				return &v.unknownFields569			default:570				return nil571			}572		}573	}574	type x struct{}575	out := protoimpl.TypeBuilder{576		File: protoimpl.DescBuilder{577			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),578			RawDescriptor: file_google_devtools_build_v1_publish_build_event_proto_rawDesc,579			NumEnums:      1,580			NumMessages:   4,581			NumExtensions: 0,582			NumServices:   1,583		},584		GoTypes:           file_google_devtools_build_v1_publish_build_event_proto_goTypes,585		DependencyIndexes: file_google_devtools_build_v1_publish_build_event_proto_depIdxs,586		EnumInfos:         file_google_devtools_build_v1_publish_build_event_proto_enumTypes,587		MessageInfos:      file_google_devtools_build_v1_publish_build_event_proto_msgTypes,588	}.Build()589	File_google_devtools_build_v1_publish_build_event_proto = out.File590	file_google_devtools_build_v1_publish_build_event_proto_rawDesc = nil591	file_google_devtools_build_v1_publish_build_event_proto_goTypes = nil592	file_google_devtools_build_v1_publish_build_event_proto_depIdxs = nil593}594// Reference imports to suppress errors if they are not otherwise used.595var _ context.Context596var _ grpc.ClientConnInterface597// This is a compile-time assertion to ensure that this generated file598// is compatible with the grpc package it is being compiled against.599const _ = grpc.SupportPackageIsVersion6600// PublishBuildEventClient is the client API for PublishBuildEvent service.601//602// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.603type PublishBuildEventClient interface {604	// Publish a build event stating the new state of a build (typically from the605	// build queue). The BuildEnqueued event must be publishd before all other606	// events for the same build ID.607	//608	// The backend will persist the event and deliver it to registered frontend609	// jobs immediately without batching.610	//611	// The commit status of the request is reported by the RPC's util_status()612	// function. The error code is the canoncial error code defined in613	// //util/task/codes.proto.614	PublishLifecycleEvent(ctx context.Context, in *PublishLifecycleEventRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)615	// Publish build tool events belonging to the same stream to a backend job616	// using bidirectional streaming.617	PublishBuildToolEventStream(ctx context.Context, opts ...grpc.CallOption) (PublishBuildEvent_PublishBuildToolEventStreamClient, error)618}619type publishBuildEventClient struct {620	cc grpc.ClientConnInterface621}622func NewPublishBuildEventClient(cc grpc.ClientConnInterface) PublishBuildEventClient {623	return &publishBuildEventClient{cc}624}625func (c *publishBuildEventClient) PublishLifecycleEvent(ctx context.Context, in *PublishLifecycleEventRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {626	out := new(emptypb.Empty)627	err := c.cc.Invoke(ctx, "/google.devtools.build.v1.PublishBuildEvent/PublishLifecycleEvent", in, out, opts...)628	if err != nil {629		return nil, err630	}631	return out, nil632}633func (c *publishBuildEventClient) PublishBuildToolEventStream(ctx context.Context, opts ...grpc.CallOption) (PublishBuildEvent_PublishBuildToolEventStreamClient, error) {634	stream, err := c.cc.NewStream(ctx, &_PublishBuildEvent_serviceDesc.Streams[0], "/google.devtools.build.v1.PublishBuildEvent/PublishBuildToolEventStream", opts...)635	if err != nil {636		return nil, err637	}638	x := &publishBuildEventPublishBuildToolEventStreamClient{stream}639	return x, nil640}641type PublishBuildEvent_PublishBuildToolEventStreamClient interface {642	Send(*PublishBuildToolEventStreamRequest) error643	Recv() (*PublishBuildToolEventStreamResponse, error)644	grpc.ClientStream645}646type publishBuildEventPublishBuildToolEventStreamClient struct {647	grpc.ClientStream648}649func (x *publishBuildEventPublishBuildToolEventStreamClient) Send(m *PublishBuildToolEventStreamRequest) error {650	return x.ClientStream.SendMsg(m)651}652func (x *publishBuildEventPublishBuildToolEventStreamClient) Recv() (*PublishBuildToolEventStreamResponse, error) {653	m := new(PublishBuildToolEventStreamResponse)654	if err := x.ClientStream.RecvMsg(m); err != nil {655		return nil, err656	}657	return m, nil658}659// PublishBuildEventServer is the server API for PublishBuildEvent service.660type PublishBuildEventServer interface {661	// Publish a build event stating the new state of a build (typically from the662	// build queue). The BuildEnqueued event must be publishd before all other663	// events for the same build ID.664	//665	// The backend will persist the event and deliver it to registered frontend666	// jobs immediately without batching.667	//668	// The commit status of the request is reported by the RPC's util_status()669	// function. The error code is the canoncial error code defined in670	// //util/task/codes.proto.671	PublishLifecycleEvent(context.Context, *PublishLifecycleEventRequest) (*emptypb.Empty, error)672	// Publish build tool events belonging to the same stream to a backend job673	// using bidirectional streaming.674	PublishBuildToolEventStream(PublishBuildEvent_PublishBuildToolEventStreamServer) error675}676// UnimplementedPublishBuildEventServer can be embedded to have forward compatible implementations.677type UnimplementedPublishBuildEventServer struct {678}679func (*UnimplementedPublishBuildEventServer) PublishLifecycleEvent(context.Context, *PublishLifecycleEventRequest) (*emptypb.Empty, error) {680	return nil, status.Errorf(codes.Unimplemented, "method PublishLifecycleEvent not implemented")681}682func (*UnimplementedPublishBuildEventServer) PublishBuildToolEventStream(PublishBuildEvent_PublishBuildToolEventStreamServer) error {683	return status.Errorf(codes.Unimplemented, "method PublishBuildToolEventStream not implemented")684}685func RegisterPublishBuildEventServer(s *grpc.Server, srv PublishBuildEventServer) {686	s.RegisterService(&_PublishBuildEvent_serviceDesc, srv)687}688func _PublishBuildEvent_PublishLifecycleEvent_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {689	in := new(PublishLifecycleEventRequest)690	if err := dec(in); err != nil {691		return nil, err692	}693	if interceptor == nil {694		return srv.(PublishBuildEventServer).PublishLifecycleEvent(ctx, in)695	}696	info := &grpc.UnaryServerInfo{697		Server:     srv,698		FullMethod: "/google.devtools.build.v1.PublishBuildEvent/PublishLifecycleEvent",699	}700	handler := func(ctx context.Context, req interface{}) (interface{}, error) {701		return srv.(PublishBuildEventServer).PublishLifecycleEvent(ctx, req.(*PublishLifecycleEventRequest))702	}703	return interceptor(ctx, in, info, handler)704}705func _PublishBuildEvent_PublishBuildToolEventStream_Handler(srv interface{}, stream grpc.ServerStream) error {706	return srv.(PublishBuildEventServer).PublishBuildToolEventStream(&publishBuildEventPublishBuildToolEventStreamServer{stream})707}708type PublishBuildEvent_PublishBuildToolEventStreamServer interface {709	Send(*PublishBuildToolEventStreamResponse) error710	Recv() (*PublishBuildToolEventStreamRequest, error)711	grpc.ServerStream712}713type publishBuildEventPublishBuildToolEventStreamServer struct {714	grpc.ServerStream715}716func (x *publishBuildEventPublishBuildToolEventStreamServer) Send(m *PublishBuildToolEventStreamResponse) error {717	return x.ServerStream.SendMsg(m)718}719func (x *publishBuildEventPublishBuildToolEventStreamServer) Recv() (*PublishBuildToolEventStreamRequest, error) {720	m := new(PublishBuildToolEventStreamRequest)721	if err := x.ServerStream.RecvMsg(m); err != nil {722		return nil, err723	}724	return m, nil725}726var _PublishBuildEvent_serviceDesc = grpc.ServiceDesc{727	ServiceName: "google.devtools.build.v1.PublishBuildEvent",728	HandlerType: (*PublishBuildEventServer)(nil),729	Methods: []grpc.MethodDesc{730		{731			MethodName: "PublishLifecycleEvent",732			Handler:    _PublishBuildEvent_PublishLifecycleEvent_Handler,733		},734	},735	Streams: []grpc.StreamDesc{736		{737			StreamName:    "PublishBuildToolEventStream",738			Handler:       _PublishBuildEvent_PublishBuildToolEventStream_Handler,739			ServerStreams: true,740			ClientStreams: true,741		},742	},743	Metadata: "google/devtools/build/v1/publish_build_event.proto",744}...

publish_build_event_client.go

Source:publish_build_event_client.go

...26	buildpb "google.golang.org/genproto/googleapis/devtools/build/v1"27	"google.golang.org/grpc"28	"google.golang.org/grpc/metadata"29)30var newPublishBuildEventClientHook clientHook31// PublishBuildEventCallOptions contains the retry settings for each method of PublishBuildEventClient.32type PublishBuildEventCallOptions struct {33	PublishLifecycleEvent       []gax.CallOption34	PublishBuildToolEventStream []gax.CallOption35}36func defaultPublishBuildEventGRPCClientOptions() []option.ClientOption {37	return []option.ClientOption{38		internaloption.WithDefaultEndpoint("buildeventservice.googleapis.com:443"),39		internaloption.WithDefaultMTLSEndpoint("buildeventservice.mtls.googleapis.com:443"),40		internaloption.WithDefaultAudience("https://buildeventservice.googleapis.com/"),41		internaloption.WithDefaultScopes(DefaultAuthScopes()...),42		internaloption.EnableJwtWithScope(),43		option.WithGRPCDialOption(grpc.WithDefaultCallOptions(44			grpc.MaxCallRecvMsgSize(math.MaxInt32))),45	}46}47func defaultPublishBuildEventCallOptions() *PublishBuildEventCallOptions {48	return &PublishBuildEventCallOptions{49		PublishLifecycleEvent:       []gax.CallOption{},50		PublishBuildToolEventStream: []gax.CallOption{},51	}52}53// internalPublishBuildEventClient is an interface that defines the methods availaible from Build Event Service Backend API.54type internalPublishBuildEventClient interface {55	Close() error56	setGoogleClientInfo(...string)57	Connection() *grpc.ClientConn58	PublishLifecycleEvent(context.Context, *buildpb.PublishLifecycleEventRequest, ...gax.CallOption) error59	PublishBuildToolEventStream(context.Context, ...gax.CallOption) (buildpb.PublishBuildEvent_PublishBuildToolEventStreamClient, error)60}61// PublishBuildEventClient is a client for interacting with Build Event Service Backend API.62// Methods, except Close, may be called concurrently. However, fields must not be modified concurrently with method calls.63//64// A service for publishing BuildEvents. BuildEvents are generated by Build65// Systems to record actions taken during a Build. Events occur in streams,66// are identified by a StreamId, and ordered by sequence number in a stream.67//68// A Build may contain several streams of BuildEvents, depending on the systems69// that are involved in the Build. Some BuildEvents are used to declare the70// beginning and end of major portions of a Build; these are called71// LifecycleEvents, and are used (for example) to indicate the beginning or end72// of a Build, and the beginning or end of an Invocation attempt (there can be73// more than 1 Invocation in a Build if, for example, a failure occurs somewhere74// and it needs to be retried).75//76// Other, build-tool events represent actions taken by the Build tool, such as77// target objects produced via compilation, tests run, et cetera. There could be78// more than one build tool stream for an invocation attempt of a build.79type PublishBuildEventClient struct {80	// The internal transport-dependent client.81	internalClient internalPublishBuildEventClient82	// The call options for this service.83	CallOptions *PublishBuildEventCallOptions84}85// Wrapper methods routed to the internal client.86// Close closes the connection to the API service. The user should invoke this when87// the client is no longer required.88func (c *PublishBuildEventClient) Close() error {89	return c.internalClient.Close()90}91// setGoogleClientInfo sets the name and version of the application in92// the `x-goog-api-client` header passed on each request. Intended for93// use by Google-written clients.94func (c *PublishBuildEventClient) setGoogleClientInfo(keyval ...string) {95	c.internalClient.setGoogleClientInfo(keyval...)96}97// Connection returns a connection to the API service.98//99// Deprecated.100func (c *PublishBuildEventClient) Connection() *grpc.ClientConn {101	return c.internalClient.Connection()102}103// PublishLifecycleEvent publish a build event stating the new state of a build (typically from the104// build queue). The BuildEnqueued event must be publishd before all other105// events for the same build ID.106//107// The backend will persist the event and deliver it to registered frontend108// jobs immediately without batching.109//110// The commit status of the request is reported by the RPCâs util_status()111// function. The error code is the canoncial error code defined in112// //util/task/codes.proto.113func (c *PublishBuildEventClient) PublishLifecycleEvent(ctx context.Context, req *buildpb.PublishLifecycleEventRequest, opts ...gax.CallOption) error {114	return c.internalClient.PublishLifecycleEvent(ctx, req, opts...)115}116// PublishBuildToolEventStream publish build tool events belonging to the same stream to a backend job117// using bidirectional streaming.118func (c *PublishBuildEventClient) PublishBuildToolEventStream(ctx context.Context, opts ...gax.CallOption) (buildpb.PublishBuildEvent_PublishBuildToolEventStreamClient, error) {119	return c.internalClient.PublishBuildToolEventStream(ctx, opts...)120}121// publishBuildEventGRPCClient is a client for interacting with Build Event Service Backend API over gRPC transport.122//123// Methods, except Close, may be called concurrently. However, fields must not be modified concurrently with method calls.124type publishBuildEventGRPCClient struct {125	// Connection pool of gRPC connections to the service.126	connPool gtransport.ConnPool127	// flag to opt out of default deadlines via GOOGLE_API_GO_EXPERIMENTAL_DISABLE_DEFAULT_DEADLINE128	disableDeadlines bool129	// Points back to the CallOptions field of the containing PublishBuildEventClient130	CallOptions **PublishBuildEventCallOptions131	// The gRPC API client.132	publishBuildEventClient buildpb.PublishBuildEventClient133	// The x-goog-* metadata to be sent with each request.134	xGoogMetadata metadata.MD135}136// NewPublishBuildEventClient creates a new publish build event client based on gRPC.137// The returned client must be Closed when it is done being used to clean up its underlying connections.138//139// A service for publishing BuildEvents. BuildEvents are generated by Build140// Systems to record actions taken during a Build. Events occur in streams,141// are identified by a StreamId, and ordered by sequence number in a stream.142//143// A Build may contain several streams of BuildEvents, depending on the systems144// that are involved in the Build. Some BuildEvents are used to declare the145// beginning and end of major portions of a Build; these are called146// LifecycleEvents, and are used (for example) to indicate the beginning or end147// of a Build, and the beginning or end of an Invocation attempt (there can be148// more than 1 Invocation in a Build if, for example, a failure occurs somewhere149// and it needs to be retried).150//151// Other, build-tool events represent actions taken by the Build tool, such as152// target objects produced via compilation, tests run, et cetera. There could be153// more than one build tool stream for an invocation attempt of a build.154func NewPublishBuildEventClient(ctx context.Context, opts ...option.ClientOption) (*PublishBuildEventClient, error) {155	clientOpts := defaultPublishBuildEventGRPCClientOptions()156	if newPublishBuildEventClientHook != nil {157		hookOpts, err := newPublishBuildEventClientHook(ctx, clientHookParams{})158		if err != nil {159			return nil, err160		}161		clientOpts = append(clientOpts, hookOpts...)162	}163	disableDeadlines, err := checkDisableDeadlines()164	if err != nil {165		return nil, err166	}167	connPool, err := gtransport.DialPool(ctx, append(clientOpts, opts...)...)168	if err != nil {169		return nil, err170	}171	client := PublishBuildEventClient{CallOptions: defaultPublishBuildEventCallOptions()}172	c := &publishBuildEventGRPCClient{173		connPool:                connPool,174		disableDeadlines:        disableDeadlines,175		publishBuildEventClient: buildpb.NewPublishBuildEventClient(connPool),176		CallOptions:             &client.CallOptions,177	}178	c.setGoogleClientInfo()179	client.internalClient = c180	return &client, nil181}182// Connection returns a connection to the API service.183//184// Deprecated.185func (c *publishBuildEventGRPCClient) Connection() *grpc.ClientConn {186	return c.connPool.Conn()187}188// setGoogleClientInfo sets the name and version of the application in189// the `x-goog-api-client` header passed on each request. Intended for190// use by Google-written clients.191func (c *publishBuildEventGRPCClient) setGoogleClientInfo(keyval ...string) {192	kv := append([]string{"gl-go", versionGo()}, keyval...)193	kv = append(kv, "gapic", versionClient, "gax", gax.Version, "grpc", grpc.Version)194	c.xGoogMetadata = metadata.Pairs("x-goog-api-client", gax.XGoogHeader(kv...))195}196// Close closes the connection to the API service. The user should invoke this when197// the client is no longer required.198func (c *publishBuildEventGRPCClient) Close() error {199	return c.connPool.Close()200}201func (c *publishBuildEventGRPCClient) PublishLifecycleEvent(ctx context.Context, req *buildpb.PublishLifecycleEventRequest, opts ...gax.CallOption) error {202	if _, ok := ctx.Deadline(); !ok && !c.disableDeadlines {203		cctx, cancel := context.WithTimeout(ctx, 600000*time.Millisecond)204		defer cancel()205		ctx = cctx206	}207	md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "project_id", url.QueryEscape(req.GetProjectId())))208	ctx = insertMetadata(ctx, c.xGoogMetadata, md)209	opts = append((*c.CallOptions).PublishLifecycleEvent[0:len((*c.CallOptions).PublishLifecycleEvent):len((*c.CallOptions).PublishLifecycleEvent)], opts...)210	err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error {211		var err error212		_, err = c.publishBuildEventClient.PublishLifecycleEvent(ctx, req, settings.GRPC...)213		return err214	}, opts...)215	return err216}217func (c *publishBuildEventGRPCClient) PublishBuildToolEventStream(ctx context.Context, opts ...gax.CallOption) (buildpb.PublishBuildEvent_PublishBuildToolEventStreamClient, error) {218	ctx = insertMetadata(ctx, c.xGoogMetadata)219	var resp buildpb.PublishBuildEvent_PublishBuildToolEventStreamClient220	opts = append((*c.CallOptions).PublishBuildToolEventStream[0:len((*c.CallOptions).PublishBuildToolEventStream):len((*c.CallOptions).PublishBuildToolEventStream)], opts...)221	err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error {222		var err error223		resp, err = c.publishBuildEventClient.PublishBuildToolEventStream(ctx, settings.GRPC...)224		return err225	}, opts...)226	if err != nil {227		return nil, err228	}229	return resp, nil230}...

event_bus.go

Source:event_bus.go

...67}68func (b *EventBus) UnsubscribeAll(ctx context.Context, subscriber string) error {69	return b.pubsub.UnsubscribeAll(ctx, subscriber)70}71func (b *EventBus) Publish(eventType string, eventData TMEventData) error {72	// no explicit deadline for publishing events73	ctx := context.Background()74	b.pubsub.PublishWithTags(ctx, eventData, map[string]string{EventTypeKey: eventType})75	return nil76}77func (b *EventBus) validateAndStringifyTags(tags []cmn.KVPair, logger log.Logger) map[string]string {78	result := make(map[string]string)79	for _, tag := range tags {80		// basic validation81		if len(tag.Key) == 0 {82			logger.Debug("Got tag with an empty key (skipping)", "tag", tag)83			continue84		}85		result[string(tag.Key)] = string(tag.Value)86	}87	return result88}89func (b *EventBus) PublishEventNewBlock(data EventDataNewBlock) error {90	// no explicit deadline for publishing events91	ctx := context.Background()92	resultTags := append(data.ResultBeginBlock.Tags, data.ResultEndBlock.Tags...)93	tags := b.validateAndStringifyTags(resultTags, b.Logger.With("block", data.Block.StringShort()))94	// add predefined tags95	logIfTagExists(EventTypeKey, tags, b.Logger)96	tags[EventTypeKey] = EventNewBlock97	b.pubsub.PublishWithTags(ctx, data, tags)98	return nil99}100func (b *EventBus) PublishEventNewBlockHeader(data EventDataNewBlockHeader) error {101	// no explicit deadline for publishing events102	ctx := context.Background()103	resultTags := append(data.ResultBeginBlock.Tags, data.ResultEndBlock.Tags...)104	// TODO: Create StringShort method for Header and use it in logger.105	tags := b.validateAndStringifyTags(resultTags, b.Logger.With("header", data.Header))106	// add predefined tags107	logIfTagExists(EventTypeKey, tags, b.Logger)108	tags[EventTypeKey] = EventNewBlockHeader109	b.pubsub.PublishWithTags(ctx, data, tags)110	return nil111}112func (b *EventBus) PublishEventVote(data EventDataVote) error {113	return b.Publish(EventVote, data)114}115func (b *EventBus) PublishEventValidBlock(data EventDataRoundState) error {116	return b.Publish(EventValidBlock, data)117}118// PublishEventTx publishes tx event with tags from Result. Note it will add119// predefined tags (EventTypeKey, TxHashKey). Existing tags with the same names120// will be overwritten.121func (b *EventBus) PublishEventTx(data EventDataTx) error {122	// no explicit deadline for publishing events123	ctx := context.Background()124	tags := b.validateAndStringifyTags(data.Result.Tags, b.Logger.With("tx", data.Tx))125	// add predefined tags126	logIfTagExists(EventTypeKey, tags, b.Logger)127	tags[EventTypeKey] = EventTx128	logIfTagExists(TxHashKey, tags, b.Logger)129	tags[TxHashKey] = fmt.Sprintf("%X", data.Tx.Hash())130	logIfTagExists(TxHeightKey, tags, b.Logger)131	tags[TxHeightKey] = fmt.Sprintf("%d", data.Height)132	b.pubsub.PublishWithTags(ctx, data, tags)133	return nil134}135func (b *EventBus) PublishEventNewRoundStep(data EventDataRoundState) error {136	return b.Publish(EventNewRoundStep, data)137}138func (b *EventBus) PublishEventTimeoutPropose(data EventDataRoundState) error {139	return b.Publish(EventTimeoutPropose, data)140}141func (b *EventBus) PublishEventTimeoutWait(data EventDataRoundState) error {142	return b.Publish(EventTimeoutWait, data)143}144func (b *EventBus) PublishEventNewRound(data EventDataNewRound) error {145	return b.Publish(EventNewRound, data)146}147func (b *EventBus) PublishEventCompleteProposal(data EventDataCompleteProposal) error {148	return b.Publish(EventCompleteProposal, data)149}150func (b *EventBus) PublishEventPolka(data EventDataRoundState) error {151	return b.Publish(EventPolka, data)152}153func (b *EventBus) PublishEventUnlock(data EventDataRoundState) error {154	return b.Publish(EventUnlock, data)155}156func (b *EventBus) PublishEventRelock(data EventDataRoundState) error {157	return b.Publish(EventRelock, data)158}159func (b *EventBus) PublishEventLock(data EventDataRoundState) error {160	return b.Publish(EventLock, data)161}162func (b *EventBus) PublishEventValidatorSetUpdates(data EventDataValidatorSetUpdates) error {163	return b.Publish(EventValidatorSetUpdates, data)164}165func logIfTagExists(tag string, tags map[string]string, logger log.Logger) {166	if value, ok := tags[tag]; ok {167		logger.Error("Found predefined tag (value will be overwritten)", "tag", tag, "value", value)168	}169}170//-----------------------------------------------------------------------------171type NopEventBus struct{}172func (NopEventBus) Subscribe(ctx context.Context, subscriber string, query tmpubsub.Query, out chan<- interface{}) error {173	return nil174}175func (NopEventBus) Unsubscribe(ctx context.Context, subscriber string, query tmpubsub.Query) error {176	return nil177}178func (NopEventBus) UnsubscribeAll(ctx context.Context, subscriber string) error {179	return nil180}181func (NopEventBus) PublishEventNewBlock(data EventDataNewBlock) error {182	return nil183}184func (NopEventBus) PublishEventNewBlockHeader(data EventDataNewBlockHeader) error {185	return nil186}187func (NopEventBus) PublishEventVote(data EventDataVote) error {188	return nil189}190func (NopEventBus) PublishEventTx(data EventDataTx) error {191	return nil192}193func (NopEventBus) PublishEventNewRoundStep(data EventDataRoundState) error {194	return nil195}196func (NopEventBus) PublishEventTimeoutPropose(data EventDataRoundState) error {197	return nil198}199func (NopEventBus) PublishEventTimeoutWait(data EventDataRoundState) error {200	return nil201}202func (NopEventBus) PublishEventNewRound(data EventDataRoundState) error {203	return nil204}205func (NopEventBus) PublishEventCompleteProposal(data EventDataRoundState) error {206	return nil207}208func (NopEventBus) PublishEventPolka(data EventDataRoundState) error {209	return nil210}211func (NopEventBus) PublishEventUnlock(data EventDataRoundState) error {212	return nil213}214func (NopEventBus) PublishEventRelock(data EventDataRoundState) error {215	return nil216}217func (NopEventBus) PublishEventLock(data EventDataRoundState) error {218	return nil219}220func (NopEventBus) PublishEventValidatorSetUpdates(data EventDataValidatorSetUpdates) error {221	return nil222}...

Publish

Using AI Code Generation

1import (2func main() {3	config := cluster.NewConfig()4	brokers := []string{"localhost:9092"}5	topics := []string{"test"}6	consumer, err := cluster.NewConsumer(brokers, "test-group", topics, config)7	if err != nil {8		panic(err)9	}10	defer consumer.Close()11	go func() {12		for err := range consumer.Errors() {13			fmt.Println(err)14		}15	}()16	go func() {17		for note := range consumer.Notifications() {18			fmt.Println(note)19		}20	}()21	go func() {22		for {23			select {24			case msg, ok := <-consumer.Messages():25				if ok {26					fmt.Println("Message: ", string(msg.Value))27				}28			}29		}30	}()31	signals := make(chan os.Signal, 1)32	signal.Notify(signals, os.Interrupt)33}34import (35func main() {36	config := cluster.NewConfig()

Publish

Using AI Code Generation

1import (2func main() {3	fmt.Println("hello world")4	golenv.Initialize()5	event := goltype.Event{6		EventID:   goluuid.UUID(),7		Timestamp: goltime.Now(),8	}9	goltype.Publish(event)10}11import (12func main() {13	fmt.Println("hello world")14	golenv.Initialize()15	eventStream := goltype.Subscribe()16	for event := range eventStream {17		fmt.Println(event)18	}19}20import (21func main() {22	fmt.Println("hello world")23	golenv.Initialize()24	eventStream := goltype.Subscribe()25	for event := range eventStream {26		fmt.Println(event)27	}28}29import (30func main() {31	fmt.Println("hello world")32	golenv.Initialize()33	event := goltype.Event{34		EventID:   goluuid.UUID(),35		Timestamp: goltime.Now(),36	}

Publish

Using AI Code Generation

1import "fmt"2type Event struct {3}4func (e *Event) Publish() {5    fmt.Println("Publishing event", e.Name)6}7func main() {8    e := Event{"Go Workshop", 101}9    e.Publish()10}

Publish

Using AI Code Generation

1import (2type Event struct {3}4type Observer interface {5	Notify()6}7type User struct {8}9func (u *User) Notify() {10	fmt.Println(u.name, "is notified")11}12func (e *Event) Attach(observer Observer) {13	e.observerList = append(e.observerList, observer)14}15func (e *Event) Detach(observer Observer) {16	for i, o := range e.observerList {17		if reflect.DeepEqual(o, observer) {18			e.observerList = append(e.observerList[:i], e.observerList[i+1:]...)19		}20	}21}22func (e *Event) Publish() {23	for _, observer := range e.observerList {24		observer.Notify()25	}26}27func main() {28	e := new(Event)29	u1 := new(User)30	u2 := new(User)31	e.Attach(u1)32	e.Attach(u2)33	e.Publish()34	e.Detach(u1)35	e.Publish()36}

Publish

Using AI Code Generation

1func main() {2    event := NewEvent()3    event.Publish("Hello World")4}5func main() {6    event := NewEvent()7    event.Subscribe(func(message string) {8        fmt.Println(message)9    })10    event.Publish("Hello World")11}12func main() {13    event := NewEvent()14    handle := event.Subscribe(func(message string) {15        fmt.Println(message)16    })17    event.Unsubscribe(handle)18    event.Publish("Hello World")19}20func main() {21    event := NewEvent()22    event.Subscribe(func(message string) {23        fmt.Println(message)24    })25    event.Subscribe(func(message string) {26        fmt.Println(message)27    })28    event.UnsubscribeAll()29    event.Publish("Hello World")30}31func main() {32    event := NewEvent()33    event.Subscribe(func(message string) {34        fmt.Println(message)35    })36    event.Subscribe(func(message string) {37        fmt.Println(message)38    })39    event.UnsubscribeAll()40    event.Publish("Hello World")41}42func main() {43    event := NewEvent()44    event.Subscribe(func(message string) {45        fmt.Println(message)46    })47    event.Subscribe(func(message string) {48        fmt.Println(message)49    })50    event.UnsubscribeAll()51    event.Publish("Hello World")52}53func main() {54    event := NewEvent()55    event.Subscribe(func(message string) {56        fmt.Println(message)57    })58    event.Subscribe(func(message string) {59        fmt.Println(message)60    })61    event.UnsubscribeAll()62    event.Publish("Hello World")63}64func main() {65    event := NewEvent()66    event.Subscribe(func(message string) {

Publish

Using AI Code Generation

1import (2func main() {3	consumerGroup, err := sarama.NewConsumerGroupFromClient("my-consumer-group", real_consumer.Client)4	if err != nil {5		panic(err)6	}7	defer func() {8		if err := consumerGroup.Close(); err != nil {9			panic(err)10		}11	}()12	go func() {13		for err := range consumerGroup.Errors() {14			fmt.Println("Error:", err)15		}16	}()17	ctx := context.Background()18	for {19		handler := real_consumer.ConsumerGroupHandler{}20		err := consumerGroup.Consume(ctx, []string{"my-topic"}, handler)21		if err != nil {22			panic(err)23		}24	}25}26import (27func main() {28	consumerGroup, err := sarama.NewConsumerGroupFromClient("my-consumer-group", real_consumer.Client)29	if err != nil {30		panic(err)31	}32	defer func() {33		if err := consumerGroup.Close(); err != nil {34			panic(err)35		}36	}()37	go func() {38		for err := range consumerGroup.Errors() {39			fmt.Println("Error:", err)40		}41	}()42	ctx := context.Background()43	for {44		handler := real_consumer.ConsumerGroupHandler{}45		err := consumerGroup.Consume(ctx, []string{"my-topic"}, handler)46		if err != nil {47			panic(err)

Publish

Using AI Code Generation

1import (2var (3	event = new(Event)4type Event struct {5	Subscribers []func(interface{})6}7func (e *Event) Subscribe(subscriber func(interface{})) {8	e.Subscribers = append(e.Subscribers, subscriber)9}10func (e *Event) Publish(data interface{}) {11	for _, sub := range e.Subscribers {12		sub(data)13	}14}15func main() {16	event.Subscribe(func(data interface{}) {17		fmt.Println("Subscriber 1: ", data)18	})19	event.Subscribe(func(data interface{}) {20		fmt.Println("Subscriber 2: ", data)21	})22	event.Publish("Event fired")23	time.Sleep(time.Second)24}

Publish

Using AI Code Generation

1import (2func main() {3	e := event.New("test")4	e.AddHandler(func(m *sarama.ConsumerMessage) {5		fmt.Println("Message received: ", string(m.Value))6	})7	e.Start()8	e.Publish("This is a test message")9	time.Sleep(1 * time.Second)10	e.Stop()11	e1 := event.New("test")12	e1.AddHandler(func(m *sarama.ConsumerMessage) {13		fmt.Println("Message received: ", string(m.Value))14	})15	e1.Start()16	e1.Publish("This is a test message")17	time.Sleep(1 * time.Second)18	e1.Stop()19}

Publish

Using AI Code Generation

1import (2type Event struct {3	Payload interface{}4}5func (e *Event) Publish() {6	fmt.Printf("Event: %s, Payload: %v7}8func main() {9	e := Event{Type: "user.created", Payload: "User created at " + time.Now().Format(time.RFC3339)}10	e.Publish()11}

Publish

Using AI Code Generation

1import (2type Event struct {3	data interface{}4	target interface{}5}6func (e *Event) Publish() {7	eventType := reflect.TypeOf(e)8	eventValue := reflect.ValueOf(e)9	targetType := reflect.TypeOf(e.target)10	targetValue := reflect.ValueOf(e.target)11	methodCount := targetValue.NumMethod()12	for i := 0; i < methodCount; i++ {13		method := targetValue.Method(i)14		methodType := targetType.Method(i)15		if len(methodName) > 2 && methodName[0:2] == "On" && methodType.Type.NumIn() == 1 {16			methodParamType := methodType.Type.In(0)17			if methodParamType == eventType {18				method.Call([]reflect.Value{eventValue})19			}20		}21	}22}23type Publisher struct {24}25func (p *Publisher) PublishEvent(e *Event) {26	e.Publish()27}28type Subscriber struct {29}30func (s *Subscriber) SubscribeToEvent(e *Event) {31	e.Subscribe(s)32}33func (s *Subscriber) OnEvent

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.