// Broker wire schema: the client/server broker conversations.
//
// The broker is an independently versioned conversation from the session
// protocol: client tags 101-113 and server tags 201-210 are disjoint from
// every session tag, and each direction is its own closed oneof union.
// Scope (broker epoch plus client connection) is carried explicitly on
// every payload so stream IDs and events never cross a scope. Semantic
// validation stays outside this package; conversion mirrors the port
// types losslessly.

// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// 	protoc-gen-go v1.36.12
// 	protoc        (unknown)
// source: broker.proto

package wire

import (
	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
	reflect "reflect"
	sync "sync"
	unsafe "unsafe"
)

const (
	// Verify that this generated code is sufficiently up-to-date.
	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
	// Verify that runtime/protoimpl is sufficiently up-to-date.
	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
)

// BrokerScope identifies one broker process incarnation and one client
// connection within it (ports.BrokerEpoch / ports.BrokerConnectionID).
// Streams and events are scoped to one scope; an epoch change forces a
// full resynchronization.
type BrokerScope struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	BrokerEpoch   uint64                 `protobuf:"varint,1,opt,name=broker_epoch,json=brokerEpoch,proto3" json:"broker_epoch,omitempty"`
	ConnectionId  []byte                 `protobuf:"bytes,2,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"` // exactly 16 bytes
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *BrokerScope) Reset() {
	*x = BrokerScope{}
	mi := &file_broker_proto_msgTypes[0]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *BrokerScope) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*BrokerScope) ProtoMessage() {}

func (x *BrokerScope) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[0]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use BrokerScope.ProtoReflect.Descriptor instead.
func (*BrokerScope) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{0}
}

func (x *BrokerScope) GetBrokerEpoch() uint64 {
	if x != nil {
		return x.BrokerEpoch
	}
	return 0
}

func (x *BrokerScope) GetConnectionId() []byte {
	if x != nil {
		return x.ConnectionId
	}
	return nil
}

// BrokerStreamRef identifies one logical stream within one scope
// (ports.BrokerStreamID). It never crosses connections or epochs.
type BrokerStreamRef struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Scope         *BrokerScope           `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	StreamId      uint64                 `protobuf:"varint,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *BrokerStreamRef) Reset() {
	*x = BrokerStreamRef{}
	mi := &file_broker_proto_msgTypes[1]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *BrokerStreamRef) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*BrokerStreamRef) ProtoMessage() {}

func (x *BrokerStreamRef) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[1]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use BrokerStreamRef.ProtoReflect.Descriptor instead.
func (*BrokerStreamRef) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{1}
}

func (x *BrokerStreamRef) GetScope() *BrokerScope {
	if x != nil {
		return x.Scope
	}
	return nil
}

func (x *BrokerStreamRef) GetStreamId() uint64 {
	if x != nil {
		return x.StreamId
	}
	return 0
}

// BrokerWirePolicy is the exact connection policy two endpoints must share
// before pooling one physical transport (ports.BrokerPolicy). Tokens are
// opaque, authoritative identities: never display labels, never secrets.
type BrokerWirePolicy struct {
	state            protoimpl.MessageState `protogen:"open.v1"`
	ProtocolVersion  uint32                 `protobuf:"varint,1,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
	CatalogueVersion uint32                 `protobuf:"varint,2,opt,name=catalogue_version,json=catalogueVersion,proto3" json:"catalogue_version,omitempty"`
	// Closed taxonomy: 0 = client-owned, 1 = daemon-owned.
	EnvironmentPolicy uint32 `protobuf:"varint,3,opt,name=environment_policy,json=environmentPolicy,proto3" json:"environment_policy,omitempty"`
	Transport         string `protobuf:"bytes,4,opt,name=transport,proto3" json:"transport,omitempty"`
	Trust             string `protobuf:"bytes,5,opt,name=trust,proto3" json:"trust,omitempty"`
	Launch            string `protobuf:"bytes,6,opt,name=launch,proto3" json:"launch,omitempty"`
	Isolation         string `protobuf:"bytes,7,opt,name=isolation,proto3" json:"isolation,omitempty"`
	unknownFields     protoimpl.UnknownFields
	sizeCache         protoimpl.SizeCache
}

func (x *BrokerWirePolicy) Reset() {
	*x = BrokerWirePolicy{}
	mi := &file_broker_proto_msgTypes[2]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *BrokerWirePolicy) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*BrokerWirePolicy) ProtoMessage() {}

func (x *BrokerWirePolicy) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[2]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use BrokerWirePolicy.ProtoReflect.Descriptor instead.
func (*BrokerWirePolicy) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{2}
}

func (x *BrokerWirePolicy) GetProtocolVersion() uint32 {
	if x != nil {
		return x.ProtocolVersion
	}
	return 0
}

func (x *BrokerWirePolicy) GetCatalogueVersion() uint32 {
	if x != nil {
		return x.CatalogueVersion
	}
	return 0
}

func (x *BrokerWirePolicy) GetEnvironmentPolicy() uint32 {
	if x != nil {
		return x.EnvironmentPolicy
	}
	return 0
}

func (x *BrokerWirePolicy) GetTransport() string {
	if x != nil {
		return x.Transport
	}
	return ""
}

func (x *BrokerWirePolicy) GetTrust() string {
	if x != nil {
		return x.Trust
	}
	return ""
}

func (x *BrokerWirePolicy) GetLaunch() string {
	if x != nil {
		return x.Launch
	}
	return ""
}

func (x *BrokerWirePolicy) GetIsolation() string {
	if x != nil {
		return x.Isolation
	}
	return ""
}

// BrokerErrorDetail is the typed broker failure carried to clients
// (ports.BrokerError plus bounded display text). The underlying cause is
// local-only diagnostic authority and never travels on this wire.
type BrokerErrorDetail struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Closed taxonomy: 1 = unavailable, 2 = incompatible, 3 = timeout,
	// 4 = cancelled, 5 = outcome_unknown, 6 = attachment_lost,
	// 7 = stale_epoch, 8 = conflicting_policy, 9 = explicit_exit,
	// 10 = fatal_terminal, 11 = host_conflict, 12 = membership_immutable.
	Code uint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Text string `protobuf:"bytes,2,opt,name=text,proto3" json:"text,omitempty"`
	// Closed admission-refusal taxonomy; 0 = none. Codes are assigned by the
	// broker admission slice.
	AdmissionCode uint32 `protobuf:"varint,3,opt,name=admission_code,json=admissionCode,proto3" json:"admission_code,omitempty"`
	// Closed cause taxonomy (domain.RemoteFailureKind): 0 = none, 1 =
	// transport, through the last declared failure kind.
	FailureKind   uint32 `protobuf:"varint,4,opt,name=failure_kind,json=failureKind,proto3" json:"failure_kind,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *BrokerErrorDetail) Reset() {
	*x = BrokerErrorDetail{}
	mi := &file_broker_proto_msgTypes[3]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *BrokerErrorDetail) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*BrokerErrorDetail) ProtoMessage() {}

func (x *BrokerErrorDetail) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[3]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use BrokerErrorDetail.ProtoReflect.Descriptor instead.
func (*BrokerErrorDetail) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{3}
}

func (x *BrokerErrorDetail) GetCode() uint32 {
	if x != nil {
		return x.Code
	}
	return 0
}

func (x *BrokerErrorDetail) GetText() string {
	if x != nil {
		return x.Text
	}
	return ""
}

func (x *BrokerErrorDetail) GetAdmissionCode() uint32 {
	if x != nil {
		return x.AdmissionCode
	}
	return 0
}

func (x *BrokerErrorDetail) GetFailureKind() uint32 {
	if x != nil {
		return x.FailureKind
	}
	return 0
}

// BrokerTimestamp is one instant split into seconds and nanoseconds so
// time.Time survives the wire exactly.
type BrokerTimestamp struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Seconds       int64                  `protobuf:"varint,1,opt,name=seconds,proto3" json:"seconds,omitempty"`
	Nanos         int32                  `protobuf:"varint,2,opt,name=nanos,proto3" json:"nanos,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *BrokerTimestamp) Reset() {
	*x = BrokerTimestamp{}
	mi := &file_broker_proto_msgTypes[4]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *BrokerTimestamp) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*BrokerTimestamp) ProtoMessage() {}

func (x *BrokerTimestamp) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[4]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use BrokerTimestamp.ProtoReflect.Descriptor instead.
func (*BrokerTimestamp) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{4}
}

func (x *BrokerTimestamp) GetSeconds() int64 {
	if x != nil {
		return x.Seconds
	}
	return 0
}

func (x *BrokerTimestamp) GetNanos() int32 {
	if x != nil {
		return x.Nanos
	}
	return 0
}

// BrokerClientEnvelope is the closed client-to-server broker union. Exactly
// one variant must be set per envelope; empty, duplicate, and
// wrong-direction payloads are rejected before generated unmarshal.
type BrokerClientEnvelope struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Types that are valid to be assigned to Payload:
	//
	//	*BrokerClientEnvelope_Register
	//	*BrokerClientEnvelope_Subscribe
	//	*BrokerClientEnvelope_Resync
	//	*BrokerClientEnvelope_Unsubscribe
	//	*BrokerClientEnvelope_AddHost
	//	*BrokerClientEnvelope_RemoveHost
	//	*BrokerClientEnvelope_Reconcile
	//	*BrokerClientEnvelope_OpenStream
	//	*BrokerClientEnvelope_ClientStreamData
	//	*BrokerClientEnvelope_CloseStream
	//	*BrokerClientEnvelope_UpdateHostPolicy
	//	*BrokerClientEnvelope_StartPreview
	//	*BrokerClientEnvelope_CancelPreview
	Payload       isBrokerClientEnvelope_Payload `protobuf_oneof:"payload"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *BrokerClientEnvelope) Reset() {
	*x = BrokerClientEnvelope{}
	mi := &file_broker_proto_msgTypes[5]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *BrokerClientEnvelope) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*BrokerClientEnvelope) ProtoMessage() {}

func (x *BrokerClientEnvelope) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[5]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use BrokerClientEnvelope.ProtoReflect.Descriptor instead.
func (*BrokerClientEnvelope) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{5}
}

func (x *BrokerClientEnvelope) GetPayload() isBrokerClientEnvelope_Payload {
	if x != nil {
		return x.Payload
	}
	return nil
}

func (x *BrokerClientEnvelope) GetRegister() *Register {
	if x != nil {
		if x, ok := x.Payload.(*BrokerClientEnvelope_Register); ok {
			return x.Register
		}
	}
	return nil
}

func (x *BrokerClientEnvelope) GetSubscribe() *Subscribe {
	if x != nil {
		if x, ok := x.Payload.(*BrokerClientEnvelope_Subscribe); ok {
			return x.Subscribe
		}
	}
	return nil
}

func (x *BrokerClientEnvelope) GetResync() *Resync {
	if x != nil {
		if x, ok := x.Payload.(*BrokerClientEnvelope_Resync); ok {
			return x.Resync
		}
	}
	return nil
}

func (x *BrokerClientEnvelope) GetUnsubscribe() *Unsubscribe {
	if x != nil {
		if x, ok := x.Payload.(*BrokerClientEnvelope_Unsubscribe); ok {
			return x.Unsubscribe
		}
	}
	return nil
}

func (x *BrokerClientEnvelope) GetAddHost() *AddHost {
	if x != nil {
		if x, ok := x.Payload.(*BrokerClientEnvelope_AddHost); ok {
			return x.AddHost
		}
	}
	return nil
}

func (x *BrokerClientEnvelope) GetRemoveHost() *RemoveHost {
	if x != nil {
		if x, ok := x.Payload.(*BrokerClientEnvelope_RemoveHost); ok {
			return x.RemoveHost
		}
	}
	return nil
}

func (x *BrokerClientEnvelope) GetReconcile() *Reconcile {
	if x != nil {
		if x, ok := x.Payload.(*BrokerClientEnvelope_Reconcile); ok {
			return x.Reconcile
		}
	}
	return nil
}

func (x *BrokerClientEnvelope) GetOpenStream() *OpenStream {
	if x != nil {
		if x, ok := x.Payload.(*BrokerClientEnvelope_OpenStream); ok {
			return x.OpenStream
		}
	}
	return nil
}

func (x *BrokerClientEnvelope) GetClientStreamData() *ClientStreamData {
	if x != nil {
		if x, ok := x.Payload.(*BrokerClientEnvelope_ClientStreamData); ok {
			return x.ClientStreamData
		}
	}
	return nil
}

func (x *BrokerClientEnvelope) GetCloseStream() *CloseStream {
	if x != nil {
		if x, ok := x.Payload.(*BrokerClientEnvelope_CloseStream); ok {
			return x.CloseStream
		}
	}
	return nil
}

func (x *BrokerClientEnvelope) GetUpdateHostPolicy() *UpdateHostPolicy {
	if x != nil {
		if x, ok := x.Payload.(*BrokerClientEnvelope_UpdateHostPolicy); ok {
			return x.UpdateHostPolicy
		}
	}
	return nil
}

func (x *BrokerClientEnvelope) GetStartPreview() *StartPreview {
	if x != nil {
		if x, ok := x.Payload.(*BrokerClientEnvelope_StartPreview); ok {
			return x.StartPreview
		}
	}
	return nil
}

func (x *BrokerClientEnvelope) GetCancelPreview() *CancelPreview {
	if x != nil {
		if x, ok := x.Payload.(*BrokerClientEnvelope_CancelPreview); ok {
			return x.CancelPreview
		}
	}
	return nil
}

type isBrokerClientEnvelope_Payload interface {
	isBrokerClientEnvelope_Payload()
}

type BrokerClientEnvelope_Register struct {
	Register *Register `protobuf:"bytes,101,opt,name=register,proto3,oneof"`
}

type BrokerClientEnvelope_Subscribe struct {
	Subscribe *Subscribe `protobuf:"bytes,102,opt,name=subscribe,proto3,oneof"`
}

type BrokerClientEnvelope_Resync struct {
	Resync *Resync `protobuf:"bytes,103,opt,name=resync,proto3,oneof"`
}

