// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// 	protoc-gen-go v1.36.11
// 	protoc        v5.29.3
// source: proto/iop/agent.proto

package iop

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)
)

// AgentLocalKind identifies the semantic role of one local-control envelope.
type AgentLocalKind int32

const (
	AgentLocalKind_AGENT_LOCAL_KIND_UNSPECIFIED AgentLocalKind = 0
	AgentLocalKind_AGENT_LOCAL_KIND_REQUEST     AgentLocalKind = 1
	AgentLocalKind_AGENT_LOCAL_KIND_RESPONSE    AgentLocalKind = 2
	AgentLocalKind_AGENT_LOCAL_KIND_EVENT       AgentLocalKind = 3
	AgentLocalKind_AGENT_LOCAL_KIND_ERROR       AgentLocalKind = 4
)

// Enum value maps for AgentLocalKind.
var (
	AgentLocalKind_name = map[int32]string{
		0: "AGENT_LOCAL_KIND_UNSPECIFIED",
		1: "AGENT_LOCAL_KIND_REQUEST",
		2: "AGENT_LOCAL_KIND_RESPONSE",
		3: "AGENT_LOCAL_KIND_EVENT",
		4: "AGENT_LOCAL_KIND_ERROR",
	}
	AgentLocalKind_value = map[string]int32{
		"AGENT_LOCAL_KIND_UNSPECIFIED": 0,
		"AGENT_LOCAL_KIND_REQUEST":     1,
		"AGENT_LOCAL_KIND_RESPONSE":    2,
		"AGENT_LOCAL_KIND_EVENT":       3,
		"AGENT_LOCAL_KIND_ERROR":       4,
	}
)

func (x AgentLocalKind) Enum() *AgentLocalKind {
	p := new(AgentLocalKind)
	*p = x
	return p
}

func (x AgentLocalKind) String() string {
	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}

func (AgentLocalKind) Descriptor() protoreflect.EnumDescriptor {
	return file_proto_iop_agent_proto_enumTypes[0].Descriptor()
}

func (AgentLocalKind) Type() protoreflect.EnumType {
	return &file_proto_iop_agent_proto_enumTypes[0]
}

func (x AgentLocalKind) Number() protoreflect.EnumNumber {
	return protoreflect.EnumNumber(x)
}

// Deprecated: Use AgentLocalKind.Descriptor instead.
func (AgentLocalKind) EnumDescriptor() ([]byte, []int) {
	return file_proto_iop_agent_proto_rawDescGZIP(), []int{0}
}

