broker.pb.go RawHistoryFolder

1// Broker wire schema: the client/server broker conversations.
2//
3// The broker is an independently versioned conversation from the session
4// protocol: client tags 101-113 and server tags 201-210 are disjoint from
5// every session tag, and each direction is its own closed oneof union.
6// Scope (broker epoch plus client connection) is carried explicitly on
7// every payload so stream IDs and events never cross a scope. Semantic
8// validation stays outside this package; conversion mirrors the port
9// types losslessly.
10
11// Code generated by protoc-gen-go. DO NOT EDIT.
12// versions:
13// 	protoc-gen-go v1.36.12
14// 	protoc        (unknown)
15// source: broker.proto
16
17package wire
18
19import (
20	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
21	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
22	reflect "reflect"
23	sync "sync"
24	unsafe "unsafe"
25)
26
27const (
28	// Verify that this generated code is sufficiently up-to-date.
29	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
30	// Verify that runtime/protoimpl is sufficiently up-to-date.
31	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
32)
33
34// BrokerScope identifies one broker process incarnation and one client
35// connection within it (ports.BrokerEpoch / ports.BrokerConnectionID).
36// Streams and events are scoped to one scope; an epoch change forces a
37// full resynchronization.
38type BrokerScope struct {
39	state         protoimpl.MessageState `protogen:"open.v1"`
40	BrokerEpoch   uint64                 `protobuf:"varint,1,opt,name=broker_epoch,json=brokerEpoch,proto3" json:"broker_epoch,omitempty"`
41	ConnectionId  []byte                 `protobuf:"bytes,2,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"` // exactly 16 bytes
42	unknownFields protoimpl.UnknownFields
43	sizeCache     protoimpl.SizeCache
44}
45
46func (x *BrokerScope) Reset() {
47	*x = BrokerScope{}
48	mi := &file_broker_proto_msgTypes[0]
49	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
50	ms.StoreMessageInfo(mi)
51}
52
53func (x *BrokerScope) String() string {
54	return protoimpl.X.MessageStringOf(x)
55}
56
57func (*BrokerScope) ProtoMessage() {}
58
59func (x *BrokerScope) ProtoReflect() protoreflect.Message {
60	mi := &file_broker_proto_msgTypes[0]
61	if x != nil {
62		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
63		if ms.LoadMessageInfo() == nil {
64			ms.StoreMessageInfo(mi)
65		}
66		return ms
67	}
68	return mi.MessageOf(x)
69}
70
71// Deprecated: Use BrokerScope.ProtoReflect.Descriptor instead.
72func (*BrokerScope) Descriptor() ([]byte, []int) {
73	return file_broker_proto_rawDescGZIP(), []int{0}
74}
75
76func (x *BrokerScope) GetBrokerEpoch() uint64 {
77	if x != nil {
78		return x.BrokerEpoch
79	}
80	return 0
81}
82
83func (x *BrokerScope) GetConnectionId() []byte {
84	if x != nil {
85		return x.ConnectionId
86	}
87	return nil
88}
89
90// BrokerStreamRef identifies one logical stream within one scope
91// (ports.BrokerStreamID). It never crosses connections or epochs.
92type BrokerStreamRef struct {
93	state         protoimpl.MessageState `protogen:"open.v1"`
94	Scope         *BrokerScope           `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
95	StreamId      uint64                 `protobuf:"varint,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
96	unknownFields protoimpl.UnknownFields
97	sizeCache     protoimpl.SizeCache
98}
99
100func (x *BrokerStreamRef) Reset() {
101	*x = BrokerStreamRef{}
102	mi := &file_broker_proto_msgTypes[1]
103	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
104	ms.StoreMessageInfo(mi)
105}
106
107func (x *BrokerStreamRef) String() string {
108	return protoimpl.X.MessageStringOf(x)
109}
110
111func (*BrokerStreamRef) ProtoMessage() {}
112
113func (x *BrokerStreamRef) ProtoReflect() protoreflect.Message {
114	mi := &file_broker_proto_msgTypes[1]
115	if x != nil {
116		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
117		if ms.LoadMessageInfo() == nil {
118			ms.StoreMessageInfo(mi)
119		}
120		return ms
121	}
122	return mi.MessageOf(x)
123}
124
125// Deprecated: Use BrokerStreamRef.ProtoReflect.Descriptor instead.
126func (*BrokerStreamRef) Descriptor() ([]byte, []int) {
127	return file_broker_proto_rawDescGZIP(), []int{1}
128}
129
130func (x *BrokerStreamRef) GetScope() *BrokerScope {
131	if x != nil {
132		return x.Scope
133	}
134	return nil
135}
136
137func (x *BrokerStreamRef) GetStreamId() uint64 {
138	if x != nil {
139		return x.StreamId
140	}
141	return 0
142}
143
144// BrokerWirePolicy is the exact connection policy two endpoints must share
145// before pooling one physical transport (ports.BrokerPolicy). Tokens are
146// opaque, authoritative identities: never display labels, never secrets.
147type BrokerWirePolicy struct {
148	state            protoimpl.MessageState `protogen:"open.v1"`
149	ProtocolVersion  uint32                 `protobuf:"varint,1,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
150	CatalogueVersion uint32                 `protobuf:"varint,2,opt,name=catalogue_version,json=catalogueVersion,proto3" json:"catalogue_version,omitempty"`
151	// Closed taxonomy: 0 = client-owned, 1 = daemon-owned.
152	EnvironmentPolicy uint32 `protobuf:"varint,3,opt,name=environment_policy,json=environmentPolicy,proto3" json:"environment_policy,omitempty"`
153	Transport         string `protobuf:"bytes,4,opt,name=transport,proto3" json:"transport,omitempty"`
154	Trust             string `protobuf:"bytes,5,opt,name=trust,proto3" json:"trust,omitempty"`
155	Launch            string `protobuf:"bytes,6,opt,name=launch,proto3" json:"launch,omitempty"`
156	Isolation         string `protobuf:"bytes,7,opt,name=isolation,proto3" json:"isolation,omitempty"`
157	unknownFields     protoimpl.UnknownFields
158	sizeCache         protoimpl.SizeCache
159}
160
161func (x *BrokerWirePolicy) Reset() {
162	*x = BrokerWirePolicy{}
163	mi := &file_broker_proto_msgTypes[2]
164	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
165	ms.StoreMessageInfo(mi)
166}
167
168func (x *BrokerWirePolicy) String() string {
169	return protoimpl.X.MessageStringOf(x)
170}
171
172func (*BrokerWirePolicy) ProtoMessage() {}
173
174func (x *BrokerWirePolicy) ProtoReflect() protoreflect.Message {
175	mi := &file_broker_proto_msgTypes[2]
176	if x != nil {
177		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
178		if ms.LoadMessageInfo() == nil {
179			ms.StoreMessageInfo(mi)
180		}
181		return ms
182	}
183	return mi.MessageOf(x)
184}
185
186// Deprecated: Use BrokerWirePolicy.ProtoReflect.Descriptor instead.
187func (*BrokerWirePolicy) Descriptor() ([]byte, []int) {
188	return file_broker_proto_rawDescGZIP(), []int{2}
189}
190
191func (x *BrokerWirePolicy) GetProtocolVersion() uint32 {
192	if x != nil {
193		return x.ProtocolVersion
194	}
195	return 0
196}
197
198func (x *BrokerWirePolicy) GetCatalogueVersion() uint32 {
199	if x != nil {
200		return x.CatalogueVersion
201	}
202	return 0
203}
204
205func (x *BrokerWirePolicy) GetEnvironmentPolicy() uint32 {
206	if x != nil {
207		return x.EnvironmentPolicy
208	}
209	return 0
210}
211
212func (x *BrokerWirePolicy) GetTransport() string {
213	if x != nil {
214		return x.Transport
215	}
216	return ""
217}
218
219func (x *BrokerWirePolicy) GetTrust() string {
220	if x != nil {
221		return x.Trust
222	}
223	return ""
224}
225
226func (x *BrokerWirePolicy) GetLaunch() string {
227	if x != nil {
228		return x.Launch
229	}
230	return ""
231}
232
233func (x *BrokerWirePolicy) GetIsolation() string {
234	if x != nil {
235		return x.Isolation
236	}
237	return ""
238}
239
240// BrokerErrorDetail is the typed broker failure carried to clients
241// (ports.BrokerError plus bounded display text). The underlying cause is
242// local-only diagnostic authority and never travels on this wire.
243type BrokerErrorDetail struct {
244	state protoimpl.MessageState `protogen:"open.v1"`
245	// Closed taxonomy: 1 = unavailable, 2 = incompatible, 3 = timeout,
246	// 4 = cancelled, 5 = outcome_unknown, 6 = attachment_lost,
247	// 7 = stale_epoch, 8 = conflicting_policy, 9 = explicit_exit,
248	// 10 = fatal_terminal, 11 = host_conflict, 12 = membership_immutable.
249	Code uint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
250	Text string `protobuf:"bytes,2,opt,name=text,proto3" json:"text,omitempty"`
251	// Closed admission-refusal taxonomy; 0 = none. Codes are assigned by the
252	// broker admission slice.
253	AdmissionCode uint32 `protobuf:"varint,3,opt,name=admission_code,json=admissionCode,proto3" json:"admission_code,omitempty"`
254	// Closed cause taxonomy (domain.RemoteFailureKind): 0 = none, 1 =
255	// transport, through the last declared failure kind.
256	FailureKind   uint32 `protobuf:"varint,4,opt,name=failure_kind,json=failureKind,proto3" json:"failure_kind,omitempty"`
257	unknownFields protoimpl.UnknownFields
258	sizeCache     protoimpl.SizeCache
259}
260
261func (x *BrokerErrorDetail) Reset() {
262	*x = BrokerErrorDetail{}
263	mi := &file_broker_proto_msgTypes[3]
264	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
265	ms.StoreMessageInfo(mi)
266}
267
268func (x *BrokerErrorDetail) String() string {
269	return protoimpl.X.MessageStringOf(x)
270}
271
272func (*BrokerErrorDetail) ProtoMessage() {}
273
274func (x *BrokerErrorDetail) ProtoReflect() protoreflect.Message {
275	mi := &file_broker_proto_msgTypes[3]
276	if x != nil {
277		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
278		if ms.LoadMessageInfo() == nil {
279			ms.StoreMessageInfo(mi)
280		}
281		return ms
282	}
283	return mi.MessageOf(x)
284}
285
286// Deprecated: Use BrokerErrorDetail.ProtoReflect.Descriptor instead.
287func (*BrokerErrorDetail) Descriptor() ([]byte, []int) {
288	return file_broker_proto_rawDescGZIP(), []int{3}
289}
290
291func (x *BrokerErrorDetail) GetCode() uint32 {
292	if x != nil {
293		return x.Code
294	}
295	return 0
296}
297
298func (x *BrokerErrorDetail) GetText() string {
299	if x != nil {
300		return x.Text
301	}
302	return ""
303}
304
305func (x *BrokerErrorDetail) GetAdmissionCode() uint32 {
306	if x != nil {
307		return x.AdmissionCode
308	}
309	return 0
310}
311
312func (x *BrokerErrorDetail) GetFailureKind() uint32 {
313	if x != nil {
314		return x.FailureKind
315	}
316	return 0
317}
318
319// BrokerTimestamp is one instant split into seconds and nanoseconds so
320// time.Time survives the wire exactly.
321type BrokerTimestamp struct {
322	state         protoimpl.MessageState `protogen:"open.v1"`
323	Seconds       int64                  `protobuf:"varint,1,opt,name=seconds,proto3" json:"seconds,omitempty"`
324	Nanos         int32                  `protobuf:"varint,2,opt,name=nanos,proto3" json:"nanos,omitempty"`
325	unknownFields protoimpl.UnknownFields
326	sizeCache     protoimpl.SizeCache
327}
328
329func (x *BrokerTimestamp) Reset() {
330	*x = BrokerTimestamp{}
331	mi := &file_broker_proto_msgTypes[4]
332	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
333	ms.StoreMessageInfo(mi)
334}
335
336func (x *BrokerTimestamp) String() string {
337	return protoimpl.X.MessageStringOf(x)
338}
339
340func (*BrokerTimestamp) ProtoMessage() {}
341
342func (x *BrokerTimestamp) ProtoReflect() protoreflect.Message {
343	mi := &file_broker_proto_msgTypes[4]
344	if x != nil {
345		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
346		if ms.LoadMessageInfo() == nil {
347			ms.StoreMessageInfo(mi)
348		}
349		return ms
350	}
351	return mi.MessageOf(x)
352}
353
354// Deprecated: Use BrokerTimestamp.ProtoReflect.Descriptor instead.
355func (*BrokerTimestamp) Descriptor() ([]byte, []int) {
356	return file_broker_proto_rawDescGZIP(), []int{4}
357}
358
359func (x *BrokerTimestamp) GetSeconds() int64 {
360	if x != nil {
361		return x.Seconds
362	}
363	return 0
364}
365
366func (x *BrokerTimestamp) GetNanos() int32 {
367	if x != nil {
368		return x.Nanos
369	}
370	return 0
371}
372
373// BrokerClientEnvelope is the closed client-to-server broker union. Exactly
374// one variant must be set per envelope; empty, duplicate, and
375// wrong-direction payloads are rejected before generated unmarshal.
376type BrokerClientEnvelope struct {
377	state protoimpl.MessageState `protogen:"open.v1"`
378	// Types that are valid to be assigned to Payload:
379	//
380	//	*BrokerClientEnvelope_Register
381	//	*BrokerClientEnvelope_Subscribe
382	//	*BrokerClientEnvelope_Resync
383	//	*BrokerClientEnvelope_Unsubscribe
384	//	*BrokerClientEnvelope_AddHost
385	//	*BrokerClientEnvelope_RemoveHost
386	//	*BrokerClientEnvelope_Reconcile
387	//	*BrokerClientEnvelope_OpenStream
388	//	*BrokerClientEnvelope_ClientStreamData
389	//	*BrokerClientEnvelope_CloseStream
390	//	*BrokerClientEnvelope_UpdateHostPolicy
391	//	*BrokerClientEnvelope_StartPreview
392	//	*BrokerClientEnvelope_CancelPreview
393	//	*BrokerClientEnvelope_StreamWindowUpdate
394	Payload       isBrokerClientEnvelope_Payload `protobuf_oneof:"payload"`
395	unknownFields protoimpl.UnknownFields
396	sizeCache     protoimpl.SizeCache
397}
398
399func (x *BrokerClientEnvelope) Reset() {
400	*x = BrokerClientEnvelope{}
401	mi := &file_broker_proto_msgTypes[5]
402	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
403	ms.StoreMessageInfo(mi)
404}
405
406func (x *BrokerClientEnvelope) String() string {
407	return protoimpl.X.MessageStringOf(x)
408}
409
410func (*BrokerClientEnvelope) ProtoMessage() {}
411
412func (x *BrokerClientEnvelope) ProtoReflect() protoreflect.Message {
413	mi := &file_broker_proto_msgTypes[5]
414	if x != nil {
415		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
416		if ms.LoadMessageInfo() == nil {
417			ms.StoreMessageInfo(mi)
418		}
419		return ms
420	}
421	return mi.MessageOf(x)
422}
423
424// Deprecated: Use BrokerClientEnvelope.ProtoReflect.Descriptor instead.
425func (*BrokerClientEnvelope) Descriptor() ([]byte, []int) {
426	return file_broker_proto_rawDescGZIP(), []int{5}
427}
428
429func (x *BrokerClientEnvelope) GetPayload() isBrokerClientEnvelope_Payload {
430	if x != nil {
431		return x.Payload
432	}
433	return nil
434}
435
436func (x *BrokerClientEnvelope) GetRegister() *Register {
437	if x != nil {
438		if x, ok := x.Payload.(*BrokerClientEnvelope_Register); ok {
439			return x.Register
440		}
441	}
442	return nil
443}
444
445func (x *BrokerClientEnvelope) GetSubscribe() *Subscribe {
446	if x != nil {
447		if x, ok := x.Payload.(*BrokerClientEnvelope_Subscribe); ok {
448			return x.Subscribe
449		}
450	}
451	return nil
452}
453
454func (x *BrokerClientEnvelope) GetResync() *Resync {
455	if x != nil {
456		if x, ok := x.Payload.(*BrokerClientEnvelope_Resync); ok {
457			return x.Resync
458		}
459	}
460	return nil
461}
462
463func (x *BrokerClientEnvelope) GetUnsubscribe() *Unsubscribe {
464	if x != nil {
465		if x, ok := x.Payload.(*BrokerClientEnvelope_Unsubscribe); ok {
466			return x.Unsubscribe
467		}
468	}
469	return nil
470}
471
472func (x *BrokerClientEnvelope) GetAddHost() *AddHost {
473	if x != nil {
474		if x, ok := x.Payload.(*BrokerClientEnvelope_AddHost); ok {
475			return x.AddHost
476		}
477	}
478	return nil
479}
480
481func (x *BrokerClientEnvelope) GetRemoveHost() *RemoveHost {
482	if x != nil {
483		if x, ok := x.Payload.(*BrokerClientEnvelope_RemoveHost); ok {
484			return x.RemoveHost
485		}
486	}
487	return nil
488}
489
490func (x *BrokerClientEnvelope) GetReconcile() *Reconcile {
491	if x != nil {
492		if x, ok := x.Payload.(*BrokerClientEnvelope_Reconcile); ok {
493			return x.Reconcile
494		}
495	}
496	return nil
497}
498
499func (x *BrokerClientEnvelope) GetOpenStream() *OpenStream {
500	if x != nil {
501		if x, ok := x.Payload.(*BrokerClientEnvelope_OpenStream); ok {
502			return x.OpenStream
503		}
504	}
505	return nil
506}
507
508func (x *BrokerClientEnvelope) GetClientStreamData() *ClientStreamData {
509	if x != nil {
510		if x, ok := x.Payload.(*BrokerClientEnvelope_ClientStreamData); ok {
511			return x.ClientStreamData
512		}
513	}
514	return nil
515}
516
517func (x *BrokerClientEnvelope) GetCloseStream() *CloseStream {
518	if x != nil {
519		if x, ok := x.Payload.(*BrokerClientEnvelope_CloseStream); ok {
520			return x.CloseStream
521		}
522	}
523	return nil
524}
525
526func (x *BrokerClientEnvelope) GetUpdateHostPolicy() *UpdateHostPolicy {
527	if x != nil {
528		if x, ok := x.Payload.(*BrokerClientEnvelope_UpdateHostPolicy); ok {
529			return x.UpdateHostPolicy
530		}
531	}
532	return nil
533}
534
535func (x *BrokerClientEnvelope) GetStartPreview() *StartPreview {
536	if x != nil {
537		if x, ok := x.Payload.(*BrokerClientEnvelope_StartPreview); ok {
538			return x.StartPreview
539		}
540	}
541	return nil
542}
543
544func (x *BrokerClientEnvelope) GetCancelPreview() *CancelPreview {
545	if x != nil {
546		if x, ok := x.Payload.(*BrokerClientEnvelope_CancelPreview); ok {
547			return x.CancelPreview
548		}
549	}
550	return nil
551}
552
553func (x *BrokerClientEnvelope) GetStreamWindowUpdate() *StreamWindowUpdate {
554	if x != nil {
555		if x, ok := x.Payload.(*BrokerClientEnvelope_StreamWindowUpdate); ok {
556			return x.StreamWindowUpdate
557		}
558	}
559	return nil
560}
561
562type isBrokerClientEnvelope_Payload interface {
563	isBrokerClientEnvelope_Payload()
564}
565
566type BrokerClientEnvelope_Register struct {
567	Register *Register `protobuf:"bytes,101,opt,name=register,proto3,oneof"`
568}
569
570type BrokerClientEnvelope_Subscribe struct {
571	Subscribe *Subscribe `protobuf:"bytes,102,opt,name=subscribe,proto3,oneof"`
572}
573
574type BrokerClientEnvelope_Resync struct {
575	Resync *Resync `protobuf:"bytes,103,opt,name=resync,proto3,oneof"`
576}
577
578type BrokerClientEnvelope_Unsubscribe struct {
579	Unsubscribe *Unsubscribe `protobuf:"bytes,104,opt,name=unsubscribe,proto3,oneof"`
580}
581
582type BrokerClientEnvelope_AddHost struct {
583	AddHost *AddHost `protobuf:"bytes,105,opt,name=add_host,json=addHost,proto3,oneof"`
584}
585
586type BrokerClientEnvelope_RemoveHost struct {
587	RemoveHost *RemoveHost `protobuf:"bytes,106,opt,name=remove_host,json=removeHost,proto3,oneof"`
588}
589
590type BrokerClientEnvelope_Reconcile struct {
591	Reconcile *Reconcile `protobuf:"bytes,107,opt,name=reconcile,proto3,oneof"`
592}
593
594type BrokerClientEnvelope_OpenStream struct {
595	OpenStream *OpenStream `protobuf:"bytes,108,opt,name=open_stream,json=openStream,proto3,oneof"`
596}
597
598type BrokerClientEnvelope_ClientStreamData struct {
599	ClientStreamData *ClientStreamData `protobuf:"bytes,109,opt,name=client_stream_data,json=clientStreamData,proto3,oneof"`
600}
601
602type BrokerClientEnvelope_CloseStream struct {
603	CloseStream *CloseStream `protobuf:"bytes,110,opt,name=close_stream,json=closeStream,proto3,oneof"`
604}
605
606type BrokerClientEnvelope_UpdateHostPolicy struct {
607	UpdateHostPolicy *UpdateHostPolicy `protobuf:"bytes,111,opt,name=update_host_policy,json=updateHostPolicy,proto3,oneof"`
608}
609
610type BrokerClientEnvelope_StartPreview struct {
611	StartPreview *StartPreview `protobuf:"bytes,112,opt,name=start_preview,json=startPreview,proto3,oneof"`
612}
613
614type BrokerClientEnvelope_CancelPreview struct {
615	CancelPreview *CancelPreview `protobuf:"bytes,113,opt,name=cancel_preview,json=cancelPreview,proto3,oneof"`
616}
617
618type BrokerClientEnvelope_StreamWindowUpdate struct {
619	StreamWindowUpdate *StreamWindowUpdate `protobuf:"bytes,114,opt,name=stream_window_update,json=streamWindowUpdate,proto3,oneof"`
620}
621
622func (*BrokerClientEnvelope_Register) isBrokerClientEnvelope_Payload() {}
623
624func (*BrokerClientEnvelope_Subscribe) isBrokerClientEnvelope_Payload() {}
625
626func (*BrokerClientEnvelope_Resync) isBrokerClientEnvelope_Payload() {}
627
628func (*BrokerClientEnvelope_Unsubscribe) isBrokerClientEnvelope_Payload() {}
629
630func (*BrokerClientEnvelope_AddHost) isBrokerClientEnvelope_Payload() {}
631
632func (*BrokerClientEnvelope_RemoveHost) isBrokerClientEnvelope_Payload() {}
633
634func (*BrokerClientEnvelope_Reconcile) isBrokerClientEnvelope_Payload() {}
635
636func (*BrokerClientEnvelope_OpenStream) isBrokerClientEnvelope_Payload() {}
637
638func (*BrokerClientEnvelope_ClientStreamData) isBrokerClientEnvelope_Payload() {}
639
640func (*BrokerClientEnvelope_CloseStream) isBrokerClientEnvelope_Payload() {}
641
642func (*BrokerClientEnvelope_UpdateHostPolicy) isBrokerClientEnvelope_Payload() {}
643
644func (*BrokerClientEnvelope_StartPreview) isBrokerClientEnvelope_Payload() {}
645
646func (*BrokerClientEnvelope_CancelPreview) isBrokerClientEnvelope_Payload() {}
647
648func (*BrokerClientEnvelope_StreamWindowUpdate) isBrokerClientEnvelope_Payload() {}
649
650// BrokerServerEnvelope is the closed server-to-client broker union. Exactly
651// one variant must be set per envelope.
652type BrokerServerEnvelope struct {
653	state protoimpl.MessageState `protogen:"open.v1"`
654	// Types that are valid to be assigned to Payload:
655	//
656	//	*BrokerServerEnvelope_Registered
657	//	*BrokerServerEnvelope_SnapshotPart
658	//	*BrokerServerEnvelope_OperationResult
659	//	*BrokerServerEnvelope_StreamOpened
660	//	*BrokerServerEnvelope_ServerStreamData
661	//	*BrokerServerEnvelope_StreamClosed
662	//	*BrokerServerEnvelope_Progress
663	//	*BrokerServerEnvelope_BrokerErrorMessage
664	//	*BrokerServerEnvelope_Shutdown
665	//	*BrokerServerEnvelope_PreviewPublication
666	//	*BrokerServerEnvelope_StreamWindowUpdate
667	Payload       isBrokerServerEnvelope_Payload `protobuf_oneof:"payload"`
668	unknownFields protoimpl.UnknownFields
669	sizeCache     protoimpl.SizeCache
670}
671
672func (x *BrokerServerEnvelope) Reset() {
673	*x = BrokerServerEnvelope{}
674	mi := &file_broker_proto_msgTypes[6]
675	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
676	ms.StoreMessageInfo(mi)
677}
678
679func (x *BrokerServerEnvelope) String() string {
680	return protoimpl.X.MessageStringOf(x)
681}
682
683func (*BrokerServerEnvelope) ProtoMessage() {}
684
685func (x *BrokerServerEnvelope) ProtoReflect() protoreflect.Message {
686	mi := &file_broker_proto_msgTypes[6]
687	if x != nil {
688		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
689		if ms.LoadMessageInfo() == nil {
690			ms.StoreMessageInfo(mi)
691		}
692		return ms
693	}
694	return mi.MessageOf(x)
695}
696
697// Deprecated: Use BrokerServerEnvelope.ProtoReflect.Descriptor instead.
698func (*BrokerServerEnvelope) Descriptor() ([]byte, []int) {
699	return file_broker_proto_rawDescGZIP(), []int{6}
700}
701
702func (x *BrokerServerEnvelope) GetPayload() isBrokerServerEnvelope_Payload {
703	if x != nil {
704		return x.Payload
705	}
706	return nil
707}
708
709func (x *BrokerServerEnvelope) GetRegistered() *Registered {
710	if x != nil {
711		if x, ok := x.Payload.(*BrokerServerEnvelope_Registered); ok {
712			return x.Registered
713		}
714	}
715	return nil
716}
717
718func (x *BrokerServerEnvelope) GetSnapshotPart() *SnapshotPart {
719	if x != nil {
720		if x, ok := x.Payload.(*BrokerServerEnvelope_SnapshotPart); ok {
721			return x.SnapshotPart
722		}
723	}
724	return nil
725}
726
727func (x *BrokerServerEnvelope) GetOperationResult() *OperationResult {
728	if x != nil {
729		if x, ok := x.Payload.(*BrokerServerEnvelope_OperationResult); ok {
730			return x.OperationResult
731		}
732	}
733	return nil
734}
735
736func (x *BrokerServerEnvelope) GetStreamOpened() *StreamOpened {
737	if x != nil {
738		if x, ok := x.Payload.(*BrokerServerEnvelope_StreamOpened); ok {
739			return x.StreamOpened
740		}
741	}
742	return nil
743}
744
745func (x *BrokerServerEnvelope) GetServerStreamData() *ServerStreamData {
746	if x != nil {
747		if x, ok := x.Payload.(*BrokerServerEnvelope_ServerStreamData); ok {
748			return x.ServerStreamData
749		}
750	}
751	return nil
752}
753
754func (x *BrokerServerEnvelope) GetStreamClosed() *StreamClosed {
755	if x != nil {
756		if x, ok := x.Payload.(*BrokerServerEnvelope_StreamClosed); ok {
757			return x.StreamClosed
758		}
759	}
760	return nil
761}
762
763func (x *BrokerServerEnvelope) GetProgress() *Progress {
764	if x != nil {
765		if x, ok := x.Payload.(*BrokerServerEnvelope_Progress); ok {
766			return x.Progress
767		}
768	}
769	return nil
770}
771
772func (x *BrokerServerEnvelope) GetBrokerErrorMessage() *BrokerErrorMessage {
773	if x != nil {
774		if x, ok := x.Payload.(*BrokerServerEnvelope_BrokerErrorMessage); ok {
775			return x.BrokerErrorMessage
776		}
777	}
778	return nil
779}
780
781func (x *BrokerServerEnvelope) GetShutdown() *Shutdown {
782	if x != nil {
783		if x, ok := x.Payload.(*BrokerServerEnvelope_Shutdown); ok {
784			return x.Shutdown
785		}
786	}
787	return nil
788}
789
790func (x *BrokerServerEnvelope) GetPreviewPublication() *PreviewPublication {
791	if x != nil {
792		if x, ok := x.Payload.(*BrokerServerEnvelope_PreviewPublication); ok {
793			return x.PreviewPublication
794		}
795	}
796	return nil
797}
798
799func (x *BrokerServerEnvelope) GetStreamWindowUpdate() *StreamWindowUpdate {
800	if x != nil {
801		if x, ok := x.Payload.(*BrokerServerEnvelope_StreamWindowUpdate); ok {
802			return x.StreamWindowUpdate
803		}
804	}
805	return nil
806}
807
808type isBrokerServerEnvelope_Payload interface {
809	isBrokerServerEnvelope_Payload()
810}
811
812type BrokerServerEnvelope_Registered struct {
813	Registered *Registered `protobuf:"bytes,201,opt,name=registered,proto3,oneof"`
814}
815
816type BrokerServerEnvelope_SnapshotPart struct {
817	SnapshotPart *SnapshotPart `protobuf:"bytes,202,opt,name=snapshot_part,json=snapshotPart,proto3,oneof"`
818}
819
820type BrokerServerEnvelope_OperationResult struct {
821	OperationResult *OperationResult `protobuf:"bytes,203,opt,name=operation_result,json=operationResult,proto3,oneof"`
822}
823
824type BrokerServerEnvelope_StreamOpened struct {
825	StreamOpened *StreamOpened `protobuf:"bytes,204,opt,name=stream_opened,json=streamOpened,proto3,oneof"`
826}
827
828type BrokerServerEnvelope_ServerStreamData struct {
829	ServerStreamData *ServerStreamData `protobuf:"bytes,205,opt,name=server_stream_data,json=serverStreamData,proto3,oneof"`
830}
831
832type BrokerServerEnvelope_StreamClosed struct {
833	StreamClosed *StreamClosed `protobuf:"bytes,206,opt,name=stream_closed,json=streamClosed,proto3,oneof"`
834}
835
836type BrokerServerEnvelope_Progress struct {
837	Progress *Progress `protobuf:"bytes,207,opt,name=progress,proto3,oneof"`
838}
839
840type BrokerServerEnvelope_BrokerErrorMessage struct {
841	BrokerErrorMessage *BrokerErrorMessage `protobuf:"bytes,208,opt,name=broker_error_message,json=brokerErrorMessage,proto3,oneof"`
842}
843
844type BrokerServerEnvelope_Shutdown struct {
845	Shutdown *Shutdown `protobuf:"bytes,209,opt,name=shutdown,proto3,oneof"`
846}
847
848type BrokerServerEnvelope_PreviewPublication struct {
849	PreviewPublication *PreviewPublication `protobuf:"bytes,210,opt,name=preview_publication,json=previewPublication,proto3,oneof"`
850}
851
852type BrokerServerEnvelope_StreamWindowUpdate struct {
853	StreamWindowUpdate *StreamWindowUpdate `protobuf:"bytes,211,opt,name=stream_window_update,json=streamWindowUpdate,proto3,oneof"`
854}
855
856func (*BrokerServerEnvelope_Registered) isBrokerServerEnvelope_Payload() {}
857
858func (*BrokerServerEnvelope_SnapshotPart) isBrokerServerEnvelope_Payload() {}
859
860func (*BrokerServerEnvelope_OperationResult) isBrokerServerEnvelope_Payload() {}
861
862func (*BrokerServerEnvelope_StreamOpened) isBrokerServerEnvelope_Payload() {}
863
864func (*BrokerServerEnvelope_ServerStreamData) isBrokerServerEnvelope_Payload() {}
865
866func (*BrokerServerEnvelope_StreamClosed) isBrokerServerEnvelope_Payload() {}
867
868func (*BrokerServerEnvelope_Progress) isBrokerServerEnvelope_Payload() {}
869
870func (*BrokerServerEnvelope_BrokerErrorMessage) isBrokerServerEnvelope_Payload() {}
871
872func (*BrokerServerEnvelope_Shutdown) isBrokerServerEnvelope_Payload() {}
873
874func (*BrokerServerEnvelope_PreviewPublication) isBrokerServerEnvelope_Payload() {}
875
876func (*BrokerServerEnvelope_StreamWindowUpdate) isBrokerServerEnvelope_Payload() {}
877
878// Register opens one client connection to the broker.
879type Register struct {
880	state         protoimpl.MessageState `protogen:"open.v1"`
881	Build         string                 `protobuf:"bytes,1,opt,name=build,proto3" json:"build,omitempty"`
882	unknownFields protoimpl.UnknownFields
883	sizeCache     protoimpl.SizeCache
884}
885
886func (x *Register) Reset() {
887	*x = Register{}
888	mi := &file_broker_proto_msgTypes[7]
889	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
890	ms.StoreMessageInfo(mi)
891}
892
893func (x *Register) String() string {
894	return protoimpl.X.MessageStringOf(x)
895}
896
897func (*Register) ProtoMessage() {}
898
899func (x *Register) ProtoReflect() protoreflect.Message {
900	mi := &file_broker_proto_msgTypes[7]
901	if x != nil {
902		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
903		if ms.LoadMessageInfo() == nil {
904			ms.StoreMessageInfo(mi)
905		}
906		return ms
907	}
908	return mi.MessageOf(x)
909}
910
911// Deprecated: Use Register.ProtoReflect.Descriptor instead.
912func (*Register) Descriptor() ([]byte, []int) {
913	return file_broker_proto_rawDescGZIP(), []int{7}
914}
915
916func (x *Register) GetBuild() string {
917	if x != nil {
918		return x.Build
919	}
920	return ""
921}
922
923// Subscribe asks for snapshot and lifecycle publications for one scope.
924type Subscribe struct {
925	state      protoimpl.MessageState `protogen:"open.v1"`
926	Scope      *BrokerScope           `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
927	Generation uint64                 `protobuf:"varint,2,opt,name=generation,proto3" json:"generation,omitempty"`
928	// passive marks a read-only snapshot reader (vev ls, vev host list). It
929	// receives publications but never counts as observation demand, so reading
930	// state never triggers a probe.
931	Passive       bool `protobuf:"varint,3,opt,name=passive,proto3" json:"passive,omitempty"`
932	unknownFields protoimpl.UnknownFields
933	sizeCache     protoimpl.SizeCache
934}
935
936func (x *Subscribe) Reset() {
937	*x = Subscribe{}
938	mi := &file_broker_proto_msgTypes[8]
939	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
940	ms.StoreMessageInfo(mi)
941}
942
943func (x *Subscribe) String() string {
944	return protoimpl.X.MessageStringOf(x)
945}
946
947func (*Subscribe) ProtoMessage() {}
948
949func (x *Subscribe) ProtoReflect() protoreflect.Message {
950	mi := &file_broker_proto_msgTypes[8]
951	if x != nil {
952		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
953		if ms.LoadMessageInfo() == nil {
954			ms.StoreMessageInfo(mi)
955		}
956		return ms
957	}
958	return mi.MessageOf(x)
959}
960
961// Deprecated: Use Subscribe.ProtoReflect.Descriptor instead.
962func (*Subscribe) Descriptor() ([]byte, []int) {
963	return file_broker_proto_rawDescGZIP(), []int{8}
964}
965
966func (x *Subscribe) GetScope() *BrokerScope {
967	if x != nil {
968		return x.Scope
969	}
970	return nil
971}
972
973func (x *Subscribe) GetGeneration() uint64 {
974	if x != nil {
975		return x.Generation
976	}
977	return 0
978}
979
980func (x *Subscribe) GetPassive() bool {
981	if x != nil {
982		return x.Passive
983	}
984	return false
985}
986
987// Resync asks for a full snapshot publication after an epoch change or a
988// gap in the client's generation series.
989type Resync struct {
990	state         protoimpl.MessageState `protogen:"open.v1"`
991	Scope         *BrokerScope           `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
992	Generation    uint64                 `protobuf:"varint,2,opt,name=generation,proto3" json:"generation,omitempty"`
993	unknownFields protoimpl.UnknownFields
994	sizeCache     protoimpl.SizeCache
995}
996
997func (x *Resync) Reset() {
998	*x = Resync{}
999	mi := &file_broker_proto_msgTypes[9]
1000	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1001	ms.StoreMessageInfo(mi)
1002}
1003
1004func (x *Resync) String() string {
1005	return protoimpl.X.MessageStringOf(x)
1006}
1007
1008func (*Resync) ProtoMessage() {}
1009
1010func (x *Resync) ProtoReflect() protoreflect.Message {
1011	mi := &file_broker_proto_msgTypes[9]
1012	if x != nil {
1013		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1014		if ms.LoadMessageInfo() == nil {
1015			ms.StoreMessageInfo(mi)
1016		}
1017		return ms
1018	}
1019	return mi.MessageOf(x)
1020}
1021
1022// Deprecated: Use Resync.ProtoReflect.Descriptor instead.
1023func (*Resync) Descriptor() ([]byte, []int) {
1024	return file_broker_proto_rawDescGZIP(), []int{9}
1025}
1026
1027func (x *Resync) GetScope() *BrokerScope {
1028	if x != nil {
1029		return x.Scope
1030	}
1031	return nil
1032}
1033
1034func (x *Resync) GetGeneration() uint64 {
1035	if x != nil {
1036		return x.Generation
1037	}
1038	return 0
1039}
1040
1041// Unsubscribe stops publications for one scope.
1042type Unsubscribe struct {
1043	state         protoimpl.MessageState `protogen:"open.v1"`
1044	Scope         *BrokerScope           `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
1045	Generation    uint64                 `protobuf:"varint,2,opt,name=generation,proto3" json:"generation,omitempty"`
1046	unknownFields protoimpl.UnknownFields
1047	sizeCache     protoimpl.SizeCache
1048}
1049
1050func (x *Unsubscribe) Reset() {
1051	*x = Unsubscribe{}
1052	mi := &file_broker_proto_msgTypes[10]
1053	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1054	ms.StoreMessageInfo(mi)
1055}
1056
1057func (x *Unsubscribe) String() string {
1058	return protoimpl.X.MessageStringOf(x)
1059}
1060
1061func (*Unsubscribe) ProtoMessage() {}
1062
1063func (x *Unsubscribe) ProtoReflect() protoreflect.Message {
1064	mi := &file_broker_proto_msgTypes[10]
1065	if x != nil {
1066		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1067		if ms.LoadMessageInfo() == nil {
1068			ms.StoreMessageInfo(mi)
1069		}
1070		return ms
1071	}
1072	return mi.MessageOf(x)
1073}
1074
1075// Deprecated: Use Unsubscribe.ProtoReflect.Descriptor instead.
1076func (*Unsubscribe) Descriptor() ([]byte, []int) {
1077	return file_broker_proto_rawDescGZIP(), []int{10}
1078}
1079
1080func (x *Unsubscribe) GetScope() *BrokerScope {
1081	if x != nil {
1082		return x.Scope
1083	}
1084	return nil
1085}
1086
1087func (x *Unsubscribe) GetGeneration() uint64 {
1088	if x != nil {
1089		return x.Generation
1090	}
1091	return 0
1092}
1093
1094// AddHost adds one configured host registration. operation_id is the
1095// idempotency identity of this mutating operation. policy is mandatory:
1096// the request is refused unless it carries an exact valid policy, so a
1097// membership addition can never be authorized by an absent policy.
1098type AddHost struct {
1099	state         protoimpl.MessageState `protogen:"open.v1"`
1100	Scope         *BrokerScope           `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
1101	OperationId   []byte                 `protobuf:"bytes,2,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"` // exactly 16 bytes
1102	Endpoint      string                 `protobuf:"bytes,3,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
1103	Policy        *BrokerWirePolicy      `protobuf:"bytes,4,opt,name=policy,proto3" json:"policy,omitempty"`
1104	unknownFields protoimpl.UnknownFields
1105	sizeCache     protoimpl.SizeCache
1106}
1107
1108func (x *AddHost) Reset() {
1109	*x = AddHost{}
1110	mi := &file_broker_proto_msgTypes[11]
1111	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1112	ms.StoreMessageInfo(mi)
1113}
1114
1115func (x *AddHost) String() string {
1116	return protoimpl.X.MessageStringOf(x)
1117}
1118
1119func (*AddHost) ProtoMessage() {}
1120
1121func (x *AddHost) ProtoReflect() protoreflect.Message {
1122	mi := &file_broker_proto_msgTypes[11]
1123	if x != nil {
1124		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1125		if ms.LoadMessageInfo() == nil {
1126			ms.StoreMessageInfo(mi)
1127		}
1128		return ms
1129	}
1130	return mi.MessageOf(x)
1131}
1132
1133// Deprecated: Use AddHost.ProtoReflect.Descriptor instead.
1134func (*AddHost) Descriptor() ([]byte, []int) {
1135	return file_broker_proto_rawDescGZIP(), []int{11}
1136}
1137
1138func (x *AddHost) GetScope() *BrokerScope {
1139	if x != nil {
1140		return x.Scope
1141	}
1142	return nil
1143}
1144
1145func (x *AddHost) GetOperationId() []byte {
1146	if x != nil {
1147		return x.OperationId
1148	}
1149	return nil
1150}
1151
1152func (x *AddHost) GetEndpoint() string {
1153	if x != nil {
1154		return x.Endpoint
1155	}
1156	return ""
1157}
1158
1159func (x *AddHost) GetPolicy() *BrokerWirePolicy {
1160	if x != nil {
1161		return x.Policy
1162	}
1163	return nil
1164}
1165
1166// RemoveHost removes exactly the registration carried by registration
1167// (endpoint, incarnation, and generation). A request whose authority does
1168// not exactly match the current registration is refused rather than
1169// applied to an endpoint name.
1170type RemoveHost struct {
1171	state         protoimpl.MessageState `protogen:"open.v1"`
1172	Scope         *BrokerScope           `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
1173	OperationId   []byte                 `protobuf:"bytes,2,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"` // exactly 16 bytes
1174	Registration  *RemoteRegistration    `protobuf:"bytes,3,opt,name=registration,proto3" json:"registration,omitempty"`
1175	unknownFields protoimpl.UnknownFields
1176	sizeCache     protoimpl.SizeCache
1177}
1178
1179func (x *RemoveHost) Reset() {
1180	*x = RemoveHost{}
1181	mi := &file_broker_proto_msgTypes[12]
1182	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1183	ms.StoreMessageInfo(mi)
1184}
1185
1186func (x *RemoveHost) String() string {
1187	return protoimpl.X.MessageStringOf(x)
1188}
1189
1190func (*RemoveHost) ProtoMessage() {}
1191
1192func (x *RemoveHost) ProtoReflect() protoreflect.Message {
1193	mi := &file_broker_proto_msgTypes[12]
1194	if x != nil {
1195		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1196		if ms.LoadMessageInfo() == nil {
1197			ms.StoreMessageInfo(mi)
1198		}
1199		return ms
1200	}
1201	return mi.MessageOf(x)
1202}
1203
1204// Deprecated: Use RemoveHost.ProtoReflect.Descriptor instead.
1205func (*RemoveHost) Descriptor() ([]byte, []int) {
1206	return file_broker_proto_rawDescGZIP(), []int{12}
1207}
1208
1209func (x *RemoveHost) GetScope() *BrokerScope {
1210	if x != nil {
1211		return x.Scope
1212	}
1213	return nil
1214}
1215
1216func (x *RemoveHost) GetOperationId() []byte {
1217	if x != nil {
1218		return x.OperationId
1219	}
1220	return nil
1221}
1222
1223func (x *RemoveHost) GetRegistration() *RemoteRegistration {
1224	if x != nil {
1225		return x.Registration
1226	}
1227	return nil
1228}
1229
1230// UpdateHostPolicy replaces the policy of exactly the registration carried
1231// by registration and answers with the advanced registration authority.
1232// policy is mandatory: an absent policy is refused like an invalid one.
1233type UpdateHostPolicy struct {
1234	state         protoimpl.MessageState `protogen:"open.v1"`
1235	Scope         *BrokerScope           `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
1236	OperationId   []byte                 `protobuf:"bytes,2,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"` // exactly 16 bytes
1237	Registration  *RemoteRegistration    `protobuf:"bytes,3,opt,name=registration,proto3" json:"registration,omitempty"`
1238	Policy        *BrokerWirePolicy      `protobuf:"bytes,4,opt,name=policy,proto3" json:"policy,omitempty"`
1239	unknownFields protoimpl.UnknownFields
1240	sizeCache     protoimpl.SizeCache
1241}
1242
1243func (x *UpdateHostPolicy) Reset() {
1244	*x = UpdateHostPolicy{}
1245	mi := &file_broker_proto_msgTypes[13]
1246	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1247	ms.StoreMessageInfo(mi)
1248}
1249
1250func (x *UpdateHostPolicy) String() string {
1251	return protoimpl.X.MessageStringOf(x)
1252}
1253
1254func (*UpdateHostPolicy) ProtoMessage() {}
1255
1256func (x *UpdateHostPolicy) ProtoReflect() protoreflect.Message {
1257	mi := &file_broker_proto_msgTypes[13]
1258	if x != nil {
1259		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1260		if ms.LoadMessageInfo() == nil {
1261			ms.StoreMessageInfo(mi)
1262		}
1263		return ms
1264	}
1265	return mi.MessageOf(x)
1266}
1267
1268// Deprecated: Use UpdateHostPolicy.ProtoReflect.Descriptor instead.
1269func (*UpdateHostPolicy) Descriptor() ([]byte, []int) {
1270	return file_broker_proto_rawDescGZIP(), []int{13}
1271}
1272
1273func (x *UpdateHostPolicy) GetScope() *BrokerScope {
1274	if x != nil {
1275		return x.Scope
1276	}
1277	return nil
1278}
1279
1280func (x *UpdateHostPolicy) GetOperationId() []byte {
1281	if x != nil {
1282		return x.OperationId
1283	}
1284	return nil
1285}
1286
1287func (x *UpdateHostPolicy) GetRegistration() *RemoteRegistration {
1288	if x != nil {
1289		return x.Registration
1290	}
1291	return nil
1292}
1293
1294func (x *UpdateHostPolicy) GetPolicy() *BrokerWirePolicy {
1295	if x != nil {
1296		return x.Policy
1297	}
1298	return nil
1299}
1300
1301// Reconcile hands the broker one exact registration to probe.
1302type Reconcile struct {
1303	state         protoimpl.MessageState `protogen:"open.v1"`
1304	Scope         *BrokerScope           `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
1305	Registration  *RemoteRegistration    `protobuf:"bytes,2,opt,name=registration,proto3" json:"registration,omitempty"`
1306	unknownFields protoimpl.UnknownFields
1307	sizeCache     protoimpl.SizeCache
1308}
1309
1310func (x *Reconcile) Reset() {
1311	*x = Reconcile{}
1312	mi := &file_broker_proto_msgTypes[14]
1313	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1314	ms.StoreMessageInfo(mi)
1315}
1316
1317func (x *Reconcile) String() string {
1318	return protoimpl.X.MessageStringOf(x)
1319}
1320
1321func (*Reconcile) ProtoMessage() {}
1322
1323func (x *Reconcile) ProtoReflect() protoreflect.Message {
1324	mi := &file_broker_proto_msgTypes[14]
1325	if x != nil {
1326		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1327		if ms.LoadMessageInfo() == nil {
1328			ms.StoreMessageInfo(mi)
1329		}
1330		return ms
1331	}
1332	return mi.MessageOf(x)
1333}
1334
1335// Deprecated: Use Reconcile.ProtoReflect.Descriptor instead.
1336func (*Reconcile) Descriptor() ([]byte, []int) {
1337	return file_broker_proto_rawDescGZIP(), []int{14}
1338}
1339
1340func (x *Reconcile) GetScope() *BrokerScope {
1341	if x != nil {
1342		return x.Scope
1343	}
1344	return nil
1345}
1346
1347func (x *Reconcile) GetRegistration() *RemoteRegistration {
1348	if x != nil {
1349		return x.Registration
1350	}
1351	return nil
1352}
1353
1354// OpenStream asks the broker to open one independently cancellable logical
1355// stream to the owning daemon. env is the per-request session environment
1356// and is never inherited from the broker process environment.
1357//
1358// admission is the closed attachment-admission taxonomy: an attachment
1359// stream names exactly how the daemon must admit it, while control and
1360// observation streams carry none (0). name is validated session-name
1361// authority for create-named and attach-named and is empty for every other
1362// variant.
1363// start_mode is the explicit daemon-start authorization carried to the
1364// transport: observation and daemon-stop must be existing_only, while
1365// attach/creation and the explicit list/mutate controls may be
1366// start_if_needed. Zero is invalid and is refused by semantic validation.
1367type OpenStream struct {
1368	state protoimpl.MessageState `protogen:"open.v1"`
1369	Ref   *BrokerStreamRef       `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
1370	// Closed taxonomy: 1 = attachment, 2 = control, 3 = observation.
1371	Purpose      uint32              `protobuf:"varint,2,opt,name=purpose,proto3" json:"purpose,omitempty"`
1372	Local        bool                `protobuf:"varint,3,opt,name=local,proto3" json:"local,omitempty"`
1373	Endpoint     string              `protobuf:"bytes,4,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
1374	Registration *RemoteRegistration `protobuf:"bytes,5,opt,name=registration,proto3" json:"registration,omitempty"`
1375	// Present only for exact attach/resume; the zero-value message is never
1376	// sent for a creation admission.
1377	Target *ExactTarget      `protobuf:"bytes,6,opt,name=target,proto3" json:"target,omitempty"`
1378	Env    []string          `protobuf:"bytes,7,rep,name=env,proto3" json:"env,omitempty"`
1379	Policy *BrokerWirePolicy `protobuf:"bytes,8,opt,name=policy,proto3" json:"policy,omitempty"`
1380	// Closed admission taxonomy: 0 = none (control/observation), 1 = exact
1381	// attach/resume, 2 = create named, 3 = create ephemeral, 4 = attach named
1382	// (the daemon resolves the name and refuses an unknown one).
1383	Admission uint32 `protobuf:"varint,9,opt,name=admission,proto3" json:"admission,omitempty"`
1384	// Validated session name for create-named and attach-named; empty otherwise.
1385	Name string `protobuf:"bytes,10,opt,name=name,proto3" json:"name,omitempty"`
1386	// Closed daemon-start taxonomy (ports.BrokerDaemonStartMode): 1 =
1387	// existing_only, 2 = start_if_needed. Always present; zero is refused.
1388	StartMode     uint32 `protobuf:"varint,11,opt,name=start_mode,json=startMode,proto3" json:"start_mode,omitempty"`
1389	unknownFields protoimpl.UnknownFields
1390	sizeCache     protoimpl.SizeCache
1391}
1392
1393func (x *OpenStream) Reset() {
1394	*x = OpenStream{}
1395	mi := &file_broker_proto_msgTypes[15]
1396	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1397	ms.StoreMessageInfo(mi)
1398}
1399
1400func (x *OpenStream) String() string {
1401	return protoimpl.X.MessageStringOf(x)
1402}
1403
1404func (*OpenStream) ProtoMessage() {}
1405
1406func (x *OpenStream) ProtoReflect() protoreflect.Message {
1407	mi := &file_broker_proto_msgTypes[15]
1408	if x != nil {
1409		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1410		if ms.LoadMessageInfo() == nil {
1411			ms.StoreMessageInfo(mi)
1412		}
1413		return ms
1414	}
1415	return mi.MessageOf(x)
1416}
1417
1418// Deprecated: Use OpenStream.ProtoReflect.Descriptor instead.
1419func (*OpenStream) Descriptor() ([]byte, []int) {
1420	return file_broker_proto_rawDescGZIP(), []int{15}
1421}
1422
1423func (x *OpenStream) GetRef() *BrokerStreamRef {
1424	if x != nil {
1425		return x.Ref
1426	}
1427	return nil
1428}
1429
1430func (x *OpenStream) GetPurpose() uint32 {
1431	if x != nil {
1432		return x.Purpose
1433	}
1434	return 0
1435}
1436
1437func (x *OpenStream) GetLocal() bool {
1438	if x != nil {
1439		return x.Local
1440	}
1441	return false
1442}
1443
1444func (x *OpenStream) GetEndpoint() string {
1445	if x != nil {
1446		return x.Endpoint
1447	}
1448	return ""
1449}
1450
1451func (x *OpenStream) GetRegistration() *RemoteRegistration {
1452	if x != nil {
1453		return x.Registration
1454	}
1455	return nil
1456}
1457
1458func (x *OpenStream) GetTarget() *ExactTarget {
1459	if x != nil {
1460		return x.Target
1461	}
1462	return nil
1463}
1464
1465func (x *OpenStream) GetEnv() []string {
1466	if x != nil {
1467		return x.Env
1468	}
1469	return nil
1470}
1471
1472func (x *OpenStream) GetPolicy() *BrokerWirePolicy {
1473	if x != nil {
1474		return x.Policy
1475	}
1476	return nil
1477}
1478
1479func (x *OpenStream) GetAdmission() uint32 {
1480	if x != nil {
1481		return x.Admission
1482	}
1483	return 0
1484}
1485
1486func (x *OpenStream) GetName() string {
1487	if x != nil {
1488		return x.Name
1489	}
1490	return ""
1491}
1492
1493func (x *OpenStream) GetStartMode() uint32 {
1494	if x != nil {
1495		return x.StartMode
1496	}
1497	return 0
1498}
1499
1500// ClientStreamData carries one opaque client-to-daemon stream frame.
1501type ClientStreamData struct {
1502	state         protoimpl.MessageState `protogen:"open.v1"`
1503	Ref           *BrokerStreamRef       `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
1504	Data          []byte                 `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
1505	unknownFields protoimpl.UnknownFields
1506	sizeCache     protoimpl.SizeCache
1507}
1508
1509func (x *ClientStreamData) Reset() {
1510	*x = ClientStreamData{}
1511	mi := &file_broker_proto_msgTypes[16]
1512	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1513	ms.StoreMessageInfo(mi)
1514}
1515
1516func (x *ClientStreamData) String() string {
1517	return protoimpl.X.MessageStringOf(x)
1518}
1519
1520func (*ClientStreamData) ProtoMessage() {}
1521
1522func (x *ClientStreamData) ProtoReflect() protoreflect.Message {
1523	mi := &file_broker_proto_msgTypes[16]
1524	if x != nil {
1525		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1526		if ms.LoadMessageInfo() == nil {
1527			ms.StoreMessageInfo(mi)
1528		}
1529		return ms
1530	}
1531	return mi.MessageOf(x)
1532}
1533
1534// Deprecated: Use ClientStreamData.ProtoReflect.Descriptor instead.
1535func (*ClientStreamData) Descriptor() ([]byte, []int) {
1536	return file_broker_proto_rawDescGZIP(), []int{16}
1537}
1538
1539func (x *ClientStreamData) GetRef() *BrokerStreamRef {
1540	if x != nil {
1541		return x.Ref
1542	}
1543	return nil
1544}
1545
1546func (x *ClientStreamData) GetData() []byte {
1547	if x != nil {
1548		return x.Data
1549	}
1550	return nil
1551}
1552
1553// CloseStream closes one logical stream.
1554type CloseStream struct {
1555	state         protoimpl.MessageState `protogen:"open.v1"`
1556	Ref           *BrokerStreamRef       `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
1557	unknownFields protoimpl.UnknownFields
1558	sizeCache     protoimpl.SizeCache
1559}
1560
1561func (x *CloseStream) Reset() {
1562	*x = CloseStream{}
1563	mi := &file_broker_proto_msgTypes[17]
1564	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1565	ms.StoreMessageInfo(mi)
1566}
1567
1568func (x *CloseStream) String() string {
1569	return protoimpl.X.MessageStringOf(x)
1570}
1571
1572func (*CloseStream) ProtoMessage() {}
1573
1574func (x *CloseStream) ProtoReflect() protoreflect.Message {
1575	mi := &file_broker_proto_msgTypes[17]
1576	if x != nil {
1577		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1578		if ms.LoadMessageInfo() == nil {
1579			ms.StoreMessageInfo(mi)
1580		}
1581		return ms
1582	}
1583	return mi.MessageOf(x)
1584}
1585
1586// Deprecated: Use CloseStream.ProtoReflect.Descriptor instead.
1587func (*CloseStream) Descriptor() ([]byte, []int) {
1588	return file_broker_proto_rawDescGZIP(), []int{17}
1589}
1590
1591func (x *CloseStream) GetRef() *BrokerStreamRef {
1592	if x != nil {
1593		return x.Ref
1594	}
1595	return nil
1596}
1597
1598// StreamWindowUpdate grants the peer credit to send more stream data on one
1599// logical stream: the receiver consumed that much of its stream window. Each
1600// direction of a stream has its own window, so a client grants credit for
1601// ServerStreamData and the server grants credit for ClientStreamData.
1602type StreamWindowUpdate struct {
1603	state         protoimpl.MessageState `protogen:"open.v1"`
1604	Ref           *BrokerStreamRef       `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
1605	Credit        uint64                 `protobuf:"varint,2,opt,name=credit,proto3" json:"credit,omitempty"`
1606	unknownFields protoimpl.UnknownFields
1607	sizeCache     protoimpl.SizeCache
1608}
1609
1610func (x *StreamWindowUpdate) Reset() {
1611	*x = StreamWindowUpdate{}
1612	mi := &file_broker_proto_msgTypes[18]
1613	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1614	ms.StoreMessageInfo(mi)
1615}
1616
1617func (x *StreamWindowUpdate) String() string {
1618	return protoimpl.X.MessageStringOf(x)
1619}
1620
1621func (*StreamWindowUpdate) ProtoMessage() {}
1622
1623func (x *StreamWindowUpdate) ProtoReflect() protoreflect.Message {
1624	mi := &file_broker_proto_msgTypes[18]
1625	if x != nil {
1626		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1627		if ms.LoadMessageInfo() == nil {
1628			ms.StoreMessageInfo(mi)
1629		}
1630		return ms
1631	}
1632	return mi.MessageOf(x)
1633}
1634
1635// Deprecated: Use StreamWindowUpdate.ProtoReflect.Descriptor instead.
1636func (*StreamWindowUpdate) Descriptor() ([]byte, []int) {
1637	return file_broker_proto_rawDescGZIP(), []int{18}
1638}
1639
1640func (x *StreamWindowUpdate) GetRef() *BrokerStreamRef {
1641	if x != nil {
1642		return x.Ref
1643	}
1644	return nil
1645}
1646
1647func (x *StreamWindowUpdate) GetCredit() uint64 {
1648	if x != nil {
1649		return x.Credit
1650	}
1651	return 0
1652}
1653
1654// Registered confirms one accepted client connection and its assigned scope.
1655type Registered struct {
1656	state         protoimpl.MessageState `protogen:"open.v1"`
1657	Scope         *BrokerScope           `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
1658	Build         string                 `protobuf:"bytes,2,opt,name=build,proto3" json:"build,omitempty"`
1659	Retiring      bool                   `protobuf:"varint,3,opt,name=retiring,proto3" json:"retiring,omitempty"`
1660	unknownFields protoimpl.UnknownFields
1661	sizeCache     protoimpl.SizeCache
1662}
1663
1664func (x *Registered) Reset() {
1665	*x = Registered{}
1666	mi := &file_broker_proto_msgTypes[19]
1667	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1668	ms.StoreMessageInfo(mi)
1669}
1670
1671func (x *Registered) String() string {
1672	return protoimpl.X.MessageStringOf(x)
1673}
1674
1675func (*Registered) ProtoMessage() {}
1676
1677func (x *Registered) ProtoReflect() protoreflect.Message {
1678	mi := &file_broker_proto_msgTypes[19]
1679	if x != nil {
1680		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1681		if ms.LoadMessageInfo() == nil {
1682			ms.StoreMessageInfo(mi)
1683		}
1684		return ms
1685	}
1686	return mi.MessageOf(x)
1687}
1688
1689// Deprecated: Use Registered.ProtoReflect.Descriptor instead.
1690func (*Registered) Descriptor() ([]byte, []int) {
1691	return file_broker_proto_rawDescGZIP(), []int{19}
1692}
1693
1694func (x *Registered) GetScope() *BrokerScope {
1695	if x != nil {
1696		return x.Scope
1697	}
1698	return nil
1699}
1700
1701func (x *Registered) GetBuild() string {
1702	if x != nil {
1703		return x.Build
1704	}
1705	return ""
1706}
1707
1708func (x *Registered) GetRetiring() bool {
1709	if x != nil {
1710		return x.Retiring
1711	}
1712	return false
1713}
1714
1715// SnapshotPart is one fragment of a snapshot publication. Parts of one
1716// generation and revision arrive in index order and carry exactly one
1717// nested payload.
1718type SnapshotPart struct {
1719	state      protoimpl.MessageState `protogen:"open.v1"`
1720	Scope      *BrokerScope           `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
1721	Generation uint64                 `protobuf:"varint,2,opt,name=generation,proto3" json:"generation,omitempty"`
1722	Revision   uint64                 `protobuf:"varint,3,opt,name=revision,proto3" json:"revision,omitempty"`
1723	Index      uint32                 `protobuf:"varint,4,opt,name=index,proto3" json:"index,omitempty"`
1724	// Types that are valid to be assigned to Part:
1725	//
1726	//	*SnapshotPart_Begin
1727	//	*SnapshotPart_Daemon
1728	//	*SnapshotPart_Session
1729	//	*SnapshotPart_Tombstone
1730	//	*SnapshotPart_End
1731	Part          isSnapshotPart_Part `protobuf_oneof:"part"`
1732	unknownFields protoimpl.UnknownFields
1733	sizeCache     protoimpl.SizeCache
1734}
1735
1736func (x *SnapshotPart) Reset() {
1737	*x = SnapshotPart{}
1738	mi := &file_broker_proto_msgTypes[20]
1739	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1740	ms.StoreMessageInfo(mi)
1741}
1742
1743func (x *SnapshotPart) String() string {
1744	return protoimpl.X.MessageStringOf(x)
1745}
1746
1747func (*SnapshotPart) ProtoMessage() {}
1748
1749func (x *SnapshotPart) ProtoReflect() protoreflect.Message {
1750	mi := &file_broker_proto_msgTypes[20]
1751	if x != nil {
1752		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1753		if ms.LoadMessageInfo() == nil {
1754			ms.StoreMessageInfo(mi)
1755		}
1756		return ms
1757	}
1758	return mi.MessageOf(x)
1759}
1760
1761// Deprecated: Use SnapshotPart.ProtoReflect.Descriptor instead.
1762func (*SnapshotPart) Descriptor() ([]byte, []int) {
1763	return file_broker_proto_rawDescGZIP(), []int{20}
1764}
1765
1766func (x *SnapshotPart) GetScope() *BrokerScope {
1767	if x != nil {
1768		return x.Scope
1769	}
1770	return nil
1771}
1772
1773func (x *SnapshotPart) GetGeneration() uint64 {
1774	if x != nil {
1775		return x.Generation
1776	}
1777	return 0
1778}
1779
1780func (x *SnapshotPart) GetRevision() uint64 {
1781	if x != nil {
1782		return x.Revision
1783	}
1784	return 0
1785}
1786
1787func (x *SnapshotPart) GetIndex() uint32 {
1788	if x != nil {
1789		return x.Index
1790	}
1791	return 0
1792}
1793
1794func (x *SnapshotPart) GetPart() isSnapshotPart_Part {
1795	if x != nil {
1796		return x.Part
1797	}
1798	return nil
1799}
1800
1801func (x *SnapshotPart) GetBegin() *SnapshotBegin {
1802	if x != nil {
1803		if x, ok := x.Part.(*SnapshotPart_Begin); ok {
1804			return x.Begin
1805		}
1806	}
1807	return nil
1808}
1809
1810func (x *SnapshotPart) GetDaemon() *SnapshotDaemon {
1811	if x != nil {
1812		if x, ok := x.Part.(*SnapshotPart_Daemon); ok {
1813			return x.Daemon
1814		}
1815	}
1816	return nil
1817}
1818
1819func (x *SnapshotPart) GetSession() *SnapshotSession {
1820	if x != nil {
1821		if x, ok := x.Part.(*SnapshotPart_Session); ok {
1822			return x.Session
1823		}
1824	}
1825	return nil
1826}
1827
1828func (x *SnapshotPart) GetTombstone() *SnapshotTombstone {
1829	if x != nil {
1830		if x, ok := x.Part.(*SnapshotPart_Tombstone); ok {
1831			return x.Tombstone
1832		}
1833	}
1834	return nil
1835}
1836
1837func (x *SnapshotPart) GetEnd() *SnapshotEnd {
1838	if x != nil {
1839		if x, ok := x.Part.(*SnapshotPart_End); ok {
1840			return x.End
1841		}
1842	}
1843	return nil
1844}
1845
1846type isSnapshotPart_Part interface {
1847	isSnapshotPart_Part()
1848}
1849
1850type SnapshotPart_Begin struct {
1851	Begin *SnapshotBegin `protobuf:"bytes,10,opt,name=begin,proto3,oneof"`
1852}
1853
1854type SnapshotPart_Daemon struct {
1855	Daemon *SnapshotDaemon `protobuf:"bytes,15,opt,name=daemon,proto3,oneof"`
1856}
1857
1858type SnapshotPart_Session struct {
1859	Session *SnapshotSession `protobuf:"bytes,12,opt,name=session,proto3,oneof"`
1860}
1861
1862type SnapshotPart_Tombstone struct {
1863	Tombstone *SnapshotTombstone `protobuf:"bytes,13,opt,name=tombstone,proto3,oneof"`
1864}
1865
1866type SnapshotPart_End struct {
1867	End *SnapshotEnd `protobuf:"bytes,14,opt,name=end,proto3,oneof"`
1868}
1869
1870func (*SnapshotPart_Begin) isSnapshotPart_Part() {}
1871
1872func (*SnapshotPart_Daemon) isSnapshotPart_Part() {}
1873
1874func (*SnapshotPart_Session) isSnapshotPart_Part() {}
1875
1876func (*SnapshotPart_Tombstone) isSnapshotPart_Part() {}
1877
1878func (*SnapshotPart_End) isSnapshotPart_Part() {}
1879
1880// SnapshotBegin opens a snapshot publication with its element counts.
1881// host_count counts every daemon part in the transfer (the local daemon plus
1882// every remote host), and local_present reports whether daemon index 0 is the
1883// local daemon. A publication carries at most one local daemon, always first.
1884type SnapshotBegin struct {
1885	state          protoimpl.MessageState `protogen:"open.v1"`
1886	HostCount      uint32                 `protobuf:"varint,1,opt,name=host_count,json=hostCount,proto3" json:"host_count,omitempty"`
1887	SessionCount   uint32                 `protobuf:"varint,2,opt,name=session_count,json=sessionCount,proto3" json:"session_count,omitempty"`
1888	TombstoneCount uint32                 `protobuf:"varint,3,opt,name=tombstone_count,json=tombstoneCount,proto3" json:"tombstone_count,omitempty"`
1889	LocalPresent   bool                   `protobuf:"varint,4,opt,name=local_present,json=localPresent,proto3" json:"local_present,omitempty"`
1890	unknownFields  protoimpl.UnknownFields
1891	sizeCache      protoimpl.SizeCache
1892}
1893
1894func (x *SnapshotBegin) Reset() {
1895	*x = SnapshotBegin{}
1896	mi := &file_broker_proto_msgTypes[21]
1897	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1898	ms.StoreMessageInfo(mi)
1899}
1900
1901func (x *SnapshotBegin) String() string {
1902	return protoimpl.X.MessageStringOf(x)
1903}
1904
1905func (*SnapshotBegin) ProtoMessage() {}
1906
1907func (x *SnapshotBegin) ProtoReflect() protoreflect.Message {
1908	mi := &file_broker_proto_msgTypes[21]
1909	if x != nil {
1910		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1911		if ms.LoadMessageInfo() == nil {
1912			ms.StoreMessageInfo(mi)
1913		}
1914		return ms
1915	}
1916	return mi.MessageOf(x)
1917}
1918
1919// Deprecated: Use SnapshotBegin.ProtoReflect.Descriptor instead.
1920func (*SnapshotBegin) Descriptor() ([]byte, []int) {
1921	return file_broker_proto_rawDescGZIP(), []int{21}
1922}
1923
1924func (x *SnapshotBegin) GetHostCount() uint32 {
1925	if x != nil {
1926		return x.HostCount
1927	}
1928	return 0
1929}
1930
1931func (x *SnapshotBegin) GetSessionCount() uint32 {
1932	if x != nil {
1933		return x.SessionCount
1934	}
1935	return 0
1936}
1937
1938func (x *SnapshotBegin) GetTombstoneCount() uint32 {
1939	if x != nil {
1940		return x.TombstoneCount
1941	}
1942	return 0
1943}
1944
1945func (x *SnapshotBegin) GetLocalPresent() bool {
1946	if x != nil {
1947		return x.LocalPresent
1948	}
1949	return false
1950}
1951
1952// SnapshotDaemon is one daemon projection (ports.BrokerDaemonObservation),
1953// local or remote. Configured authority (endpoint, registration, policy,
1954// display origin, rank) stays separate from observed state (identity,
1955// incarnation, version, capabilities, availability, failure, freshness),
1956// and observation never invents unknown values. registration is absent for
1957// the local daemon; policy is always present. Sessions travel as separate
1958// SnapshotSession parts.
1959type SnapshotDaemon struct {
1960	state         protoimpl.MessageState `protogen:"open.v1"`
1961	HostIndex     uint32                 `protobuf:"varint,1,opt,name=host_index,json=hostIndex,proto3" json:"host_index,omitempty"`
1962	Local         bool                   `protobuf:"varint,2,opt,name=local,proto3" json:"local,omitempty"`
1963	Endpoint      string                 `protobuf:"bytes,3,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
1964	DisplayOrigin string                 `protobuf:"bytes,4,opt,name=display_origin,json=displayOrigin,proto3" json:"display_origin,omitempty"`
1965	Rank          uint32                 `protobuf:"varint,5,opt,name=rank,proto3" json:"rank,omitempty"`
1966	Registration  *RemoteRegistration    `protobuf:"bytes,6,opt,name=registration,proto3" json:"registration,omitempty"`
1967	Policy        *BrokerWirePolicy      `protobuf:"bytes,7,opt,name=policy,proto3" json:"policy,omitempty"`
1968	// Authenticated daemon identity; empty until observed.
1969	DaemonIdentity string `protobuf:"bytes,8,opt,name=daemon_identity,json=daemonIdentity,proto3" json:"daemon_identity,omitempty"`
1970	// Daemon process incarnation; exactly 16 bytes when an identity is
1971	// present and absent otherwise.
1972	DaemonIncarnation []byte `protobuf:"bytes,9,opt,name=daemon_incarnation,json=daemonIncarnation,proto3" json:"daemon_incarnation,omitempty"`
1973	// Observed daemon protocol version; 0 = unobserved.
1974	ProtocolVersion uint32 `protobuf:"varint,10,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
1975	// Observed capability bitmask (mirrors protocol.Capability* bits).
1976	Capabilities uint32 `protobuf:"varint,11,opt,name=capabilities,proto3" json:"capabilities,omitempty"`
1977	// Closed availability taxonomy (domain.RemoteAvailability); 0 is
1978	// invalid, an unobserved daemon carries RemoteAvailabilityUnknown.
1979	Availability        uint32           `protobuf:"varint,12,opt,name=availability,proto3" json:"availability,omitempty"`
1980	Checking            bool             `protobuf:"varint,13,opt,name=checking,proto3" json:"checking,omitempty"`
1981	LastAttempt         *BrokerTimestamp `protobuf:"bytes,14,opt,name=last_attempt,json=lastAttempt,proto3" json:"last_attempt,omitempty"`
1982	LastSuccess         *BrokerTimestamp `protobuf:"bytes,15,opt,name=last_success,json=lastSuccess,proto3" json:"last_success,omitempty"`
1983	NextDue             *BrokerTimestamp `protobuf:"bytes,16,opt,name=next_due,json=nextDue,proto3" json:"next_due,omitempty"`
1984	ConsecutiveFailures uint64           `protobuf:"varint,17,opt,name=consecutive_failures,json=consecutiveFailures,proto3" json:"consecutive_failures,omitempty"`
1985	FailureEpisode      uint64           `protobuf:"varint,18,opt,name=failure_episode,json=failureEpisode,proto3" json:"failure_episode,omitempty"`
1986	// Closed cause taxonomy (domain.RemoteFailureKind); 0 = none.
1987	FailureKind    uint32 `protobuf:"varint,19,opt,name=failure_kind,json=failureKind,proto3" json:"failure_kind,omitempty"`
1988	InventoryKnown bool   `protobuf:"varint,20,opt,name=inventory_known,json=inventoryKnown,proto3" json:"inventory_known,omitempty"`
1989	SessionCount   uint32 `protobuf:"varint,21,opt,name=session_count,json=sessionCount,proto3" json:"session_count,omitempty"`
1990	unknownFields  protoimpl.UnknownFields
1991	sizeCache      protoimpl.SizeCache
1992}
1993
1994func (x *SnapshotDaemon) Reset() {
1995	*x = SnapshotDaemon{}
1996	mi := &file_broker_proto_msgTypes[22]
1997	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
1998	ms.StoreMessageInfo(mi)
1999}
2000
2001func (x *SnapshotDaemon) String() string {
2002	return protoimpl.X.MessageStringOf(x)
2003}
2004
2005func (*SnapshotDaemon) ProtoMessage() {}
2006
2007func (x *SnapshotDaemon) ProtoReflect() protoreflect.Message {
2008	mi := &file_broker_proto_msgTypes[22]
2009	if x != nil {
2010		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2011		if ms.LoadMessageInfo() == nil {
2012			ms.StoreMessageInfo(mi)
2013		}
2014		return ms
2015	}
2016	return mi.MessageOf(x)
2017}
2018
2019// Deprecated: Use SnapshotDaemon.ProtoReflect.Descriptor instead.
2020func (*SnapshotDaemon) Descriptor() ([]byte, []int) {
2021	return file_broker_proto_rawDescGZIP(), []int{22}
2022}
2023
2024func (x *SnapshotDaemon) GetHostIndex() uint32 {
2025	if x != nil {
2026		return x.HostIndex
2027	}
2028	return 0
2029}
2030
2031func (x *SnapshotDaemon) GetLocal() bool {
2032	if x != nil {
2033		return x.Local
2034	}
2035	return false
2036}
2037
2038func (x *SnapshotDaemon) GetEndpoint() string {
2039	if x != nil {
2040		return x.Endpoint
2041	}
2042	return ""
2043}
2044
2045func (x *SnapshotDaemon) GetDisplayOrigin() string {
2046	if x != nil {
2047		return x.DisplayOrigin
2048	}
2049	return ""
2050}
2051
2052func (x *SnapshotDaemon) GetRank() uint32 {
2053	if x != nil {
2054		return x.Rank
2055	}
2056	return 0
2057}
2058
2059func (x *SnapshotDaemon) GetRegistration() *RemoteRegistration {
2060	if x != nil {
2061		return x.Registration
2062	}
2063	return nil
2064}
2065
2066func (x *SnapshotDaemon) GetPolicy() *BrokerWirePolicy {
2067	if x != nil {
2068		return x.Policy
2069	}
2070	return nil
2071}
2072
2073func (x *SnapshotDaemon) GetDaemonIdentity() string {
2074	if x != nil {
2075		return x.DaemonIdentity
2076	}
2077	return ""
2078}
2079
2080func (x *SnapshotDaemon) GetDaemonIncarnation() []byte {
2081	if x != nil {
2082		return x.DaemonIncarnation
2083	}
2084	return nil
2085}
2086
2087func (x *SnapshotDaemon) GetProtocolVersion() uint32 {
2088	if x != nil {
2089		return x.ProtocolVersion
2090	}
2091	return 0
2092}
2093
2094func (x *SnapshotDaemon) GetCapabilities() uint32 {
2095	if x != nil {
2096		return x.Capabilities
2097	}
2098	return 0
2099}
2100
2101func (x *SnapshotDaemon) GetAvailability() uint32 {
2102	if x != nil {
2103		return x.Availability
2104	}
2105	return 0
2106}
2107
2108func (x *SnapshotDaemon) GetChecking() bool {
2109	if x != nil {
2110		return x.Checking
2111	}
2112	return false
2113}
2114
2115func (x *SnapshotDaemon) GetLastAttempt() *BrokerTimestamp {
2116	if x != nil {
2117		return x.LastAttempt
2118	}
2119	return nil
2120}
2121
2122func (x *SnapshotDaemon) GetLastSuccess() *BrokerTimestamp {
2123	if x != nil {
2124		return x.LastSuccess
2125	}
2126	return nil
2127}
2128
2129func (x *SnapshotDaemon) GetNextDue() *BrokerTimestamp {
2130	if x != nil {
2131		return x.NextDue
2132	}
2133	return nil
2134}
2135
2136func (x *SnapshotDaemon) GetConsecutiveFailures() uint64 {
2137	if x != nil {
2138		return x.ConsecutiveFailures
2139	}
2140	return 0
2141}
2142
2143func (x *SnapshotDaemon) GetFailureEpisode() uint64 {
2144	if x != nil {
2145		return x.FailureEpisode
2146	}
2147	return 0
2148}
2149
2150func (x *SnapshotDaemon) GetFailureKind() uint32 {
2151	if x != nil {
2152		return x.FailureKind
2153	}
2154	return 0
2155}
2156
2157func (x *SnapshotDaemon) GetInventoryKnown() bool {
2158	if x != nil {
2159		return x.InventoryKnown
2160	}
2161	return false
2162}
2163
2164func (x *SnapshotDaemon) GetSessionCount() uint32 {
2165	if x != nil {
2166		return x.SessionCount
2167	}
2168	return 0
2169}
2170
2171// SnapshotSession is one catalogue session bound to its daemon by index.
2172// local marks a session of the local daemon; its host_index is then exactly
2173// 0 and follows the local daemon part rather than a remote host index.
2174type SnapshotSession struct {
2175	state         protoimpl.MessageState `protogen:"open.v1"`
2176	HostIndex     uint32                 `protobuf:"varint,1,opt,name=host_index,json=hostIndex,proto3" json:"host_index,omitempty"`
2177	SessionIndex  uint32                 `protobuf:"varint,2,opt,name=session_index,json=sessionIndex,proto3" json:"session_index,omitempty"`
2178	Session       *BrokerCatalogSession  `protobuf:"bytes,3,opt,name=session,proto3" json:"session,omitempty"`
2179	Local         bool                   `protobuf:"varint,4,opt,name=local,proto3" json:"local,omitempty"`
2180	unknownFields protoimpl.UnknownFields
2181	sizeCache     protoimpl.SizeCache
2182}
2183
2184func (x *SnapshotSession) Reset() {
2185	*x = SnapshotSession{}
2186	mi := &file_broker_proto_msgTypes[23]
2187	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2188	ms.StoreMessageInfo(mi)
2189}
2190
2191func (x *SnapshotSession) String() string {
2192	return protoimpl.X.MessageStringOf(x)
2193}
2194
2195func (*SnapshotSession) ProtoMessage() {}
2196
2197func (x *SnapshotSession) ProtoReflect() protoreflect.Message {
2198	mi := &file_broker_proto_msgTypes[23]
2199	if x != nil {
2200		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2201		if ms.LoadMessageInfo() == nil {
2202			ms.StoreMessageInfo(mi)
2203		}
2204		return ms
2205	}
2206	return mi.MessageOf(x)
2207}
2208
2209// Deprecated: Use SnapshotSession.ProtoReflect.Descriptor instead.
2210func (*SnapshotSession) Descriptor() ([]byte, []int) {
2211	return file_broker_proto_rawDescGZIP(), []int{23}
2212}
2213
2214func (x *SnapshotSession) GetHostIndex() uint32 {
2215	if x != nil {
2216		return x.HostIndex
2217	}
2218	return 0
2219}
2220
2221func (x *SnapshotSession) GetSessionIndex() uint32 {
2222	if x != nil {
2223		return x.SessionIndex
2224	}
2225	return 0
2226}
2227
2228func (x *SnapshotSession) GetSession() *BrokerCatalogSession {
2229	if x != nil {
2230		return x.Session
2231	}
2232	return nil
2233}
2234
2235func (x *SnapshotSession) GetLocal() bool {
2236	if x != nil {
2237		return x.Local
2238	}
2239	return false
2240}
2241
2242// SnapshotTombstone fences one retired host registration so a stale probe
2243// cannot revive authority for that exact incarnation.
2244type SnapshotTombstone struct {
2245	state           protoimpl.MessageState `protogen:"open.v1"`
2246	TombstoneIndex  uint32                 `protobuf:"varint,1,opt,name=tombstone_index,json=tombstoneIndex,proto3" json:"tombstone_index,omitempty"`
2247	Registration    *RemoteRegistration    `protobuf:"bytes,2,opt,name=registration,proto3" json:"registration,omitempty"`
2248	RetiredRevision uint64                 `protobuf:"varint,3,opt,name=retired_revision,json=retiredRevision,proto3" json:"retired_revision,omitempty"`
2249	unknownFields   protoimpl.UnknownFields
2250	sizeCache       protoimpl.SizeCache
2251}
2252
2253func (x *SnapshotTombstone) Reset() {
2254	*x = SnapshotTombstone{}
2255	mi := &file_broker_proto_msgTypes[24]
2256	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2257	ms.StoreMessageInfo(mi)
2258}
2259
2260func (x *SnapshotTombstone) String() string {
2261	return protoimpl.X.MessageStringOf(x)
2262}
2263
2264func (*SnapshotTombstone) ProtoMessage() {}
2265
2266func (x *SnapshotTombstone) ProtoReflect() protoreflect.Message {
2267	mi := &file_broker_proto_msgTypes[24]
2268	if x != nil {
2269		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2270		if ms.LoadMessageInfo() == nil {
2271			ms.StoreMessageInfo(mi)
2272		}
2273		return ms
2274	}
2275	return mi.MessageOf(x)
2276}
2277
2278// Deprecated: Use SnapshotTombstone.ProtoReflect.Descriptor instead.
2279func (*SnapshotTombstone) Descriptor() ([]byte, []int) {
2280	return file_broker_proto_rawDescGZIP(), []int{24}
2281}
2282
2283func (x *SnapshotTombstone) GetTombstoneIndex() uint32 {
2284	if x != nil {
2285		return x.TombstoneIndex
2286	}
2287	return 0
2288}
2289
2290func (x *SnapshotTombstone) GetRegistration() *RemoteRegistration {
2291	if x != nil {
2292		return x.Registration
2293	}
2294	return nil
2295}
2296
2297func (x *SnapshotTombstone) GetRetiredRevision() uint64 {
2298	if x != nil {
2299		return x.RetiredRevision
2300	}
2301	return 0
2302}
2303
2304// SnapshotEnd closes a snapshot publication.
2305type SnapshotEnd struct {
2306	state         protoimpl.MessageState `protogen:"open.v1"`
2307	unknownFields protoimpl.UnknownFields
2308	sizeCache     protoimpl.SizeCache
2309}
2310
2311func (x *SnapshotEnd) Reset() {
2312	*x = SnapshotEnd{}
2313	mi := &file_broker_proto_msgTypes[25]
2314	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2315	ms.StoreMessageInfo(mi)
2316}
2317
2318func (x *SnapshotEnd) String() string {
2319	return protoimpl.X.MessageStringOf(x)
2320}
2321
2322func (*SnapshotEnd) ProtoMessage() {}
2323
2324func (x *SnapshotEnd) ProtoReflect() protoreflect.Message {
2325	mi := &file_broker_proto_msgTypes[25]
2326	if x != nil {
2327		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2328		if ms.LoadMessageInfo() == nil {
2329			ms.StoreMessageInfo(mi)
2330		}
2331		return ms
2332	}
2333	return mi.MessageOf(x)
2334}
2335
2336// Deprecated: Use SnapshotEnd.ProtoReflect.Descriptor instead.
2337func (*SnapshotEnd) Descriptor() ([]byte, []int) {
2338	return file_broker_proto_rawDescGZIP(), []int{25}
2339}
2340
2341// OperationResult is exactly one completion for one admitted mutating
2342// operation. removed and registration are presence-carrying authority:
2343// an authoritative success carries the resulting registration, a removal
2344// success carries none, and a failed or outcome-unknown result carries
2345// neither removal nor registration, only its typed error.
2346type OperationResult struct {
2347	state       protoimpl.MessageState `protogen:"open.v1"`
2348	Scope       *BrokerScope           `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
2349	OperationId []byte                 `protobuf:"bytes,2,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"` // exactly 16 bytes
2350	// Closed taxonomy: 1 = ok, 2 = failed, 3 = outcome_unknown.
2351	Outcome       uint32              `protobuf:"varint,3,opt,name=outcome,proto3" json:"outcome,omitempty"`
2352	Removed       bool                `protobuf:"varint,4,opt,name=removed,proto3" json:"removed,omitempty"`
2353	Error         *BrokerErrorDetail  `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
2354	Registration  *RemoteRegistration `protobuf:"bytes,6,opt,name=registration,proto3" json:"registration,omitempty"`
2355	unknownFields protoimpl.UnknownFields
2356	sizeCache     protoimpl.SizeCache
2357}
2358
2359func (x *OperationResult) Reset() {
2360	*x = OperationResult{}
2361	mi := &file_broker_proto_msgTypes[26]
2362	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2363	ms.StoreMessageInfo(mi)
2364}
2365
2366func (x *OperationResult) String() string {
2367	return protoimpl.X.MessageStringOf(x)
2368}
2369
2370func (*OperationResult) ProtoMessage() {}
2371
2372func (x *OperationResult) ProtoReflect() protoreflect.Message {
2373	mi := &file_broker_proto_msgTypes[26]
2374	if x != nil {
2375		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2376		if ms.LoadMessageInfo() == nil {
2377			ms.StoreMessageInfo(mi)
2378		}
2379		return ms
2380	}
2381	return mi.MessageOf(x)
2382}
2383
2384// Deprecated: Use OperationResult.ProtoReflect.Descriptor instead.
2385func (*OperationResult) Descriptor() ([]byte, []int) {
2386	return file_broker_proto_rawDescGZIP(), []int{26}
2387}
2388
2389func (x *OperationResult) GetScope() *BrokerScope {
2390	if x != nil {
2391		return x.Scope
2392	}
2393	return nil
2394}
2395
2396func (x *OperationResult) GetOperationId() []byte {
2397	if x != nil {
2398		return x.OperationId
2399	}
2400	return nil
2401}
2402
2403func (x *OperationResult) GetOutcome() uint32 {
2404	if x != nil {
2405		return x.Outcome
2406	}
2407	return 0
2408}
2409
2410func (x *OperationResult) GetRemoved() bool {
2411	if x != nil {
2412		return x.Removed
2413	}
2414	return false
2415}
2416
2417func (x *OperationResult) GetError() *BrokerErrorDetail {
2418	if x != nil {
2419		return x.Error
2420	}
2421	return nil
2422}
2423
2424func (x *OperationResult) GetRegistration() *RemoteRegistration {
2425	if x != nil {
2426		return x.Registration
2427	}
2428	return nil
2429}
2430
2431// StreamOpened confirms one logical stream is established.
2432type StreamOpened struct {
2433	state         protoimpl.MessageState `protogen:"open.v1"`
2434	Ref           *BrokerStreamRef       `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
2435	unknownFields protoimpl.UnknownFields
2436	sizeCache     protoimpl.SizeCache
2437}
2438
2439func (x *StreamOpened) Reset() {
2440	*x = StreamOpened{}
2441	mi := &file_broker_proto_msgTypes[27]
2442	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2443	ms.StoreMessageInfo(mi)
2444}
2445
2446func (x *StreamOpened) String() string {
2447	return protoimpl.X.MessageStringOf(x)
2448}
2449
2450func (*StreamOpened) ProtoMessage() {}
2451
2452func (x *StreamOpened) ProtoReflect() protoreflect.Message {
2453	mi := &file_broker_proto_msgTypes[27]
2454	if x != nil {
2455		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2456		if ms.LoadMessageInfo() == nil {
2457			ms.StoreMessageInfo(mi)
2458		}
2459		return ms
2460	}
2461	return mi.MessageOf(x)
2462}
2463
2464// Deprecated: Use StreamOpened.ProtoReflect.Descriptor instead.
2465func (*StreamOpened) Descriptor() ([]byte, []int) {
2466	return file_broker_proto_rawDescGZIP(), []int{27}
2467}
2468
2469func (x *StreamOpened) GetRef() *BrokerStreamRef {
2470	if x != nil {
2471		return x.Ref
2472	}
2473	return nil
2474}
2475
2476// ServerStreamData carries one opaque daemon-to-client stream frame.
2477type ServerStreamData struct {
2478	state         protoimpl.MessageState `protogen:"open.v1"`
2479	Ref           *BrokerStreamRef       `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
2480	Data          []byte                 `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
2481	unknownFields protoimpl.UnknownFields
2482	sizeCache     protoimpl.SizeCache
2483}
2484
2485func (x *ServerStreamData) Reset() {
2486	*x = ServerStreamData{}
2487	mi := &file_broker_proto_msgTypes[28]
2488	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2489	ms.StoreMessageInfo(mi)
2490}
2491
2492func (x *ServerStreamData) String() string {
2493	return protoimpl.X.MessageStringOf(x)
2494}
2495
2496func (*ServerStreamData) ProtoMessage() {}
2497
2498func (x *ServerStreamData) ProtoReflect() protoreflect.Message {
2499	mi := &file_broker_proto_msgTypes[28]
2500	if x != nil {
2501		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2502		if ms.LoadMessageInfo() == nil {
2503			ms.StoreMessageInfo(mi)
2504		}
2505		return ms
2506	}
2507	return mi.MessageOf(x)
2508}
2509
2510// Deprecated: Use ServerStreamData.ProtoReflect.Descriptor instead.
2511func (*ServerStreamData) Descriptor() ([]byte, []int) {
2512	return file_broker_proto_rawDescGZIP(), []int{28}
2513}
2514
2515func (x *ServerStreamData) GetRef() *BrokerStreamRef {
2516	if x != nil {
2517		return x.Ref
2518	}
2519	return nil
2520}
2521
2522func (x *ServerStreamData) GetData() []byte {
2523	if x != nil {
2524		return x.Data
2525	}
2526	return nil
2527}
2528
2529// StreamClosed ends one logical stream. An unset error is an orderly close;
2530// a set error reports the typed failure that ended it.
2531type StreamClosed struct {
2532	state         protoimpl.MessageState `protogen:"open.v1"`
2533	Ref           *BrokerStreamRef       `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
2534	Error         *BrokerErrorDetail     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
2535	unknownFields protoimpl.UnknownFields
2536	sizeCache     protoimpl.SizeCache
2537}
2538
2539func (x *StreamClosed) Reset() {
2540	*x = StreamClosed{}
2541	mi := &file_broker_proto_msgTypes[29]
2542	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2543	ms.StoreMessageInfo(mi)
2544}
2545
2546func (x *StreamClosed) String() string {
2547	return protoimpl.X.MessageStringOf(x)
2548}
2549
2550func (*StreamClosed) ProtoMessage() {}
2551
2552func (x *StreamClosed) ProtoReflect() protoreflect.Message {
2553	mi := &file_broker_proto_msgTypes[29]
2554	if x != nil {
2555		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2556		if ms.LoadMessageInfo() == nil {
2557			ms.StoreMessageInfo(mi)
2558		}
2559		return ms
2560	}
2561	return mi.MessageOf(x)
2562}
2563
2564// Deprecated: Use StreamClosed.ProtoReflect.Descriptor instead.
2565func (*StreamClosed) Descriptor() ([]byte, []int) {
2566	return file_broker_proto_rawDescGZIP(), []int{29}
2567}
2568
2569func (x *StreamClosed) GetRef() *BrokerStreamRef {
2570	if x != nil {
2571		return x.Ref
2572	}
2573	return nil
2574}
2575
2576func (x *StreamClosed) GetError() *BrokerErrorDetail {
2577	if x != nil {
2578		return x.Error
2579	}
2580	return nil
2581}
2582
2583// Progress reports one phase of a long-running broker operation.
2584type Progress struct {
2585	state         protoimpl.MessageState `protogen:"open.v1"`
2586	Ref           *BrokerStreamRef       `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
2587	Phase         uint32                 `protobuf:"varint,2,opt,name=phase,proto3" json:"phase,omitempty"`
2588	Text          string                 `protobuf:"bytes,3,opt,name=text,proto3" json:"text,omitempty"`
2589	unknownFields protoimpl.UnknownFields
2590	sizeCache     protoimpl.SizeCache
2591}
2592
2593func (x *Progress) Reset() {
2594	*x = Progress{}
2595	mi := &file_broker_proto_msgTypes[30]
2596	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2597	ms.StoreMessageInfo(mi)
2598}
2599
2600func (x *Progress) String() string {
2601	return protoimpl.X.MessageStringOf(x)
2602}
2603
2604func (*Progress) ProtoMessage() {}
2605
2606func (x *Progress) ProtoReflect() protoreflect.Message {
2607	mi := &file_broker_proto_msgTypes[30]
2608	if x != nil {
2609		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2610		if ms.LoadMessageInfo() == nil {
2611			ms.StoreMessageInfo(mi)
2612		}
2613		return ms
2614	}
2615	return mi.MessageOf(x)
2616}
2617
2618// Deprecated: Use Progress.ProtoReflect.Descriptor instead.
2619func (*Progress) Descriptor() ([]byte, []int) {
2620	return file_broker_proto_rawDescGZIP(), []int{30}
2621}
2622
2623func (x *Progress) GetRef() *BrokerStreamRef {
2624	if x != nil {
2625		return x.Ref
2626	}
2627	return nil
2628}
2629
2630func (x *Progress) GetPhase() uint32 {
2631	if x != nil {
2632		return x.Phase
2633	}
2634	return 0
2635}
2636
2637func (x *Progress) GetText() string {
2638	if x != nil {
2639		return x.Text
2640	}
2641	return ""
2642}
2643
2644// BrokerErrorMessage reports a broker-wide typed failure for one scope.
2645type BrokerErrorMessage struct {
2646	state         protoimpl.MessageState `protogen:"open.v1"`
2647	Scope         *BrokerScope           `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
2648	Error         *BrokerErrorDetail     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
2649	unknownFields protoimpl.UnknownFields
2650	sizeCache     protoimpl.SizeCache
2651}
2652
2653func (x *BrokerErrorMessage) Reset() {
2654	*x = BrokerErrorMessage{}
2655	mi := &file_broker_proto_msgTypes[31]
2656	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2657	ms.StoreMessageInfo(mi)
2658}
2659
2660func (x *BrokerErrorMessage) String() string {
2661	return protoimpl.X.MessageStringOf(x)
2662}
2663
2664func (*BrokerErrorMessage) ProtoMessage() {}
2665
2666func (x *BrokerErrorMessage) ProtoReflect() protoreflect.Message {
2667	mi := &file_broker_proto_msgTypes[31]
2668	if x != nil {
2669		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2670		if ms.LoadMessageInfo() == nil {
2671			ms.StoreMessageInfo(mi)
2672		}
2673		return ms
2674	}
2675	return mi.MessageOf(x)
2676}
2677
2678// Deprecated: Use BrokerErrorMessage.ProtoReflect.Descriptor instead.
2679func (*BrokerErrorMessage) Descriptor() ([]byte, []int) {
2680	return file_broker_proto_rawDescGZIP(), []int{31}
2681}
2682
2683func (x *BrokerErrorMessage) GetScope() *BrokerScope {
2684	if x != nil {
2685		return x.Scope
2686	}
2687	return nil
2688}
2689
2690func (x *BrokerErrorMessage) GetError() *BrokerErrorDetail {
2691	if x != nil {
2692		return x.Error
2693	}
2694	return nil
2695}
2696
2697// Shutdown reports the broker process is stopping.
2698type Shutdown struct {
2699	state protoimpl.MessageState `protogen:"open.v1"`
2700	Scope *BrokerScope           `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
2701	// Closed reason taxonomy; 0 is the zero value.
2702	Reason        uint32 `protobuf:"varint,2,opt,name=reason,proto3" json:"reason,omitempty"`
2703	Text          string `protobuf:"bytes,3,opt,name=text,proto3" json:"text,omitempty"`
2704	unknownFields protoimpl.UnknownFields
2705	sizeCache     protoimpl.SizeCache
2706}
2707
2708func (x *Shutdown) Reset() {
2709	*x = Shutdown{}
2710	mi := &file_broker_proto_msgTypes[32]
2711	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2712	ms.StoreMessageInfo(mi)
2713}
2714
2715func (x *Shutdown) String() string {
2716	return protoimpl.X.MessageStringOf(x)
2717}
2718
2719func (*Shutdown) ProtoMessage() {}
2720
2721func (x *Shutdown) ProtoReflect() protoreflect.Message {
2722	mi := &file_broker_proto_msgTypes[32]
2723	if x != nil {
2724		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2725		if ms.LoadMessageInfo() == nil {
2726			ms.StoreMessageInfo(mi)
2727		}
2728		return ms
2729	}
2730	return mi.MessageOf(x)
2731}
2732
2733// Deprecated: Use Shutdown.ProtoReflect.Descriptor instead.
2734func (*Shutdown) Descriptor() ([]byte, []int) {
2735	return file_broker_proto_rawDescGZIP(), []int{32}
2736}
2737
2738func (x *Shutdown) GetScope() *BrokerScope {
2739	if x != nil {
2740		return x.Scope
2741	}
2742	return nil
2743}
2744
2745func (x *Shutdown) GetReason() uint32 {
2746	if x != nil {
2747		return x.Reason
2748	}
2749	return 0
2750}
2751
2752func (x *Shutdown) GetText() string {
2753	if x != nil {
2754		return x.Text
2755	}
2756	return ""
2757}
2758
2759// PreviewRoute names the daemon a preview observes. The broker allocates the
2760// observation stream itself; endpoint and registration are present only for a
2761// remote route, and policy is always present.
2762type PreviewRoute struct {
2763	state         protoimpl.MessageState `protogen:"open.v1"`
2764	Local         bool                   `protobuf:"varint,1,opt,name=local,proto3" json:"local,omitempty"`
2765	Endpoint      string                 `protobuf:"bytes,2,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
2766	Registration  *RemoteRegistration    `protobuf:"bytes,3,opt,name=registration,proto3" json:"registration,omitempty"`
2767	Policy        *BrokerWirePolicy      `protobuf:"bytes,4,opt,name=policy,proto3" json:"policy,omitempty"`
2768	unknownFields protoimpl.UnknownFields
2769	sizeCache     protoimpl.SizeCache
2770}
2771
2772func (x *PreviewRoute) Reset() {
2773	*x = PreviewRoute{}
2774	mi := &file_broker_proto_msgTypes[33]
2775	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2776	ms.StoreMessageInfo(mi)
2777}
2778
2779func (x *PreviewRoute) String() string {
2780	return protoimpl.X.MessageStringOf(x)
2781}
2782
2783func (*PreviewRoute) ProtoMessage() {}
2784
2785func (x *PreviewRoute) ProtoReflect() protoreflect.Message {
2786	mi := &file_broker_proto_msgTypes[33]
2787	if x != nil {
2788		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2789		if ms.LoadMessageInfo() == nil {
2790			ms.StoreMessageInfo(mi)
2791		}
2792		return ms
2793	}
2794	return mi.MessageOf(x)
2795}
2796
2797// Deprecated: Use PreviewRoute.ProtoReflect.Descriptor instead.
2798func (*PreviewRoute) Descriptor() ([]byte, []int) {
2799	return file_broker_proto_rawDescGZIP(), []int{33}
2800}
2801
2802func (x *PreviewRoute) GetLocal() bool {
2803	if x != nil {
2804		return x.Local
2805	}
2806	return false
2807}
2808
2809func (x *PreviewRoute) GetEndpoint() string {
2810	if x != nil {
2811		return x.Endpoint
2812	}
2813	return ""
2814}
2815
2816func (x *PreviewRoute) GetRegistration() *RemoteRegistration {
2817	if x != nil {
2818		return x.Registration
2819	}
2820	return nil
2821}
2822
2823func (x *PreviewRoute) GetPolicy() *BrokerWirePolicy {
2824	if x != nil {
2825		return x.Policy
2826	}
2827	return nil
2828}
2829
2830// StartPreview starts or replaces one connection-scoped live preview.
2831// scope carries the broker epoch plus client connection; generation is the
2832// connection-scoped preview authority. route names the observed daemon and
2833// preview is the bounded viewport request sent to it. Repeated authority is
2834// scope/generation plus the preview target identity response.
2835type StartPreview struct {
2836	state         protoimpl.MessageState `protogen:"open.v1"`
2837	Scope         *BrokerScope           `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
2838	Generation    uint64                 `protobuf:"varint,2,opt,name=generation,proto3" json:"generation,omitempty"`
2839	Preview       *RemotePreviewRequest  `protobuf:"bytes,4,opt,name=preview,proto3" json:"preview,omitempty"`
2840	Route         *PreviewRoute          `protobuf:"bytes,5,opt,name=route,proto3" json:"route,omitempty"`
2841	unknownFields protoimpl.UnknownFields
2842	sizeCache     protoimpl.SizeCache
2843}
2844
2845func (x *StartPreview) Reset() {
2846	*x = StartPreview{}
2847	mi := &file_broker_proto_msgTypes[34]
2848	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2849	ms.StoreMessageInfo(mi)
2850}
2851
2852func (x *StartPreview) String() string {
2853	return protoimpl.X.MessageStringOf(x)
2854}
2855
2856func (*StartPreview) ProtoMessage() {}
2857
2858func (x *StartPreview) ProtoReflect() protoreflect.Message {
2859	mi := &file_broker_proto_msgTypes[34]
2860	if x != nil {
2861		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2862		if ms.LoadMessageInfo() == nil {
2863			ms.StoreMessageInfo(mi)
2864		}
2865		return ms
2866	}
2867	return mi.MessageOf(x)
2868}
2869
2870// Deprecated: Use StartPreview.ProtoReflect.Descriptor instead.
2871func (*StartPreview) Descriptor() ([]byte, []int) {
2872	return file_broker_proto_rawDescGZIP(), []int{34}
2873}
2874
2875func (x *StartPreview) GetScope() *BrokerScope {
2876	if x != nil {
2877		return x.Scope
2878	}
2879	return nil
2880}
2881
2882func (x *StartPreview) GetGeneration() uint64 {
2883	if x != nil {
2884		return x.Generation
2885	}
2886	return 0
2887}
2888
2889func (x *StartPreview) GetPreview() *RemotePreviewRequest {
2890	if x != nil {
2891		return x.Preview
2892	}
2893	return nil
2894}
2895
2896func (x *StartPreview) GetRoute() *PreviewRoute {
2897	if x != nil {
2898		return x.Route
2899	}
2900	return nil
2901}
2902
2903// CancelPreview cancels one connection-scoped live preview.
2904type CancelPreview struct {
2905	state         protoimpl.MessageState `protogen:"open.v1"`
2906	Scope         *BrokerScope           `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
2907	Generation    uint64                 `protobuf:"varint,2,opt,name=generation,proto3" json:"generation,omitempty"`
2908	unknownFields protoimpl.UnknownFields
2909	sizeCache     protoimpl.SizeCache
2910}
2911
2912func (x *CancelPreview) Reset() {
2913	*x = CancelPreview{}
2914	mi := &file_broker_proto_msgTypes[35]
2915	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2916	ms.StoreMessageInfo(mi)
2917}
2918
2919func (x *CancelPreview) String() string {
2920	return protoimpl.X.MessageStringOf(x)
2921}
2922
2923func (*CancelPreview) ProtoMessage() {}
2924
2925func (x *CancelPreview) ProtoReflect() protoreflect.Message {
2926	mi := &file_broker_proto_msgTypes[35]
2927	if x != nil {
2928		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2929		if ms.LoadMessageInfo() == nil {
2930			ms.StoreMessageInfo(mi)
2931		}
2932		return ms
2933	}
2934	return mi.MessageOf(x)
2935}
2936
2937// Deprecated: Use CancelPreview.ProtoReflect.Descriptor instead.
2938func (*CancelPreview) Descriptor() ([]byte, []int) {
2939	return file_broker_proto_rawDescGZIP(), []int{35}
2940}
2941
2942func (x *CancelPreview) GetScope() *BrokerScope {
2943	if x != nil {
2944		return x.Scope
2945	}
2946	return nil
2947}
2948
2949func (x *CancelPreview) GetGeneration() uint64 {
2950	if x != nil {
2951		return x.Generation
2952	}
2953	return 0
2954}
2955
2956// PreviewPublication is the newest result for one preview subscription.
2957// Exactly one of preview/error is set via the result oneof.
2958type PreviewPublication struct {
2959	state      protoimpl.MessageState `protogen:"open.v1"`
2960	Scope      *BrokerScope           `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
2961	Generation uint64                 `protobuf:"varint,2,opt,name=generation,proto3" json:"generation,omitempty"`
2962	// Types that are valid to be assigned to Result:
2963	//
2964	//	*PreviewPublication_Preview
2965	//	*PreviewPublication_Error
2966	Result        isPreviewPublication_Result `protobuf_oneof:"result"`
2967	unknownFields protoimpl.UnknownFields
2968	sizeCache     protoimpl.SizeCache
2969}
2970
2971func (x *PreviewPublication) Reset() {
2972	*x = PreviewPublication{}
2973	mi := &file_broker_proto_msgTypes[36]
2974	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2975	ms.StoreMessageInfo(mi)
2976}
2977
2978func (x *PreviewPublication) String() string {
2979	return protoimpl.X.MessageStringOf(x)
2980}
2981
2982func (*PreviewPublication) ProtoMessage() {}
2983
2984func (x *PreviewPublication) ProtoReflect() protoreflect.Message {
2985	mi := &file_broker_proto_msgTypes[36]
2986	if x != nil {
2987		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
2988		if ms.LoadMessageInfo() == nil {
2989			ms.StoreMessageInfo(mi)
2990		}
2991		return ms
2992	}
2993	return mi.MessageOf(x)
2994}
2995
2996// Deprecated: Use PreviewPublication.ProtoReflect.Descriptor instead.
2997func (*PreviewPublication) Descriptor() ([]byte, []int) {
2998	return file_broker_proto_rawDescGZIP(), []int{36}
2999}
3000
3001func (x *PreviewPublication) GetScope() *BrokerScope {
3002	if x != nil {
3003		return x.Scope
3004	}
3005	return nil
3006}
3007
3008func (x *PreviewPublication) GetGeneration() uint64 {
3009	if x != nil {
3010		return x.Generation
3011	}
3012	return 0
3013}
3014
3015func (x *PreviewPublication) GetResult() isPreviewPublication_Result {
3016	if x != nil {
3017		return x.Result
3018	}
3019	return nil
3020}
3021
3022func (x *PreviewPublication) GetPreview() *RemotePreview {
3023	if x != nil {
3024		if x, ok := x.Result.(*PreviewPublication_Preview); ok {
3025			return x.Preview
3026		}
3027	}
3028	return nil
3029}
3030
3031func (x *PreviewPublication) GetError() *BrokerErrorDetail {
3032	if x != nil {
3033		if x, ok := x.Result.(*PreviewPublication_Error); ok {
3034			return x.Error
3035		}
3036	}
3037	return nil
3038}
3039
3040type isPreviewPublication_Result interface {
3041	isPreviewPublication_Result()
3042}
3043
3044type PreviewPublication_Preview struct {
3045	Preview *RemotePreview `protobuf:"bytes,3,opt,name=preview,proto3,oneof"`
3046}
3047
3048type PreviewPublication_Error struct {
3049	Error *BrokerErrorDetail `protobuf:"bytes,4,opt,name=error,proto3,oneof"`
3050}
3051
3052func (*PreviewPublication_Preview) isPreviewPublication_Result() {}
3053
3054func (*PreviewPublication_Error) isPreviewPublication_Result() {}
3055
3056// BrokerCatalogSession mirrors catalogue.RemoteCatalogSession exactly: the
3057// lifecycle identity is a fixed 16-byte value, the state is a closed
3058// taxonomy, and the tab list keeps its presence separately from its
3059// length.
3060type BrokerCatalogSession struct {
3061	state       protoimpl.MessageState `protogen:"open.v1"`
3062	LifecycleId []byte                 `protobuf:"bytes,1,opt,name=lifecycle_id,json=lifecycleId,proto3" json:"lifecycle_id,omitempty"` // exactly 16 bytes
3063	Name        string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
3064	// Closed taxonomy: 1 = up, 2 = down, 3 = broken.
3065	State         uint32              `protobuf:"varint,3,opt,name=state,proto3" json:"state,omitempty"`
3066	Ephemeral     bool                `protobuf:"varint,4,opt,name=ephemeral,proto3" json:"ephemeral,omitempty"`
3067	Tabs          []*BrokerCatalogTab `protobuf:"bytes,5,rep,name=tabs,proto3" json:"tabs,omitempty"`
3068	Attached      bool                `protobuf:"varint,6,opt,name=attached,proto3" json:"attached,omitempty"`
3069	LastUsedSeq   uint64              `protobuf:"varint,7,opt,name=last_used_seq,json=lastUsedSeq,proto3" json:"last_used_seq,omitempty"`
3070	ActiveTabId   string              `protobuf:"bytes,8,opt,name=active_tab_id,json=activeTabId,proto3" json:"active_tab_id,omitempty"`
3071	Reason        string              `protobuf:"bytes,9,opt,name=reason,proto3" json:"reason,omitempty"`
3072	unknownFields protoimpl.UnknownFields
3073	sizeCache     protoimpl.SizeCache
3074}
3075
3076func (x *BrokerCatalogSession) Reset() {
3077	*x = BrokerCatalogSession{}
3078	mi := &file_broker_proto_msgTypes[37]
3079	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
3080	ms.StoreMessageInfo(mi)
3081}
3082
3083func (x *BrokerCatalogSession) String() string {
3084	return protoimpl.X.MessageStringOf(x)
3085}
3086
3087func (*BrokerCatalogSession) ProtoMessage() {}
3088
3089func (x *BrokerCatalogSession) ProtoReflect() protoreflect.Message {
3090	mi := &file_broker_proto_msgTypes[37]
3091	if x != nil {
3092		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
3093		if ms.LoadMessageInfo() == nil {
3094			ms.StoreMessageInfo(mi)
3095		}
3096		return ms
3097	}
3098	return mi.MessageOf(x)
3099}
3100
3101// Deprecated: Use BrokerCatalogSession.ProtoReflect.Descriptor instead.
3102func (*BrokerCatalogSession) Descriptor() ([]byte, []int) {
3103	return file_broker_proto_rawDescGZIP(), []int{37}
3104}
3105
3106func (x *BrokerCatalogSession) GetLifecycleId() []byte {
3107	if x != nil {
3108		return x.LifecycleId
3109	}
3110	return nil
3111}
3112
3113func (x *BrokerCatalogSession) GetName() string {
3114	if x != nil {
3115		return x.Name
3116	}
3117	return ""
3118}
3119
3120func (x *BrokerCatalogSession) GetState() uint32 {
3121	if x != nil {
3122		return x.State
3123	}
3124	return 0
3125}
3126
3127func (x *BrokerCatalogSession) GetEphemeral() bool {
3128	if x != nil {
3129		return x.Ephemeral
3130	}
3131	return false
3132}
3133
3134func (x *BrokerCatalogSession) GetTabs() []*BrokerCatalogTab {
3135	if x != nil {
3136		return x.Tabs
3137	}
3138	return nil
3139}
3140
3141func (x *BrokerCatalogSession) GetAttached() bool {
3142	if x != nil {
3143		return x.Attached
3144	}
3145	return false
3146}
3147
3148func (x *BrokerCatalogSession) GetLastUsedSeq() uint64 {
3149	if x != nil {
3150		return x.LastUsedSeq
3151	}
3152	return 0
3153}
3154
3155func (x *BrokerCatalogSession) GetActiveTabId() string {
3156	if x != nil {
3157		return x.ActiveTabId
3158	}
3159	return ""
3160}
3161
3162func (x *BrokerCatalogSession) GetReason() string {
3163	if x != nil {
3164		return x.Reason
3165	}
3166	return ""
3167}
3168
3169// BrokerCatalogTab mirrors catalogue.RemoteCatalogTab exactly.
3170type BrokerCatalogTab struct {
3171	state         protoimpl.MessageState `protogen:"open.v1"`
3172	Id            string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
3173	Index         uint32                 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
3174	Name          string                 `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
3175	Detail        string                 `protobuf:"bytes,4,opt,name=detail,proto3" json:"detail,omitempty"`
3176	Attention     bool                   `protobuf:"varint,5,opt,name=attention,proto3" json:"attention,omitempty"`
3177	unknownFields protoimpl.UnknownFields
3178	sizeCache     protoimpl.SizeCache
3179}
3180
3181func (x *BrokerCatalogTab) Reset() {
3182	*x = BrokerCatalogTab{}
3183	mi := &file_broker_proto_msgTypes[38]
3184	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
3185	ms.StoreMessageInfo(mi)
3186}
3187
3188func (x *BrokerCatalogTab) String() string {
3189	return protoimpl.X.MessageStringOf(x)
3190}
3191
3192func (*BrokerCatalogTab) ProtoMessage() {}
3193
3194func (x *BrokerCatalogTab) ProtoReflect() protoreflect.Message {
3195	mi := &file_broker_proto_msgTypes[38]
3196	if x != nil {
3197		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
3198		if ms.LoadMessageInfo() == nil {
3199			ms.StoreMessageInfo(mi)
3200		}
3201		return ms
3202	}
3203	return mi.MessageOf(x)
3204}
3205
3206// Deprecated: Use BrokerCatalogTab.ProtoReflect.Descriptor instead.
3207func (*BrokerCatalogTab) Descriptor() ([]byte, []int) {
3208	return file_broker_proto_rawDescGZIP(), []int{38}
3209}
3210
3211func (x *BrokerCatalogTab) GetId() string {
3212	if x != nil {
3213		return x.Id
3214	}
3215	return ""
3216}
3217
3218func (x *BrokerCatalogTab) GetIndex() uint32 {
3219	if x != nil {
3220		return x.Index
3221	}
3222	return 0
3223}
3224
3225func (x *BrokerCatalogTab) GetName() string {
3226	if x != nil {
3227		return x.Name
3228	}
3229	return ""
3230}
3231
3232func (x *BrokerCatalogTab) GetDetail() string {
3233	if x != nil {
3234		return x.Detail
3235	}
3236	return ""
3237}
3238
3239func (x *BrokerCatalogTab) GetAttention() bool {
3240	if x != nil {
3241		return x.Attention
3242	}
3243	return false
3244}
3245
3246var File_broker_proto protoreflect.FileDescriptor
3247
3248const file_broker_proto_rawDesc = "" +
3249	"\n" +
3250	"\fbroker.proto\x12\vvev.wire.v1\x1a\fcommon.proto\x1a\x0eterminal.proto\"U\n" +
3251	"\vBrokerScope\x12!\n" +
3252	"\fbroker_epoch\x18\x01 \x01(\x04R\vbrokerEpoch\x12#\n" +
3253	"\rconnection_id\x18\x02 \x01(\fR\fconnectionId\"^\n" +
3254	"\x0fBrokerStreamRef\x12.\n" +
3255	"\x05scope\x18\x01 \x01(\v2\x18.vev.wire.v1.BrokerScopeR\x05scope\x12\x1b\n" +
3256	"\tstream_id\x18\x02 \x01(\x04R\bstreamId\"\x83\x02\n" +
3257	"\x10BrokerWirePolicy\x12)\n" +
3258	"\x10protocol_version\x18\x01 \x01(\rR\x0fprotocolVersion\x12+\n" +
3259	"\x11catalogue_version\x18\x02 \x01(\rR\x10catalogueVersion\x12-\n" +
3260	"\x12environment_policy\x18\x03 \x01(\rR\x11environmentPolicy\x12\x1c\n" +
3261	"\ttransport\x18\x04 \x01(\tR\ttransport\x12\x14\n" +
3262	"\x05trust\x18\x05 \x01(\tR\x05trust\x12\x16\n" +
3263	"\x06launch\x18\x06 \x01(\tR\x06launch\x12\x1c\n" +
3264	"\tisolation\x18\a \x01(\tR\tisolation\"\x85\x01\n" +
3265	"\x11BrokerErrorDetail\x12\x12\n" +
3266	"\x04code\x18\x01 \x01(\rR\x04code\x12\x12\n" +
3267	"\x04text\x18\x02 \x01(\tR\x04text\x12%\n" +
3268	"\x0eadmission_code\x18\x03 \x01(\rR\radmissionCode\x12!\n" +
3269	"\ffailure_kind\x18\x04 \x01(\rR\vfailureKind\"A\n" +
3270	"\x0fBrokerTimestamp\x12\x18\n" +
3271	"\aseconds\x18\x01 \x01(\x03R\aseconds\x12\x14\n" +
3272	"\x05nanos\x18\x02 \x01(\x05R\x05nanos\"\x97\a\n" +
3273	"\x14BrokerClientEnvelope\x123\n" +
3274	"\bregister\x18e \x01(\v2\x15.vev.wire.v1.RegisterH\x00R\bregister\x126\n" +
3275	"\tsubscribe\x18f \x01(\v2\x16.vev.wire.v1.SubscribeH\x00R\tsubscribe\x12-\n" +
3276	"\x06resync\x18g \x01(\v2\x13.vev.wire.v1.ResyncH\x00R\x06resync\x12<\n" +
3277	"\vunsubscribe\x18h \x01(\v2\x18.vev.wire.v1.UnsubscribeH\x00R\vunsubscribe\x121\n" +
3278	"\badd_host\x18i \x01(\v2\x14.vev.wire.v1.AddHostH\x00R\aaddHost\x12:\n" +
3279	"\vremove_host\x18j \x01(\v2\x17.vev.wire.v1.RemoveHostH\x00R\n" +
3280	"removeHost\x126\n" +
3281	"\treconcile\x18k \x01(\v2\x16.vev.wire.v1.ReconcileH\x00R\treconcile\x12:\n" +
3282	"\vopen_stream\x18l \x01(\v2\x17.vev.wire.v1.OpenStreamH\x00R\n" +
3283	"openStream\x12M\n" +
3284	"\x12client_stream_data\x18m \x01(\v2\x1d.vev.wire.v1.ClientStreamDataH\x00R\x10clientStreamData\x12=\n" +
3285	"\fclose_stream\x18n \x01(\v2\x18.vev.wire.v1.CloseStreamH\x00R\vcloseStream\x12M\n" +
3286	"\x12update_host_policy\x18o \x01(\v2\x1d.vev.wire.v1.UpdateHostPolicyH\x00R\x10updateHostPolicy\x12@\n" +
3287	"\rstart_preview\x18p \x01(\v2\x19.vev.wire.v1.StartPreviewH\x00R\fstartPreview\x12C\n" +
3288	"\x0ecancel_preview\x18q \x01(\v2\x1a.vev.wire.v1.CancelPreviewH\x00R\rcancelPreview\x12S\n" +
3289	"\x14stream_window_update\x18r \x01(\v2\x1f.vev.wire.v1.StreamWindowUpdateH\x00R\x12streamWindowUpdateB\t\n" +
3290	"\apayload\"\xaf\x06\n" +
3291	"\x14BrokerServerEnvelope\x12:\n" +
3292	"\n" +
3293	"registered\x18\xc9\x01 \x01(\v2\x17.vev.wire.v1.RegisteredH\x00R\n" +
3294	"registered\x12A\n" +
3295	"\rsnapshot_part\x18\xca\x01 \x01(\v2\x19.vev.wire.v1.SnapshotPartH\x00R\fsnapshotPart\x12J\n" +
3296	"\x10operation_result\x18\xcb\x01 \x01(\v2\x1c.vev.wire.v1.OperationResultH\x00R\x0foperationResult\x12A\n" +
3297	"\rstream_opened\x18\xcc\x01 \x01(\v2\x19.vev.wire.v1.StreamOpenedH\x00R\fstreamOpened\x12N\n" +
3298	"\x12server_stream_data\x18\xcd\x01 \x01(\v2\x1d.vev.wire.v1.ServerStreamDataH\x00R\x10serverStreamData\x12A\n" +
3299	"\rstream_closed\x18\xce\x01 \x01(\v2\x19.vev.wire.v1.StreamClosedH\x00R\fstreamClosed\x124\n" +
3300	"\bprogress\x18\xcf\x01 \x01(\v2\x15.vev.wire.v1.ProgressH\x00R\bprogress\x12T\n" +
3301	"\x14broker_error_message\x18\xd0\x01 \x01(\v2\x1f.vev.wire.v1.BrokerErrorMessageH\x00R\x12brokerErrorMessage\x124\n" +
3302	"\bshutdown\x18\xd1\x01 \x01(\v2\x15.vev.wire.v1.ShutdownH\x00R\bshutdown\x12S\n" +
3303	"\x13preview_publication\x18\xd2\x01 \x01(\v2\x1f.vev.wire.v1.PreviewPublicationH\x00R\x12previewPublication\x12T\n" +
3304	"\x14stream_window_update\x18\xd3\x01 \x01(\v2\x1f.vev.wire.v1.StreamWindowUpdateH\x00R\x12streamWindowUpdateB\t\n" +
3305	"\apayload\" \n" +
3306	"\bRegister\x12\x14\n" +
3307	"\x05build\x18\x01 \x01(\tR\x05build\"u\n" +
3308	"\tSubscribe\x12.\n" +
3309	"\x05scope\x18\x01 \x01(\v2\x18.vev.wire.v1.BrokerScopeR\x05scope\x12\x1e\n" +
3310	"\n" +
3311	"generation\x18\x02 \x01(\x04R\n" +
3312	"generation\x12\x18\n" +
3313	"\apassive\x18\x03 \x01(\bR\apassive\"X\n" +
3314	"\x06Resync\x12.\n" +
3315	"\x05scope\x18\x01 \x01(\v2\x18.vev.wire.v1.BrokerScopeR\x05scope\x12\x1e\n" +
3316	"\n" +
3317	"generation\x18\x02 \x01(\x04R\n" +
3318	"generation\"]\n" +
3319	"\vUnsubscribe\x12.\n" +
3320	"\x05scope\x18\x01 \x01(\v2\x18.vev.wire.v1.BrokerScopeR\x05scope\x12\x1e\n" +
3321	"\n" +
3322	"generation\x18\x02 \x01(\x04R\n" +
3323	"generation\"\xaf\x01\n" +
3324	"\aAddHost\x12.\n" +
3325	"\x05scope\x18\x01 \x01(\v2\x18.vev.wire.v1.BrokerScopeR\x05scope\x12!\n" +
3326	"\foperation_id\x18\x02 \x01(\fR\voperationId\x12\x1a\n" +
3327	"\bendpoint\x18\x03 \x01(\tR\bendpoint\x125\n" +
3328	"\x06policy\x18\x04 \x01(\v2\x1d.vev.wire.v1.BrokerWirePolicyR\x06policy\"\xa4\x01\n" +
3329	"\n" +
3330	"RemoveHost\x12.\n" +
3331	"\x05scope\x18\x01 \x01(\v2\x18.vev.wire.v1.BrokerScopeR\x05scope\x12!\n" +
3332	"\foperation_id\x18\x02 \x01(\fR\voperationId\x12C\n" +
3333	"\fregistration\x18\x03 \x01(\v2\x1f.vev.wire.v1.RemoteRegistrationR\fregistration\"\xe1\x01\n" +
3334	"\x10UpdateHostPolicy\x12.\n" +
3335	"\x05scope\x18\x01 \x01(\v2\x18.vev.wire.v1.BrokerScopeR\x05scope\x12!\n" +
3336	"\foperation_id\x18\x02 \x01(\fR\voperationId\x12C\n" +
3337	"\fregistration\x18\x03 \x01(\v2\x1f.vev.wire.v1.RemoteRegistrationR\fregistration\x125\n" +
3338	"\x06policy\x18\x04 \x01(\v2\x1d.vev.wire.v1.BrokerWirePolicyR\x06policy\"\x80\x01\n" +
3339	"\tReconcile\x12.\n" +
3340	"\x05scope\x18\x01 \x01(\v2\x18.vev.wire.v1.BrokerScopeR\x05scope\x12C\n" +
3341	"\fregistration\x18\x02 \x01(\v2\x1f.vev.wire.v1.RemoteRegistrationR\fregistration\"\x99\x03\n" +
3342	"\n" +
3343	"OpenStream\x12.\n" +
3344	"\x03ref\x18\x01 \x01(\v2\x1c.vev.wire.v1.BrokerStreamRefR\x03ref\x12\x18\n" +
3345	"\apurpose\x18\x02 \x01(\rR\apurpose\x12\x14\n" +
3346	"\x05local\x18\x03 \x01(\bR\x05local\x12\x1a\n" +
3347	"\bendpoint\x18\x04 \x01(\tR\bendpoint\x12C\n" +
3348	"\fregistration\x18\x05 \x01(\v2\x1f.vev.wire.v1.RemoteRegistrationR\fregistration\x120\n" +
3349	"\x06target\x18\x06 \x01(\v2\x18.vev.wire.v1.ExactTargetR\x06target\x12\x10\n" +
3350	"\x03env\x18\a \x03(\tR\x03env\x125\n" +
3351	"\x06policy\x18\b \x01(\v2\x1d.vev.wire.v1.BrokerWirePolicyR\x06policy\x12\x1c\n" +
3352	"\tadmission\x18\t \x01(\rR\tadmission\x12\x12\n" +
3353	"\x04name\x18\n" +
3354	" \x01(\tR\x04name\x12\x1d\n" +
3355	"\n" +
3356	"start_mode\x18\v \x01(\rR\tstartMode\"V\n" +
3357	"\x10ClientStreamData\x12.\n" +
3358	"\x03ref\x18\x01 \x01(\v2\x1c.vev.wire.v1.BrokerStreamRefR\x03ref\x12\x12\n" +
3359	"\x04data\x18\x02 \x01(\fR\x04data\"=\n" +
3360	"\vCloseStream\x12.\n" +
3361	"\x03ref\x18\x01 \x01(\v2\x1c.vev.wire.v1.BrokerStreamRefR\x03ref\"\\\n" +
3362	"\x12StreamWindowUpdate\x12.\n" +
3363	"\x03ref\x18\x01 \x01(\v2\x1c.vev.wire.v1.BrokerStreamRefR\x03ref\x12\x16\n" +
3364	"\x06credit\x18\x02 \x01(\x04R\x06credit\"n\n" +
3365	"\n" +
3366	"Registered\x12.\n" +
3367	"\x05scope\x18\x01 \x01(\v2\x18.vev.wire.v1.BrokerScopeR\x05scope\x12\x14\n" +
3368	"\x05build\x18\x02 \x01(\tR\x05build\x12\x1a\n" +
3369	"\bretiring\x18\x03 \x01(\bR\bretiring\"\xab\x03\n" +
3370	"\fSnapshotPart\x12.\n" +
3371	"\x05scope\x18\x01 \x01(\v2\x18.vev.wire.v1.BrokerScopeR\x05scope\x12\x1e\n" +
3372	"\n" +
3373	"generation\x18\x02 \x01(\x04R\n" +
3374	"generation\x12\x1a\n" +
3375	"\brevision\x18\x03 \x01(\x04R\brevision\x12\x14\n" +
3376	"\x05index\x18\x04 \x01(\rR\x05index\x122\n" +
3377	"\x05begin\x18\n" +
3378	" \x01(\v2\x1a.vev.wire.v1.SnapshotBeginH\x00R\x05begin\x125\n" +
3379	"\x06daemon\x18\x0f \x01(\v2\x1b.vev.wire.v1.SnapshotDaemonH\x00R\x06daemon\x128\n" +
3380	"\asession\x18\f \x01(\v2\x1c.vev.wire.v1.SnapshotSessionH\x00R\asession\x12>\n" +
3381	"\ttombstone\x18\r \x01(\v2\x1e.vev.wire.v1.SnapshotTombstoneH\x00R\ttombstone\x12,\n" +
3382	"\x03end\x18\x0e \x01(\v2\x18.vev.wire.v1.SnapshotEndH\x00R\x03endB\x06\n" +
3383	"\x04part\"\xa1\x01\n" +
3384	"\rSnapshotBegin\x12\x1d\n" +
3385	"\n" +
3386	"host_count\x18\x01 \x01(\rR\thostCount\x12#\n" +
3387	"\rsession_count\x18\x02 \x01(\rR\fsessionCount\x12'\n" +
3388	"\x0ftombstone_count\x18\x03 \x01(\rR\x0etombstoneCount\x12#\n" +
3389	"\rlocal_present\x18\x04 \x01(\bR\flocalPresent\"\x87\a\n" +
3390	"\x0eSnapshotDaemon\x12\x1d\n" +
3391	"\n" +
3392	"host_index\x18\x01 \x01(\rR\thostIndex\x12\x14\n" +
3393	"\x05local\x18\x02 \x01(\bR\x05local\x12\x1a\n" +
3394	"\bendpoint\x18\x03 \x01(\tR\bendpoint\x12%\n" +
3395	"\x0edisplay_origin\x18\x04 \x01(\tR\rdisplayOrigin\x12\x12\n" +
3396	"\x04rank\x18\x05 \x01(\rR\x04rank\x12C\n" +
3397	"\fregistration\x18\x06 \x01(\v2\x1f.vev.wire.v1.RemoteRegistrationR\fregistration\x125\n" +
3398	"\x06policy\x18\a \x01(\v2\x1d.vev.wire.v1.BrokerWirePolicyR\x06policy\x12'\n" +
3399	"\x0fdaemon_identity\x18\b \x01(\tR\x0edaemonIdentity\x12-\n" +
3400	"\x12daemon_incarnation\x18\t \x01(\fR\x11daemonIncarnation\x12)\n" +
3401	"\x10protocol_version\x18\n" +
3402	" \x01(\rR\x0fprotocolVersion\x12\"\n" +
3403	"\fcapabilities\x18\v \x01(\rR\fcapabilities\x12\"\n" +
3404	"\favailability\x18\f \x01(\rR\favailability\x12\x1a\n" +
3405	"\bchecking\x18\r \x01(\bR\bchecking\x12?\n" +
3406	"\flast_attempt\x18\x0e \x01(\v2\x1c.vev.wire.v1.BrokerTimestampR\vlastAttempt\x12?\n" +
3407	"\flast_success\x18\x0f \x01(\v2\x1c.vev.wire.v1.BrokerTimestampR\vlastSuccess\x127\n" +
3408	"\bnext_due\x18\x10 \x01(\v2\x1c.vev.wire.v1.BrokerTimestampR\anextDue\x121\n" +
3409	"\x14consecutive_failures\x18\x11 \x01(\x04R\x13consecutiveFailures\x12'\n" +
3410	"\x0ffailure_episode\x18\x12 \x01(\x04R\x0efailureEpisode\x12!\n" +
3411	"\ffailure_kind\x18\x13 \x01(\rR\vfailureKind\x12'\n" +
3412	"\x0finventory_known\x18\x14 \x01(\bR\x0einventoryKnown\x12#\n" +
3413	"\rsession_count\x18\x15 \x01(\rR\fsessionCount\"\xa8\x01\n" +
3414	"\x0fSnapshotSession\x12\x1d\n" +
3415	"\n" +
3416	"host_index\x18\x01 \x01(\rR\thostIndex\x12#\n" +
3417	"\rsession_index\x18\x02 \x01(\rR\fsessionIndex\x12;\n" +
3418	"\asession\x18\x03 \x01(\v2!.vev.wire.v1.BrokerCatalogSessionR\asession\x12\x14\n" +
3419	"\x05local\x18\x04 \x01(\bR\x05local\"\xac\x01\n" +
3420	"\x11SnapshotTombstone\x12'\n" +
3421	"\x0ftombstone_index\x18\x01 \x01(\rR\x0etombstoneIndex\x12C\n" +
3422	"\fregistration\x18\x02 \x01(\v2\x1f.vev.wire.v1.RemoteRegistrationR\fregistration\x12)\n" +
3423	"\x10retired_revision\x18\x03 \x01(\x04R\x0fretiredRevision\"\r\n" +
3424	"\vSnapshotEnd\"\x93\x02\n" +
3425	"\x0fOperationResult\x12.\n" +
3426	"\x05scope\x18\x01 \x01(\v2\x18.vev.wire.v1.BrokerScopeR\x05scope\x12!\n" +
3427	"\foperation_id\x18\x02 \x01(\fR\voperationId\x12\x18\n" +
3428	"\aoutcome\x18\x03 \x01(\rR\aoutcome\x12\x18\n" +
3429	"\aremoved\x18\x04 \x01(\bR\aremoved\x124\n" +
3430	"\x05error\x18\x05 \x01(\v2\x1e.vev.wire.v1.BrokerErrorDetailR\x05error\x12C\n" +
3431	"\fregistration\x18\x06 \x01(\v2\x1f.vev.wire.v1.RemoteRegistrationR\fregistration\">\n" +
3432	"\fStreamOpened\x12.\n" +
3433	"\x03ref\x18\x01 \x01(\v2\x1c.vev.wire.v1.BrokerStreamRefR\x03ref\"V\n" +
3434	"\x10ServerStreamData\x12.\n" +
3435	"\x03ref\x18\x01 \x01(\v2\x1c.vev.wire.v1.BrokerStreamRefR\x03ref\x12\x12\n" +
3436	"\x04data\x18\x02 \x01(\fR\x04data\"t\n" +
3437	"\fStreamClosed\x12.\n" +
3438	"\x03ref\x18\x01 \x01(\v2\x1c.vev.wire.v1.BrokerStreamRefR\x03ref\x124\n" +
3439	"\x05error\x18\x02 \x01(\v2\x1e.vev.wire.v1.BrokerErrorDetailR\x05error\"d\n" +
3440	"\bProgress\x12.\n" +
3441	"\x03ref\x18\x01 \x01(\v2\x1c.vev.wire.v1.BrokerStreamRefR\x03ref\x12\x14\n" +
3442	"\x05phase\x18\x02 \x01(\rR\x05phase\x12\x12\n" +
3443	"\x04text\x18\x03 \x01(\tR\x04text\"z\n" +
3444	"\x12BrokerErrorMessage\x12.\n" +
3445	"\x05scope\x18\x01 \x01(\v2\x18.vev.wire.v1.BrokerScopeR\x05scope\x124\n" +
3446	"\x05error\x18\x02 \x01(\v2\x1e.vev.wire.v1.BrokerErrorDetailR\x05error\"f\n" +
3447	"\bShutdown\x12.\n" +
3448	"\x05scope\x18\x01 \x01(\v2\x18.vev.wire.v1.BrokerScopeR\x05scope\x12\x16\n" +
3449	"\x06reason\x18\x02 \x01(\rR\x06reason\x12\x12\n" +
3450	"\x04text\x18\x03 \x01(\tR\x04text\"\xbc\x01\n" +
3451	"\fPreviewRoute\x12\x14\n" +
3452	"\x05local\x18\x01 \x01(\bR\x05local\x12\x1a\n" +
3453	"\bendpoint\x18\x02 \x01(\tR\bendpoint\x12C\n" +
3454	"\fregistration\x18\x03 \x01(\v2\x1f.vev.wire.v1.RemoteRegistrationR\fregistration\x125\n" +
3455	"\x06policy\x18\x04 \x01(\v2\x1d.vev.wire.v1.BrokerWirePolicyR\x06policy\"\xd2\x01\n" +
3456	"\fStartPreview\x12.\n" +
3457	"\x05scope\x18\x01 \x01(\v2\x18.vev.wire.v1.BrokerScopeR\x05scope\x12\x1e\n" +
3458	"\n" +
3459	"generation\x18\x02 \x01(\x04R\n" +
3460	"generation\x12;\n" +
3461	"\apreview\x18\x04 \x01(\v2!.vev.wire.v1.RemotePreviewRequestR\apreview\x12/\n" +
3462	"\x05route\x18\x05 \x01(\v2\x19.vev.wire.v1.PreviewRouteR\x05routeJ\x04\b\x03\x10\x04\"_\n" +
3463	"\rCancelPreview\x12.\n" +
3464	"\x05scope\x18\x01 \x01(\v2\x18.vev.wire.v1.BrokerScopeR\x05scope\x12\x1e\n" +
3465	"\n" +
3466	"generation\x18\x02 \x01(\x04R\n" +
3467	"generation\"\xde\x01\n" +
3468	"\x12PreviewPublication\x12.\n" +
3469	"\x05scope\x18\x01 \x01(\v2\x18.vev.wire.v1.BrokerScopeR\x05scope\x12\x1e\n" +
3470	"\n" +
3471	"generation\x18\x02 \x01(\x04R\n" +
3472	"generation\x126\n" +
3473	"\apreview\x18\x03 \x01(\v2\x1a.vev.wire.v1.RemotePreviewH\x00R\apreview\x126\n" +
3474	"\x05error\x18\x04 \x01(\v2\x1e.vev.wire.v1.BrokerErrorDetailH\x00R\x05errorB\b\n" +
3475	"\x06result\"\xb0\x02\n" +
3476	"\x14BrokerCatalogSession\x12!\n" +
3477	"\flifecycle_id\x18\x01 \x01(\fR\vlifecycleId\x12\x12\n" +
3478	"\x04name\x18\x02 \x01(\tR\x04name\x12\x14\n" +
3479	"\x05state\x18\x03 \x01(\rR\x05state\x12\x1c\n" +
3480	"\tephemeral\x18\x04 \x01(\bR\tephemeral\x121\n" +
3481	"\x04tabs\x18\x05 \x03(\v2\x1d.vev.wire.v1.BrokerCatalogTabR\x04tabs\x12\x1a\n" +
3482	"\battached\x18\x06 \x01(\bR\battached\x12\"\n" +
3483	"\rlast_used_seq\x18\a \x01(\x04R\vlastUsedSeq\x12\"\n" +
3484	"\ractive_tab_id\x18\b \x01(\tR\vactiveTabId\x12\x16\n" +
3485	"\x06reason\x18\t \x01(\tR\x06reason\"\x82\x01\n" +
3486	"\x10BrokerCatalogTab\x12\x0e\n" +
3487	"\x02id\x18\x01 \x01(\tR\x02id\x12\x14\n" +
3488	"\x05index\x18\x02 \x01(\rR\x05index\x12\x12\n" +
3489	"\x04name\x18\x03 \x01(\tR\x04name\x12\x16\n" +
3490	"\x06detail\x18\x04 \x01(\tR\x06detail\x12\x1c\n" +
3491	"\tattention\x18\x05 \x01(\bR\tattentionB-Z+github.com/bnema/vev/internal/protocol/wireb\x06proto3"
3492
3493var (
3494	file_broker_proto_rawDescOnce sync.Once
3495	file_broker_proto_rawDescData []byte
3496)
3497
3498func file_broker_proto_rawDescGZIP() []byte {
3499	file_broker_proto_rawDescOnce.Do(func() {
3500		file_broker_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_broker_proto_rawDesc), len(file_broker_proto_rawDesc)))
3501	})
3502	return file_broker_proto_rawDescData
3503}
3504
3505var file_broker_proto_msgTypes = make([]protoimpl.MessageInfo, 39)
3506var file_broker_proto_goTypes = []any{
3507	(*BrokerScope)(nil),          // 0: vev.wire.v1.BrokerScope
3508	(*BrokerStreamRef)(nil),      // 1: vev.wire.v1.BrokerStreamRef
3509	(*BrokerWirePolicy)(nil),     // 2: vev.wire.v1.BrokerWirePolicy
3510	(*BrokerErrorDetail)(nil),    // 3: vev.wire.v1.BrokerErrorDetail
3511	(*BrokerTimestamp)(nil),      // 4: vev.wire.v1.BrokerTimestamp
3512	(*BrokerClientEnvelope)(nil), // 5: vev.wire.v1.BrokerClientEnvelope
3513	(*BrokerServerEnvelope)(nil), // 6: vev.wire.v1.BrokerServerEnvelope
3514	(*Register)(nil),             // 7: vev.wire.v1.Register
3515	(*Subscribe)(nil),            // 8: vev.wire.v1.Subscribe
3516	(*Resync)(nil),               // 9: vev.wire.v1.Resync
3517	(*Unsubscribe)(nil),          // 10: vev.wire.v1.Unsubscribe
3518	(*AddHost)(nil),              // 11: vev.wire.v1.AddHost
3519	(*RemoveHost)(nil),           // 12: vev.wire.v1.RemoveHost
3520	(*UpdateHostPolicy)(nil),     // 13: vev.wire.v1.UpdateHostPolicy
3521	(*Reconcile)(nil),            // 14: vev.wire.v1.Reconcile
3522	(*OpenStream)(nil),           // 15: vev.wire.v1.OpenStream
3523	(*ClientStreamData)(nil),     // 16: vev.wire.v1.ClientStreamData
3524	(*CloseStream)(nil),          // 17: vev.wire.v1.CloseStream
3525	(*StreamWindowUpdate)(nil),   // 18: vev.wire.v1.StreamWindowUpdate
3526	(*Registered)(nil),           // 19: vev.wire.v1.Registered
3527	(*SnapshotPart)(nil),         // 20: vev.wire.v1.SnapshotPart
3528	(*SnapshotBegin)(nil),        // 21: vev.wire.v1.SnapshotBegin
3529	(*SnapshotDaemon)(nil),       // 22: vev.wire.v1.SnapshotDaemon
3530	(*SnapshotSession)(nil),      // 23: vev.wire.v1.SnapshotSession
3531	(*SnapshotTombstone)(nil),    // 24: vev.wire.v1.SnapshotTombstone
3532	(*SnapshotEnd)(nil),          // 25: vev.wire.v1.SnapshotEnd
3533	(*OperationResult)(nil),      // 26: vev.wire.v1.OperationResult
3534	(*StreamOpened)(nil),         // 27: vev.wire.v1.StreamOpened
3535	(*ServerStreamData)(nil),     // 28: vev.wire.v1.ServerStreamData
3536	(*StreamClosed)(nil),         // 29: vev.wire.v1.StreamClosed
3537	(*Progress)(nil),             // 30: vev.wire.v1.Progress
3538	(*BrokerErrorMessage)(nil),   // 31: vev.wire.v1.BrokerErrorMessage
3539	(*Shutdown)(nil),             // 32: vev.wire.v1.Shutdown
3540	(*PreviewRoute)(nil),         // 33: vev.wire.v1.PreviewRoute
3541	(*StartPreview)(nil),         // 34: vev.wire.v1.StartPreview
3542	(*CancelPreview)(nil),        // 35: vev.wire.v1.CancelPreview
3543	(*PreviewPublication)(nil),   // 36: vev.wire.v1.PreviewPublication
3544	(*BrokerCatalogSession)(nil), // 37: vev.wire.v1.BrokerCatalogSession
3545	(*BrokerCatalogTab)(nil),     // 38: vev.wire.v1.BrokerCatalogTab
3546	(*RemoteRegistration)(nil),   // 39: vev.wire.v1.RemoteRegistration
3547	(*ExactTarget)(nil),          // 40: vev.wire.v1.ExactTarget
3548	(*RemotePreviewRequest)(nil), // 41: vev.wire.v1.RemotePreviewRequest
3549	(*RemotePreview)(nil),        // 42: vev.wire.v1.RemotePreview
3550}
3551var file_broker_proto_depIdxs = []int32{
3552	0,  // 0: vev.wire.v1.BrokerStreamRef.scope:type_name -> vev.wire.v1.BrokerScope
3553	7,  // 1: vev.wire.v1.BrokerClientEnvelope.register:type_name -> vev.wire.v1.Register
3554	8,  // 2: vev.wire.v1.BrokerClientEnvelope.subscribe:type_name -> vev.wire.v1.Subscribe
3555	9,  // 3: vev.wire.v1.BrokerClientEnvelope.resync:type_name -> vev.wire.v1.Resync
3556	10, // 4: vev.wire.v1.BrokerClientEnvelope.unsubscribe:type_name -> vev.wire.v1.Unsubscribe
3557	11, // 5: vev.wire.v1.BrokerClientEnvelope.add_host:type_name -> vev.wire.v1.AddHost
3558	12, // 6: vev.wire.v1.BrokerClientEnvelope.remove_host:type_name -> vev.wire.v1.RemoveHost
3559	14, // 7: vev.wire.v1.BrokerClientEnvelope.reconcile:type_name -> vev.wire.v1.Reconcile
3560	15, // 8: vev.wire.v1.BrokerClientEnvelope.open_stream:type_name -> vev.wire.v1.OpenStream
3561	16, // 9: vev.wire.v1.BrokerClientEnvelope.client_stream_data:type_name -> vev.wire.v1.ClientStreamData
3562	17, // 10: vev.wire.v1.BrokerClientEnvelope.close_stream:type_name -> vev.wire.v1.CloseStream
3563	13, // 11: vev.wire.v1.BrokerClientEnvelope.update_host_policy:type_name -> vev.wire.v1.UpdateHostPolicy
3564	34, // 12: vev.wire.v1.BrokerClientEnvelope.start_preview:type_name -> vev.wire.v1.StartPreview
3565	35, // 13: vev.wire.v1.BrokerClientEnvelope.cancel_preview:type_name -> vev.wire.v1.CancelPreview
3566	18, // 14: vev.wire.v1.BrokerClientEnvelope.stream_window_update:type_name -> vev.wire.v1.StreamWindowUpdate
3567	19, // 15: vev.wire.v1.BrokerServerEnvelope.registered:type_name -> vev.wire.v1.Registered
3568	20, // 16: vev.wire.v1.BrokerServerEnvelope.snapshot_part:type_name -> vev.wire.v1.SnapshotPart
3569	26, // 17: vev.wire.v1.BrokerServerEnvelope.operation_result:type_name -> vev.wire.v1.OperationResult
3570	27, // 18: vev.wire.v1.BrokerServerEnvelope.stream_opened:type_name -> vev.wire.v1.StreamOpened
3571	28, // 19: vev.wire.v1.BrokerServerEnvelope.server_stream_data:type_name -> vev.wire.v1.ServerStreamData
3572	29, // 20: vev.wire.v1.BrokerServerEnvelope.stream_closed:type_name -> vev.wire.v1.StreamClosed
3573	30, // 21: vev.wire.v1.BrokerServerEnvelope.progress:type_name -> vev.wire.v1.Progress
3574	31, // 22: vev.wire.v1.BrokerServerEnvelope.broker_error_message:type_name -> vev.wire.v1.BrokerErrorMessage
3575	32, // 23: vev.wire.v1.BrokerServerEnvelope.shutdown:type_name -> vev.wire.v1.Shutdown
3576	36, // 24: vev.wire.v1.BrokerServerEnvelope.preview_publication:type_name -> vev.wire.v1.PreviewPublication
3577	18, // 25: vev.wire.v1.BrokerServerEnvelope.stream_window_update:type_name -> vev.wire.v1.StreamWindowUpdate
3578	0,  // 26: vev.wire.v1.Subscribe.scope:type_name -> vev.wire.v1.BrokerScope
3579	0,  // 27: vev.wire.v1.Resync.scope:type_name -> vev.wire.v1.BrokerScope
3580	0,  // 28: vev.wire.v1.Unsubscribe.scope:type_name -> vev.wire.v1.BrokerScope
3581	0,  // 29: vev.wire.v1.AddHost.scope:type_name -> vev.wire.v1.BrokerScope
3582	2,  // 30: vev.wire.v1.AddHost.policy:type_name -> vev.wire.v1.BrokerWirePolicy
3583	0,  // 31: vev.wire.v1.RemoveHost.scope:type_name -> vev.wire.v1.BrokerScope
3584	39, // 32: vev.wire.v1.RemoveHost.registration:type_name -> vev.wire.v1.RemoteRegistration
3585	0,  // 33: vev.wire.v1.UpdateHostPolicy.scope:type_name -> vev.wire.v1.BrokerScope
3586	39, // 34: vev.wire.v1.UpdateHostPolicy.registration:type_name -> vev.wire.v1.RemoteRegistration
3587	2,  // 35: vev.wire.v1.UpdateHostPolicy.policy:type_name -> vev.wire.v1.BrokerWirePolicy
3588	0,  // 36: vev.wire.v1.Reconcile.scope:type_name -> vev.wire.v1.BrokerScope
3589	39, // 37: vev.wire.v1.Reconcile.registration:type_name -> vev.wire.v1.RemoteRegistration
3590	1,  // 38: vev.wire.v1.OpenStream.ref:type_name -> vev.wire.v1.BrokerStreamRef
3591	39, // 39: vev.wire.v1.OpenStream.registration:type_name -> vev.wire.v1.RemoteRegistration
3592	40, // 40: vev.wire.v1.OpenStream.target:type_name -> vev.wire.v1.ExactTarget
3593	2,  // 41: vev.wire.v1.OpenStream.policy:type_name -> vev.wire.v1.BrokerWirePolicy
3594	1,  // 42: vev.wire.v1.ClientStreamData.ref:type_name -> vev.wire.v1.BrokerStreamRef
3595	1,  // 43: vev.wire.v1.CloseStream.ref:type_name -> vev.wire.v1.BrokerStreamRef
3596	1,  // 44: vev.wire.v1.StreamWindowUpdate.ref:type_name -> vev.wire.v1.BrokerStreamRef
3597	0,  // 45: vev.wire.v1.Registered.scope:type_name -> vev.wire.v1.BrokerScope
3598	0,  // 46: vev.wire.v1.SnapshotPart.scope:type_name -> vev.wire.v1.BrokerScope
3599	21, // 47: vev.wire.v1.SnapshotPart.begin:type_name -> vev.wire.v1.SnapshotBegin
3600	22, // 48: vev.wire.v1.SnapshotPart.daemon:type_name -> vev.wire.v1.SnapshotDaemon
3601	23, // 49: vev.wire.v1.SnapshotPart.session:type_name -> vev.wire.v1.SnapshotSession
3602	24, // 50: vev.wire.v1.SnapshotPart.tombstone:type_name -> vev.wire.v1.SnapshotTombstone
3603	25, // 51: vev.wire.v1.SnapshotPart.end:type_name -> vev.wire.v1.SnapshotEnd
3604	39, // 52: vev.wire.v1.SnapshotDaemon.registration:type_name -> vev.wire.v1.RemoteRegistration
3605	2,  // 53: vev.wire.v1.SnapshotDaemon.policy:type_name -> vev.wire.v1.BrokerWirePolicy
3606	4,  // 54: vev.wire.v1.SnapshotDaemon.last_attempt:type_name -> vev.wire.v1.BrokerTimestamp
3607	4,  // 55: vev.wire.v1.SnapshotDaemon.last_success:type_name -> vev.wire.v1.BrokerTimestamp
3608	4,  // 56: vev.wire.v1.SnapshotDaemon.next_due:type_name -> vev.wire.v1.BrokerTimestamp
3609	37, // 57: vev.wire.v1.SnapshotSession.session:type_name -> vev.wire.v1.BrokerCatalogSession
3610	39, // 58: vev.wire.v1.SnapshotTombstone.registration:type_name -> vev.wire.v1.RemoteRegistration
3611	0,  // 59: vev.wire.v1.OperationResult.scope:type_name -> vev.wire.v1.BrokerScope
3612	3,  // 60: vev.wire.v1.OperationResult.error:type_name -> vev.wire.v1.BrokerErrorDetail
3613	39, // 61: vev.wire.v1.OperationResult.registration:type_name -> vev.wire.v1.RemoteRegistration
3614	1,  // 62: vev.wire.v1.StreamOpened.ref:type_name -> vev.wire.v1.BrokerStreamRef
3615	1,  // 63: vev.wire.v1.ServerStreamData.ref:type_name -> vev.wire.v1.BrokerStreamRef
3616	1,  // 64: vev.wire.v1.StreamClosed.ref:type_name -> vev.wire.v1.BrokerStreamRef
3617	3,  // 65: vev.wire.v1.StreamClosed.error:type_name -> vev.wire.v1.BrokerErrorDetail
3618	1,  // 66: vev.wire.v1.Progress.ref:type_name -> vev.wire.v1.BrokerStreamRef
3619	0,  // 67: vev.wire.v1.BrokerErrorMessage.scope:type_name -> vev.wire.v1.BrokerScope
3620	3,  // 68: vev.wire.v1.BrokerErrorMessage.error:type_name -> vev.wire.v1.BrokerErrorDetail
3621	0,  // 69: vev.wire.v1.Shutdown.scope:type_name -> vev.wire.v1.BrokerScope
3622	39, // 70: vev.wire.v1.PreviewRoute.registration:type_name -> vev.wire.v1.RemoteRegistration
3623	2,  // 71: vev.wire.v1.PreviewRoute.policy:type_name -> vev.wire.v1.BrokerWirePolicy
3624	0,  // 72: vev.wire.v1.StartPreview.scope:type_name -> vev.wire.v1.BrokerScope
3625	41, // 73: vev.wire.v1.StartPreview.preview:type_name -> vev.wire.v1.RemotePreviewRequest
3626	33, // 74: vev.wire.v1.StartPreview.route:type_name -> vev.wire.v1.PreviewRoute
3627	0,  // 75: vev.wire.v1.CancelPreview.scope:type_name -> vev.wire.v1.BrokerScope
3628	0,  // 76: vev.wire.v1.PreviewPublication.scope:type_name -> vev.wire.v1.BrokerScope
3629	42, // 77: vev.wire.v1.PreviewPublication.preview:type_name -> vev.wire.v1.RemotePreview
3630	3,  // 78: vev.wire.v1.PreviewPublication.error:type_name -> vev.wire.v1.BrokerErrorDetail
3631	38, // 79: vev.wire.v1.BrokerCatalogSession.tabs:type_name -> vev.wire.v1.BrokerCatalogTab
3632	80, // [80:80] is the sub-list for method output_type
3633	80, // [80:80] is the sub-list for method input_type
3634	80, // [80:80] is the sub-list for extension type_name
3635	80, // [80:80] is the sub-list for extension extendee
3636	0,  // [0:80] is the sub-list for field type_name
3637}
3638
3639func init() { file_broker_proto_init() }
3640func file_broker_proto_init() {
3641	if File_broker_proto != nil {
3642		return
3643	}
3644	file_common_proto_init()
3645	file_terminal_proto_init()
3646	file_broker_proto_msgTypes[5].OneofWrappers = []any{
3647		(*BrokerClientEnvelope_Register)(nil),
3648		(*BrokerClientEnvelope_Subscribe)(nil),
3649		(*BrokerClientEnvelope_Resync)(nil),
3650		(*BrokerClientEnvelope_Unsubscribe)(nil),
3651		(*BrokerClientEnvelope_AddHost)(nil),
3652		(*BrokerClientEnvelope_RemoveHost)(nil),
3653		(*BrokerClientEnvelope_Reconcile)(nil),
3654		(*BrokerClientEnvelope_OpenStream)(nil),
3655		(*BrokerClientEnvelope_ClientStreamData)(nil),
3656		(*BrokerClientEnvelope_CloseStream)(nil),
3657		(*BrokerClientEnvelope_UpdateHostPolicy)(nil),
3658		(*BrokerClientEnvelope_StartPreview)(nil),
3659		(*BrokerClientEnvelope_CancelPreview)(nil),
3660		(*BrokerClientEnvelope_StreamWindowUpdate)(nil),
3661	}
3662	file_broker_proto_msgTypes[6].OneofWrappers = []any{
3663		(*BrokerServerEnvelope_Registered)(nil),
3664		(*BrokerServerEnvelope_SnapshotPart)(nil),
3665		(*BrokerServerEnvelope_OperationResult)(nil),
3666		(*BrokerServerEnvelope_StreamOpened)(nil),
3667		(*BrokerServerEnvelope_ServerStreamData)(nil),
3668		(*BrokerServerEnvelope_StreamClosed)(nil),
3669		(*BrokerServerEnvelope_Progress)(nil),
3670		(*BrokerServerEnvelope_BrokerErrorMessage)(nil),
3671		(*BrokerServerEnvelope_Shutdown)(nil),
3672		(*BrokerServerEnvelope_PreviewPublication)(nil),
3673		(*BrokerServerEnvelope_StreamWindowUpdate)(nil),
3674	}
3675	file_broker_proto_msgTypes[20].OneofWrappers = []any{
3676		(*SnapshotPart_Begin)(nil),
3677		(*SnapshotPart_Daemon)(nil),
3678		(*SnapshotPart_Session)(nil),
3679		(*SnapshotPart_Tombstone)(nil),
3680		(*SnapshotPart_End)(nil),
3681	}
3682	file_broker_proto_msgTypes[36].OneofWrappers = []any{
3683		(*PreviewPublication_Preview)(nil),
3684		(*PreviewPublication_Error)(nil),
3685	}
3686	type x struct{}
3687	out := protoimpl.TypeBuilder{
3688		File: protoimpl.DescBuilder{
3689			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
3690			RawDescriptor: unsafe.Slice(unsafe.StringData(file_broker_proto_rawDesc), len(file_broker_proto_rawDesc)),
3691			NumEnums:      0,
3692			NumMessages:   39,
3693			NumExtensions: 0,
3694			NumServices:   0,
3695		},
3696		GoTypes:           file_broker_proto_goTypes,
3697		DependencyIndexes: file_broker_proto_depIdxs,
3698		MessageInfos:      file_broker_proto_msgTypes,
3699	}.Build()
3700	File_broker_proto = out.File
3701	file_broker_proto_goTypes = nil
3702	file_broker_proto_depIdxs = nil
3703}