type BrokerClientEnvelope_Unsubscribe struct {
	Unsubscribe *Unsubscribe `protobuf:"bytes,104,opt,name=unsubscribe,proto3,oneof"`
}

type BrokerClientEnvelope_AddHost struct {
	AddHost *AddHost `protobuf:"bytes,105,opt,name=add_host,json=addHost,proto3,oneof"`
}

type BrokerClientEnvelope_RemoveHost struct {
	RemoveHost *RemoveHost `protobuf:"bytes,106,opt,name=remove_host,json=removeHost,proto3,oneof"`
}

type BrokerClientEnvelope_Reconcile struct {
	Reconcile *Reconcile `protobuf:"bytes,107,opt,name=reconcile,proto3,oneof"`
}

type BrokerClientEnvelope_OpenStream struct {
	OpenStream *OpenStream `protobuf:"bytes,108,opt,name=open_stream,json=openStream,proto3,oneof"`
}

type BrokerClientEnvelope_ClientStreamData struct {
	ClientStreamData *ClientStreamData `protobuf:"bytes,109,opt,name=client_stream_data,json=clientStreamData,proto3,oneof"`
}

type BrokerClientEnvelope_CloseStream struct {
	CloseStream *CloseStream `protobuf:"bytes,110,opt,name=close_stream,json=closeStream,proto3,oneof"`
}

type BrokerClientEnvelope_UpdateHostPolicy struct {
	UpdateHostPolicy *UpdateHostPolicy `protobuf:"bytes,111,opt,name=update_host_policy,json=updateHostPolicy,proto3,oneof"`
}

type BrokerClientEnvelope_StartPreview struct {
	StartPreview *StartPreview `protobuf:"bytes,112,opt,name=start_preview,json=startPreview,proto3,oneof"`
}

type BrokerClientEnvelope_CancelPreview struct {
	CancelPreview *CancelPreview `protobuf:"bytes,113,opt,name=cancel_preview,json=cancelPreview,proto3,oneof"`
}

func (*BrokerClientEnvelope_Register) isBrokerClientEnvelope_Payload() {}

func (*BrokerClientEnvelope_Subscribe) isBrokerClientEnvelope_Payload() {}

func (*BrokerClientEnvelope_Resync) isBrokerClientEnvelope_Payload() {}

func (*BrokerClientEnvelope_Unsubscribe) isBrokerClientEnvelope_Payload() {}

func (*BrokerClientEnvelope_AddHost) isBrokerClientEnvelope_Payload() {}

func (*BrokerClientEnvelope_RemoveHost) isBrokerClientEnvelope_Payload() {}

func (*BrokerClientEnvelope_Reconcile) isBrokerClientEnvelope_Payload() {}

func (*BrokerClientEnvelope_OpenStream) isBrokerClientEnvelope_Payload() {}

func (*BrokerClientEnvelope_ClientStreamData) isBrokerClientEnvelope_Payload() {}

func (*BrokerClientEnvelope_CloseStream) isBrokerClientEnvelope_Payload() {}

func (*BrokerClientEnvelope_UpdateHostPolicy) isBrokerClientEnvelope_Payload() {}

func (*BrokerClientEnvelope_StartPreview) isBrokerClientEnvelope_Payload() {}

func (*BrokerClientEnvelope_CancelPreview) isBrokerClientEnvelope_Payload() {}

// BrokerServerEnvelope is the closed server-to-client broker union. Exactly
// one variant must be set per envelope.
type BrokerServerEnvelope struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Types that are valid to be assigned to Payload:
	//
	//	*BrokerServerEnvelope_Registered
	//	*BrokerServerEnvelope_SnapshotPart
	//	*BrokerServerEnvelope_OperationResult
	//	*BrokerServerEnvelope_StreamOpened
	//	*BrokerServerEnvelope_ServerStreamData
	//	*BrokerServerEnvelope_StreamClosed
	//	*BrokerServerEnvelope_Progress
	//	*BrokerServerEnvelope_BrokerErrorMessage
	//	*BrokerServerEnvelope_Shutdown
	//	*BrokerServerEnvelope_PreviewPublication
	Payload       isBrokerServerEnvelope_Payload `protobuf_oneof:"payload"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *BrokerServerEnvelope) Reset() {
	*x = BrokerServerEnvelope{}
	mi := &file_broker_proto_msgTypes[6]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *BrokerServerEnvelope) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*BrokerServerEnvelope) ProtoMessage() {}

func (x *BrokerServerEnvelope) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[6]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use BrokerServerEnvelope.ProtoReflect.Descriptor instead.
func (*BrokerServerEnvelope) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{6}
}

func (x *BrokerServerEnvelope) GetPayload() isBrokerServerEnvelope_Payload {
	if x != nil {
		return x.Payload
	}
	return nil
}

func (x *BrokerServerEnvelope) GetRegistered() *Registered {
	if x != nil {
		if x, ok := x.Payload.(*BrokerServerEnvelope_Registered); ok {
			return x.Registered
		}
	}
	return nil
}

func (x *BrokerServerEnvelope) GetSnapshotPart() *SnapshotPart {
	if x != nil {
		if x, ok := x.Payload.(*BrokerServerEnvelope_SnapshotPart); ok {
			return x.SnapshotPart
		}
	}
	return nil
}

func (x *BrokerServerEnvelope) GetOperationResult() *OperationResult {
	if x != nil {
		if x, ok := x.Payload.(*BrokerServerEnvelope_OperationResult); ok {
			return x.OperationResult
		}
	}
	return nil
}

func (x *BrokerServerEnvelope) GetStreamOpened() *StreamOpened {
	if x != nil {
		if x, ok := x.Payload.(*BrokerServerEnvelope_StreamOpened); ok {
			return x.StreamOpened
		}
	}
	return nil
}

func (x *BrokerServerEnvelope) GetServerStreamData() *ServerStreamData {
	if x != nil {
		if x, ok := x.Payload.(*BrokerServerEnvelope_ServerStreamData); ok {
			return x.ServerStreamData
		}
	}
	return nil
}

func (x *BrokerServerEnvelope) GetStreamClosed() *StreamClosed {
	if x != nil {
		if x, ok := x.Payload.(*BrokerServerEnvelope_StreamClosed); ok {
			return x.StreamClosed
		}
	}
	return nil
}

func (x *BrokerServerEnvelope) GetProgress() *Progress {
	if x != nil {
		if x, ok := x.Payload.(*BrokerServerEnvelope_Progress); ok {
			return x.Progress
		}
	}
	return nil
}

func (x *BrokerServerEnvelope) GetBrokerErrorMessage() *BrokerErrorMessage {
	if x != nil {
		if x, ok := x.Payload.(*BrokerServerEnvelope_BrokerErrorMessage); ok {
			return x.BrokerErrorMessage
		}
	}
	return nil
}

func (x *BrokerServerEnvelope) GetShutdown() *Shutdown {
	if x != nil {
		if x, ok := x.Payload.(*BrokerServerEnvelope_Shutdown); ok {
			return x.Shutdown
		}
	}
	return nil
}

func (x *BrokerServerEnvelope) GetPreviewPublication() *PreviewPublication {
	if x != nil {
		if x, ok := x.Payload.(*BrokerServerEnvelope_PreviewPublication); ok {
			return x.PreviewPublication
		}
	}
	return nil
}

type isBrokerServerEnvelope_Payload interface {
	isBrokerServerEnvelope_Payload()
}

type BrokerServerEnvelope_Registered struct {
	Registered *Registered `protobuf:"bytes,201,opt,name=registered,proto3,oneof"`
}

type BrokerServerEnvelope_SnapshotPart struct {
	SnapshotPart *SnapshotPart `protobuf:"bytes,202,opt,name=snapshot_part,json=snapshotPart,proto3,oneof"`
}

type BrokerServerEnvelope_OperationResult struct {
	OperationResult *OperationResult `protobuf:"bytes,203,opt,name=operation_result,json=operationResult,proto3,oneof"`
}

type BrokerServerEnvelope_StreamOpened struct {
	StreamOpened *StreamOpened `protobuf:"bytes,204,opt,name=stream_opened,json=streamOpened,proto3,oneof"`
}

type BrokerServerEnvelope_ServerStreamData struct {
	ServerStreamData *ServerStreamData `protobuf:"bytes,205,opt,name=server_stream_data,json=serverStreamData,proto3,oneof"`
}

type BrokerServerEnvelope_StreamClosed struct {
	StreamClosed *StreamClosed `protobuf:"bytes,206,opt,name=stream_closed,json=streamClosed,proto3,oneof"`
}

type BrokerServerEnvelope_Progress struct {
	Progress *Progress `protobuf:"bytes,207,opt,name=progress,proto3,oneof"`
}

type BrokerServerEnvelope_BrokerErrorMessage struct {
	BrokerErrorMessage *BrokerErrorMessage `protobuf:"bytes,208,opt,name=broker_error_message,json=brokerErrorMessage,proto3,oneof"`
}

type BrokerServerEnvelope_Shutdown struct {
	Shutdown *Shutdown `protobuf:"bytes,209,opt,name=shutdown,proto3,oneof"`
}

type BrokerServerEnvelope_PreviewPublication struct {
	PreviewPublication *PreviewPublication `protobuf:"bytes,210,opt,name=preview_publication,json=previewPublication,proto3,oneof"`
}

func (*BrokerServerEnvelope_Registered) isBrokerServerEnvelope_Payload() {}

func (*BrokerServerEnvelope_SnapshotPart) isBrokerServerEnvelope_Payload() {}

func (*BrokerServerEnvelope_OperationResult) isBrokerServerEnvelope_Payload() {}

func (*BrokerServerEnvelope_StreamOpened) isBrokerServerEnvelope_Payload() {}

func (*BrokerServerEnvelope_ServerStreamData) isBrokerServerEnvelope_Payload() {}

func (*BrokerServerEnvelope_StreamClosed) isBrokerServerEnvelope_Payload() {}

func (*BrokerServerEnvelope_Progress) isBrokerServerEnvelope_Payload() {}

func (*BrokerServerEnvelope_BrokerErrorMessage) isBrokerServerEnvelope_Payload() {}

func (*BrokerServerEnvelope_Shutdown) isBrokerServerEnvelope_Payload() {}

func (*BrokerServerEnvelope_PreviewPublication) isBrokerServerEnvelope_Payload() {}

// Register opens one client connection to the broker.
type Register struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Build         string                 `protobuf:"bytes,1,opt,name=build,proto3" json:"build,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *Register) Reset() {
	*x = Register{}
	mi := &file_broker_proto_msgTypes[7]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *Register) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*Register) ProtoMessage() {}

func (x *Register) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[7]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use Register.ProtoReflect.Descriptor instead.
func (*Register) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{7}
}

func (x *Register) GetBuild() string {
	if x != nil {
		return x.Build
	}
	return ""
}

// Subscribe asks for snapshot and lifecycle publications for one scope.
type Subscribe struct {
	state      protoimpl.MessageState `protogen:"open.v1"`
	Scope      *BrokerScope           `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	Generation uint64                 `protobuf:"varint,2,opt,name=generation,proto3" json:"generation,omitempty"`
	// passive marks a read-only snapshot reader (vev ls, vev host list). It
	// receives publications but never counts as observation demand, so reading
	// state never triggers a probe.
	Passive       bool `protobuf:"varint,3,opt,name=passive,proto3" json:"passive,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *Subscribe) Reset() {
	*x = Subscribe{}
	mi := &file_broker_proto_msgTypes[8]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *Subscribe) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*Subscribe) ProtoMessage() {}

func (x *Subscribe) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[8]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use Subscribe.ProtoReflect.Descriptor instead.
func (*Subscribe) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{8}
}

func (x *Subscribe) GetScope() *BrokerScope {
	if x != nil {
		return x.Scope
	}
	return nil
}

func (x *Subscribe) GetGeneration() uint64 {
	if x != nil {
		return x.Generation
	}
	return 0
}

func (x *Subscribe) GetPassive() bool {
	if x != nil {
		return x.Passive
	}
	return false
}

// Resync asks for a full snapshot publication after an epoch change or a
// gap in the client's generation series.
type Resync struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Scope         *BrokerScope           `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	Generation    uint64                 `protobuf:"varint,2,opt,name=generation,proto3" json:"generation,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *Resync) Reset() {
	*x = Resync{}
	mi := &file_broker_proto_msgTypes[9]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *Resync) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*Resync) ProtoMessage() {}

func (x *Resync) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[9]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use Resync.ProtoReflect.Descriptor instead.
func (*Resync) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{9}
}

func (x *Resync) GetScope() *BrokerScope {
	if x != nil {
		return x.Scope
	}
	return nil
}

func (x *Resync) GetGeneration() uint64 {
	if x != nil {
		return x.Generation
	}
	return 0
}

// Unsubscribe stops publications for one scope.
type Unsubscribe struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Scope         *BrokerScope           `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	Generation    uint64                 `protobuf:"varint,2,opt,name=generation,proto3" json:"generation,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *Unsubscribe) Reset() {
	*x = Unsubscribe{}
	mi := &file_broker_proto_msgTypes[10]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *Unsubscribe) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*Unsubscribe) ProtoMessage() {}

func (x *Unsubscribe) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[10]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use Unsubscribe.ProtoReflect.Descriptor instead.
func (*Unsubscribe) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{10}
}

func (x *Unsubscribe) GetScope() *BrokerScope {
	if x != nil {
		return x.Scope
	}
	return nil
}

func (x *Unsubscribe) GetGeneration() uint64 {
	if x != nil {
		return x.Generation
	}
	return 0
}

// AddHost adds one configured host registration. operation_id is the
// idempotency identity of this mutating operation. policy is mandatory:
// the request is refused unless it carries an exact valid policy, so a
// membership addition can never be authorized by an absent policy.
type AddHost struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Scope         *BrokerScope           `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	OperationId   []byte                 `protobuf:"bytes,2,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"` // exactly 16 bytes
	Endpoint      string                 `protobuf:"bytes,3,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Policy        *BrokerWirePolicy      `protobuf:"bytes,4,opt,name=policy,proto3" json:"policy,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *AddHost) Reset() {
	*x = AddHost{}
	mi := &file_broker_proto_msgTypes[11]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *AddHost) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*AddHost) ProtoMessage() {}