// AgentLocalEnvelope is the only protobuf message carried by the local
// proto-socket. The explicit kind and typed payload must agree.
type AgentLocalEnvelope struct {
	state           protoimpl.MessageState `protogen:"open.v1"`
	ProtocolVersion uint32                 `protobuf:"varint,1,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
	Kind            AgentLocalKind         `protobuf:"varint,2,opt,name=kind,proto3,enum=iop.AgentLocalKind" json:"kind,omitempty"`
	MessageId       string                 `protobuf:"bytes,3,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	CorrelationId   string                 `protobuf:"bytes,4,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	EventSequence   uint64                 `protobuf:"varint,5,opt,name=event_sequence,json=eventSequence,proto3" json:"event_sequence,omitempty"`
	Operation       string                 `protobuf:"bytes,6,opt,name=operation,proto3" json:"operation,omitempty"`
	// Types that are valid to be assigned to Payload:
	//
	//	*AgentLocalEnvelope_Request
	//	*AgentLocalEnvelope_Response
	//	*AgentLocalEnvelope_Event
	//	*AgentLocalEnvelope_Error
	Payload       isAgentLocalEnvelope_Payload `protobuf_oneof:"payload"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*AgentLocalEnvelope) ProtoMessage() {}

func (x *AgentLocalEnvelope) ProtoReflect() protoreflect.Message {
	mi := &file_proto_iop_agent_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 AgentLocalEnvelope.ProtoReflect.Descriptor instead.
func (*AgentLocalEnvelope) Descriptor() ([]byte, []int) {
	return file_proto_iop_agent_proto_rawDescGZIP(), []int{0}
}

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

func (x *AgentLocalEnvelope) GetKind() AgentLocalKind {
	if x != nil {
		return x.Kind
	}
	return AgentLocalKind_AGENT_LOCAL_KIND_UNSPECIFIED
}

func (x *AgentLocalEnvelope) GetMessageId() string {
	if x != nil {
		return x.MessageId
	}
	return ""
}

func (x *AgentLocalEnvelope) GetCorrelationId() string {
	if x != nil {
		return x.CorrelationId
	}
	return ""
}

func (x *AgentLocalEnvelope) GetEventSequence() uint64 {
	if x != nil {
		return x.EventSequence
	}
	return 0
}

func (x *AgentLocalEnvelope) GetOperation() string {
	if x != nil {
		return x.Operation
	}
	return ""
}

func (x *AgentLocalEnvelope) GetPayload() isAgentLocalEnvelope_Payload {
	if x != nil {
		return x.Payload
	}
	return nil
}

func (x *AgentLocalEnvelope) GetRequest() *AgentLocalRequest {
	if x != nil {
		if x, ok := x.Payload.(*AgentLocalEnvelope_Request); ok {
			return x.Request
		}
	}
	return nil
}

func (x *AgentLocalEnvelope) GetResponse() *AgentLocalResponse {
	if x != nil {
		if x, ok := x.Payload.(*AgentLocalEnvelope_Response); ok {
			return x.Response
		}
	}
	return nil
}

func (x *AgentLocalEnvelope) GetEvent() *AgentLocalEvent {
	if x != nil {
		if x, ok := x.Payload.(*AgentLocalEnvelope_Event); ok {
			return x.Event
		}
	}
	return nil
}

func (x *AgentLocalEnvelope) GetError() *AgentLocalError {
	if x != nil {
		if x, ok := x.Payload.(*AgentLocalEnvelope_Error); ok {
			return x.Error
		}
	}
	return nil
}

type isAgentLocalEnvelope_Payload interface {
	isAgentLocalEnvelope_Payload()
}

type AgentLocalEnvelope_Request struct {
	Request *AgentLocalRequest `protobuf:"bytes,10,opt,name=request,proto3,oneof"`
}

type AgentLocalEnvelope_Response struct {
	Response *AgentLocalResponse `protobuf:"bytes,11,opt,name=response,proto3,oneof"`
}

type AgentLocalEnvelope_Event struct {
	Event *AgentLocalEvent `protobuf:"bytes,12,opt,name=event,proto3,oneof"`
}

type AgentLocalEnvelope_Error struct {
	Error *AgentLocalError `protobuf:"bytes,13,opt,name=error,proto3,oneof"`
}

func (*AgentLocalEnvelope_Request) isAgentLocalEnvelope_Payload() {}

func (*AgentLocalEnvelope_Response) isAgentLocalEnvelope_Payload() {}

func (*AgentLocalEnvelope_Event) isAgentLocalEnvelope_Payload() {}

func (*AgentLocalEnvelope_Error) isAgentLocalEnvelope_Payload() {}

// AgentLocalRequest contains exactly one typed operation payload. A replay
// cursor is optional and is meaningful only when replay_daemon_id is present.
type AgentLocalRequest struct {
	state               protoimpl.MessageState `protogen:"open.v1"`
	CommandId           string                 `protobuf:"bytes,1,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`
	ReplayDaemonId      string                 `protobuf:"bytes,2,opt,name=replay_daemon_id,json=replayDaemonId,proto3" json:"replay_daemon_id,omitempty"`
	ReplayAfterSequence *uint64                `protobuf:"varint,3,opt,name=replay_after_sequence,json=replayAfterSequence,proto3,oneof" json:"replay_after_sequence,omitempty"`
	// Types that are valid to be assigned to Payload:
	//
	//	*AgentLocalRequest_Read
	//	*AgentLocalRequest_Project
	//	*AgentLocalRequest_Client
	Payload       isAgentLocalRequest_Payload `protobuf_oneof:"payload"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*AgentLocalRequest) ProtoMessage() {}

func (x *AgentLocalRequest) ProtoReflect() protoreflect.Message {
	mi := &file_proto_iop_agent_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 AgentLocalRequest.ProtoReflect.Descriptor instead.
func (*AgentLocalRequest) Descriptor() ([]byte, []int) {
	return file_proto_iop_agent_proto_rawDescGZIP(), []int{1}
}

func (x *AgentLocalRequest) GetCommandId() string {
	if x != nil {
		return x.CommandId
	}
	return ""
}

func (x *AgentLocalRequest) GetReplayDaemonId() string {
	if x != nil {
		return x.ReplayDaemonId
	}
	return ""
}

func (x *AgentLocalRequest) GetReplayAfterSequence() uint64 {
	if x != nil && x.ReplayAfterSequence != nil {
		return *x.ReplayAfterSequence
	}
	return 0
}

func (x *AgentLocalRequest) GetPayload() isAgentLocalRequest_Payload {
	if x != nil {
		return x.Payload
	}
	return nil
}

func (x *AgentLocalRequest) GetRead() *AgentLocalReadRequest {
	if x != nil {
		if x, ok := x.Payload.(*AgentLocalRequest_Read); ok {
			return x.Read
		}
	}
	return nil
}

func (x *AgentLocalRequest) GetProject() *AgentLocalProjectRequest {
	if x != nil {
		if x, ok := x.Payload.(*AgentLocalRequest_Project); ok {
			return x.Project
		}
	}
	return nil
}

func (x *AgentLocalRequest) GetClient() *AgentLocalClientRequest {
	if x != nil {
		if x, ok := x.Payload.(*AgentLocalRequest_Client); ok {
			return x.Client
		}
	}
	return nil
}

type isAgentLocalRequest_Payload interface {
	isAgentLocalRequest_Payload()
}

type AgentLocalRequest_Read struct {
	Read *AgentLocalReadRequest `protobuf:"bytes,10,opt,name=read,proto3,oneof"`
}

type AgentLocalRequest_Project struct {
	Project *AgentLocalProjectRequest `protobuf:"bytes,11,opt,name=project,proto3,oneof"`
}

type AgentLocalRequest_Client struct {
	Client *AgentLocalClientRequest `protobuf:"bytes,12,opt,name=client,proto3,oneof"`
}

func (*AgentLocalRequest_Read) isAgentLocalRequest_Payload() {}

func (*AgentLocalRequest_Project) isAgentLocalRequest_Payload() {}

func (*AgentLocalRequest_Client) isAgentLocalRequest_Payload() {}

// AgentLocalReadRequest selects a safe host projection. Empty selectors are
// allowed only for runtime.status.
type AgentLocalReadRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	ProjectId     string                 `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	WorkUnitId    string                 `protobuf:"bytes,2,opt,name=work_unit_id,json=workUnitId,proto3" json:"work_unit_id,omitempty"`
	ClientKind    string                 `protobuf:"bytes,3,opt,name=client_kind,json=clientKind,proto3" json:"client_kind,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*AgentLocalReadRequest) ProtoMessage() {}

func (x *AgentLocalReadRequest) ProtoReflect() protoreflect.Message {
	mi := &file_proto_iop_agent_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 AgentLocalReadRequest.ProtoReflect.Descriptor instead.
func (*AgentLocalReadRequest) Descriptor() ([]byte, []int) {
	return file_proto_iop_agent_proto_rawDescGZIP(), []int{2}
}

func (x *AgentLocalReadRequest) GetProjectId() string {
	if x != nil {
		return x.ProjectId
	}
	return ""
}

func (x *AgentLocalReadRequest) GetWorkUnitId() string {
	if x != nil {
		return x.WorkUnitId
	}
	return ""
}

func (x *AgentLocalReadRequest) GetClientKind() string {
	if x != nil {
		return x.ClientKind
	}
	return ""
}

// AgentLocalProjectRequest carries immutable shared-runtime lifecycle inputs.
type AgentLocalProjectRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	ProjectId     string                 `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	WorkspaceId   string                 `protobuf:"bytes,2,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	MilestoneId   string                 `protobuf:"bytes,3,opt,name=milestone_id,json=milestoneId,proto3" json:"milestone_id,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*AgentLocalProjectRequest) ProtoMessage() {}

func (x *AgentLocalProjectRequest) ProtoReflect() protoreflect.Message {
	mi := &file_proto_iop_agent_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 AgentLocalProjectRequest.ProtoReflect.Descriptor instead.
func (*AgentLocalProjectRequest) Descriptor() ([]byte, []int) {
	return file_proto_iop_agent_proto_rawDescGZIP(), []int{3}
}

func (x *AgentLocalProjectRequest) GetProjectId() string {
	if x != nil {
		return x.ProjectId
	}
	return ""
}

func (x *AgentLocalProjectRequest) GetWorkspaceId() string {
	if x != nil {
		return x.WorkspaceId
	}
	return ""
}

func (x *AgentLocalProjectRequest) GetMilestoneId() string {
	if x != nil {
		return x.MilestoneId
	}
	return ""
}

// AgentLocalClientRequest reserves the typed S15 client-process input without
// enabling those operations in the S11 service.
type AgentLocalClientRequest struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	ClientKind    string                 `protobuf:"bytes,1,opt,name=client_kind,json=clientKind,proto3" json:"client_kind,omitempty"`
	Capability    string                 `protobuf:"bytes,2,opt,name=capability,proto3" json:"capability,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*AgentLocalClientRequest) ProtoMessage() {}

func (x *AgentLocalClientRequest) ProtoReflect() protoreflect.Message {
	mi := &file_proto_iop_agent_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 AgentLocalClientRequest.ProtoReflect.Descriptor instead.
func (*AgentLocalClientRequest) Descriptor() ([]byte, []int) {
	return file_proto_iop_agent_proto_rawDescGZIP(), []int{4}
}

func (x *AgentLocalClientRequest) GetClientKind() string {
	if x != nil {
		return x.ClientKind
	}
	return ""
}

func (x *AgentLocalClientRequest) GetCapability() string {
	if x != nil {
		return x.Capability
	}
	return ""
}

// AgentLocalResponse carries either a coherent snapshot or one accepted
// mutation result, plus any retained events requested by the replay cursor.
type AgentLocalResponse struct {
	state          protoimpl.MessageState `protogen:"open.v1"`
	CommandId      string                 `protobuf:"bytes,1,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`
	StateRevision  uint64                 `protobuf:"varint,2,opt,name=state_revision,json=stateRevision,proto3" json:"state_revision,omitempty"`
	SnapshotMarker string                 `protobuf:"bytes,3,opt,name=snapshot_marker,json=snapshotMarker,proto3" json:"snapshot_marker,omitempty"`
	ReplayDaemonId string                 `protobuf:"bytes,4,opt,name=replay_daemon_id,json=replayDaemonId,proto3" json:"replay_daemon_id,omitempty"`
	ReplayCursor   uint64                 `protobuf:"varint,5,opt,name=replay_cursor,json=replayCursor,proto3" json:"replay_cursor,omitempty"`
	// Types that are valid to be assigned to Payload:
	//
	//	*AgentLocalResponse_Snapshot
	//	*AgentLocalResponse_Mutation
	Payload       isAgentLocalResponse_Payload `protobuf_oneof:"payload"`
	ReplayEvents  []*AgentLocalEvent           `protobuf:"bytes,12,rep,name=replay_events,json=replayEvents,proto3" json:"replay_events,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*AgentLocalResponse) ProtoMessage() {}

func (x *AgentLocalResponse) ProtoReflect() protoreflect.Message {
	mi := &file_proto_iop_agent_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 AgentLocalResponse.ProtoReflect.Descriptor instead.
func (*AgentLocalResponse) Descriptor() ([]byte, []int) {
	return file_proto_iop_agent_proto_rawDescGZIP(), []int{5}
}

func (x *AgentLocalResponse) GetCommandId() string {
	if x != nil {
		return x.CommandId
	}
	return ""
}

func (x *AgentLocalResponse) GetStateRevision() uint64 {
	if x != nil {
		return x.StateRevision
	}
	return 0
}

func (x *AgentLocalResponse) GetSnapshotMarker() string {
	if x != nil {
		return x.SnapshotMarker
	}
	return ""
}

func (x *AgentLocalResponse) GetReplayDaemonId() string {
	if x != nil {
		return x.ReplayDaemonId
	}
	return ""
}

func (x *AgentLocalResponse) GetReplayCursor() uint64 {
	if x != nil {
		return x.ReplayCursor
	}
	return 0
}

func (x *AgentLocalResponse) GetPayload() isAgentLocalResponse_Payload {
	if x != nil {
		return x.Payload
	}
	return nil
}

func (x *AgentLocalResponse) GetSnapshot() *AgentLocalSnapshot {
	if x != nil {
		if x, ok := x.Payload.(*AgentLocalResponse_Snapshot); ok {
			return x.Snapshot
		}
	}
	return nil
}

func (x *AgentLocalResponse) GetMutation() *AgentLocalMutationResult {
	if x != nil {
		if x, ok := x.Payload.(*AgentLocalResponse_Mutation); ok {
			return x.Mutation
		}
	}
	return nil
}

func (x *AgentLocalResponse) GetReplayEvents() []*AgentLocalEvent {
	if x != nil {
		return x.ReplayEvents
	}
	return nil
}

type isAgentLocalResponse_Payload interface {
	isAgentLocalResponse_Payload()
}

type AgentLocalResponse_Snapshot struct {
	Snapshot *AgentLocalSnapshot `protobuf:"bytes,10,opt,name=snapshot,proto3,oneof"`
}

type AgentLocalResponse_Mutation struct {
	Mutation *AgentLocalMutationResult `protobuf:"bytes,11,opt,name=mutation,proto3,oneof"`
}

func (*AgentLocalResponse_Snapshot) isAgentLocalResponse_Payload() {}

func (*AgentLocalResponse_Mutation) isAgentLocalResponse_Payload() {}

// AgentLocalSnapshot is a client-neutral, path-free status projection.
type AgentLocalSnapshot struct {
	state         protoimpl.MessageState   `protogen:"open.v1"`
	DaemonId      string                   `protobuf:"bytes,1,opt,name=daemon_id,json=daemonId,proto3" json:"daemon_id,omitempty"`
	StateRevision uint64                   `protobuf:"varint,2,opt,name=state_revision,json=stateRevision,proto3" json:"state_revision,omitempty"`
	ReplayCursor  uint64                   `protobuf:"varint,3,opt,name=replay_cursor,json=replayCursor,proto3" json:"replay_cursor,omitempty"`
	SubjectId     string                   `protobuf:"bytes,4,opt,name=subject_id,json=subjectId,proto3" json:"subject_id,omitempty"`
	State         string                   `protobuf:"bytes,5,opt,name=state,proto3" json:"state,omitempty"`
	Summary       string                   `protobuf:"bytes,6,opt,name=summary,proto3" json:"summary,omitempty"`
	Entries       []*AgentLocalStatusEntry `protobuf:"bytes,7,rep,name=entries,proto3" json:"entries,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*AgentLocalSnapshot) ProtoMessage() {}

func (x *AgentLocalSnapshot) ProtoReflect() protoreflect.Message {
	mi := &file_proto_iop_agent_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 AgentLocalSnapshot.ProtoReflect.Descriptor instead.
func (*AgentLocalSnapshot) Descriptor() ([]byte, []int) {
	return file_proto_iop_agent_proto_rawDescGZIP(), []int{6}
}

func (x *AgentLocalSnapshot) GetDaemonId() string {
	if x != nil {
		return x.DaemonId
	}
	return ""
}

func (x *AgentLocalSnapshot) GetStateRevision() uint64 {
	if x != nil {
		return x.StateRevision
	}
	return 0
}

func (x *AgentLocalSnapshot) GetReplayCursor() uint64 {
	if x != nil {
		return x.ReplayCursor
	}
	return 0
}

func (x *AgentLocalSnapshot) GetSubjectId() string {
	if x != nil {
		return x.SubjectId
	}
	return ""
}

func (x *AgentLocalSnapshot) GetState() string {
	if x != nil {
		return x.State
	}
	return ""
}

func (x *AgentLocalSnapshot) GetSummary() string {
	if x != nil {
		return x.Summary
	}
	return ""
}

func (x *AgentLocalSnapshot) GetEntries() []*AgentLocalStatusEntry {
	if x != nil {
		return x.Entries
	}
	return nil
}

type AgentLocalStatusEntry struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Kind          string                 `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
	SubjectId     string                 `protobuf:"bytes,2,opt,name=subject_id,json=subjectId,proto3" json:"subject_id,omitempty"`
	State         string                 `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"`
	Summary       string                 `protobuf:"bytes,4,opt,name=summary,proto3" json:"summary,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*AgentLocalStatusEntry) ProtoMessage() {}

func (x *AgentLocalStatusEntry) ProtoReflect() protoreflect.Message {
	mi := &file_proto_iop_agent_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 AgentLocalStatusEntry.ProtoReflect.Descriptor instead.
func (*AgentLocalStatusEntry) Descriptor() ([]byte, []int) {
	return file_proto_iop_agent_proto_rawDescGZIP(), []int{7}
}

func (x *AgentLocalStatusEntry) GetKind() string {
	if x != nil {
		return x.Kind
	}
	return ""
}

func (x *AgentLocalStatusEntry) GetSubjectId() string {
	if x != nil {
		return x.SubjectId
	}
	return ""
}

func (x *AgentLocalStatusEntry) GetState() string {
	if x != nil {
		return x.State
	}
	return ""
}

func (x *AgentLocalStatusEntry) GetSummary() string {
	if x != nil {
		return x.Summary
	}
	return ""
}

type AgentLocalMutationResult struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Accepted      bool                   `protobuf:"varint,1,opt,name=accepted,proto3" json:"accepted,omitempty"`
	SubjectId     string                 `protobuf:"bytes,2,opt,name=subject_id,json=subjectId,proto3" json:"subject_id,omitempty"`
	State         string                 `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"`
	Summary       string                 `protobuf:"bytes,4,opt,name=summary,proto3" json:"summary,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*AgentLocalMutationResult) ProtoMessage() {}

func (x *AgentLocalMutationResult) ProtoReflect() protoreflect.Message {
	mi := &file_proto_iop_agent_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 AgentLocalMutationResult.ProtoReflect.Descriptor instead.
func (*AgentLocalMutationResult) Descriptor() ([]byte, []int) {
	return file_proto_iop_agent_proto_rawDescGZIP(), []int{8}
}

func (x *AgentLocalMutationResult) GetAccepted() bool {
	if x != nil {
		return x.Accepted
	}
	return false
}

func (x *AgentLocalMutationResult) GetSubjectId() string {
	if x != nil {
		return x.SubjectId
	}
	return ""
}

func (x *AgentLocalMutationResult) GetState() string {
	if x != nil {
		return x.State
	}
	return ""
}

func (x *AgentLocalMutationResult) GetSummary() string {
	if x != nil {
		return x.Summary
	}
	return ""
}

// AgentLocalEvent is retained in monotonically increasing sequence order.
type AgentLocalEvent struct {
	state         protoimpl.MessageState    `protogen:"open.v1"`
	EventSequence uint64                    `protobuf:"varint,1,opt,name=event_sequence,json=eventSequence,proto3" json:"event_sequence,omitempty"`
	EventType     string                    `protobuf:"bytes,2,opt,name=event_type,json=eventType,proto3" json:"event_type,omitempty"`
	SubjectId     string                    `protobuf:"bytes,3,opt,name=subject_id,json=subjectId,proto3" json:"subject_id,omitempty"`
	StateRevision uint64                    `protobuf:"varint,4,opt,name=state_revision,json=stateRevision,proto3" json:"state_revision,omitempty"`
	Mutation      *AgentLocalMutationResult `protobuf:"bytes,5,opt,name=mutation,proto3" json:"mutation,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

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

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

func (*AgentLocalEvent) ProtoMessage() {}

func (x *AgentLocalEvent) ProtoReflect() protoreflect.Message {
	mi := &file_proto_iop_agent_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 AgentLocalEvent.ProtoReflect.Descriptor instead.
func (*AgentLocalEvent) Descriptor() ([]byte, []int) {
	return file_proto_iop_agent_proto_rawDescGZIP(), []int{9}
}

func (x *AgentLocalEvent) GetEventSequence() uint64 {
	if x != nil {
		return x.EventSequence
	}
	return 0
}

func (x *AgentLocalEvent) GetEventType() string {
	if x != nil {
		return x.EventType
	}
	return ""
}

func (x *AgentLocalEvent) GetSubjectId() string {
	if x != nil {
		return x.SubjectId
	}
	return ""
}

func (x *AgentLocalEvent) GetStateRevision() uint64 {
	if x != nil {
		return x.StateRevision
	}
	return 0
}

func (x *AgentLocalEvent) GetMutation() *AgentLocalMutationResult {
	if x != nil {
		return x.Mutation
	}
	return nil
}

// AgentLocalError exposes only stable, bounded, path-free diagnostics.
type AgentLocalError struct {
	state            protoimpl.MessageState `protogen:"open.v1"`
	Code             string                 `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	SafeMessage      string                 `protobuf:"bytes,2,opt,name=safe_message,json=safeMessage,proto3" json:"safe_message,omitempty"`
	Retryable        bool                   `protobuf:"varint,3,opt,name=retryable,proto3" json:"retryable,omitempty"`
	CorrelationId    string                 `protobuf:"bytes,4,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	ReplayFloor      uint64                 `protobuf:"varint,5,opt,name=replay_floor,json=replayFloor,proto3" json:"replay_floor,omitempty"`
	SnapshotRequired bool                   `protobuf:"varint,6,opt,name=snapshot_required,json=snapshotRequired,proto3" json:"snapshot_required,omitempty"`
	SnapshotMarker   string                 `protobuf:"bytes,7,opt,name=snapshot_marker,json=snapshotMarker,proto3" json:"snapshot_marker,omitempty"`
	unknownFields    protoimpl.UnknownFields
	sizeCache        protoimpl.SizeCache
}

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

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

func (*AgentLocalError) ProtoMessage() {}

func (x *AgentLocalError) ProtoReflect() protoreflect.Message {
	mi := &file_proto_iop_agent_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 AgentLocalError.ProtoReflect.Descriptor instead.
func (*AgentLocalError) Descriptor() ([]byte, []int) {
	return file_proto_iop_agent_proto_rawDescGZIP(), []int{10}
}

func (x *AgentLocalError) GetCode() string {
	if x != nil {
		return x.Code
	}
	return ""
}

func (x *AgentLocalError) GetSafeMessage() string {
	if x != nil {
		return x.SafeMessage
	}
	return ""
}

func (x *AgentLocalError) GetRetryable() bool {
	if x != nil {
		return x.Retryable
	}
	return false
}

func (x *AgentLocalError) GetCorrelationId() string {
	if x != nil {
		return x.CorrelationId
	}
	return ""
}

func (x *AgentLocalError) GetReplayFloor() uint64 {
	if x != nil {
		return x.ReplayFloor
	}
	return 0
}

func (x *AgentLocalError) GetSnapshotRequired() bool {
	if x != nil {
		return x.SnapshotRequired
	}
	return false
}

func (x *AgentLocalError) GetSnapshotMarker() string {
	if x != nil {
		return x.SnapshotMarker
	}
	return ""
}

var File_proto_iop_agent_proto protoreflect.FileDescriptor

const file_proto_iop_agent_proto_rawDesc = "" +
	"\n" +
	"\x15proto/iop/agent.proto\x12\x03iop\"\xd1\x03\n" +
	"\x12AgentLocalEnvelope\x12)\n" +
	"\x10protocol_version\x18\x01 \x01(\rR\x0fprotocolVersion\x12'\n" +
	"\x04kind\x18\x02 \x01(\x0e2\x13.iop.AgentLocalKindR\x04kind\x12\x1d\n" +
	"\n" +
	"message_id\x18\x03 \x01(\tR\tmessageId\x12%\n" +
	"\x0ecorrelation_id\x18\x04 \x01(\tR\rcorrelationId\x12%\n" +
	"\x0eevent_sequence\x18\x05 \x01(\x04R\reventSequence\x12\x1c\n" +
	"\toperation\x18\x06 \x01(\tR\toperation\x122\n" +
	"\arequest\x18\n" +
	" \x01(\v2\x16.iop.AgentLocalRequestH\x00R\arequest\x125\n" +
	"\bresponse\x18\v \x01(\v2\x17.iop.AgentLocalResponseH\x00R\bresponse\x12,\n" +
	"\x05event\x18\f \x01(\v2\x14.iop.AgentLocalEventH\x00R\x05event\x12,\n" +
	"\x05error\x18\r \x01(\v2\x14.iop.AgentLocalErrorH\x00R\x05errorB\t\n" +
	"\apayloadJ\x04\b\a\x10\n" +
	"J\x04\b\x0e\x10\x14\"\xeb\x02\n" +
	"\x11AgentLocalRequest\x12\x1d\n" +
	"\n" +
	"command_id\x18\x01 \x01(\tR\tcommandId\x12(\n" +
	"\x10replay_daemon_id\x18\x02 \x01(\tR\x0ereplayDaemonId\x127\n" +
	"\x15replay_after_sequence\x18\x03 \x01(\x04H\x01R\x13replayAfterSequence\x88\x01\x01\x120\n" +
	"\x04read\x18\n" +
	" \x01(\v2\x1a.iop.AgentLocalReadRequestH\x00R\x04read\x129\n" +
	"\aproject\x18\v \x01(\v2\x1d.iop.AgentLocalProjectRequestH\x00R\aproject\x126\n" +
	"\x06client\x18\f \x01(\v2\x1c.iop.AgentLocalClientRequestH\x00R\x06clientB\t\n" +
	"\apayloadB\x18\n" +
	"\x16_replay_after_sequenceJ\x04\b\x04\x10\n" +
	"J\x04\b\r\x10\x14\"y\n" +
	"\x15AgentLocalReadRequest\x12\x1d\n" +
	"\n" +
	"project_id\x18\x01 \x01(\tR\tprojectId\x12 \n" +
	"\fwork_unit_id\x18\x02 \x01(\tR\n" +
	"workUnitId\x12\x1f\n" +
	"\vclient_kind\x18\x03 \x01(\tR\n" +
	"clientKind\"\x7f\n" +
	"\x18AgentLocalProjectRequest\x12\x1d\n" +
	"\n" +
	"project_id\x18\x01 \x01(\tR\tprojectId\x12!\n" +
	"\fworkspace_id\x18\x02 \x01(\tR\vworkspaceId\x12!\n" +
	"\fmilestone_id\x18\x03 \x01(\tR\vmilestoneId\"Z\n" +
	"\x17AgentLocalClientRequest\x12\x1f\n" +
	"\vclient_kind\x18\x01 \x01(\tR\n" +
	"clientKind\x12\x1e\n" +
	"\n" +
	"capability\x18\x02 \x01(\tR\n" +
	"capability\"\x98\x03\n" +
	"\x12AgentLocalResponse\x12\x1d\n" +
	"\n" +
	"command_id\x18\x01 \x01(\tR\tcommandId\x12%\n" +
	"\x0estate_revision\x18\x02 \x01(\x04R\rstateRevision\x12'\n" +
	"\x0fsnapshot_marker\x18\x03 \x01(\tR\x0esnapshotMarker\x12(\n" +
	"\x10replay_daemon_id\x18\x04 \x01(\tR\x0ereplayDaemonId\x12#\n" +
	"\rreplay_cursor\x18\x05 \x01(\x04R\freplayCursor\x125\n" +
	"\bsnapshot\x18\n" +
	" \x01(\v2\x17.iop.AgentLocalSnapshotH\x00R\bsnapshot\x12;\n" +
	"\bmutation\x18\v \x01(\v2\x1d.iop.AgentLocalMutationResultH\x00R\bmutation\x129\n" +
	"\rreplay_events\x18\f \x03(\v2\x14.iop.AgentLocalEventR\freplayEventsB\t\n" +
	"\apayloadJ\x04\b\x06\x10\n" +
	"J\x04\b\r\x10\x14\"\x82\x02\n" +
	"\x12AgentLocalSnapshot\x12\x1b\n" +
	"\tdaemon_id\x18\x01 \x01(\tR\bdaemonId\x12%\n" +
	"\x0estate_revision\x18\x02 \x01(\x04R\rstateRevision\x12#\n" +
	"\rreplay_cursor\x18\x03 \x01(\x04R\freplayCursor\x12\x1d\n" +
	"\n" +
	"subject_id\x18\x04 \x01(\tR\tsubjectId\x12\x14\n" +
	"\x05state\x18\x05 \x01(\tR\x05state\x12\x18\n" +
	"\asummary\x18\x06 \x01(\tR\asummary\x124\n" +
	"\aentries\x18\a \x03(\v2\x1a.iop.AgentLocalStatusEntryR\aentries\"z\n" +
	"\x15AgentLocalStatusEntry\x12\x12\n" +
	"\x04kind\x18\x01 \x01(\tR\x04kind\x12\x1d\n" +
	"\n" +
	"subject_id\x18\x02 \x01(\tR\tsubjectId\x12\x14\n" +
	"\x05state\x18\x03 \x01(\tR\x05state\x12\x18\n" +
	"\asummary\x18\x04 \x01(\tR\asummary\"\x85\x01\n" +
	"\x18AgentLocalMutationResult\x12\x1a\n" +
	"\baccepted\x18\x01 \x01(\bR\baccepted\x12\x1d\n" +
	"\n" +
	"subject_id\x18\x02 \x01(\tR\tsubjectId\x12\x14\n" +
	"\x05state\x18\x03 \x01(\tR\x05state\x12\x18\n" +
	"\asummary\x18\x04 \x01(\tR\asummary\"\xd8\x01\n" +
	"\x0fAgentLocalEvent\x12%\n" +
	"\x0eevent_sequence\x18\x01 \x01(\x04R\reventSequence\x12\x1d\n" +
	"\n" +
	"event_type\x18\x02 \x01(\tR\teventType\x12\x1d\n" +
	"\n" +
	"subject_id\x18\x03 \x01(\tR\tsubjectId\x12%\n" +
	"\x0estate_revision\x18\x04 \x01(\x04R\rstateRevision\x129\n" +
	"\bmutation\x18\x05 \x01(\v2\x1d.iop.AgentLocalMutationResultR\bmutation\"\x86\x02\n" +
	"\x0fAgentLocalError\x12\x12\n" +
	"\x04code\x18\x01 \x01(\tR\x04code\x12!\n" +
	"\fsafe_message\x18\x02 \x01(\tR\vsafeMessage\x12\x1c\n" +
	"\tretryable\x18\x03 \x01(\bR\tretryable\x12%\n" +
	"\x0ecorrelation_id\x18\x04 \x01(\tR\rcorrelationId\x12!\n" +
	"\freplay_floor\x18\x05 \x01(\x04R\vreplayFloor\x12+\n" +
	"\x11snapshot_required\x18\x06 \x01(\bR\x10snapshotRequired\x12'\n" +
	"\x0fsnapshot_marker\x18\a \x01(\tR\x0esnapshotMarker*\xa7\x01\n" +
	"\x0eAgentLocalKind\x12 \n" +
	"\x1cAGENT_LOCAL_KIND_UNSPECIFIED\x10\x00\x12\x1c\n" +
	"\x18AGENT_LOCAL_KIND_REQUEST\x10\x01\x12\x1d\n" +
	"\x19AGENT_LOCAL_KIND_RESPONSE\x10\x02\x12\x1a\n" +
	"\x16AGENT_LOCAL_KIND_EVENT\x10\x03\x12\x1a\n" +
	"\x16AGENT_LOCAL_KIND_ERROR\x10\x04B\x13Z\x11iop/proto/gen/iopb\x06proto3"

var (
	file_proto_iop_agent_proto_rawDescOnce sync.Once
	file_proto_iop_agent_proto_rawDescData []byte
)

func file_proto_iop_agent_proto_rawDescGZIP() []byte {
	file_proto_iop_agent_proto_rawDescOnce.Do(func() {
		file_proto_iop_agent_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_proto_iop_agent_proto_rawDesc), len(file_proto_iop_agent_proto_rawDesc)))
	})
	return file_proto_iop_agent_proto_rawDescData
}

var file_proto_iop_agent_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
var file_proto_iop_agent_proto_msgTypes = make([]protoimpl.MessageInfo, 11)
var file_proto_iop_agent_proto_goTypes = []any{
	(AgentLocalKind)(0),              // 0: iop.AgentLocalKind
	(*AgentLocalEnvelope)(nil),       // 1: iop.AgentLocalEnvelope
	(*AgentLocalRequest)(nil),        // 2: iop.AgentLocalRequest
	(*AgentLocalReadRequest)(nil),    // 3: iop.AgentLocalReadRequest
	(*AgentLocalProjectRequest)(nil), // 4: iop.AgentLocalProjectRequest
	(*AgentLocalClientRequest)(nil),  // 5: iop.AgentLocalClientRequest
	(*AgentLocalResponse)(nil),       // 6: iop.AgentLocalResponse
	(*AgentLocalSnapshot)(nil),       // 7: iop.AgentLocalSnapshot
	(*AgentLocalStatusEntry)(nil),    // 8: iop.AgentLocalStatusEntry
	(*AgentLocalMutationResult)(nil), // 9: iop.AgentLocalMutationResult
	(*AgentLocalEvent)(nil),          // 10: iop.AgentLocalEvent
	(*AgentLocalError)(nil),          // 11: iop.AgentLocalError
}
var file_proto_iop_agent_proto_depIdxs = []int32{
	0,  // 0: iop.AgentLocalEnvelope.kind:type_name -> iop.AgentLocalKind
	2,  // 1: iop.AgentLocalEnvelope.request:type_name -> iop.AgentLocalRequest
	6,  // 2: iop.AgentLocalEnvelope.response:type_name -> iop.AgentLocalResponse
	10, // 3: iop.AgentLocalEnvelope.event:type_name -> iop.AgentLocalEvent
	11, // 4: iop.AgentLocalEnvelope.error:type_name -> iop.AgentLocalError
	3,  // 5: iop.AgentLocalRequest.read:type_name -> iop.AgentLocalReadRequest
	4,  // 6: iop.AgentLocalRequest.project:type_name -> iop.AgentLocalProjectRequest
	5,  // 7: iop.AgentLocalRequest.client:type_name -> iop.AgentLocalClientRequest
	7,  // 8: iop.AgentLocalResponse.snapshot:type_name -> iop.AgentLocalSnapshot
	9,  // 9: iop.AgentLocalResponse.mutation:type_name -> iop.AgentLocalMutationResult
	10, // 10: iop.AgentLocalResponse.replay_events:type_name -> iop.AgentLocalEvent
	8,  // 11: iop.AgentLocalSnapshot.entries:type_name -> iop.AgentLocalStatusEntry
	9,  // 12: iop.AgentLocalEvent.mutation:type_name -> iop.AgentLocalMutationResult
	13, // [13:13] is the sub-list for method output_type
	13, // [13:13] is the sub-list for method input_type
	13, // [13:13] is the sub-list for extension type_name
	13, // [13:13] is the sub-list for extension extendee
	0,  // [0:13] is the sub-list for field type_name
}

func init() { file_proto_iop_agent_proto_init() }
func file_proto_iop_agent_proto_init() {
	if File_proto_iop_agent_proto != nil {
		return
	}
	file_proto_iop_agent_proto_msgTypes[0].OneofWrappers = []any{
		(*AgentLocalEnvelope_Request)(nil),
		(*AgentLocalEnvelope_Response)(nil),
		(*AgentLocalEnvelope_Event)(nil),
		(*AgentLocalEnvelope_Error)(nil),
	}
	file_proto_iop_agent_proto_msgTypes[1].OneofWrappers = []any{
		(*AgentLocalRequest_Read)(nil),
		(*AgentLocalRequest_Project)(nil),
		(*AgentLocalRequest_Client)(nil),
	}
	file_proto_iop_agent_proto_msgTypes[5].OneofWrappers = []any{
		(*AgentLocalResponse_Snapshot)(nil),
		(*AgentLocalResponse_Mutation)(nil),
	}
	type x struct{}
	out := protoimpl.TypeBuilder{
		File: protoimpl.DescBuilder{
			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
			RawDescriptor: unsafe.Slice(unsafe.StringData(file_proto_iop_agent_proto_rawDesc), len(file_proto_iop_agent_proto_rawDesc)),
			NumEnums:      1,
			NumMessages:   11,
			NumExtensions: 0,
			NumServices:   0,
		},
		GoTypes:           file_proto_iop_agent_proto_goTypes,
		DependencyIndexes: file_proto_iop_agent_proto_depIdxs,
		EnumInfos:         file_proto_iop_agent_proto_enumTypes,
		MessageInfos:      file_proto_iop_agent_proto_msgTypes,
	}.Build()
	File_proto_iop_agent_proto = out.File
	file_proto_iop_agent_proto_goTypes = nil
	file_proto_iop_agent_proto_depIdxs = nil
}
