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