func (x *AddHost) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[11]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use AddHost.ProtoReflect.Descriptor instead.
func (*AddHost) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{11}
}

func (x *AddHost) GetScope() *BrokerScope {
	if x != nil {
		return x.Scope
	}
	return nil
}

func (x *AddHost) GetOperationId() []byte {
	if x != nil {
		return x.OperationId
	}
	return nil
}

func (x *AddHost) GetEndpoint() string {
	if x != nil {
		return x.Endpoint
	}
	return ""
}

func (x *AddHost) GetPolicy() *BrokerWirePolicy {
	if x != nil {
		return x.Policy
	}
	return nil
}

// RemoveHost removes exactly the registration carried by registration
// (endpoint, incarnation, and generation). A request whose authority does
// not exactly match the current registration is refused rather than
// applied to an endpoint name.
type RemoveHost struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Scope         *BrokerScope           `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	OperationId   []byte                 `protobuf:"bytes,2,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"` // exactly 16 bytes
	Registration  *RemoteRegistration    `protobuf:"bytes,3,opt,name=registration,proto3" json:"registration,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *RemoveHost) Reset() {
	*x = RemoveHost{}
	mi := &file_broker_proto_msgTypes[12]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *RemoveHost) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*RemoveHost) ProtoMessage() {}

func (x *RemoveHost) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[12]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use RemoveHost.ProtoReflect.Descriptor instead.
func (*RemoveHost) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{12}
}

func (x *RemoveHost) GetScope() *BrokerScope {
	if x != nil {
		return x.Scope
	}
	return nil
}

func (x *RemoveHost) GetOperationId() []byte {
	if x != nil {
		return x.OperationId
	}
	return nil
}

func (x *RemoveHost) GetRegistration() *RemoteRegistration {
	if x != nil {
		return x.Registration
	}
	return nil
}

// UpdateHostPolicy replaces the policy of exactly the registration carried
// by registration and answers with the advanced registration authority.
// policy is mandatory: an absent policy is refused like an invalid one.
type UpdateHostPolicy struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Scope         *BrokerScope           `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	OperationId   []byte                 `protobuf:"bytes,2,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"` // exactly 16 bytes
	Registration  *RemoteRegistration    `protobuf:"bytes,3,opt,name=registration,proto3" json:"registration,omitempty"`
	Policy        *BrokerWirePolicy      `protobuf:"bytes,4,opt,name=policy,proto3" json:"policy,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *UpdateHostPolicy) Reset() {
	*x = UpdateHostPolicy{}
	mi := &file_broker_proto_msgTypes[13]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *UpdateHostPolicy) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*UpdateHostPolicy) ProtoMessage() {}

func (x *UpdateHostPolicy) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[13]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use UpdateHostPolicy.ProtoReflect.Descriptor instead.
func (*UpdateHostPolicy) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{13}
}

func (x *UpdateHostPolicy) GetScope() *BrokerScope {
	if x != nil {
		return x.Scope
	}
	return nil
}

func (x *UpdateHostPolicy) GetOperationId() []byte {
	if x != nil {
		return x.OperationId
	}
	return nil
}

func (x *UpdateHostPolicy) GetRegistration() *RemoteRegistration {
	if x != nil {
		return x.Registration
	}
	return nil
}

func (x *UpdateHostPolicy) GetPolicy() *BrokerWirePolicy {
	if x != nil {
		return x.Policy
	}
	return nil
}

// Reconcile hands the broker one exact registration to probe.
type Reconcile struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Scope         *BrokerScope           `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	Registration  *RemoteRegistration    `protobuf:"bytes,2,opt,name=registration,proto3" json:"registration,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *Reconcile) Reset() {
	*x = Reconcile{}
	mi := &file_broker_proto_msgTypes[14]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *Reconcile) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*Reconcile) ProtoMessage() {}

func (x *Reconcile) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[14]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use Reconcile.ProtoReflect.Descriptor instead.
func (*Reconcile) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{14}
}

func (x *Reconcile) GetScope() *BrokerScope {
	if x != nil {
		return x.Scope
	}
	return nil
}

func (x *Reconcile) GetRegistration() *RemoteRegistration {
	if x != nil {
		return x.Registration
	}
	return nil
}

// OpenStream asks the broker to open one independently cancellable logical
// stream to the owning daemon. env is the per-request session environment
// and is never inherited from the broker process environment.
//
// admission is the closed attachment-admission taxonomy: an attachment
// stream names exactly how the daemon must admit it, while control and
// observation streams carry none (0). name is validated session-name
// authority for create-named and attach-named and is empty for every other
// variant.
// start_mode is the explicit daemon-start authorization carried to the
// transport: observation and daemon-stop must be existing_only, while
// attach/creation and the explicit list/mutate controls may be
// start_if_needed. Zero is invalid and is refused by semantic validation.
type OpenStream struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	Ref   *BrokerStreamRef       `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// Closed taxonomy: 1 = attachment, 2 = control, 3 = observation.
	Purpose      uint32              `protobuf:"varint,2,opt,name=purpose,proto3" json:"purpose,omitempty"`
	Local        bool                `protobuf:"varint,3,opt,name=local,proto3" json:"local,omitempty"`
	Endpoint     string              `protobuf:"bytes,4,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Registration *RemoteRegistration `protobuf:"bytes,5,opt,name=registration,proto3" json:"registration,omitempty"`
	// Present only for exact attach/resume; the zero-value message is never
	// sent for a creation admission.
	Target *ExactTarget      `protobuf:"bytes,6,opt,name=target,proto3" json:"target,omitempty"`
	Env    []string          `protobuf:"bytes,7,rep,name=env,proto3" json:"env,omitempty"`
	Policy *BrokerWirePolicy `protobuf:"bytes,8,opt,name=policy,proto3" json:"policy,omitempty"`
	// Closed admission taxonomy: 0 = none (control/observation), 1 = exact
	// attach/resume, 2 = create named, 3 = create ephemeral, 4 = attach named
	// (the daemon resolves the name and refuses an unknown one).
	Admission uint32 `protobuf:"varint,9,opt,name=admission,proto3" json:"admission,omitempty"`
	// Validated session name for create-named and attach-named; empty otherwise.
	Name string `protobuf:"bytes,10,opt,name=name,proto3" json:"name,omitempty"`
	// Closed daemon-start taxonomy (ports.BrokerDaemonStartMode): 1 =
	// existing_only, 2 = start_if_needed. Always present; zero is refused.
	StartMode     uint32 `protobuf:"varint,11,opt,name=start_mode,json=startMode,proto3" json:"start_mode,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *OpenStream) Reset() {
	*x = OpenStream{}
	mi := &file_broker_proto_msgTypes[15]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *OpenStream) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*OpenStream) ProtoMessage() {}

func (x *OpenStream) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[15]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use OpenStream.ProtoReflect.Descriptor instead.
func (*OpenStream) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{15}
}

func (x *OpenStream) GetRef() *BrokerStreamRef {
	if x != nil {
		return x.Ref
	}
	return nil
}

func (x *OpenStream) GetPurpose() uint32 {
	if x != nil {
		return x.Purpose
	}
	return 0
}

func (x *OpenStream) GetLocal() bool {
	if x != nil {
		return x.Local
	}
	return false
}

func (x *OpenStream) GetEndpoint() string {
	if x != nil {
		return x.Endpoint
	}
	return ""
}

func (x *OpenStream) GetRegistration() *RemoteRegistration {
	if x != nil {
		return x.Registration
	}
	return nil
}

func (x *OpenStream) GetTarget() *ExactTarget {
	if x != nil {
		return x.Target
	}
	return nil
}

func (x *OpenStream) GetEnv() []string {
	if x != nil {
		return x.Env
	}
	return nil
}

func (x *OpenStream) GetPolicy() *BrokerWirePolicy {
	if x != nil {
		return x.Policy
	}
	return nil
}

func (x *OpenStream) GetAdmission() uint32 {
	if x != nil {
		return x.Admission
	}
	return 0
}

func (x *OpenStream) GetName() string {
	if x != nil {
		return x.Name
	}
	return ""
}

func (x *OpenStream) GetStartMode() uint32 {
	if x != nil {
		return x.StartMode
	}
	return 0
}

// ClientStreamData carries one opaque client-to-daemon stream frame.
type ClientStreamData struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Ref           *BrokerStreamRef       `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	Data          []byte                 `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *ClientStreamData) Reset() {
	*x = ClientStreamData{}
	mi := &file_broker_proto_msgTypes[16]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *ClientStreamData) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*ClientStreamData) ProtoMessage() {}

func (x *ClientStreamData) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[16]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use ClientStreamData.ProtoReflect.Descriptor instead.
func (*ClientStreamData) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{16}
}

func (x *ClientStreamData) GetRef() *BrokerStreamRef {
	if x != nil {
		return x.Ref
	}
	return nil
}

func (x *ClientStreamData) GetData() []byte {
	if x != nil {
		return x.Data
	}
	return nil
}

// CloseStream closes one logical stream.
type CloseStream struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Ref           *BrokerStreamRef       `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *CloseStream) Reset() {
	*x = CloseStream{}
	mi := &file_broker_proto_msgTypes[17]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *CloseStream) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*CloseStream) ProtoMessage() {}

func (x *CloseStream) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[17]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use CloseStream.ProtoReflect.Descriptor instead.
func (*CloseStream) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{17}
}

func (x *CloseStream) GetRef() *BrokerStreamRef {
	if x != nil {
		return x.Ref
	}
	return nil
}

// Registered confirms one accepted client connection and its assigned scope.
type Registered struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Scope         *BrokerScope           `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	Build         string                 `protobuf:"bytes,2,opt,name=build,proto3" json:"build,omitempty"`
	Retiring      bool                   `protobuf:"varint,3,opt,name=retiring,proto3" json:"retiring,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *Registered) Reset() {
	*x = Registered{}
	mi := &file_broker_proto_msgTypes[18]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *Registered) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*Registered) ProtoMessage() {}

func (x *Registered) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[18]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use Registered.ProtoReflect.Descriptor instead.
func (*Registered) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{18}
}

func (x *Registered) GetScope() *BrokerScope {
	if x != nil {
		return x.Scope
	}
	return nil
}

func (x *Registered) GetBuild() string {
	if x != nil {
		return x.Build
	}
	return ""
}

func (x *Registered) GetRetiring() bool {
	if x != nil {
		return x.Retiring
	}
	return false
}

// SnapshotPart is one fragment of a snapshot publication. Parts of one
// generation and revision arrive in index order and carry exactly one
// nested payload.
type SnapshotPart struct {
	state      protoimpl.MessageState `protogen:"open.v1"`
	Scope      *BrokerScope           `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	Generation uint64                 `protobuf:"varint,2,opt,name=generation,proto3" json:"generation,omitempty"`
	Revision   uint64                 `protobuf:"varint,3,opt,name=revision,proto3" json:"revision,omitempty"`
	Index      uint32                 `protobuf:"varint,4,opt,name=index,proto3" json:"index,omitempty"`
	// Types that are valid to be assigned to Part:
	//
	//	*SnapshotPart_Begin
	//	*SnapshotPart_Daemon
	//	*SnapshotPart_Session
	//	*SnapshotPart_Tombstone
	//	*SnapshotPart_End
	Part          isSnapshotPart_Part `protobuf_oneof:"part"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *SnapshotPart) Reset() {
	*x = SnapshotPart{}
	mi := &file_broker_proto_msgTypes[19]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *SnapshotPart) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*SnapshotPart) ProtoMessage() {}

func (x *SnapshotPart) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[19]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use SnapshotPart.ProtoReflect.Descriptor instead.
func (*SnapshotPart) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{19}
}

func (x *SnapshotPart) GetScope() *BrokerScope {
	if x != nil {
		return x.Scope
	}
	return nil
}

func (x *SnapshotPart) GetGeneration() uint64 {
	if x != nil {
		return x.Generation
	}
	return 0
}

func (x *SnapshotPart) GetRevision() uint64 {
	if x != nil {
		return x.Revision
	}
	return 0
}

func (x *SnapshotPart) GetIndex() uint32 {
	if x != nil {
		return x.Index
	}
	return 0
}

func (x *SnapshotPart) GetPart() isSnapshotPart_Part {
	if x != nil {
		return x.Part
	}
	return nil
}

func (x *SnapshotPart) GetBegin() *SnapshotBegin {
	if x != nil {
		if x, ok := x.Part.(*SnapshotPart_Begin); ok {
			return x.Begin
		}
	}
	return nil
}

func (x *SnapshotPart) GetDaemon() *SnapshotDaemon {
	if x != nil {
		if x, ok := x.Part.(*SnapshotPart_Daemon); ok {
			return x.Daemon
		}
	}
	return nil
}

func (x *SnapshotPart) GetSession() *SnapshotSession {
	if x != nil {
		if x, ok := x.Part.(*SnapshotPart_Session); ok {
			return x.Session
		}
	}
	return nil
}

func (x *SnapshotPart) GetTombstone() *SnapshotTombstone {
	if x != nil {
		if x, ok := x.Part.(*SnapshotPart_Tombstone); ok {
			return x.Tombstone
		}
	}
	return nil
}

func (x *SnapshotPart) GetEnd() *SnapshotEnd {
	if x != nil {
		if x, ok := x.Part.(*SnapshotPart_End); ok {
			return x.End
		}
	}
	return nil
}

type isSnapshotPart_Part interface {
	isSnapshotPart_Part()
}

type SnapshotPart_Begin struct {
	Begin *SnapshotBegin `protobuf:"bytes,10,opt,name=begin,proto3,oneof"`
}

type SnapshotPart_Daemon struct {
	Daemon *SnapshotDaemon `protobuf:"bytes,15,opt,name=daemon,proto3,oneof"`
}

type SnapshotPart_Session struct {
	Session *SnapshotSession `protobuf:"bytes,12,opt,name=session,proto3,oneof"`
}

type SnapshotPart_Tombstone struct {
	Tombstone *SnapshotTombstone `protobuf:"bytes,13,opt,name=tombstone,proto3,oneof"`
}

type SnapshotPart_End struct {
	End *SnapshotEnd `protobuf:"bytes,14,opt,name=end,proto3,oneof"`
}

func (*SnapshotPart_Begin) isSnapshotPart_Part() {}

func (*SnapshotPart_Daemon) isSnapshotPart_Part() {}

func (*SnapshotPart_Session) isSnapshotPart_Part() {}

func (*SnapshotPart_Tombstone) isSnapshotPart_Part() {}

func (*SnapshotPart_End) isSnapshotPart_Part() {}

// SnapshotBegin opens a snapshot publication with its element counts.
// host_count counts every daemon part in the transfer (the local daemon plus
// every remote host), and local_present reports whether daemon index 0 is the
// local daemon. A publication carries at most one local daemon, always first.
type SnapshotBegin struct {
	state          protoimpl.MessageState `protogen:"open.v1"`
	HostCount      uint32                 `protobuf:"varint,1,opt,name=host_count,json=hostCount,proto3" json:"host_count,omitempty"`
	SessionCount   uint32                 `protobuf:"varint,2,opt,name=session_count,json=sessionCount,proto3" json:"session_count,omitempty"`
	TombstoneCount uint32                 `protobuf:"varint,3,opt,name=tombstone_count,json=tombstoneCount,proto3" json:"tombstone_count,omitempty"`
	LocalPresent   bool                   `protobuf:"varint,4,opt,name=local_present,json=localPresent,proto3" json:"local_present,omitempty"`
	unknownFields  protoimpl.UnknownFields
	sizeCache      protoimpl.SizeCache
}

func (x *SnapshotBegin) Reset() {
	*x = SnapshotBegin{}
	mi := &file_broker_proto_msgTypes[20]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *SnapshotBegin) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*SnapshotBegin) ProtoMessage() {}

func (x *SnapshotBegin) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[20]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use SnapshotBegin.ProtoReflect.Descriptor instead.
func (*SnapshotBegin) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{20}
}

func (x *SnapshotBegin) GetHostCount() uint32 {
	if x != nil {
		return x.HostCount
	}
	return 0
}

func (x *SnapshotBegin) GetSessionCount() uint32 {
	if x != nil {
		return x.SessionCount
	}
	return 0
}

func (x *SnapshotBegin) GetTombstoneCount() uint32 {
	if x != nil {
		return x.TombstoneCount
	}
	return 0
}

func (x *SnapshotBegin) GetLocalPresent() bool {
	if x != nil {
		return x.LocalPresent
	}
	return false
}

// SnapshotDaemon is one daemon projection (ports.BrokerDaemonObservation),
// local or remote. Configured authority (endpoint, registration, policy,
// display origin, rank) stays separate from observed state (identity,
// incarnation, version, capabilities, availability, failure, freshness),
// and observation never invents unknown values. registration is absent for
// the local daemon; policy is always present. Sessions travel as separate
// SnapshotSession parts.
type SnapshotDaemon struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	HostIndex     uint32                 `protobuf:"varint,1,opt,name=host_index,json=hostIndex,proto3" json:"host_index,omitempty"`
	Local         bool                   `protobuf:"varint,2,opt,name=local,proto3" json:"local,omitempty"`
	Endpoint      string                 `protobuf:"bytes,3,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	DisplayOrigin string                 `protobuf:"bytes,4,opt,name=display_origin,json=displayOrigin,proto3" json:"display_origin,omitempty"`
	Rank          uint32                 `protobuf:"varint,5,opt,name=rank,proto3" json:"rank,omitempty"`
	Registration  *RemoteRegistration    `protobuf:"bytes,6,opt,name=registration,proto3" json:"registration,omitempty"`
	Policy        *BrokerWirePolicy      `protobuf:"bytes,7,opt,name=policy,proto3" json:"policy,omitempty"`
	// Authenticated daemon identity; empty until observed.
	DaemonIdentity string `protobuf:"bytes,8,opt,name=daemon_identity,json=daemonIdentity,proto3" json:"daemon_identity,omitempty"`
	// Daemon process incarnation; exactly 16 bytes when an identity is
	// present and absent otherwise.
	DaemonIncarnation []byte `protobuf:"bytes,9,opt,name=daemon_incarnation,json=daemonIncarnation,proto3" json:"daemon_incarnation,omitempty"`
	// Observed daemon protocol version; 0 = unobserved.
	ProtocolVersion uint32 `protobuf:"varint,10,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
	// Observed capability bitmask (mirrors protocol.Capability* bits).
	Capabilities uint32 `protobuf:"varint,11,opt,name=capabilities,proto3" json:"capabilities,omitempty"`
	// Closed availability taxonomy (domain.RemoteAvailability); 0 is
	// invalid, an unobserved daemon carries RemoteAvailabilityUnknown.
	Availability        uint32           `protobuf:"varint,12,opt,name=availability,proto3" json:"availability,omitempty"`
	Checking            bool             `protobuf:"varint,13,opt,name=checking,proto3" json:"checking,omitempty"`
	LastAttempt         *BrokerTimestamp `protobuf:"bytes,14,opt,name=last_attempt,json=lastAttempt,proto3" json:"last_attempt,omitempty"`
	LastSuccess         *BrokerTimestamp `protobuf:"bytes,15,opt,name=last_success,json=lastSuccess,proto3" json:"last_success,omitempty"`
	NextDue             *BrokerTimestamp `protobuf:"bytes,16,opt,name=next_due,json=nextDue,proto3" json:"next_due,omitempty"`
	ConsecutiveFailures uint64           `protobuf:"varint,17,opt,name=consecutive_failures,json=consecutiveFailures,proto3" json:"consecutive_failures,omitempty"`
	FailureEpisode      uint64           `protobuf:"varint,18,opt,name=failure_episode,json=failureEpisode,proto3" json:"failure_episode,omitempty"`
	// Closed cause taxonomy (domain.RemoteFailureKind); 0 = none.
	FailureKind    uint32 `protobuf:"varint,19,opt,name=failure_kind,json=failureKind,proto3" json:"failure_kind,omitempty"`
	InventoryKnown bool   `protobuf:"varint,20,opt,name=inventory_known,json=inventoryKnown,proto3" json:"inventory_known,omitempty"`
	SessionCount   uint32 `protobuf:"varint,21,opt,name=session_count,json=sessionCount,proto3" json:"session_count,omitempty"`
	unknownFields  protoimpl.UnknownFields
	sizeCache      protoimpl.SizeCache
}

func (x *SnapshotDaemon) Reset() {
	*x = SnapshotDaemon{}
	mi := &file_broker_proto_msgTypes[21]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *SnapshotDaemon) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*SnapshotDaemon) ProtoMessage() {}

func (x *SnapshotDaemon) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[21]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use SnapshotDaemon.ProtoReflect.Descriptor instead.
func (*SnapshotDaemon) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{21}
}

func (x *SnapshotDaemon) GetHostIndex() uint32 {
	if x != nil {
		return x.HostIndex
	}
	return 0
}

func (x *SnapshotDaemon) GetLocal() bool {
	if x != nil {
		return x.Local
	}
	return false
}

func (x *SnapshotDaemon) GetEndpoint() string {
	if x != nil {
		return x.Endpoint
	}
	return ""
}

func (x *SnapshotDaemon) GetDisplayOrigin() string {
	if x != nil {
		return x.DisplayOrigin
	}
	return ""
}

func (x *SnapshotDaemon) GetRank() uint32 {
	if x != nil {
		return x.Rank
	}
	return 0
}

func (x *SnapshotDaemon) GetRegistration() *RemoteRegistration {
	if x != nil {
		return x.Registration
	}
	return nil
}

func (x *SnapshotDaemon) GetPolicy() *BrokerWirePolicy {
	if x != nil {
		return x.Policy
	}
	return nil
}

func (x *SnapshotDaemon) GetDaemonIdentity() string {
	if x != nil {
		return x.DaemonIdentity
	}
	return ""
}

func (x *SnapshotDaemon) GetDaemonIncarnation() []byte {
	if x != nil {
		return x.DaemonIncarnation
	}
	return nil
}

func (x *SnapshotDaemon) GetProtocolVersion() uint32 {
	if x != nil {
		return x.ProtocolVersion
	}
	return 0
}

func (x *SnapshotDaemon) GetCapabilities() uint32 {
	if x != nil {
		return x.Capabilities
	}
	return 0
}

func (x *SnapshotDaemon) GetAvailability() uint32 {
	if x != nil {
		return x.Availability
	}
	return 0
}

func (x *SnapshotDaemon) GetChecking() bool {
	if x != nil {
		return x.Checking
	}
	return false
}

func (x *SnapshotDaemon) GetLastAttempt() *BrokerTimestamp {
	if x != nil {
		return x.LastAttempt
	}
	return nil
}

func (x *SnapshotDaemon) GetLastSuccess() *BrokerTimestamp {
	if x != nil {
		return x.LastSuccess
	}
	return nil
}

func (x *SnapshotDaemon) GetNextDue() *BrokerTimestamp {
	if x != nil {
		return x.NextDue
	}
	return nil
}

func (x *SnapshotDaemon) GetConsecutiveFailures() uint64 {
	if x != nil {
		return x.ConsecutiveFailures
	}
	return 0
}

func (x *SnapshotDaemon) GetFailureEpisode() uint64 {
	if x != nil {
		return x.FailureEpisode
	}
	return 0
}

func (x *SnapshotDaemon) GetFailureKind() uint32 {
	if x != nil {
		return x.FailureKind
	}
	return 0
}

func (x *SnapshotDaemon) GetInventoryKnown() bool {
	if x != nil {
		return x.InventoryKnown
	}
	return false
}

func (x *SnapshotDaemon) GetSessionCount() uint32 {
	if x != nil {
		return x.SessionCount
	}
	return 0
}

// SnapshotSession is one catalogue session bound to its daemon by index.
// local marks a session of the local daemon; its host_index is then exactly
// 0 and follows the local daemon part rather than a remote host index.
type SnapshotSession struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	HostIndex     uint32                 `protobuf:"varint,1,opt,name=host_index,json=hostIndex,proto3" json:"host_index,omitempty"`
	SessionIndex  uint32                 `protobuf:"varint,2,opt,name=session_index,json=sessionIndex,proto3" json:"session_index,omitempty"`
	Session       *BrokerCatalogSession  `protobuf:"bytes,3,opt,name=session,proto3" json:"session,omitempty"`
	Local         bool                   `protobuf:"varint,4,opt,name=local,proto3" json:"local,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *SnapshotSession) Reset() {
	*x = SnapshotSession{}
	mi := &file_broker_proto_msgTypes[22]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *SnapshotSession) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*SnapshotSession) ProtoMessage() {}

func (x *SnapshotSession) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[22]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use SnapshotSession.ProtoReflect.Descriptor instead.
func (*SnapshotSession) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{22}
}

func (x *SnapshotSession) GetHostIndex() uint32 {
	if x != nil {
		return x.HostIndex
	}
	return 0
}

func (x *SnapshotSession) GetSessionIndex() uint32 {
	if x != nil {
		return x.SessionIndex
	}
	return 0
}

func (x *SnapshotSession) GetSession() *BrokerCatalogSession {
	if x != nil {
		return x.Session
	}
	return nil
}

func (x *SnapshotSession) GetLocal() bool {
	if x != nil {
		return x.Local
	}
	return false
}

// SnapshotTombstone fences one retired host registration so a stale probe
// cannot revive authority for that exact incarnation.
type SnapshotTombstone struct {
	state           protoimpl.MessageState `protogen:"open.v1"`
	TombstoneIndex  uint32                 `protobuf:"varint,1,opt,name=tombstone_index,json=tombstoneIndex,proto3" json:"tombstone_index,omitempty"`
	Registration    *RemoteRegistration    `protobuf:"bytes,2,opt,name=registration,proto3" json:"registration,omitempty"`
	RetiredRevision uint64                 `protobuf:"varint,3,opt,name=retired_revision,json=retiredRevision,proto3" json:"retired_revision,omitempty"`
	unknownFields   protoimpl.UnknownFields
	sizeCache       protoimpl.SizeCache
}

func (x *SnapshotTombstone) Reset() {
	*x = SnapshotTombstone{}
	mi := &file_broker_proto_msgTypes[23]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *SnapshotTombstone) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*SnapshotTombstone) ProtoMessage() {}

func (x *SnapshotTombstone) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[23]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use SnapshotTombstone.ProtoReflect.Descriptor instead.
func (*SnapshotTombstone) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{23}
}

func (x *SnapshotTombstone) GetTombstoneIndex() uint32 {
	if x != nil {
		return x.TombstoneIndex
	}
	return 0
}

func (x *SnapshotTombstone) GetRegistration() *RemoteRegistration {
	if x != nil {
		return x.Registration
	}
	return nil
}

func (x *SnapshotTombstone) GetRetiredRevision() uint64 {
	if x != nil {
		return x.RetiredRevision
	}
	return 0
}

// SnapshotEnd closes a snapshot publication.
type SnapshotEnd struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *SnapshotEnd) Reset() {
	*x = SnapshotEnd{}
	mi := &file_broker_proto_msgTypes[24]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *SnapshotEnd) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*SnapshotEnd) ProtoMessage() {}

func (x *SnapshotEnd) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[24]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use SnapshotEnd.ProtoReflect.Descriptor instead.
func (*SnapshotEnd) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{24}
}

// OperationResult is exactly one completion for one admitted mutating
// operation. removed and registration are presence-carrying authority:
// an authoritative success carries the resulting registration, a removal
// success carries none, and a failed or outcome-unknown result carries
// neither removal nor registration, only its typed error.
type OperationResult struct {
	state       protoimpl.MessageState `protogen:"open.v1"`
	Scope       *BrokerScope           `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	OperationId []byte                 `protobuf:"bytes,2,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"` // exactly 16 bytes
	// Closed taxonomy: 1 = ok, 2 = failed, 3 = outcome_unknown.
	Outcome       uint32              `protobuf:"varint,3,opt,name=outcome,proto3" json:"outcome,omitempty"`
	Removed       bool                `protobuf:"varint,4,opt,name=removed,proto3" json:"removed,omitempty"`
	Error         *BrokerErrorDetail  `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
	Registration  *RemoteRegistration `protobuf:"bytes,6,opt,name=registration,proto3" json:"registration,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *OperationResult) Reset() {
	*x = OperationResult{}
	mi := &file_broker_proto_msgTypes[25]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *OperationResult) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*OperationResult) ProtoMessage() {}

func (x *OperationResult) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[25]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use OperationResult.ProtoReflect.Descriptor instead.
func (*OperationResult) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{25}
}

func (x *OperationResult) GetScope() *BrokerScope {
	if x != nil {
		return x.Scope
	}
	return nil
}

func (x *OperationResult) GetOperationId() []byte {
	if x != nil {
		return x.OperationId
	}
	return nil
}

func (x *OperationResult) GetOutcome() uint32 {
	if x != nil {
		return x.Outcome
	}
	return 0
}

func (x *OperationResult) GetRemoved() bool {
	if x != nil {
		return x.Removed
	}
	return false
}

func (x *OperationResult) GetError() *BrokerErrorDetail {
	if x != nil {
		return x.Error
	}
	return nil
}

func (x *OperationResult) GetRegistration() *RemoteRegistration {
	if x != nil {
		return x.Registration
	}
	return nil
}

// StreamOpened confirms one logical stream is established.
type StreamOpened struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Ref           *BrokerStreamRef       `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *StreamOpened) Reset() {
	*x = StreamOpened{}
	mi := &file_broker_proto_msgTypes[26]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *StreamOpened) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*StreamOpened) ProtoMessage() {}

func (x *StreamOpened) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[26]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use StreamOpened.ProtoReflect.Descriptor instead.
func (*StreamOpened) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{26}
}

func (x *StreamOpened) GetRef() *BrokerStreamRef {
	if x != nil {
		return x.Ref
	}
	return nil
}

// ServerStreamData carries one opaque daemon-to-client stream frame.
type ServerStreamData struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Ref           *BrokerStreamRef       `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	Data          []byte                 `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *ServerStreamData) Reset() {
	*x = ServerStreamData{}
	mi := &file_broker_proto_msgTypes[27]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *ServerStreamData) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*ServerStreamData) ProtoMessage() {}

func (x *ServerStreamData) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[27]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use ServerStreamData.ProtoReflect.Descriptor instead.
func (*ServerStreamData) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{27}
}

func (x *ServerStreamData) GetRef() *BrokerStreamRef {
	if x != nil {
		return x.Ref
	}
	return nil
}

func (x *ServerStreamData) GetData() []byte {
	if x != nil {
		return x.Data
	}
	return nil
}

// StreamClosed ends one logical stream. An unset error is an orderly close;
// a set error reports the typed failure that ended it.
type StreamClosed struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Ref           *BrokerStreamRef       `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	Error         *BrokerErrorDetail     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *StreamClosed) Reset() {
	*x = StreamClosed{}
	mi := &file_broker_proto_msgTypes[28]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *StreamClosed) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*StreamClosed) ProtoMessage() {}

func (x *StreamClosed) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[28]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use StreamClosed.ProtoReflect.Descriptor instead.
func (*StreamClosed) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{28}
}

func (x *StreamClosed) GetRef() *BrokerStreamRef {
	if x != nil {
		return x.Ref
	}
	return nil
}

func (x *StreamClosed) GetError() *BrokerErrorDetail {
	if x != nil {
		return x.Error
	}
	return nil
}

// Progress reports one phase of a long-running broker operation.
type Progress struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Ref           *BrokerStreamRef       `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	Phase         uint32                 `protobuf:"varint,2,opt,name=phase,proto3" json:"phase,omitempty"`
	Text          string                 `protobuf:"bytes,3,opt,name=text,proto3" json:"text,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *Progress) Reset() {
	*x = Progress{}
	mi := &file_broker_proto_msgTypes[29]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *Progress) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*Progress) ProtoMessage() {}

func (x *Progress) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[29]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use Progress.ProtoReflect.Descriptor instead.
func (*Progress) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{29}
}

func (x *Progress) GetRef() *BrokerStreamRef {
	if x != nil {
		return x.Ref
	}
	return nil
}

func (x *Progress) GetPhase() uint32 {
	if x != nil {
		return x.Phase
	}
	return 0
}

func (x *Progress) GetText() string {
	if x != nil {
		return x.Text
	}
	return ""
}

// BrokerErrorMessage reports a broker-wide typed failure for one scope.
type BrokerErrorMessage struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Scope         *BrokerScope           `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	Error         *BrokerErrorDetail     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *BrokerErrorMessage) Reset() {
	*x = BrokerErrorMessage{}
	mi := &file_broker_proto_msgTypes[30]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *BrokerErrorMessage) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*BrokerErrorMessage) ProtoMessage() {}

func (x *BrokerErrorMessage) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[30]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use BrokerErrorMessage.ProtoReflect.Descriptor instead.
func (*BrokerErrorMessage) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{30}
}

func (x *BrokerErrorMessage) GetScope() *BrokerScope {
	if x != nil {
		return x.Scope
	}
	return nil
}

func (x *BrokerErrorMessage) GetError() *BrokerErrorDetail {
	if x != nil {
		return x.Error
	}
	return nil
}

// Shutdown reports the broker process is stopping.
type Shutdown struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	Scope *BrokerScope           `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	// Closed reason taxonomy; 0 is the zero value.
	Reason        uint32 `protobuf:"varint,2,opt,name=reason,proto3" json:"reason,omitempty"`
	Text          string `protobuf:"bytes,3,opt,name=text,proto3" json:"text,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *Shutdown) Reset() {
	*x = Shutdown{}
	mi := &file_broker_proto_msgTypes[31]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *Shutdown) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*Shutdown) ProtoMessage() {}

func (x *Shutdown) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[31]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use Shutdown.ProtoReflect.Descriptor instead.
func (*Shutdown) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{31}
}

func (x *Shutdown) GetScope() *BrokerScope {
	if x != nil {
		return x.Scope
	}
	return nil
}

func (x *Shutdown) GetReason() uint32 {
	if x != nil {
		return x.Reason
	}
	return 0
}

func (x *Shutdown) GetText() string {
	if x != nil {
		return x.Text
	}
	return ""
}

// PreviewRoute names the daemon a preview observes. The broker allocates the
// observation stream itself; endpoint and registration are present only for a
// remote route, and policy is always present.
type PreviewRoute struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Local         bool                   `protobuf:"varint,1,opt,name=local,proto3" json:"local,omitempty"`
	Endpoint      string                 `protobuf:"bytes,2,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Registration  *RemoteRegistration    `protobuf:"bytes,3,opt,name=registration,proto3" json:"registration,omitempty"`
	Policy        *BrokerWirePolicy      `protobuf:"bytes,4,opt,name=policy,proto3" json:"policy,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *PreviewRoute) Reset() {
	*x = PreviewRoute{}
	mi := &file_broker_proto_msgTypes[32]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *PreviewRoute) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*PreviewRoute) ProtoMessage() {}

func (x *PreviewRoute) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[32]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use PreviewRoute.ProtoReflect.Descriptor instead.
func (*PreviewRoute) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{32}
}

func (x *PreviewRoute) GetLocal() bool {
	if x != nil {
		return x.Local
	}
	return false
}

func (x *PreviewRoute) GetEndpoint() string {
	if x != nil {
		return x.Endpoint
	}
	return ""
}

func (x *PreviewRoute) GetRegistration() *RemoteRegistration {
	if x != nil {
		return x.Registration
	}
	return nil
}

func (x *PreviewRoute) GetPolicy() *BrokerWirePolicy {
	if x != nil {
		return x.Policy
	}
	return nil
}

// StartPreview starts or replaces one connection-scoped live preview.
// scope carries the broker epoch plus client connection; generation is the
// connection-scoped preview authority. route names the observed daemon and
// preview is the bounded viewport request sent to it. Repeated authority is
// scope/generation plus the preview target identity response.
type StartPreview struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Scope         *BrokerScope           `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	Generation    uint64                 `protobuf:"varint,2,opt,name=generation,proto3" json:"generation,omitempty"`
	Preview       *RemotePreviewRequest  `protobuf:"bytes,4,opt,name=preview,proto3" json:"preview,omitempty"`
	Route         *PreviewRoute          `protobuf:"bytes,5,opt,name=route,proto3" json:"route,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *StartPreview) Reset() {
	*x = StartPreview{}
	mi := &file_broker_proto_msgTypes[33]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *StartPreview) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*StartPreview) ProtoMessage() {}

func (x *StartPreview) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[33]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use StartPreview.ProtoReflect.Descriptor instead.
func (*StartPreview) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{33}
}

func (x *StartPreview) GetScope() *BrokerScope {
	if x != nil {
		return x.Scope
	}
	return nil
}

func (x *StartPreview) GetGeneration() uint64 {
	if x != nil {
		return x.Generation
	}
	return 0
}

func (x *StartPreview) GetPreview() *RemotePreviewRequest {
	if x != nil {
		return x.Preview
	}
	return nil
}

func (x *StartPreview) GetRoute() *PreviewRoute {
	if x != nil {
		return x.Route
	}
	return nil
}

// CancelPreview cancels one connection-scoped live preview.
type CancelPreview struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Scope         *BrokerScope           `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	Generation    uint64                 `protobuf:"varint,2,opt,name=generation,proto3" json:"generation,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *CancelPreview) Reset() {
	*x = CancelPreview{}
	mi := &file_broker_proto_msgTypes[34]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *CancelPreview) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*CancelPreview) ProtoMessage() {}

func (x *CancelPreview) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[34]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use CancelPreview.ProtoReflect.Descriptor instead.
func (*CancelPreview) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{34}
}

func (x *CancelPreview) GetScope() *BrokerScope {
	if x != nil {
		return x.Scope
	}
	return nil
}

func (x *CancelPreview) GetGeneration() uint64 {
	if x != nil {
		return x.Generation
	}
	return 0
}

// PreviewPublication is the newest result for one preview subscription.
// Exactly one of preview/error is set via the result oneof.
type PreviewPublication struct {
	state      protoimpl.MessageState `protogen:"open.v1"`
	Scope      *BrokerScope           `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	Generation uint64                 `protobuf:"varint,2,opt,name=generation,proto3" json:"generation,omitempty"`
	// Types that are valid to be assigned to Result:
	//
	//	*PreviewPublication_Preview
	//	*PreviewPublication_Error
	Result        isPreviewPublication_Result `protobuf_oneof:"result"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *PreviewPublication) Reset() {
	*x = PreviewPublication{}
	mi := &file_broker_proto_msgTypes[35]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *PreviewPublication) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*PreviewPublication) ProtoMessage() {}

func (x *PreviewPublication) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[35]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use PreviewPublication.ProtoReflect.Descriptor instead.
func (*PreviewPublication) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{35}
}

func (x *PreviewPublication) GetScope() *BrokerScope {
	if x != nil {
		return x.Scope
	}
	return nil
}

func (x *PreviewPublication) GetGeneration() uint64 {
	if x != nil {
		return x.Generation
	}
	return 0
}

func (x *PreviewPublication) GetResult() isPreviewPublication_Result {
	if x != nil {
		return x.Result
	}
	return nil
}

func (x *PreviewPublication) GetPreview() *RemotePreview {
	if x != nil {
		if x, ok := x.Result.(*PreviewPublication_Preview); ok {
			return x.Preview
		}
	}
	return nil
}

func (x *PreviewPublication) GetError() *BrokerErrorDetail {
	if x != nil {
		if x, ok := x.Result.(*PreviewPublication_Error); ok {
			return x.Error
		}
	}
	return nil
}

type isPreviewPublication_Result interface {
	isPreviewPublication_Result()
}

type PreviewPublication_Preview struct {
	Preview *RemotePreview `protobuf:"bytes,3,opt,name=preview,proto3,oneof"`
}

type PreviewPublication_Error struct {
	Error *BrokerErrorDetail `protobuf:"bytes,4,opt,name=error,proto3,oneof"`
}

func (*PreviewPublication_Preview) isPreviewPublication_Result() {}

func (*PreviewPublication_Error) isPreviewPublication_Result() {}

// BrokerCatalogSession mirrors catalogue.RemoteCatalogSession exactly: the
// lifecycle identity is a fixed 16-byte value, the state is a closed
// taxonomy, and the tab list keeps its presence separately from its
// length.
type BrokerCatalogSession struct {
	state       protoimpl.MessageState `protogen:"open.v1"`
	LifecycleId []byte                 `protobuf:"bytes,1,opt,name=lifecycle_id,json=lifecycleId,proto3" json:"lifecycle_id,omitempty"` // exactly 16 bytes
	Name        string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Closed taxonomy: 1 = up, 2 = down, 3 = broken.
	State         uint32              `protobuf:"varint,3,opt,name=state,proto3" json:"state,omitempty"`
	Ephemeral     bool                `protobuf:"varint,4,opt,name=ephemeral,proto3" json:"ephemeral,omitempty"`
	Tabs          []*BrokerCatalogTab `protobuf:"bytes,5,rep,name=tabs,proto3" json:"tabs,omitempty"`
	Attached      bool                `protobuf:"varint,6,opt,name=attached,proto3" json:"attached,omitempty"`
	LastUsedSeq   uint64              `protobuf:"varint,7,opt,name=last_used_seq,json=lastUsedSeq,proto3" json:"last_used_seq,omitempty"`
	ActiveTabId   string              `protobuf:"bytes,8,opt,name=active_tab_id,json=activeTabId,proto3" json:"active_tab_id,omitempty"`
	Reason        string              `protobuf:"bytes,9,opt,name=reason,proto3" json:"reason,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *BrokerCatalogSession) Reset() {
	*x = BrokerCatalogSession{}
	mi := &file_broker_proto_msgTypes[36]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *BrokerCatalogSession) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*BrokerCatalogSession) ProtoMessage() {}

func (x *BrokerCatalogSession) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[36]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use BrokerCatalogSession.ProtoReflect.Descriptor instead.
func (*BrokerCatalogSession) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{36}
}

func (x *BrokerCatalogSession) GetLifecycleId() []byte {
	if x != nil {
		return x.LifecycleId
	}
	return nil
}

func (x *BrokerCatalogSession) GetName() string {
	if x != nil {
		return x.Name
	}
	return ""
}

func (x *BrokerCatalogSession) GetState() uint32 {
	if x != nil {
		return x.State
	}
	return 0
}

func (x *BrokerCatalogSession) GetEphemeral() bool {
	if x != nil {
		return x.Ephemeral
	}
	return false
}

func (x *BrokerCatalogSession) GetTabs() []*BrokerCatalogTab {
	if x != nil {
		return x.Tabs
	}
	return nil
}

func (x *BrokerCatalogSession) GetAttached() bool {
	if x != nil {
		return x.Attached
	}
	return false
}

func (x *BrokerCatalogSession) GetLastUsedSeq() uint64 {
	if x != nil {
		return x.LastUsedSeq
	}
	return 0
}

func (x *BrokerCatalogSession) GetActiveTabId() string {
	if x != nil {
		return x.ActiveTabId
	}
	return ""
}

func (x *BrokerCatalogSession) GetReason() string {
	if x != nil {
		return x.Reason
	}
	return ""
}

// BrokerCatalogTab mirrors catalogue.RemoteCatalogTab exactly.
type BrokerCatalogTab struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Id            string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Index         uint32                 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	Name          string                 `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Detail        string                 `protobuf:"bytes,4,opt,name=detail,proto3" json:"detail,omitempty"`
	Attention     bool                   `protobuf:"varint,5,opt,name=attention,proto3" json:"attention,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *BrokerCatalogTab) Reset() {
	*x = BrokerCatalogTab{}
	mi := &file_broker_proto_msgTypes[37]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *BrokerCatalogTab) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*BrokerCatalogTab) ProtoMessage() {}

func (x *BrokerCatalogTab) ProtoReflect() protoreflect.Message {
	mi := &file_broker_proto_msgTypes[37]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use BrokerCatalogTab.ProtoReflect.Descriptor instead.
func (*BrokerCatalogTab) Descriptor() ([]byte, []int) {
	return file_broker_proto_rawDescGZIP(), []int{37}
}

func (x *BrokerCatalogTab) GetId() string {
	if x != nil {
		return x.Id
	}
	return ""
}

func (x *BrokerCatalogTab) GetIndex() uint32 {
	if x != nil {
		return x.Index
	}
	return 0
}

func (x *BrokerCatalogTab) GetName() string {
	if x != nil {
		return x.Name
	}
	return ""
}

func (x *BrokerCatalogTab) GetDetail() string {
	if x != nil {
		return x.Detail
	}
	return ""
}

func (x *BrokerCatalogTab) GetAttention() bool {
	if x != nil {
		return x.Attention
	}
	return false
}

var File_broker_proto protoreflect.FileDescriptor

const file_broker_proto_rawDesc = "" +
	"\n" +
	"\fbroker.proto\x12\vvev.wire.v1\x1a\fcommon.proto\x1a\x0eterminal.proto\"U\n" +
	"\vBrokerScope\x12!\n" +
	"\fbroker_epoch\x18\x01 \x01(\x04R\vbrokerEpoch\x12#\n" +
	"\rconnection_id\x18\x02 \x01(\fR\fconnectionId\"^\n" +
	"\x0fBrokerStreamRef\x12.\n" +
	"\x05scope\x18\x01 \x01(\v2\x18.vev.wire.v1.BrokerScopeR\x05scope\x12\x1b\n" +
	"\tstream_id\x18\x02 \x01(\x04R\bstreamId\"\x83\x02\n" +
	"\x10BrokerWirePolicy\x12)\n" +
	"\x10protocol_version\x18\x01 \x01(\rR\x0fprotocolVersion\x12+\n" +
	"\x11catalogue_version\x18\x02 \x01(\rR\x10catalogueVersion\x12-\n" +
	"\x12environment_policy\x18\x03 \x01(\rR\x11environmentPolicy\x12\x1c\n" +
	"\ttransport\x18\x04 \x01(\tR\ttransport\x12\x14\n" +
	"\x05trust\x18\x05 \x01(\tR\x05trust\x12\x16\n" +
	"\x06launch\x18\x06 \x01(\tR\x06launch\x12\x1c\n" +
	"\tisolation\x18\a \x01(\tR\tisolation\"\x85\x01\n" +
	"\x11BrokerErrorDetail\x12\x12\n" +
	"\x04code\x18\x01 \x01(\rR\x04code\x12\x12\n" +
	"\x04text\x18\x02 \x01(\tR\x04text\x12%\n" +
	"\x0eadmission_code\x18\x03 \x01(\rR\radmissionCode\x12!\n" +
	"\ffailure_kind\x18\x04 \x01(\rR\vfailureKind\"A\n" +
	"\x0fBrokerTimestamp\x12\x18\n" +
	"\aseconds\x18\x01 \x01(\x03R\aseconds\x12\x14\n" +
	"\x05nanos\x18\x02 \x01(\x05R\x05nanos\"\xc2\x06\n" +
	"\x14BrokerClientEnvelope\x123\n" +
	"\bregister\x18e \x01(\v2\x15.vev.wire.v1.RegisterH\x00R\bregister\x126\n" +
	"\tsubscribe\x18f \x01(\v2\x16.vev.wire.v1.SubscribeH\x00R\tsubscribe\x12-\n" +
	"\x06resync\x18g \x01(\v2\x13.vev.wire.v1.ResyncH\x00R\x06resync\x12<\n" +
	"\vunsubscribe\x18h \x01(\v2\x18.vev.wire.v1.UnsubscribeH\x00R\vunsubscribe\x121\n" +
	"\badd_host\x18i \x01(\v2\x14.vev.wire.v1.AddHostH\x00R\aaddHost\x12:\n" +
	"\vremove_host\x18j \x01(\v2\x17.vev.wire.v1.RemoveHostH\x00R\n" +
	"removeHost\x126\n" +
	"\treconcile\x18k \x01(\v2\x16.vev.wire.v1.ReconcileH\x00R\treconcile\x12:\n" +
	"\vopen_stream\x18l \x01(\v2\x17.vev.wire.v1.OpenStreamH\x00R\n" +
	"openStream\x12M\n" +
	"\x12client_stream_data\x18m \x01(\v2\x1d.vev.wire.v1.ClientStreamDataH\x00R\x10clientStreamData\x12=\n" +
	"\fclose_stream\x18n \x01(\v2\x18.vev.wire.v1.CloseStreamH\x00R\vcloseStream\x12M\n" +
	"\x12update_host_policy\x18o \x01(\v2\x1d.vev.wire.v1.UpdateHostPolicyH\x00R\x10updateHostPolicy\x12@\n" +
	"\rstart_preview\x18p \x01(\v2\x19.vev.wire.v1.StartPreviewH\x00R\fstartPreview\x12C\n" +
	"\x0ecancel_preview\x18q \x01(\v2\x1a.vev.wire.v1.CancelPreviewH\x00R\rcancelPreviewB\t\n" +
	"\apayload\"\xd9\x05\n" +
	"\x14BrokerServerEnvelope\x12:\n" +
	"\n" +
	"registered\x18\xc9\x01 \x01(\v2\x17.vev.wire.v1.RegisteredH\x00R\n" +
	"registered\x12A\n" +
	"\rsnapshot_part\x18\xca\x01 \x01(\v2\x19.vev.wire.v1.SnapshotPartH\x00R\fsnapshotPart\x12J\n" +
	"\x10operation_result\x18\xcb\x01 \x01(\v2\x1c.vev.wire.v1.OperationResultH\x00R\x0foperationResult\x12A\n" +
	"\rstream_opened\x18\xcc\x01 \x01(\v2\x19.vev.wire.v1.StreamOpenedH\x00R\fstreamOpened\x12N\n" +
	"\x12server_stream_data\x18\xcd\x01 \x01(\v2\x1d.vev.wire.v1.ServerStreamDataH\x00R\x10serverStreamData\x12A\n" +
	"\rstream_closed\x18\xce\x01 \x01(\v2\x19.vev.wire.v1.StreamClosedH\x00R\fstreamClosed\x124\n" +
	"\bprogress\x18\xcf\x01 \x01(\v2\x15.vev.wire.v1.ProgressH\x00R\bprogress\x12T\n" +
	"\x14broker_error_message\x18\xd0\x01 \x01(\v2\x1f.vev.wire.v1.BrokerErrorMessageH\x00R\x12brokerErrorMessage\x124\n" +
	"\bshutdown\x18\xd1\x01 \x01(\v2\x15.vev.wire.v1.ShutdownH\x00R\bshutdown\x12S\n" +
	"\x13preview_publication\x18\xd2\x01 \x01(\v2\x1f.vev.wire.v1.PreviewPublicationH\x00R\x12previewPublicationB\t\n" +
	"\apayload\" \n" +
	"\bRegister\x12\x14\n" +
	"\x05build\x18\x01 \x01(\tR\x05build\"u\n" +
	"\tSubscribe\x12.\n" +
	"\x05scope\x18\x01 \x01(\v2\x18.vev.wire.v1.BrokerScopeR\x05scope\x12\x1e\n" +
	"\n" +
	"generation\x18\x02 \x01(\x04R\n" +
	"generation\x12\x18\n" +
	"\apassive\x18\x03 \x01(\bR\apassive\"X\n" +
	"\x06Resync\x12.\n" +
	"\x05scope\x18\x01 \x01(\v2\x18.vev.wire.v1.BrokerScopeR\x05scope\x12\x1e\n" +
	"\n" +
	"generation\x18\x02 \x01(\x04R\n" +
	"generation\"]\n" +
	"\vUnsubscribe\x12.\n" +
	"\x05scope\x18\x01 \x01(\v2\x18.vev.wire.v1.BrokerScopeR\x05scope\x12\x1e\n" +
	"\n" +
	"generation\x18\x02 \x01(\x04R\n" +
	"generation\"\xaf\x01\n" +
	"\aAddHost\x12.\n" +
	"\x05scope\x18\x01 \x01(\v2\x18.vev.wire.v1.BrokerScopeR\x05scope\x12!\n" +
	"\foperation_id\x18\x02 \x01(\fR\voperationId\x12\x1a\n" +
	"\bendpoint\x18\x03 \x01(\tR\bendpoint\x125\n" +
	"\x06policy\x18\x04 \x01(\v2\x1d.vev.wire.v1.BrokerWirePolicyR\x06policy\"\xa4\x01\n" +
	"\n" +
	"RemoveHost\x12.\n" +
	"\x05scope\x18\x01 \x01(\v2\x18.vev.wire.v1.BrokerScopeR\x05scope\x12!\n" +
	"\foperation_id\x18\x02 \x01(\fR\voperationId\x12C\n" +
	"\fregistration\x18\x03 \x01(\v2\x1f.vev.wire.v1.RemoteRegistrationR\fregistration\"\xe1\x01\n" +
	"\x10UpdateHostPolicy\x12.\n" +
	"\x05scope\x18\x01 \x01(\v2\x18.vev.wire.v1.BrokerScopeR\x05scope\x12!\n" +
	"\foperation_id\x18\x02 \x01(\fR\voperationId\x12C\n" +
	"\fregistration\x18\x03 \x01(\v2\x1f.vev.wire.v1.RemoteRegistrationR\fregistration\x125\n" +
	"\x06policy\x18\x04 \x01(\v2\x1d.vev.wire.v1.BrokerWirePolicyR\x06policy\"\x80\x01\n" +
	"\tReconcile\x12.\n" +
	"\x05scope\x18\x01 \x01(\v2\x18.vev.wire.v1.BrokerScopeR\x05scope\x12C\n" +
	"\fregistration\x18\x02 \x01(\v2\x1f.vev.wire.v1.RemoteRegistrationR\fregistration\"\x99\x03\n" +
	"\n" +
	"OpenStream\x12.\n" +
	"\x03ref\x18\x01 \x01(\v2\x1c.vev.wire.v1.BrokerStreamRefR\x03ref\x12\x18\n" +
	"\apurpose\x18\x02 \x01(\rR\apurpose\x12\x14\n" +
	"\x05local\x18\x03 \x01(\bR\x05local\x12\x1a\n" +
	"\bendpoint\x18\x04 \x01(\tR\bendpoint\x12C\n" +
	"\fregistration\x18\x05 \x01(\v2\x1f.vev.wire.v1.RemoteRegistrationR\fregistration\x120\n" +
	"\x06target\x18\x06 \x01(\v2\x18.vev.wire.v1.ExactTargetR\x06target\x12\x10\n" +
	"\x03env\x18\a \x03(\tR\x03env\x125\n" +
	"\x06policy\x18\b \x01(\v2\x1d.vev.wire.v1.BrokerWirePolicyR\x06policy\x12\x1c\n" +
	"\tadmission\x18\t \x01(\rR\tadmission\x12\x12\n" +
	"\x04name\x18\n" +
	" \x01(\tR\x04name\x12\x1d\n" +
	"\n" +
	"start_mode\x18\v \x01(\rR\tstartMode\"V\n" +
	"\x10ClientStreamData\x12.\n" +
	"\x03ref\x18\x01 \x01(\v2\x1c.vev.wire.v1.BrokerStreamRefR\x03ref\x12\x12\n" +
	"\x04data\x18\x02 \x01(\fR\x04data\"=\n" +
	"\vCloseStream\x12.\n" +
	"\x03ref\x18\x01 \x01(\v2\x1c.vev.wire.v1.BrokerStreamRefR\x03ref\"n\n" +
	"\n" +
	"Registered\x12.\n" +
	"\x05scope\x18\x01 \x01(\v2\x18.vev.wire.v1.BrokerScopeR\x05scope\x12\x14\n" +
	"\x05build\x18\x02 \x01(\tR\x05build\x12\x1a\n" +
	"\bretiring\x18\x03 \x01(\bR\bretiring\"\xab\x03\n" +
	"\fSnapshotPart\x12.\n" +
	"\x05scope\x18\x01 \x01(\v2\x18.vev.wire.v1.BrokerScopeR\x05scope\x12\x1e\n" +
	"\n" +
	"generation\x18\x02 \x01(\x04R\n" +
	"generation\x12\x1a\n" +
	"\brevision\x18\x03 \x01(\x04R\brevision\x12\x14\n" +
	"\x05index\x18\x04 \x01(\rR\x05index\x122\n" +
	"\x05begin\x18\n" +
	" \x01(\v2\x1a.vev.wire.v1.SnapshotBeginH\x00R\x05begin\x125\n" +
	"\x06daemon\x18\x0f \x01(\v2\x1b.vev.wire.v1.SnapshotDaemonH\x00R\x06daemon\x128\n" +
	"\asession\x18\f \x01(\v2\x1c.vev.wire.v1.SnapshotSessionH\x00R\asession\x12>\n" +
	"\ttombstone\x18\r \x01(\v2\x1e.vev.wire.v1.SnapshotTombstoneH\x00R\ttombstone\x12,\n" +
	"\x03end\x18\x0e \x01(\v2\x18.vev.wire.v1.SnapshotEndH\x00R\x03endB\x06\n" +
	"\x04part\"\xa1\x01\n" +
	"\rSnapshotBegin\x12\x1d\n" +
	"\n" +
	"host_count\x18\x01 \x01(\rR\thostCount\x12#\n" +
	"\rsession_count\x18\x02 \x01(\rR\fsessionCount\x12'\n" +
	"\x0ftombstone_count\x18\x03 \x01(\rR\x0etombstoneCount\x12#\n" +
	"\rlocal_present\x18\x04 \x01(\bR\flocalPresent\"\x87\a\n" +
	"\x0eSnapshotDaemon\x12\x1d\n" +
	"\n" +
	"host_index\x18\x01 \x01(\rR\thostIndex\x12\x14\n" +
	"\x05local\x18\x02 \x01(\bR\x05local\x12\x1a\n" +
	"\bendpoint\x18\x03 \x01(\tR\bendpoint\x12%\n" +
	"\x0edisplay_origin\x18\x04 \x01(\tR\rdisplayOrigin\x12\x12\n" +
	"\x04rank\x18\x05 \x01(\rR\x04rank\x12C\n" +
	"\fregistration\x18\x06 \x01(\v2\x1f.vev.wire.v1.RemoteRegistrationR\fregistration\x125\n" +
	"\x06policy\x18\a \x01(\v2\x1d.vev.wire.v1.BrokerWirePolicyR\x06policy\x12'\n" +
	"\x0fdaemon_identity\x18\b \x01(\tR\x0edaemonIdentity\x12-\n" +
	"\x12daemon_incarnation\x18\t \x01(\fR\x11daemonIncarnation\x12)\n" +
	"\x10protocol_version\x18\n" +
	" \x01(\rR\x0fprotocolVersion\x12\"\n" +
	"\fcapabilities\x18\v \x01(\rR\fcapabilities\x12\"\n" +
	"\favailability\x18\f \x01(\rR\favailability\x12\x1a\n" +
	"\bchecking\x18\r \x01(\bR\bchecking\x12?\n" +
	"\flast_attempt\x18\x0e \x01(\v2\x1c.vev.wire.v1.BrokerTimestampR\vlastAttempt\x12?\n" +
	"\flast_success\x18\x0f \x01(\v2\x1c.vev.wire.v1.BrokerTimestampR\vlastSuccess\x127\n" +
	"\bnext_due\x18\x10 \x01(\v2\x1c.vev.wire.v1.BrokerTimestampR\anextDue\x121\n" +
	"\x14consecutive_failures\x18\x11 \x01(\x04R\x13consecutiveFailures\x12'\n" +
	"\x0ffailure_episode\x18\x12 \x01(\x04R\x0efailureEpisode\x12!\n" +
	"\ffailure_kind\x18\x13 \x01(\rR\vfailureKind\x12'\n" +
	"\x0finventory_known\x18\x14 \x01(\bR\x0einventoryKnown\x12#\n" +
	"\rsession_count\x18\x15 \x01(\rR\fsessionCount\"\xa8\x01\n" +
	"\x0fSnapshotSession\x12\x1d\n" +
	"\n" +
	"host_index\x18\x01 \x01(\rR\thostIndex\x12#\n" +
	"\rsession_index\x18\x02 \x01(\rR\fsessionIndex\x12;\n" +
	"\asession\x18\x03 \x01(\v2!.vev.wire.v1.BrokerCatalogSessionR\asession\x12\x14\n" +
	"\x05local\x18\x04 \x01(\bR\x05local\"\xac\x01\n" +
	"\x11SnapshotTombstone\x12'\n" +
	"\x0ftombstone_index\x18\x01 \x01(\rR\x0etombstoneIndex\x12C\n" +
	"\fregistration\x18\x02 \x01(\v2\x1f.vev.wire.v1.RemoteRegistrationR\fregistration\x12)\n" +
	"\x10retired_revision\x18\x03 \x01(\x04R\x0fretiredRevision\"\r\n" +
	"\vSnapshotEnd\"\x93\x02\n" +
	"\x0fOperationResult\x12.\n" +
	"\x05scope\x18\x01 \x01(\v2\x18.vev.wire.v1.BrokerScopeR\x05scope\x12!\n" +
	"\foperation_id\x18\x02 \x01(\fR\voperationId\x12\x18\n" +
	"\aoutcome\x18\x03 \x01(\rR\aoutcome\x12\x18\n" +
	"\aremoved\x18\x04 \x01(\bR\aremoved\x124\n" +
	"\x05error\x18\x05 \x01(\v2\x1e.vev.wire.v1.BrokerErrorDetailR\x05error\x12C\n" +
	"\fregistration\x18\x06 \x01(\v2\x1f.vev.wire.v1.RemoteRegistrationR\fregistration\">\n" +
	"\fStreamOpened\x12.\n" +
	"\x03ref\x18\x01 \x01(\v2\x1c.vev.wire.v1.BrokerStreamRefR\x03ref\"V\n" +
	"\x10ServerStreamData\x12.\n" +
	"\x03ref\x18\x01 \x01(\v2\x1c.vev.wire.v1.BrokerStreamRefR\x03ref\x12\x12\n" +
	"\x04data\x18\x02 \x01(\fR\x04data\"t\n" +
	"\fStreamClosed\x12.\n" +
	"\x03ref\x18\x01 \x01(\v2\x1c.vev.wire.v1.BrokerStreamRefR\x03ref\x124\n" +
	"\x05error\x18\x02 \x01(\v2\x1e.vev.wire.v1.BrokerErrorDetailR\x05error\"d\n" +
	"\bProgress\x12.\n" +
	"\x03ref\x18\x01 \x01(\v2\x1c.vev.wire.v1.BrokerStreamRefR\x03ref\x12\x14\n" +
	"\x05phase\x18\x02 \x01(\rR\x05phase\x12\x12\n" +
	"\x04text\x18\x03 \x01(\tR\x04text\"z\n" +
	"\x12BrokerErrorMessage\x12.\n" +
	"\x05scope\x18\x01 \x01(\v2\x18.vev.wire.v1.BrokerScopeR\x05scope\x124\n" +
	"\x05error\x18\x02 \x01(\v2\x1e.vev.wire.v1.BrokerErrorDetailR\x05error\"f\n" +
	"\bShutdown\x12.\n" +
	"\x05scope\x18\x01 \x01(\v2\x18.vev.wire.v1.BrokerScopeR\x05scope\x12\x16\n" +
	"\x06reason\x18\x02 \x01(\rR\x06reason\x12\x12\n" +
	"\x04text\x18\x03 \x01(\tR\x04text\"\xbc\x01\n" +
	"\fPreviewRoute\x12\x14\n" +
	"\x05local\x18\x01 \x01(\bR\x05local\x12\x1a\n" +
	"\bendpoint\x18\x02 \x01(\tR\bendpoint\x12C\n" +
	"\fregistration\x18\x03 \x01(\v2\x1f.vev.wire.v1.RemoteRegistrationR\fregistration\x125\n" +
	"\x06policy\x18\x04 \x01(\v2\x1d.vev.wire.v1.BrokerWirePolicyR\x06policy\"\xd2\x01\n" +
	"\fStartPreview\x12.\n" +
	"\x05scope\x18\x01 \x01(\v2\x18.vev.wire.v1.BrokerScopeR\x05scope\x12\x1e\n" +
	"\n" +
	"generation\x18\x02 \x01(\x04R\n" +
	"generation\x12;\n" +
	"\apreview\x18\x04 \x01(\v2!.vev.wire.v1.RemotePreviewRequestR\apreview\x12/\n" +
	"\x05route\x18\x05 \x01(\v2\x19.vev.wire.v1.PreviewRouteR\x05routeJ\x04\b\x03\x10\x04\"_\n" +
	"\rCancelPreview\x12.\n" +
	"\x05scope\x18\x01 \x01(\v2\x18.vev.wire.v1.BrokerScopeR\x05scope\x12\x1e\n" +
	"\n" +
	"generation\x18\x02 \x01(\x04R\n" +
	"generation\"\xde\x01\n" +
	"\x12PreviewPublication\x12.\n" +
	"\x05scope\x18\x01 \x01(\v2\x18.vev.wire.v1.BrokerScopeR\x05scope\x12\x1e\n" +
	"\n" +
	"generation\x18\x02 \x01(\x04R\n" +
	"generation\x126\n" +
	"\apreview\x18\x03 \x01(\v2\x1a.vev.wire.v1.RemotePreviewH\x00R\apreview\x126\n" +
	"\x05error\x18\x04 \x01(\v2\x1e.vev.wire.v1.BrokerErrorDetailH\x00R\x05errorB\b\n" +
	"\x06result\"\xb0\x02\n" +
	"\x14BrokerCatalogSession\x12!\n" +
	"\flifecycle_id\x18\x01 \x01(\fR\vlifecycleId\x12\x12\n" +
	"\x04name\x18\x02 \x01(\tR\x04name\x12\x14\n" +
	"\x05state\x18\x03 \x01(\rR\x05state\x12\x1c\n" +
	"\tephemeral\x18\x04 \x01(\bR\tephemeral\x121\n" +
	"\x04tabs\x18\x05 \x03(\v2\x1d.vev.wire.v1.BrokerCatalogTabR\x04tabs\x12\x1a\n" +
	"\battached\x18\x06 \x01(\bR\battached\x12\"\n" +
	"\rlast_used_seq\x18\a \x01(\x04R\vlastUsedSeq\x12\"\n" +
	"\ractive_tab_id\x18\b \x01(\tR\vactiveTabId\x12\x16\n" +
	"\x06reason\x18\t \x01(\tR\x06reason\"\x82\x01\n" +
	"\x10BrokerCatalogTab\x12\x0e\n" +
	"\x02id\x18\x01 \x01(\tR\x02id\x12\x14\n" +
	"\x05index\x18\x02 \x01(\rR\x05index\x12\x12\n" +
	"\x04name\x18\x03 \x01(\tR\x04name\x12\x16\n" +
	"\x06detail\x18\x04 \x01(\tR\x06detail\x12\x1c\n" +
	"\tattention\x18\x05 \x01(\bR\tattentionB-Z+github.com/bnema/vev/internal/protocol/wireb\x06proto3"

var (
	file_broker_proto_rawDescOnce sync.Once
	file_broker_proto_rawDescData []byte
)

func file_broker_proto_rawDescGZIP() []byte {
	file_broker_proto_rawDescOnce.Do(func() {
		file_broker_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_broker_proto_rawDesc), len(file_broker_proto_rawDesc)))
	})
	return file_broker_proto_rawDescData
}

var file_broker_proto_msgTypes = make([]protoimpl.MessageInfo, 38)
var file_broker_proto_goTypes = []any{
	(*BrokerScope)(nil),          // 0: vev.wire.v1.BrokerScope
	(*BrokerStreamRef)(nil),      // 1: vev.wire.v1.BrokerStreamRef
	(*BrokerWirePolicy)(nil),     // 2: vev.wire.v1.BrokerWirePolicy
	(*BrokerErrorDetail)(nil),    // 3: vev.wire.v1.BrokerErrorDetail
	(*BrokerTimestamp)(nil),      // 4: vev.wire.v1.BrokerTimestamp
	(*BrokerClientEnvelope)(nil), // 5: vev.wire.v1.BrokerClientEnvelope
	(*BrokerServerEnvelope)(nil), // 6: vev.wire.v1.BrokerServerEnvelope
	(*Register)(nil),             // 7: vev.wire.v1.Register
	(*Subscribe)(nil),            // 8: vev.wire.v1.Subscribe
	(*Resync)(nil),               // 9: vev.wire.v1.Resync
	(*Unsubscribe)(nil),          // 10: vev.wire.v1.Unsubscribe
	(*AddHost)(nil),              // 11: vev.wire.v1.AddHost
	(*RemoveHost)(nil),           // 12: vev.wire.v1.RemoveHost
	(*UpdateHostPolicy)(nil),     // 13: vev.wire.v1.UpdateHostPolicy
	(*Reconcile)(nil),            // 14: vev.wire.v1.Reconcile
	(*OpenStream)(nil),           // 15: vev.wire.v1.OpenStream
	(*ClientStreamData)(nil),     // 16: vev.wire.v1.ClientStreamData
	(*CloseStream)(nil),          // 17: vev.wire.v1.CloseStream
	(*Registered)(nil),           // 18: vev.wire.v1.Registered
	(*SnapshotPart)(nil),         // 19: vev.wire.v1.SnapshotPart
	(*SnapshotBegin)(nil),        // 20: vev.wire.v1.SnapshotBegin
	(*SnapshotDaemon)(nil),       // 21: vev.wire.v1.SnapshotDaemon
	(*SnapshotSession)(nil),      // 22: vev.wire.v1.SnapshotSession
	(*SnapshotTombstone)(nil),    // 23: vev.wire.v1.SnapshotTombstone
	(*SnapshotEnd)(nil),          // 24: vev.wire.v1.SnapshotEnd
	(*OperationResult)(nil),      // 25: vev.wire.v1.OperationResult
	(*StreamOpened)(nil),         // 26: vev.wire.v1.StreamOpened
	(*ServerStreamData)(nil),     // 27: vev.wire.v1.ServerStreamData
	(*StreamClosed)(nil),         // 28: vev.wire.v1.StreamClosed
	(*Progress)(nil),             // 29: vev.wire.v1.Progress
	(*BrokerErrorMessage)(nil),   // 30: vev.wire.v1.BrokerErrorMessage
	(*Shutdown)(nil),             // 31: vev.wire.v1.Shutdown
	(*PreviewRoute)(nil),         // 32: vev.wire.v1.PreviewRoute
	(*StartPreview)(nil),         // 33: vev.wire.v1.StartPreview
	(*CancelPreview)(nil),        // 34: vev.wire.v1.CancelPreview
	(*PreviewPublication)(nil),   // 35: vev.wire.v1.PreviewPublication
	(*BrokerCatalogSession)(nil), // 36: vev.wire.v1.BrokerCatalogSession
	(*BrokerCatalogTab)(nil),     // 37: vev.wire.v1.BrokerCatalogTab
	(*RemoteRegistration)(nil),   // 38: vev.wire.v1.RemoteRegistration
	(*ExactTarget)(nil),          // 39: vev.wire.v1.ExactTarget
	(*RemotePreviewRequest)(nil), // 40: vev.wire.v1.RemotePreviewRequest
	(*RemotePreview)(nil),        // 41: vev.wire.v1.RemotePreview
}
var file_broker_proto_depIdxs = []int32{
	0,  // 0: vev.wire.v1.BrokerStreamRef.scope:type_name -> vev.wire.v1.BrokerScope
	7,  // 1: vev.wire.v1.BrokerClientEnvelope.register:type_name -> vev.wire.v1.Register
	8,  // 2: vev.wire.v1.BrokerClientEnvelope.subscribe:type_name -> vev.wire.v1.Subscribe
	9,  // 3: vev.wire.v1.BrokerClientEnvelope.resync:type_name -> vev.wire.v1.Resync
	10, // 4: vev.wire.v1.BrokerClientEnvelope.unsubscribe:type_name -> vev.wire.v1.Unsubscribe
	11, // 5: vev.wire.v1.BrokerClientEnvelope.add_host:type_name -> vev.wire.v1.AddHost
	12, // 6: vev.wire.v1.BrokerClientEnvelope.remove_host:type_name -> vev.wire.v1.RemoveHost
	14, // 7: vev.wire.v1.BrokerClientEnvelope.reconcile:type_name -> vev.wire.v1.Reconcile
	15, // 8: vev.wire.v1.BrokerClientEnvelope.open_stream:type_name -> vev.wire.v1.OpenStream
	16, // 9: vev.wire.v1.BrokerClientEnvelope.client_stream_data:type_name -> vev.wire.v1.ClientStreamData
	17, // 10: vev.wire.v1.BrokerClientEnvelope.close_stream:type_name -> vev.wire.v1.CloseStream
	13, // 11: vev.wire.v1.BrokerClientEnvelope.update_host_policy:type_name -> vev.wire.v1.UpdateHostPolicy
	33, // 12: vev.wire.v1.BrokerClientEnvelope.start_preview:type_name -> vev.wire.v1.StartPreview
	34, // 13: vev.wire.v1.BrokerClientEnvelope.cancel_preview:type_name -> vev.wire.v1.CancelPreview
	18, // 14: vev.wire.v1.BrokerServerEnvelope.registered:type_name -> vev.wire.v1.Registered
	19, // 15: vev.wire.v1.BrokerServerEnvelope.snapshot_part:type_name -> vev.wire.v1.SnapshotPart
	25, // 16: vev.wire.v1.BrokerServerEnvelope.operation_result:type_name -> vev.wire.v1.OperationResult
	26, // 17: vev.wire.v1.BrokerServerEnvelope.stream_opened:type_name -> vev.wire.v1.StreamOpened
	27, // 18: vev.wire.v1.BrokerServerEnvelope.server_stream_data:type_name -> vev.wire.v1.ServerStreamData
	28, // 19: vev.wire.v1.BrokerServerEnvelope.stream_closed:type_name -> vev.wire.v1.StreamClosed
	29, // 20: vev.wire.v1.BrokerServerEnvelope.progress:type_name -> vev.wire.v1.Progress
	30, // 21: vev.wire.v1.BrokerServerEnvelope.broker_error_message:type_name -> vev.wire.v1.BrokerErrorMessage
	31, // 22: vev.wire.v1.BrokerServerEnvelope.shutdown:type_name -> vev.wire.v1.Shutdown
	35, // 23: vev.wire.v1.BrokerServerEnvelope.preview_publication:type_name -> vev.wire.v1.PreviewPublication
	0,  // 24: vev.wire.v1.Subscribe.scope:type_name -> vev.wire.v1.BrokerScope
	0,  // 25: vev.wire.v1.Resync.scope:type_name -> vev.wire.v1.BrokerScope
	0,  // 26: vev.wire.v1.Unsubscribe.scope:type_name -> vev.wire.v1.BrokerScope
	0,  // 27: vev.wire.v1.AddHost.scope:type_name -> vev.wire.v1.BrokerScope
	2,  // 28: vev.wire.v1.AddHost.policy:type_name -> vev.wire.v1.BrokerWirePolicy
	0,  // 29: vev.wire.v1.RemoveHost.scope:type_name -> vev.wire.v1.BrokerScope
	38, // 30: vev.wire.v1.RemoveHost.registration:type_name -> vev.wire.v1.RemoteRegistration
	0,  // 31: vev.wire.v1.UpdateHostPolicy.scope:type_name -> vev.wire.v1.BrokerScope
	38, // 32: vev.wire.v1.UpdateHostPolicy.registration:type_name -> vev.wire.v1.RemoteRegistration
	2,  // 33: vev.wire.v1.UpdateHostPolicy.policy:type_name -> vev.wire.v1.BrokerWirePolicy
	0,  // 34: vev.wire.v1.Reconcile.scope:type_name -> vev.wire.v1.BrokerScope
	38, // 35: vev.wire.v1.Reconcile.registration:type_name -> vev.wire.v1.RemoteRegistration
	1,  // 36: vev.wire.v1.OpenStream.ref:type_name -> vev.wire.v1.BrokerStreamRef
	38, // 37: vev.wire.v1.OpenStream.registration:type_name -> vev.wire.v1.RemoteRegistration
	39, // 38: vev.wire.v1.OpenStream.target:type_name -> vev.wire.v1.ExactTarget
	2,  // 39: vev.wire.v1.OpenStream.policy:type_name -> vev.wire.v1.BrokerWirePolicy
	1,  // 40: vev.wire.v1.ClientStreamData.ref:type_name -> vev.wire.v1.BrokerStreamRef
	1,  // 41: vev.wire.v1.CloseStream.ref:type_name -> vev.wire.v1.BrokerStreamRef
	0,  // 42: vev.wire.v1.Registered.scope:type_name -> vev.wire.v1.BrokerScope
	0,  // 43: vev.wire.v1.SnapshotPart.scope:type_name -> vev.wire.v1.BrokerScope
	20, // 44: vev.wire.v1.SnapshotPart.begin:type_name -> vev.wire.v1.SnapshotBegin
	21, // 45: vev.wire.v1.SnapshotPart.daemon:type_name -> vev.wire.v1.SnapshotDaemon
	22, // 46: vev.wire.v1.SnapshotPart.session:type_name -> vev.wire.v1.SnapshotSession
	23, // 47: vev.wire.v1.SnapshotPart.tombstone:type_name -> vev.wire.v1.SnapshotTombstone
	24, // 48: vev.wire.v1.SnapshotPart.end:type_name -> vev.wire.v1.SnapshotEnd
	38, // 49: vev.wire.v1.SnapshotDaemon.registration:type_name -> vev.wire.v1.RemoteRegistration
	2,  // 50: vev.wire.v1.SnapshotDaemon.policy:type_name -> vev.wire.v1.BrokerWirePolicy
	4,  // 51: vev.wire.v1.SnapshotDaemon.last_attempt:type_name -> vev.wire.v1.BrokerTimestamp
	4,  // 52: vev.wire.v1.SnapshotDaemon.last_success:type_name -> vev.wire.v1.BrokerTimestamp
	4,  // 53: vev.wire.v1.SnapshotDaemon.next_due:type_name -> vev.wire.v1.BrokerTimestamp
	36, // 54: vev.wire.v1.SnapshotSession.session:type_name -> vev.wire.v1.BrokerCatalogSession
	38, // 55: vev.wire.v1.SnapshotTombstone.registration:type_name -> vev.wire.v1.RemoteRegistration
	0,  // 56: vev.wire.v1.OperationResult.scope:type_name -> vev.wire.v1.BrokerScope
	3,  // 57: vev.wire.v1.OperationResult.error:type_name -> vev.wire.v1.BrokerErrorDetail
	38, // 58: vev.wire.v1.OperationResult.registration:type_name -> vev.wire.v1.RemoteRegistration
	1,  // 59: vev.wire.v1.StreamOpened.ref:type_name -> vev.wire.v1.BrokerStreamRef
	1,  // 60: vev.wire.v1.ServerStreamData.ref:type_name -> vev.wire.v1.BrokerStreamRef
	1,  // 61: vev.wire.v1.StreamClosed.ref:type_name -> vev.wire.v1.BrokerStreamRef
	3,  // 62: vev.wire.v1.StreamClosed.error:type_name -> vev.wire.v1.BrokerErrorDetail
	1,  // 63: vev.wire.v1.Progress.ref:type_name -> vev.wire.v1.BrokerStreamRef
	0,  // 64: vev.wire.v1.BrokerErrorMessage.scope:type_name -> vev.wire.v1.BrokerScope
	3,  // 65: vev.wire.v1.BrokerErrorMessage.error:type_name -> vev.wire.v1.BrokerErrorDetail
	0,  // 66: vev.wire.v1.Shutdown.scope:type_name -> vev.wire.v1.BrokerScope
	38, // 67: vev.wire.v1.PreviewRoute.registration:type_name -> vev.wire.v1.RemoteRegistration
	2,  // 68: vev.wire.v1.PreviewRoute.policy:type_name -> vev.wire.v1.BrokerWirePolicy
	0,  // 69: vev.wire.v1.StartPreview.scope:type_name -> vev.wire.v1.BrokerScope
	40, // 70: vev.wire.v1.StartPreview.preview:type_name -> vev.wire.v1.RemotePreviewRequest
	32, // 71: vev.wire.v1.StartPreview.route:type_name -> vev.wire.v1.PreviewRoute
	0,  // 72: vev.wire.v1.CancelPreview.scope:type_name -> vev.wire.v1.BrokerScope
	0,  // 73: vev.wire.v1.PreviewPublication.scope:type_name -> vev.wire.v1.BrokerScope
	41, // 74: vev.wire.v1.PreviewPublication.preview:type_name -> vev.wire.v1.RemotePreview
	3,  // 75: vev.wire.v1.PreviewPublication.error:type_name -> vev.wire.v1.BrokerErrorDetail
	37, // 76: vev.wire.v1.BrokerCatalogSession.tabs:type_name -> vev.wire.v1.BrokerCatalogTab
	77, // [77:77] is the sub-list for method output_type
	77, // [77:77] is the sub-list for method input_type
	77, // [77:77] is the sub-list for extension type_name
	77, // [77:77] is the sub-list for extension extendee
	0,  // [0:77] is the sub-list for field type_name
}

func init() { file_broker_proto_init() }
func file_broker_proto_init() {
	if File_broker_proto != nil {
		return
	}
	file_common_proto_init()
	file_terminal_proto_init()
	file_broker_proto_msgTypes[5].OneofWrappers = []any{
		(*BrokerClientEnvelope_Register)(nil),
		(*BrokerClientEnvelope_Subscribe)(nil),
		(*BrokerClientEnvelope_Resync)(nil),
		(*BrokerClientEnvelope_Unsubscribe)(nil),
		(*BrokerClientEnvelope_AddHost)(nil),
		(*BrokerClientEnvelope_RemoveHost)(nil),
		(*BrokerClientEnvelope_Reconcile)(nil),
		(*BrokerClientEnvelope_OpenStream)(nil),
		(*BrokerClientEnvelope_ClientStreamData)(nil),
		(*BrokerClientEnvelope_CloseStream)(nil),
		(*BrokerClientEnvelope_UpdateHostPolicy)(nil),
		(*BrokerClientEnvelope_StartPreview)(nil),
		(*BrokerClientEnvelope_CancelPreview)(nil),
	}
	file_broker_proto_msgTypes[6].OneofWrappers = []any{
		(*BrokerServerEnvelope_Registered)(nil),
		(*BrokerServerEnvelope_SnapshotPart)(nil),
		(*BrokerServerEnvelope_OperationResult)(nil),
		(*BrokerServerEnvelope_StreamOpened)(nil),
		(*BrokerServerEnvelope_ServerStreamData)(nil),
		(*BrokerServerEnvelope_StreamClosed)(nil),
		(*BrokerServerEnvelope_Progress)(nil),
		(*BrokerServerEnvelope_BrokerErrorMessage)(nil),
		(*BrokerServerEnvelope_Shutdown)(nil),
		(*BrokerServerEnvelope_PreviewPublication)(nil),
	}
	file_broker_proto_msgTypes[19].OneofWrappers = []any{
		(*SnapshotPart_Begin)(nil),
		(*SnapshotPart_Daemon)(nil),
		(*SnapshotPart_Session)(nil),
		(*SnapshotPart_Tombstone)(nil),
		(*SnapshotPart_End)(nil),
	}
	file_broker_proto_msgTypes[35].OneofWrappers = []any{
		(*PreviewPublication_Preview)(nil),
		(*PreviewPublication_Error)(nil),
	}
	type x struct{}
	out := protoimpl.TypeBuilder{
		File: protoimpl.DescBuilder{
			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
			RawDescriptor: unsafe.Slice(unsafe.StringData(file_broker_proto_rawDesc), len(file_broker_proto_rawDesc)),
			NumEnums:      0,
			NumMessages:   38,
			NumExtensions: 0,
			NumServices:   0,
		},
		GoTypes:           file_broker_proto_goTypes,
		DependencyIndexes: file_broker_proto_depIdxs,
		MessageInfos:      file_broker_proto_msgTypes,
	}.Build()
	File_broker_proto = out.File
	file_broker_proto_goTypes = nil
	file_broker_proto_depIdxs = nil
}