// Code generated by protoc-gen-go. DO NOT EDIT. // versions: // protoc-gen-go v1.36.11 // protoc v7.34.1 // source: mxaccess_gateway.proto package generated import ( protoreflect "google.golang.org/protobuf/reflect/protoreflect" protoimpl "google.golang.org/protobuf/runtime/protoimpl" durationpb "google.golang.org/protobuf/types/known/durationpb" timestamppb "google.golang.org/protobuf/types/known/timestamppb" 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) ) type MxCommandKind int32 const ( MxCommandKind_MX_COMMAND_KIND_UNSPECIFIED MxCommandKind = 0 MxCommandKind_MX_COMMAND_KIND_REGISTER MxCommandKind = 1 MxCommandKind_MX_COMMAND_KIND_UNREGISTER MxCommandKind = 2 MxCommandKind_MX_COMMAND_KIND_ADD_ITEM MxCommandKind = 3 MxCommandKind_MX_COMMAND_KIND_ADD_ITEM2 MxCommandKind = 4 MxCommandKind_MX_COMMAND_KIND_REMOVE_ITEM MxCommandKind = 5 MxCommandKind_MX_COMMAND_KIND_ADVISE MxCommandKind = 6 MxCommandKind_MX_COMMAND_KIND_UN_ADVISE MxCommandKind = 7 MxCommandKind_MX_COMMAND_KIND_ADVISE_SUPERVISORY MxCommandKind = 8 MxCommandKind_MX_COMMAND_KIND_ADD_BUFFERED_ITEM MxCommandKind = 9 MxCommandKind_MX_COMMAND_KIND_SET_BUFFERED_UPDATE_INTERVAL MxCommandKind = 10 MxCommandKind_MX_COMMAND_KIND_SUSPEND MxCommandKind = 11 MxCommandKind_MX_COMMAND_KIND_ACTIVATE MxCommandKind = 12 MxCommandKind_MX_COMMAND_KIND_WRITE MxCommandKind = 13 MxCommandKind_MX_COMMAND_KIND_WRITE2 MxCommandKind = 14 MxCommandKind_MX_COMMAND_KIND_WRITE_SECURED MxCommandKind = 15 MxCommandKind_MX_COMMAND_KIND_WRITE_SECURED2 MxCommandKind = 16 MxCommandKind_MX_COMMAND_KIND_AUTHENTICATE_USER MxCommandKind = 17 MxCommandKind_MX_COMMAND_KIND_ARCHESTRA_USER_TO_ID MxCommandKind = 18 MxCommandKind_MX_COMMAND_KIND_PING MxCommandKind = 100 MxCommandKind_MX_COMMAND_KIND_GET_SESSION_STATE MxCommandKind = 101 MxCommandKind_MX_COMMAND_KIND_GET_WORKER_INFO MxCommandKind = 102 MxCommandKind_MX_COMMAND_KIND_DRAIN_EVENTS MxCommandKind = 103 MxCommandKind_MX_COMMAND_KIND_SHUTDOWN_WORKER MxCommandKind = 104 ) // Enum value maps for MxCommandKind. var ( MxCommandKind_name = map[int32]string{ 0: "MX_COMMAND_KIND_UNSPECIFIED", 1: "MX_COMMAND_KIND_REGISTER", 2: "MX_COMMAND_KIND_UNREGISTER", 3: "MX_COMMAND_KIND_ADD_ITEM", 4: "MX_COMMAND_KIND_ADD_ITEM2", 5: "MX_COMMAND_KIND_REMOVE_ITEM", 6: "MX_COMMAND_KIND_ADVISE", 7: "MX_COMMAND_KIND_UN_ADVISE", 8: "MX_COMMAND_KIND_ADVISE_SUPERVISORY", 9: "MX_COMMAND_KIND_ADD_BUFFERED_ITEM", 10: "MX_COMMAND_KIND_SET_BUFFERED_UPDATE_INTERVAL", 11: "MX_COMMAND_KIND_SUSPEND", 12: "MX_COMMAND_KIND_ACTIVATE", 13: "MX_COMMAND_KIND_WRITE", 14: "MX_COMMAND_KIND_WRITE2", 15: "MX_COMMAND_KIND_WRITE_SECURED", 16: "MX_COMMAND_KIND_WRITE_SECURED2", 17: "MX_COMMAND_KIND_AUTHENTICATE_USER", 18: "MX_COMMAND_KIND_ARCHESTRA_USER_TO_ID", 100: "MX_COMMAND_KIND_PING", 101: "MX_COMMAND_KIND_GET_SESSION_STATE", 102: "MX_COMMAND_KIND_GET_WORKER_INFO", 103: "MX_COMMAND_KIND_DRAIN_EVENTS", 104: "MX_COMMAND_KIND_SHUTDOWN_WORKER", } MxCommandKind_value = map[string]int32{ "MX_COMMAND_KIND_UNSPECIFIED": 0, "MX_COMMAND_KIND_REGISTER": 1, "MX_COMMAND_KIND_UNREGISTER": 2, "MX_COMMAND_KIND_ADD_ITEM": 3, "MX_COMMAND_KIND_ADD_ITEM2": 4, "MX_COMMAND_KIND_REMOVE_ITEM": 5, "MX_COMMAND_KIND_ADVISE": 6, "MX_COMMAND_KIND_UN_ADVISE": 7, "MX_COMMAND_KIND_ADVISE_SUPERVISORY": 8, "MX_COMMAND_KIND_ADD_BUFFERED_ITEM": 9, "MX_COMMAND_KIND_SET_BUFFERED_UPDATE_INTERVAL": 10, "MX_COMMAND_KIND_SUSPEND": 11, "MX_COMMAND_KIND_ACTIVATE": 12, "MX_COMMAND_KIND_WRITE": 13, "MX_COMMAND_KIND_WRITE2": 14, "MX_COMMAND_KIND_WRITE_SECURED": 15, "MX_COMMAND_KIND_WRITE_SECURED2": 16, "MX_COMMAND_KIND_AUTHENTICATE_USER": 17, "MX_COMMAND_KIND_ARCHESTRA_USER_TO_ID": 18, "MX_COMMAND_KIND_PING": 100, "MX_COMMAND_KIND_GET_SESSION_STATE": 101, "MX_COMMAND_KIND_GET_WORKER_INFO": 102, "MX_COMMAND_KIND_DRAIN_EVENTS": 103, "MX_COMMAND_KIND_SHUTDOWN_WORKER": 104, } ) func (x MxCommandKind) Enum() *MxCommandKind { p := new(MxCommandKind) *p = x return p } func (x MxCommandKind) String() string { return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) } func (MxCommandKind) Descriptor() protoreflect.EnumDescriptor { return file_mxaccess_gateway_proto_enumTypes[0].Descriptor() } func (MxCommandKind) Type() protoreflect.EnumType { return &file_mxaccess_gateway_proto_enumTypes[0] } func (x MxCommandKind) Number() protoreflect.EnumNumber { return protoreflect.EnumNumber(x) } // Deprecated: Use MxCommandKind.Descriptor instead. func (MxCommandKind) EnumDescriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{0} } type MxEventFamily int32 const ( MxEventFamily_MX_EVENT_FAMILY_UNSPECIFIED MxEventFamily = 0 MxEventFamily_MX_EVENT_FAMILY_ON_DATA_CHANGE MxEventFamily = 1 MxEventFamily_MX_EVENT_FAMILY_ON_WRITE_COMPLETE MxEventFamily = 2 MxEventFamily_MX_EVENT_FAMILY_OPERATION_COMPLETE MxEventFamily = 3 MxEventFamily_MX_EVENT_FAMILY_ON_BUFFERED_DATA_CHANGE MxEventFamily = 4 ) // Enum value maps for MxEventFamily. var ( MxEventFamily_name = map[int32]string{ 0: "MX_EVENT_FAMILY_UNSPECIFIED", 1: "MX_EVENT_FAMILY_ON_DATA_CHANGE", 2: "MX_EVENT_FAMILY_ON_WRITE_COMPLETE", 3: "MX_EVENT_FAMILY_OPERATION_COMPLETE", 4: "MX_EVENT_FAMILY_ON_BUFFERED_DATA_CHANGE", } MxEventFamily_value = map[string]int32{ "MX_EVENT_FAMILY_UNSPECIFIED": 0, "MX_EVENT_FAMILY_ON_DATA_CHANGE": 1, "MX_EVENT_FAMILY_ON_WRITE_COMPLETE": 2, "MX_EVENT_FAMILY_OPERATION_COMPLETE": 3, "MX_EVENT_FAMILY_ON_BUFFERED_DATA_CHANGE": 4, } ) func (x MxEventFamily) Enum() *MxEventFamily { p := new(MxEventFamily) *p = x return p } func (x MxEventFamily) String() string { return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) } func (MxEventFamily) Descriptor() protoreflect.EnumDescriptor { return file_mxaccess_gateway_proto_enumTypes[1].Descriptor() } func (MxEventFamily) Type() protoreflect.EnumType { return &file_mxaccess_gateway_proto_enumTypes[1] } func (x MxEventFamily) Number() protoreflect.EnumNumber { return protoreflect.EnumNumber(x) } // Deprecated: Use MxEventFamily.Descriptor instead. func (MxEventFamily) EnumDescriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{1} } type MxStatusCategory int32 const ( MxStatusCategory_MX_STATUS_CATEGORY_UNSPECIFIED MxStatusCategory = 0 MxStatusCategory_MX_STATUS_CATEGORY_UNKNOWN MxStatusCategory = 1 MxStatusCategory_MX_STATUS_CATEGORY_OK MxStatusCategory = 2 MxStatusCategory_MX_STATUS_CATEGORY_PENDING MxStatusCategory = 3 MxStatusCategory_MX_STATUS_CATEGORY_WARNING MxStatusCategory = 4 MxStatusCategory_MX_STATUS_CATEGORY_COMMUNICATION_ERROR MxStatusCategory = 5 MxStatusCategory_MX_STATUS_CATEGORY_CONFIGURATION_ERROR MxStatusCategory = 6 MxStatusCategory_MX_STATUS_CATEGORY_OPERATIONAL_ERROR MxStatusCategory = 7 MxStatusCategory_MX_STATUS_CATEGORY_SECURITY_ERROR MxStatusCategory = 8 MxStatusCategory_MX_STATUS_CATEGORY_SOFTWARE_ERROR MxStatusCategory = 9 MxStatusCategory_MX_STATUS_CATEGORY_OTHER_ERROR MxStatusCategory = 10 ) // Enum value maps for MxStatusCategory. var ( MxStatusCategory_name = map[int32]string{ 0: "MX_STATUS_CATEGORY_UNSPECIFIED", 1: "MX_STATUS_CATEGORY_UNKNOWN", 2: "MX_STATUS_CATEGORY_OK", 3: "MX_STATUS_CATEGORY_PENDING", 4: "MX_STATUS_CATEGORY_WARNING", 5: "MX_STATUS_CATEGORY_COMMUNICATION_ERROR", 6: "MX_STATUS_CATEGORY_CONFIGURATION_ERROR", 7: "MX_STATUS_CATEGORY_OPERATIONAL_ERROR", 8: "MX_STATUS_CATEGORY_SECURITY_ERROR", 9: "MX_STATUS_CATEGORY_SOFTWARE_ERROR", 10: "MX_STATUS_CATEGORY_OTHER_ERROR", } MxStatusCategory_value = map[string]int32{ "MX_STATUS_CATEGORY_UNSPECIFIED": 0, "MX_STATUS_CATEGORY_UNKNOWN": 1, "MX_STATUS_CATEGORY_OK": 2, "MX_STATUS_CATEGORY_PENDING": 3, "MX_STATUS_CATEGORY_WARNING": 4, "MX_STATUS_CATEGORY_COMMUNICATION_ERROR": 5, "MX_STATUS_CATEGORY_CONFIGURATION_ERROR": 6, "MX_STATUS_CATEGORY_OPERATIONAL_ERROR": 7, "MX_STATUS_CATEGORY_SECURITY_ERROR": 8, "MX_STATUS_CATEGORY_SOFTWARE_ERROR": 9, "MX_STATUS_CATEGORY_OTHER_ERROR": 10, } ) func (x MxStatusCategory) Enum() *MxStatusCategory { p := new(MxStatusCategory) *p = x return p } func (x MxStatusCategory) String() string { return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) } func (MxStatusCategory) Descriptor() protoreflect.EnumDescriptor { return file_mxaccess_gateway_proto_enumTypes[2].Descriptor() } func (MxStatusCategory) Type() protoreflect.EnumType { return &file_mxaccess_gateway_proto_enumTypes[2] } func (x MxStatusCategory) Number() protoreflect.EnumNumber { return protoreflect.EnumNumber(x) } // Deprecated: Use MxStatusCategory.Descriptor instead. func (MxStatusCategory) EnumDescriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{2} } type MxStatusSource int32 const ( MxStatusSource_MX_STATUS_SOURCE_UNSPECIFIED MxStatusSource = 0 MxStatusSource_MX_STATUS_SOURCE_UNKNOWN MxStatusSource = 1 MxStatusSource_MX_STATUS_SOURCE_REQUESTING_LMX MxStatusSource = 2 MxStatusSource_MX_STATUS_SOURCE_RESPONDING_LMX MxStatusSource = 3 MxStatusSource_MX_STATUS_SOURCE_REQUESTING_NMX MxStatusSource = 4 MxStatusSource_MX_STATUS_SOURCE_RESPONDING_NMX MxStatusSource = 5 MxStatusSource_MX_STATUS_SOURCE_REQUESTING_AUTOMATION_OBJECT MxStatusSource = 6 MxStatusSource_MX_STATUS_SOURCE_RESPONDING_AUTOMATION_OBJECT MxStatusSource = 7 ) // Enum value maps for MxStatusSource. var ( MxStatusSource_name = map[int32]string{ 0: "MX_STATUS_SOURCE_UNSPECIFIED", 1: "MX_STATUS_SOURCE_UNKNOWN", 2: "MX_STATUS_SOURCE_REQUESTING_LMX", 3: "MX_STATUS_SOURCE_RESPONDING_LMX", 4: "MX_STATUS_SOURCE_REQUESTING_NMX", 5: "MX_STATUS_SOURCE_RESPONDING_NMX", 6: "MX_STATUS_SOURCE_REQUESTING_AUTOMATION_OBJECT", 7: "MX_STATUS_SOURCE_RESPONDING_AUTOMATION_OBJECT", } MxStatusSource_value = map[string]int32{ "MX_STATUS_SOURCE_UNSPECIFIED": 0, "MX_STATUS_SOURCE_UNKNOWN": 1, "MX_STATUS_SOURCE_REQUESTING_LMX": 2, "MX_STATUS_SOURCE_RESPONDING_LMX": 3, "MX_STATUS_SOURCE_REQUESTING_NMX": 4, "MX_STATUS_SOURCE_RESPONDING_NMX": 5, "MX_STATUS_SOURCE_REQUESTING_AUTOMATION_OBJECT": 6, "MX_STATUS_SOURCE_RESPONDING_AUTOMATION_OBJECT": 7, } ) func (x MxStatusSource) Enum() *MxStatusSource { p := new(MxStatusSource) *p = x return p } func (x MxStatusSource) String() string { return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) } func (MxStatusSource) Descriptor() protoreflect.EnumDescriptor { return file_mxaccess_gateway_proto_enumTypes[3].Descriptor() } func (MxStatusSource) Type() protoreflect.EnumType { return &file_mxaccess_gateway_proto_enumTypes[3] } func (x MxStatusSource) Number() protoreflect.EnumNumber { return protoreflect.EnumNumber(x) } // Deprecated: Use MxStatusSource.Descriptor instead. func (MxStatusSource) EnumDescriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{3} } type MxDataType int32 const ( MxDataType_MX_DATA_TYPE_UNSPECIFIED MxDataType = 0 MxDataType_MX_DATA_TYPE_UNKNOWN MxDataType = 1 MxDataType_MX_DATA_TYPE_NO_DATA MxDataType = 2 MxDataType_MX_DATA_TYPE_BOOLEAN MxDataType = 3 MxDataType_MX_DATA_TYPE_INTEGER MxDataType = 4 MxDataType_MX_DATA_TYPE_FLOAT MxDataType = 5 MxDataType_MX_DATA_TYPE_DOUBLE MxDataType = 6 MxDataType_MX_DATA_TYPE_STRING MxDataType = 7 MxDataType_MX_DATA_TYPE_TIME MxDataType = 8 MxDataType_MX_DATA_TYPE_ELAPSED_TIME MxDataType = 9 MxDataType_MX_DATA_TYPE_REFERENCE_TYPE MxDataType = 10 MxDataType_MX_DATA_TYPE_STATUS_TYPE MxDataType = 11 MxDataType_MX_DATA_TYPE_ENUM MxDataType = 12 MxDataType_MX_DATA_TYPE_SECURITY_CLASSIFICATION_ENUM MxDataType = 13 MxDataType_MX_DATA_TYPE_DATA_QUALITY_TYPE MxDataType = 14 MxDataType_MX_DATA_TYPE_QUALIFIED_ENUM MxDataType = 15 MxDataType_MX_DATA_TYPE_QUALIFIED_STRUCT MxDataType = 16 MxDataType_MX_DATA_TYPE_INTERNATIONALIZED_STRING MxDataType = 17 MxDataType_MX_DATA_TYPE_BIG_STRING MxDataType = 18 MxDataType_MX_DATA_TYPE_END MxDataType = 19 ) // Enum value maps for MxDataType. var ( MxDataType_name = map[int32]string{ 0: "MX_DATA_TYPE_UNSPECIFIED", 1: "MX_DATA_TYPE_UNKNOWN", 2: "MX_DATA_TYPE_NO_DATA", 3: "MX_DATA_TYPE_BOOLEAN", 4: "MX_DATA_TYPE_INTEGER", 5: "MX_DATA_TYPE_FLOAT", 6: "MX_DATA_TYPE_DOUBLE", 7: "MX_DATA_TYPE_STRING", 8: "MX_DATA_TYPE_TIME", 9: "MX_DATA_TYPE_ELAPSED_TIME", 10: "MX_DATA_TYPE_REFERENCE_TYPE", 11: "MX_DATA_TYPE_STATUS_TYPE", 12: "MX_DATA_TYPE_ENUM", 13: "MX_DATA_TYPE_SECURITY_CLASSIFICATION_ENUM", 14: "MX_DATA_TYPE_DATA_QUALITY_TYPE", 15: "MX_DATA_TYPE_QUALIFIED_ENUM", 16: "MX_DATA_TYPE_QUALIFIED_STRUCT", 17: "MX_DATA_TYPE_INTERNATIONALIZED_STRING", 18: "MX_DATA_TYPE_BIG_STRING", 19: "MX_DATA_TYPE_END", } MxDataType_value = map[string]int32{ "MX_DATA_TYPE_UNSPECIFIED": 0, "MX_DATA_TYPE_UNKNOWN": 1, "MX_DATA_TYPE_NO_DATA": 2, "MX_DATA_TYPE_BOOLEAN": 3, "MX_DATA_TYPE_INTEGER": 4, "MX_DATA_TYPE_FLOAT": 5, "MX_DATA_TYPE_DOUBLE": 6, "MX_DATA_TYPE_STRING": 7, "MX_DATA_TYPE_TIME": 8, "MX_DATA_TYPE_ELAPSED_TIME": 9, "MX_DATA_TYPE_REFERENCE_TYPE": 10, "MX_DATA_TYPE_STATUS_TYPE": 11, "MX_DATA_TYPE_ENUM": 12, "MX_DATA_TYPE_SECURITY_CLASSIFICATION_ENUM": 13, "MX_DATA_TYPE_DATA_QUALITY_TYPE": 14, "MX_DATA_TYPE_QUALIFIED_ENUM": 15, "MX_DATA_TYPE_QUALIFIED_STRUCT": 16, "MX_DATA_TYPE_INTERNATIONALIZED_STRING": 17, "MX_DATA_TYPE_BIG_STRING": 18, "MX_DATA_TYPE_END": 19, } ) func (x MxDataType) Enum() *MxDataType { p := new(MxDataType) *p = x return p } func (x MxDataType) String() string { return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) } func (MxDataType) Descriptor() protoreflect.EnumDescriptor { return file_mxaccess_gateway_proto_enumTypes[4].Descriptor() } func (MxDataType) Type() protoreflect.EnumType { return &file_mxaccess_gateway_proto_enumTypes[4] } func (x MxDataType) Number() protoreflect.EnumNumber { return protoreflect.EnumNumber(x) } // Deprecated: Use MxDataType.Descriptor instead. func (MxDataType) EnumDescriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{4} } type ProtocolStatusCode int32 const ( ProtocolStatusCode_PROTOCOL_STATUS_CODE_UNSPECIFIED ProtocolStatusCode = 0 ProtocolStatusCode_PROTOCOL_STATUS_CODE_OK ProtocolStatusCode = 1 ProtocolStatusCode_PROTOCOL_STATUS_CODE_INVALID_REQUEST ProtocolStatusCode = 2 ProtocolStatusCode_PROTOCOL_STATUS_CODE_SESSION_NOT_FOUND ProtocolStatusCode = 3 ProtocolStatusCode_PROTOCOL_STATUS_CODE_SESSION_NOT_READY ProtocolStatusCode = 4 ProtocolStatusCode_PROTOCOL_STATUS_CODE_WORKER_UNAVAILABLE ProtocolStatusCode = 5 ProtocolStatusCode_PROTOCOL_STATUS_CODE_TIMEOUT ProtocolStatusCode = 6 ProtocolStatusCode_PROTOCOL_STATUS_CODE_CANCELED ProtocolStatusCode = 7 ProtocolStatusCode_PROTOCOL_STATUS_CODE_PROTOCOL_VIOLATION ProtocolStatusCode = 8 ProtocolStatusCode_PROTOCOL_STATUS_CODE_MXACCESS_FAILURE ProtocolStatusCode = 9 ) // Enum value maps for ProtocolStatusCode. var ( ProtocolStatusCode_name = map[int32]string{ 0: "PROTOCOL_STATUS_CODE_UNSPECIFIED", 1: "PROTOCOL_STATUS_CODE_OK", 2: "PROTOCOL_STATUS_CODE_INVALID_REQUEST", 3: "PROTOCOL_STATUS_CODE_SESSION_NOT_FOUND", 4: "PROTOCOL_STATUS_CODE_SESSION_NOT_READY", 5: "PROTOCOL_STATUS_CODE_WORKER_UNAVAILABLE", 6: "PROTOCOL_STATUS_CODE_TIMEOUT", 7: "PROTOCOL_STATUS_CODE_CANCELED", 8: "PROTOCOL_STATUS_CODE_PROTOCOL_VIOLATION", 9: "PROTOCOL_STATUS_CODE_MXACCESS_FAILURE", } ProtocolStatusCode_value = map[string]int32{ "PROTOCOL_STATUS_CODE_UNSPECIFIED": 0, "PROTOCOL_STATUS_CODE_OK": 1, "PROTOCOL_STATUS_CODE_INVALID_REQUEST": 2, "PROTOCOL_STATUS_CODE_SESSION_NOT_FOUND": 3, "PROTOCOL_STATUS_CODE_SESSION_NOT_READY": 4, "PROTOCOL_STATUS_CODE_WORKER_UNAVAILABLE": 5, "PROTOCOL_STATUS_CODE_TIMEOUT": 6, "PROTOCOL_STATUS_CODE_CANCELED": 7, "PROTOCOL_STATUS_CODE_PROTOCOL_VIOLATION": 8, "PROTOCOL_STATUS_CODE_MXACCESS_FAILURE": 9, } ) func (x ProtocolStatusCode) Enum() *ProtocolStatusCode { p := new(ProtocolStatusCode) *p = x return p } func (x ProtocolStatusCode) String() string { return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) } func (ProtocolStatusCode) Descriptor() protoreflect.EnumDescriptor { return file_mxaccess_gateway_proto_enumTypes[5].Descriptor() } func (ProtocolStatusCode) Type() protoreflect.EnumType { return &file_mxaccess_gateway_proto_enumTypes[5] } func (x ProtocolStatusCode) Number() protoreflect.EnumNumber { return protoreflect.EnumNumber(x) } // Deprecated: Use ProtocolStatusCode.Descriptor instead. func (ProtocolStatusCode) EnumDescriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{5} } type SessionState int32 const ( SessionState_SESSION_STATE_UNSPECIFIED SessionState = 0 SessionState_SESSION_STATE_CREATING SessionState = 1 SessionState_SESSION_STATE_STARTING_WORKER SessionState = 2 SessionState_SESSION_STATE_WAITING_FOR_PIPE SessionState = 3 SessionState_SESSION_STATE_HANDSHAKING SessionState = 4 SessionState_SESSION_STATE_INITIALIZING_WORKER SessionState = 5 SessionState_SESSION_STATE_READY SessionState = 6 SessionState_SESSION_STATE_CLOSING SessionState = 7 SessionState_SESSION_STATE_CLOSED SessionState = 8 SessionState_SESSION_STATE_FAULTED SessionState = 9 ) // Enum value maps for SessionState. var ( SessionState_name = map[int32]string{ 0: "SESSION_STATE_UNSPECIFIED", 1: "SESSION_STATE_CREATING", 2: "SESSION_STATE_STARTING_WORKER", 3: "SESSION_STATE_WAITING_FOR_PIPE", 4: "SESSION_STATE_HANDSHAKING", 5: "SESSION_STATE_INITIALIZING_WORKER", 6: "SESSION_STATE_READY", 7: "SESSION_STATE_CLOSING", 8: "SESSION_STATE_CLOSED", 9: "SESSION_STATE_FAULTED", } SessionState_value = map[string]int32{ "SESSION_STATE_UNSPECIFIED": 0, "SESSION_STATE_CREATING": 1, "SESSION_STATE_STARTING_WORKER": 2, "SESSION_STATE_WAITING_FOR_PIPE": 3, "SESSION_STATE_HANDSHAKING": 4, "SESSION_STATE_INITIALIZING_WORKER": 5, "SESSION_STATE_READY": 6, "SESSION_STATE_CLOSING": 7, "SESSION_STATE_CLOSED": 8, "SESSION_STATE_FAULTED": 9, } ) func (x SessionState) Enum() *SessionState { p := new(SessionState) *p = x return p } func (x SessionState) String() string { return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) } func (SessionState) Descriptor() protoreflect.EnumDescriptor { return file_mxaccess_gateway_proto_enumTypes[6].Descriptor() } func (SessionState) Type() protoreflect.EnumType { return &file_mxaccess_gateway_proto_enumTypes[6] } func (x SessionState) Number() protoreflect.EnumNumber { return protoreflect.EnumNumber(x) } // Deprecated: Use SessionState.Descriptor instead. func (SessionState) EnumDescriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{6} } type OpenSessionRequest struct { state protoimpl.MessageState `protogen:"open.v1"` RequestedBackend string `protobuf:"bytes,1,opt,name=requested_backend,json=requestedBackend,proto3" json:"requested_backend,omitempty"` ClientSessionName string `protobuf:"bytes,2,opt,name=client_session_name,json=clientSessionName,proto3" json:"client_session_name,omitempty"` ClientCorrelationId string `protobuf:"bytes,3,opt,name=client_correlation_id,json=clientCorrelationId,proto3" json:"client_correlation_id,omitempty"` CommandTimeout *durationpb.Duration `protobuf:"bytes,4,opt,name=command_timeout,json=commandTimeout,proto3" json:"command_timeout,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *OpenSessionRequest) Reset() { *x = OpenSessionRequest{} mi := &file_mxaccess_gateway_proto_msgTypes[0] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *OpenSessionRequest) String() string { return protoimpl.X.MessageStringOf(x) } func (*OpenSessionRequest) ProtoMessage() {} func (x *OpenSessionRequest) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 OpenSessionRequest.ProtoReflect.Descriptor instead. func (*OpenSessionRequest) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{0} } func (x *OpenSessionRequest) GetRequestedBackend() string { if x != nil { return x.RequestedBackend } return "" } func (x *OpenSessionRequest) GetClientSessionName() string { if x != nil { return x.ClientSessionName } return "" } func (x *OpenSessionRequest) GetClientCorrelationId() string { if x != nil { return x.ClientCorrelationId } return "" } func (x *OpenSessionRequest) GetCommandTimeout() *durationpb.Duration { if x != nil { return x.CommandTimeout } return nil } type OpenSessionReply struct { state protoimpl.MessageState `protogen:"open.v1"` SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` BackendName string `protobuf:"bytes,2,opt,name=backend_name,json=backendName,proto3" json:"backend_name,omitempty"` WorkerProcessId int32 `protobuf:"varint,3,opt,name=worker_process_id,json=workerProcessId,proto3" json:"worker_process_id,omitempty"` WorkerProtocolVersion uint32 `protobuf:"varint,4,opt,name=worker_protocol_version,json=workerProtocolVersion,proto3" json:"worker_protocol_version,omitempty"` Capabilities []string `protobuf:"bytes,5,rep,name=capabilities,proto3" json:"capabilities,omitempty"` DefaultCommandTimeout *durationpb.Duration `protobuf:"bytes,6,opt,name=default_command_timeout,json=defaultCommandTimeout,proto3" json:"default_command_timeout,omitempty"` ProtocolStatus *ProtocolStatus `protobuf:"bytes,7,opt,name=protocol_status,json=protocolStatus,proto3" json:"protocol_status,omitempty"` // Public gateway contract version implemented by this endpoint. Clients use // this value to reject incompatible generated-code inputs before issuing // command-specific MXAccess calls. GatewayProtocolVersion uint32 `protobuf:"varint,8,opt,name=gateway_protocol_version,json=gatewayProtocolVersion,proto3" json:"gateway_protocol_version,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *OpenSessionReply) Reset() { *x = OpenSessionReply{} mi := &file_mxaccess_gateway_proto_msgTypes[1] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *OpenSessionReply) String() string { return protoimpl.X.MessageStringOf(x) } func (*OpenSessionReply) ProtoMessage() {} func (x *OpenSessionReply) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 OpenSessionReply.ProtoReflect.Descriptor instead. func (*OpenSessionReply) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{1} } func (x *OpenSessionReply) GetSessionId() string { if x != nil { return x.SessionId } return "" } func (x *OpenSessionReply) GetBackendName() string { if x != nil { return x.BackendName } return "" } func (x *OpenSessionReply) GetWorkerProcessId() int32 { if x != nil { return x.WorkerProcessId } return 0 } func (x *OpenSessionReply) GetWorkerProtocolVersion() uint32 { if x != nil { return x.WorkerProtocolVersion } return 0 } func (x *OpenSessionReply) GetCapabilities() []string { if x != nil { return x.Capabilities } return nil } func (x *OpenSessionReply) GetDefaultCommandTimeout() *durationpb.Duration { if x != nil { return x.DefaultCommandTimeout } return nil } func (x *OpenSessionReply) GetProtocolStatus() *ProtocolStatus { if x != nil { return x.ProtocolStatus } return nil } func (x *OpenSessionReply) GetGatewayProtocolVersion() uint32 { if x != nil { return x.GatewayProtocolVersion } return 0 } type CloseSessionRequest struct { state protoimpl.MessageState `protogen:"open.v1"` SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` ClientCorrelationId string `protobuf:"bytes,2,opt,name=client_correlation_id,json=clientCorrelationId,proto3" json:"client_correlation_id,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *CloseSessionRequest) Reset() { *x = CloseSessionRequest{} mi := &file_mxaccess_gateway_proto_msgTypes[2] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *CloseSessionRequest) String() string { return protoimpl.X.MessageStringOf(x) } func (*CloseSessionRequest) ProtoMessage() {} func (x *CloseSessionRequest) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 CloseSessionRequest.ProtoReflect.Descriptor instead. func (*CloseSessionRequest) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{2} } func (x *CloseSessionRequest) GetSessionId() string { if x != nil { return x.SessionId } return "" } func (x *CloseSessionRequest) GetClientCorrelationId() string { if x != nil { return x.ClientCorrelationId } return "" } type CloseSessionReply struct { state protoimpl.MessageState `protogen:"open.v1"` SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` FinalState SessionState `protobuf:"varint,2,opt,name=final_state,json=finalState,proto3,enum=mxaccess_gateway.v1.SessionState" json:"final_state,omitempty"` ProtocolStatus *ProtocolStatus `protobuf:"bytes,3,opt,name=protocol_status,json=protocolStatus,proto3" json:"protocol_status,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *CloseSessionReply) Reset() { *x = CloseSessionReply{} mi := &file_mxaccess_gateway_proto_msgTypes[3] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *CloseSessionReply) String() string { return protoimpl.X.MessageStringOf(x) } func (*CloseSessionReply) ProtoMessage() {} func (x *CloseSessionReply) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 CloseSessionReply.ProtoReflect.Descriptor instead. func (*CloseSessionReply) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{3} } func (x *CloseSessionReply) GetSessionId() string { if x != nil { return x.SessionId } return "" } func (x *CloseSessionReply) GetFinalState() SessionState { if x != nil { return x.FinalState } return SessionState_SESSION_STATE_UNSPECIFIED } func (x *CloseSessionReply) GetProtocolStatus() *ProtocolStatus { if x != nil { return x.ProtocolStatus } return nil } type StreamEventsRequest struct { state protoimpl.MessageState `protogen:"open.v1"` SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` AfterWorkerSequence uint64 `protobuf:"varint,2,opt,name=after_worker_sequence,json=afterWorkerSequence,proto3" json:"after_worker_sequence,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *StreamEventsRequest) Reset() { *x = StreamEventsRequest{} mi := &file_mxaccess_gateway_proto_msgTypes[4] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *StreamEventsRequest) String() string { return protoimpl.X.MessageStringOf(x) } func (*StreamEventsRequest) ProtoMessage() {} func (x *StreamEventsRequest) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 StreamEventsRequest.ProtoReflect.Descriptor instead. func (*StreamEventsRequest) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{4} } func (x *StreamEventsRequest) GetSessionId() string { if x != nil { return x.SessionId } return "" } func (x *StreamEventsRequest) GetAfterWorkerSequence() uint64 { if x != nil { return x.AfterWorkerSequence } return 0 } type MxCommandRequest struct { state protoimpl.MessageState `protogen:"open.v1"` SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` ClientCorrelationId string `protobuf:"bytes,2,opt,name=client_correlation_id,json=clientCorrelationId,proto3" json:"client_correlation_id,omitempty"` Command *MxCommand `protobuf:"bytes,3,opt,name=command,proto3" json:"command,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *MxCommandRequest) Reset() { *x = MxCommandRequest{} mi := &file_mxaccess_gateway_proto_msgTypes[5] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *MxCommandRequest) String() string { return protoimpl.X.MessageStringOf(x) } func (*MxCommandRequest) ProtoMessage() {} func (x *MxCommandRequest) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 MxCommandRequest.ProtoReflect.Descriptor instead. func (*MxCommandRequest) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{5} } func (x *MxCommandRequest) GetSessionId() string { if x != nil { return x.SessionId } return "" } func (x *MxCommandRequest) GetClientCorrelationId() string { if x != nil { return x.ClientCorrelationId } return "" } func (x *MxCommandRequest) GetCommand() *MxCommand { if x != nil { return x.Command } return nil } type MxCommand struct { state protoimpl.MessageState `protogen:"open.v1"` Kind MxCommandKind `protobuf:"varint,1,opt,name=kind,proto3,enum=mxaccess_gateway.v1.MxCommandKind" json:"kind,omitempty"` // Types that are valid to be assigned to Payload: // // *MxCommand_Register // *MxCommand_Unregister // *MxCommand_AddItem // *MxCommand_AddItem2 // *MxCommand_RemoveItem // *MxCommand_Advise // *MxCommand_UnAdvise // *MxCommand_AdviseSupervisory // *MxCommand_AddBufferedItem // *MxCommand_SetBufferedUpdateInterval // *MxCommand_Suspend // *MxCommand_Activate // *MxCommand_Write // *MxCommand_Write2 // *MxCommand_WriteSecured // *MxCommand_WriteSecured2 // *MxCommand_AuthenticateUser // *MxCommand_ArchestraUserToId // *MxCommand_Ping // *MxCommand_GetSessionState // *MxCommand_GetWorkerInfo // *MxCommand_DrainEvents // *MxCommand_ShutdownWorker Payload isMxCommand_Payload `protobuf_oneof:"payload"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *MxCommand) Reset() { *x = MxCommand{} mi := &file_mxaccess_gateway_proto_msgTypes[6] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *MxCommand) String() string { return protoimpl.X.MessageStringOf(x) } func (*MxCommand) ProtoMessage() {} func (x *MxCommand) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 MxCommand.ProtoReflect.Descriptor instead. func (*MxCommand) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{6} } func (x *MxCommand) GetKind() MxCommandKind { if x != nil { return x.Kind } return MxCommandKind_MX_COMMAND_KIND_UNSPECIFIED } func (x *MxCommand) GetPayload() isMxCommand_Payload { if x != nil { return x.Payload } return nil } func (x *MxCommand) GetRegister() *RegisterCommand { if x != nil { if x, ok := x.Payload.(*MxCommand_Register); ok { return x.Register } } return nil } func (x *MxCommand) GetUnregister() *UnregisterCommand { if x != nil { if x, ok := x.Payload.(*MxCommand_Unregister); ok { return x.Unregister } } return nil } func (x *MxCommand) GetAddItem() *AddItemCommand { if x != nil { if x, ok := x.Payload.(*MxCommand_AddItem); ok { return x.AddItem } } return nil } func (x *MxCommand) GetAddItem2() *AddItem2Command { if x != nil { if x, ok := x.Payload.(*MxCommand_AddItem2); ok { return x.AddItem2 } } return nil } func (x *MxCommand) GetRemoveItem() *RemoveItemCommand { if x != nil { if x, ok := x.Payload.(*MxCommand_RemoveItem); ok { return x.RemoveItem } } return nil } func (x *MxCommand) GetAdvise() *AdviseCommand { if x != nil { if x, ok := x.Payload.(*MxCommand_Advise); ok { return x.Advise } } return nil } func (x *MxCommand) GetUnAdvise() *UnAdviseCommand { if x != nil { if x, ok := x.Payload.(*MxCommand_UnAdvise); ok { return x.UnAdvise } } return nil } func (x *MxCommand) GetAdviseSupervisory() *AdviseSupervisoryCommand { if x != nil { if x, ok := x.Payload.(*MxCommand_AdviseSupervisory); ok { return x.AdviseSupervisory } } return nil } func (x *MxCommand) GetAddBufferedItem() *AddBufferedItemCommand { if x != nil { if x, ok := x.Payload.(*MxCommand_AddBufferedItem); ok { return x.AddBufferedItem } } return nil } func (x *MxCommand) GetSetBufferedUpdateInterval() *SetBufferedUpdateIntervalCommand { if x != nil { if x, ok := x.Payload.(*MxCommand_SetBufferedUpdateInterval); ok { return x.SetBufferedUpdateInterval } } return nil } func (x *MxCommand) GetSuspend() *SuspendCommand { if x != nil { if x, ok := x.Payload.(*MxCommand_Suspend); ok { return x.Suspend } } return nil } func (x *MxCommand) GetActivate() *ActivateCommand { if x != nil { if x, ok := x.Payload.(*MxCommand_Activate); ok { return x.Activate } } return nil } func (x *MxCommand) GetWrite() *WriteCommand { if x != nil { if x, ok := x.Payload.(*MxCommand_Write); ok { return x.Write } } return nil } func (x *MxCommand) GetWrite2() *Write2Command { if x != nil { if x, ok := x.Payload.(*MxCommand_Write2); ok { return x.Write2 } } return nil } func (x *MxCommand) GetWriteSecured() *WriteSecuredCommand { if x != nil { if x, ok := x.Payload.(*MxCommand_WriteSecured); ok { return x.WriteSecured } } return nil } func (x *MxCommand) GetWriteSecured2() *WriteSecured2Command { if x != nil { if x, ok := x.Payload.(*MxCommand_WriteSecured2); ok { return x.WriteSecured2 } } return nil } func (x *MxCommand) GetAuthenticateUser() *AuthenticateUserCommand { if x != nil { if x, ok := x.Payload.(*MxCommand_AuthenticateUser); ok { return x.AuthenticateUser } } return nil } func (x *MxCommand) GetArchestraUserToId() *ArchestrAUserToIdCommand { if x != nil { if x, ok := x.Payload.(*MxCommand_ArchestraUserToId); ok { return x.ArchestraUserToId } } return nil } func (x *MxCommand) GetPing() *PingCommand { if x != nil { if x, ok := x.Payload.(*MxCommand_Ping); ok { return x.Ping } } return nil } func (x *MxCommand) GetGetSessionState() *GetSessionStateCommand { if x != nil { if x, ok := x.Payload.(*MxCommand_GetSessionState); ok { return x.GetSessionState } } return nil } func (x *MxCommand) GetGetWorkerInfo() *GetWorkerInfoCommand { if x != nil { if x, ok := x.Payload.(*MxCommand_GetWorkerInfo); ok { return x.GetWorkerInfo } } return nil } func (x *MxCommand) GetDrainEvents() *DrainEventsCommand { if x != nil { if x, ok := x.Payload.(*MxCommand_DrainEvents); ok { return x.DrainEvents } } return nil } func (x *MxCommand) GetShutdownWorker() *ShutdownWorkerCommand { if x != nil { if x, ok := x.Payload.(*MxCommand_ShutdownWorker); ok { return x.ShutdownWorker } } return nil } type isMxCommand_Payload interface { isMxCommand_Payload() } type MxCommand_Register struct { Register *RegisterCommand `protobuf:"bytes,10,opt,name=register,proto3,oneof"` } type MxCommand_Unregister struct { Unregister *UnregisterCommand `protobuf:"bytes,11,opt,name=unregister,proto3,oneof"` } type MxCommand_AddItem struct { AddItem *AddItemCommand `protobuf:"bytes,12,opt,name=add_item,json=addItem,proto3,oneof"` } type MxCommand_AddItem2 struct { AddItem2 *AddItem2Command `protobuf:"bytes,13,opt,name=add_item2,json=addItem2,proto3,oneof"` } type MxCommand_RemoveItem struct { RemoveItem *RemoveItemCommand `protobuf:"bytes,14,opt,name=remove_item,json=removeItem,proto3,oneof"` } type MxCommand_Advise struct { Advise *AdviseCommand `protobuf:"bytes,15,opt,name=advise,proto3,oneof"` } type MxCommand_UnAdvise struct { UnAdvise *UnAdviseCommand `protobuf:"bytes,16,opt,name=un_advise,json=unAdvise,proto3,oneof"` } type MxCommand_AdviseSupervisory struct { AdviseSupervisory *AdviseSupervisoryCommand `protobuf:"bytes,17,opt,name=advise_supervisory,json=adviseSupervisory,proto3,oneof"` } type MxCommand_AddBufferedItem struct { AddBufferedItem *AddBufferedItemCommand `protobuf:"bytes,18,opt,name=add_buffered_item,json=addBufferedItem,proto3,oneof"` } type MxCommand_SetBufferedUpdateInterval struct { SetBufferedUpdateInterval *SetBufferedUpdateIntervalCommand `protobuf:"bytes,19,opt,name=set_buffered_update_interval,json=setBufferedUpdateInterval,proto3,oneof"` } type MxCommand_Suspend struct { Suspend *SuspendCommand `protobuf:"bytes,20,opt,name=suspend,proto3,oneof"` } type MxCommand_Activate struct { Activate *ActivateCommand `protobuf:"bytes,21,opt,name=activate,proto3,oneof"` } type MxCommand_Write struct { Write *WriteCommand `protobuf:"bytes,22,opt,name=write,proto3,oneof"` } type MxCommand_Write2 struct { Write2 *Write2Command `protobuf:"bytes,23,opt,name=write2,proto3,oneof"` } type MxCommand_WriteSecured struct { WriteSecured *WriteSecuredCommand `protobuf:"bytes,24,opt,name=write_secured,json=writeSecured,proto3,oneof"` } type MxCommand_WriteSecured2 struct { WriteSecured2 *WriteSecured2Command `protobuf:"bytes,25,opt,name=write_secured2,json=writeSecured2,proto3,oneof"` } type MxCommand_AuthenticateUser struct { AuthenticateUser *AuthenticateUserCommand `protobuf:"bytes,26,opt,name=authenticate_user,json=authenticateUser,proto3,oneof"` } type MxCommand_ArchestraUserToId struct { ArchestraUserToId *ArchestrAUserToIdCommand `protobuf:"bytes,27,opt,name=archestra_user_to_id,json=archestraUserToId,proto3,oneof"` } type MxCommand_Ping struct { Ping *PingCommand `protobuf:"bytes,100,opt,name=ping,proto3,oneof"` } type MxCommand_GetSessionState struct { GetSessionState *GetSessionStateCommand `protobuf:"bytes,101,opt,name=get_session_state,json=getSessionState,proto3,oneof"` } type MxCommand_GetWorkerInfo struct { GetWorkerInfo *GetWorkerInfoCommand `protobuf:"bytes,102,opt,name=get_worker_info,json=getWorkerInfo,proto3,oneof"` } type MxCommand_DrainEvents struct { DrainEvents *DrainEventsCommand `protobuf:"bytes,103,opt,name=drain_events,json=drainEvents,proto3,oneof"` } type MxCommand_ShutdownWorker struct { ShutdownWorker *ShutdownWorkerCommand `protobuf:"bytes,104,opt,name=shutdown_worker,json=shutdownWorker,proto3,oneof"` } func (*MxCommand_Register) isMxCommand_Payload() {} func (*MxCommand_Unregister) isMxCommand_Payload() {} func (*MxCommand_AddItem) isMxCommand_Payload() {} func (*MxCommand_AddItem2) isMxCommand_Payload() {} func (*MxCommand_RemoveItem) isMxCommand_Payload() {} func (*MxCommand_Advise) isMxCommand_Payload() {} func (*MxCommand_UnAdvise) isMxCommand_Payload() {} func (*MxCommand_AdviseSupervisory) isMxCommand_Payload() {} func (*MxCommand_AddBufferedItem) isMxCommand_Payload() {} func (*MxCommand_SetBufferedUpdateInterval) isMxCommand_Payload() {} func (*MxCommand_Suspend) isMxCommand_Payload() {} func (*MxCommand_Activate) isMxCommand_Payload() {} func (*MxCommand_Write) isMxCommand_Payload() {} func (*MxCommand_Write2) isMxCommand_Payload() {} func (*MxCommand_WriteSecured) isMxCommand_Payload() {} func (*MxCommand_WriteSecured2) isMxCommand_Payload() {} func (*MxCommand_AuthenticateUser) isMxCommand_Payload() {} func (*MxCommand_ArchestraUserToId) isMxCommand_Payload() {} func (*MxCommand_Ping) isMxCommand_Payload() {} func (*MxCommand_GetSessionState) isMxCommand_Payload() {} func (*MxCommand_GetWorkerInfo) isMxCommand_Payload() {} func (*MxCommand_DrainEvents) isMxCommand_Payload() {} func (*MxCommand_ShutdownWorker) isMxCommand_Payload() {} type RegisterCommand struct { state protoimpl.MessageState `protogen:"open.v1"` ClientName string `protobuf:"bytes,1,opt,name=client_name,json=clientName,proto3" json:"client_name,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *RegisterCommand) Reset() { *x = RegisterCommand{} mi := &file_mxaccess_gateway_proto_msgTypes[7] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *RegisterCommand) String() string { return protoimpl.X.MessageStringOf(x) } func (*RegisterCommand) ProtoMessage() {} func (x *RegisterCommand) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 RegisterCommand.ProtoReflect.Descriptor instead. func (*RegisterCommand) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{7} } func (x *RegisterCommand) GetClientName() string { if x != nil { return x.ClientName } return "" } type UnregisterCommand struct { state protoimpl.MessageState `protogen:"open.v1"` ServerHandle int32 `protobuf:"varint,1,opt,name=server_handle,json=serverHandle,proto3" json:"server_handle,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *UnregisterCommand) Reset() { *x = UnregisterCommand{} mi := &file_mxaccess_gateway_proto_msgTypes[8] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *UnregisterCommand) String() string { return protoimpl.X.MessageStringOf(x) } func (*UnregisterCommand) ProtoMessage() {} func (x *UnregisterCommand) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 UnregisterCommand.ProtoReflect.Descriptor instead. func (*UnregisterCommand) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{8} } func (x *UnregisterCommand) GetServerHandle() int32 { if x != nil { return x.ServerHandle } return 0 } type AddItemCommand struct { state protoimpl.MessageState `protogen:"open.v1"` ServerHandle int32 `protobuf:"varint,1,opt,name=server_handle,json=serverHandle,proto3" json:"server_handle,omitempty"` ItemDefinition string `protobuf:"bytes,2,opt,name=item_definition,json=itemDefinition,proto3" json:"item_definition,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *AddItemCommand) Reset() { *x = AddItemCommand{} mi := &file_mxaccess_gateway_proto_msgTypes[9] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *AddItemCommand) String() string { return protoimpl.X.MessageStringOf(x) } func (*AddItemCommand) ProtoMessage() {} func (x *AddItemCommand) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 AddItemCommand.ProtoReflect.Descriptor instead. func (*AddItemCommand) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{9} } func (x *AddItemCommand) GetServerHandle() int32 { if x != nil { return x.ServerHandle } return 0 } func (x *AddItemCommand) GetItemDefinition() string { if x != nil { return x.ItemDefinition } return "" } type AddItem2Command struct { state protoimpl.MessageState `protogen:"open.v1"` ServerHandle int32 `protobuf:"varint,1,opt,name=server_handle,json=serverHandle,proto3" json:"server_handle,omitempty"` ItemDefinition string `protobuf:"bytes,2,opt,name=item_definition,json=itemDefinition,proto3" json:"item_definition,omitempty"` ItemContext string `protobuf:"bytes,3,opt,name=item_context,json=itemContext,proto3" json:"item_context,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *AddItem2Command) Reset() { *x = AddItem2Command{} mi := &file_mxaccess_gateway_proto_msgTypes[10] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *AddItem2Command) String() string { return protoimpl.X.MessageStringOf(x) } func (*AddItem2Command) ProtoMessage() {} func (x *AddItem2Command) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 AddItem2Command.ProtoReflect.Descriptor instead. func (*AddItem2Command) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{10} } func (x *AddItem2Command) GetServerHandle() int32 { if x != nil { return x.ServerHandle } return 0 } func (x *AddItem2Command) GetItemDefinition() string { if x != nil { return x.ItemDefinition } return "" } func (x *AddItem2Command) GetItemContext() string { if x != nil { return x.ItemContext } return "" } type RemoveItemCommand struct { state protoimpl.MessageState `protogen:"open.v1"` ServerHandle int32 `protobuf:"varint,1,opt,name=server_handle,json=serverHandle,proto3" json:"server_handle,omitempty"` ItemHandle int32 `protobuf:"varint,2,opt,name=item_handle,json=itemHandle,proto3" json:"item_handle,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *RemoveItemCommand) Reset() { *x = RemoveItemCommand{} mi := &file_mxaccess_gateway_proto_msgTypes[11] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *RemoveItemCommand) String() string { return protoimpl.X.MessageStringOf(x) } func (*RemoveItemCommand) ProtoMessage() {} func (x *RemoveItemCommand) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 RemoveItemCommand.ProtoReflect.Descriptor instead. func (*RemoveItemCommand) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{11} } func (x *RemoveItemCommand) GetServerHandle() int32 { if x != nil { return x.ServerHandle } return 0 } func (x *RemoveItemCommand) GetItemHandle() int32 { if x != nil { return x.ItemHandle } return 0 } type AdviseCommand struct { state protoimpl.MessageState `protogen:"open.v1"` ServerHandle int32 `protobuf:"varint,1,opt,name=server_handle,json=serverHandle,proto3" json:"server_handle,omitempty"` ItemHandle int32 `protobuf:"varint,2,opt,name=item_handle,json=itemHandle,proto3" json:"item_handle,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *AdviseCommand) Reset() { *x = AdviseCommand{} mi := &file_mxaccess_gateway_proto_msgTypes[12] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *AdviseCommand) String() string { return protoimpl.X.MessageStringOf(x) } func (*AdviseCommand) ProtoMessage() {} func (x *AdviseCommand) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 AdviseCommand.ProtoReflect.Descriptor instead. func (*AdviseCommand) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{12} } func (x *AdviseCommand) GetServerHandle() int32 { if x != nil { return x.ServerHandle } return 0 } func (x *AdviseCommand) GetItemHandle() int32 { if x != nil { return x.ItemHandle } return 0 } type UnAdviseCommand struct { state protoimpl.MessageState `protogen:"open.v1"` ServerHandle int32 `protobuf:"varint,1,opt,name=server_handle,json=serverHandle,proto3" json:"server_handle,omitempty"` ItemHandle int32 `protobuf:"varint,2,opt,name=item_handle,json=itemHandle,proto3" json:"item_handle,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *UnAdviseCommand) Reset() { *x = UnAdviseCommand{} mi := &file_mxaccess_gateway_proto_msgTypes[13] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *UnAdviseCommand) String() string { return protoimpl.X.MessageStringOf(x) } func (*UnAdviseCommand) ProtoMessage() {} func (x *UnAdviseCommand) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 UnAdviseCommand.ProtoReflect.Descriptor instead. func (*UnAdviseCommand) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{13} } func (x *UnAdviseCommand) GetServerHandle() int32 { if x != nil { return x.ServerHandle } return 0 } func (x *UnAdviseCommand) GetItemHandle() int32 { if x != nil { return x.ItemHandle } return 0 } type AdviseSupervisoryCommand struct { state protoimpl.MessageState `protogen:"open.v1"` ServerHandle int32 `protobuf:"varint,1,opt,name=server_handle,json=serverHandle,proto3" json:"server_handle,omitempty"` ItemHandle int32 `protobuf:"varint,2,opt,name=item_handle,json=itemHandle,proto3" json:"item_handle,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *AdviseSupervisoryCommand) Reset() { *x = AdviseSupervisoryCommand{} mi := &file_mxaccess_gateway_proto_msgTypes[14] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *AdviseSupervisoryCommand) String() string { return protoimpl.X.MessageStringOf(x) } func (*AdviseSupervisoryCommand) ProtoMessage() {} func (x *AdviseSupervisoryCommand) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 AdviseSupervisoryCommand.ProtoReflect.Descriptor instead. func (*AdviseSupervisoryCommand) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{14} } func (x *AdviseSupervisoryCommand) GetServerHandle() int32 { if x != nil { return x.ServerHandle } return 0 } func (x *AdviseSupervisoryCommand) GetItemHandle() int32 { if x != nil { return x.ItemHandle } return 0 } type AddBufferedItemCommand struct { state protoimpl.MessageState `protogen:"open.v1"` ServerHandle int32 `protobuf:"varint,1,opt,name=server_handle,json=serverHandle,proto3" json:"server_handle,omitempty"` ItemDefinition string `protobuf:"bytes,2,opt,name=item_definition,json=itemDefinition,proto3" json:"item_definition,omitempty"` ItemContext string `protobuf:"bytes,3,opt,name=item_context,json=itemContext,proto3" json:"item_context,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *AddBufferedItemCommand) Reset() { *x = AddBufferedItemCommand{} mi := &file_mxaccess_gateway_proto_msgTypes[15] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *AddBufferedItemCommand) String() string { return protoimpl.X.MessageStringOf(x) } func (*AddBufferedItemCommand) ProtoMessage() {} func (x *AddBufferedItemCommand) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 AddBufferedItemCommand.ProtoReflect.Descriptor instead. func (*AddBufferedItemCommand) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{15} } func (x *AddBufferedItemCommand) GetServerHandle() int32 { if x != nil { return x.ServerHandle } return 0 } func (x *AddBufferedItemCommand) GetItemDefinition() string { if x != nil { return x.ItemDefinition } return "" } func (x *AddBufferedItemCommand) GetItemContext() string { if x != nil { return x.ItemContext } return "" } type SetBufferedUpdateIntervalCommand struct { state protoimpl.MessageState `protogen:"open.v1"` ServerHandle int32 `protobuf:"varint,1,opt,name=server_handle,json=serverHandle,proto3" json:"server_handle,omitempty"` UpdateIntervalMilliseconds int32 `protobuf:"varint,2,opt,name=update_interval_milliseconds,json=updateIntervalMilliseconds,proto3" json:"update_interval_milliseconds,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *SetBufferedUpdateIntervalCommand) Reset() { *x = SetBufferedUpdateIntervalCommand{} mi := &file_mxaccess_gateway_proto_msgTypes[16] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *SetBufferedUpdateIntervalCommand) String() string { return protoimpl.X.MessageStringOf(x) } func (*SetBufferedUpdateIntervalCommand) ProtoMessage() {} func (x *SetBufferedUpdateIntervalCommand) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 SetBufferedUpdateIntervalCommand.ProtoReflect.Descriptor instead. func (*SetBufferedUpdateIntervalCommand) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{16} } func (x *SetBufferedUpdateIntervalCommand) GetServerHandle() int32 { if x != nil { return x.ServerHandle } return 0 } func (x *SetBufferedUpdateIntervalCommand) GetUpdateIntervalMilliseconds() int32 { if x != nil { return x.UpdateIntervalMilliseconds } return 0 } type SuspendCommand struct { state protoimpl.MessageState `protogen:"open.v1"` ServerHandle int32 `protobuf:"varint,1,opt,name=server_handle,json=serverHandle,proto3" json:"server_handle,omitempty"` ItemHandle int32 `protobuf:"varint,2,opt,name=item_handle,json=itemHandle,proto3" json:"item_handle,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *SuspendCommand) Reset() { *x = SuspendCommand{} mi := &file_mxaccess_gateway_proto_msgTypes[17] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *SuspendCommand) String() string { return protoimpl.X.MessageStringOf(x) } func (*SuspendCommand) ProtoMessage() {} func (x *SuspendCommand) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 SuspendCommand.ProtoReflect.Descriptor instead. func (*SuspendCommand) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{17} } func (x *SuspendCommand) GetServerHandle() int32 { if x != nil { return x.ServerHandle } return 0 } func (x *SuspendCommand) GetItemHandle() int32 { if x != nil { return x.ItemHandle } return 0 } type ActivateCommand struct { state protoimpl.MessageState `protogen:"open.v1"` ServerHandle int32 `protobuf:"varint,1,opt,name=server_handle,json=serverHandle,proto3" json:"server_handle,omitempty"` ItemHandle int32 `protobuf:"varint,2,opt,name=item_handle,json=itemHandle,proto3" json:"item_handle,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *ActivateCommand) Reset() { *x = ActivateCommand{} mi := &file_mxaccess_gateway_proto_msgTypes[18] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *ActivateCommand) String() string { return protoimpl.X.MessageStringOf(x) } func (*ActivateCommand) ProtoMessage() {} func (x *ActivateCommand) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 ActivateCommand.ProtoReflect.Descriptor instead. func (*ActivateCommand) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{18} } func (x *ActivateCommand) GetServerHandle() int32 { if x != nil { return x.ServerHandle } return 0 } func (x *ActivateCommand) GetItemHandle() int32 { if x != nil { return x.ItemHandle } return 0 } type WriteCommand struct { state protoimpl.MessageState `protogen:"open.v1"` ServerHandle int32 `protobuf:"varint,1,opt,name=server_handle,json=serverHandle,proto3" json:"server_handle,omitempty"` ItemHandle int32 `protobuf:"varint,2,opt,name=item_handle,json=itemHandle,proto3" json:"item_handle,omitempty"` Value *MxValue `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` UserId int32 `protobuf:"varint,4,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *WriteCommand) Reset() { *x = WriteCommand{} mi := &file_mxaccess_gateway_proto_msgTypes[19] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *WriteCommand) String() string { return protoimpl.X.MessageStringOf(x) } func (*WriteCommand) ProtoMessage() {} func (x *WriteCommand) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 WriteCommand.ProtoReflect.Descriptor instead. func (*WriteCommand) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{19} } func (x *WriteCommand) GetServerHandle() int32 { if x != nil { return x.ServerHandle } return 0 } func (x *WriteCommand) GetItemHandle() int32 { if x != nil { return x.ItemHandle } return 0 } func (x *WriteCommand) GetValue() *MxValue { if x != nil { return x.Value } return nil } func (x *WriteCommand) GetUserId() int32 { if x != nil { return x.UserId } return 0 } type Write2Command struct { state protoimpl.MessageState `protogen:"open.v1"` ServerHandle int32 `protobuf:"varint,1,opt,name=server_handle,json=serverHandle,proto3" json:"server_handle,omitempty"` ItemHandle int32 `protobuf:"varint,2,opt,name=item_handle,json=itemHandle,proto3" json:"item_handle,omitempty"` Value *MxValue `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` TimestampValue *MxValue `protobuf:"bytes,4,opt,name=timestamp_value,json=timestampValue,proto3" json:"timestamp_value,omitempty"` UserId int32 `protobuf:"varint,5,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *Write2Command) Reset() { *x = Write2Command{} mi := &file_mxaccess_gateway_proto_msgTypes[20] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *Write2Command) String() string { return protoimpl.X.MessageStringOf(x) } func (*Write2Command) ProtoMessage() {} func (x *Write2Command) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 Write2Command.ProtoReflect.Descriptor instead. func (*Write2Command) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{20} } func (x *Write2Command) GetServerHandle() int32 { if x != nil { return x.ServerHandle } return 0 } func (x *Write2Command) GetItemHandle() int32 { if x != nil { return x.ItemHandle } return 0 } func (x *Write2Command) GetValue() *MxValue { if x != nil { return x.Value } return nil } func (x *Write2Command) GetTimestampValue() *MxValue { if x != nil { return x.TimestampValue } return nil } func (x *Write2Command) GetUserId() int32 { if x != nil { return x.UserId } return 0 } type WriteSecuredCommand struct { state protoimpl.MessageState `protogen:"open.v1"` ServerHandle int32 `protobuf:"varint,1,opt,name=server_handle,json=serverHandle,proto3" json:"server_handle,omitempty"` ItemHandle int32 `protobuf:"varint,2,opt,name=item_handle,json=itemHandle,proto3" json:"item_handle,omitempty"` CurrentUserId int32 `protobuf:"varint,3,opt,name=current_user_id,json=currentUserId,proto3" json:"current_user_id,omitempty"` VerifierUserId int32 `protobuf:"varint,4,opt,name=verifier_user_id,json=verifierUserId,proto3" json:"verifier_user_id,omitempty"` // Credential-sensitive write value. Implementations must not log this field // unless an explicit redacted value-logging path is enabled. Value *MxValue `protobuf:"bytes,5,opt,name=value,proto3" json:"value,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *WriteSecuredCommand) Reset() { *x = WriteSecuredCommand{} mi := &file_mxaccess_gateway_proto_msgTypes[21] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *WriteSecuredCommand) String() string { return protoimpl.X.MessageStringOf(x) } func (*WriteSecuredCommand) ProtoMessage() {} func (x *WriteSecuredCommand) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 WriteSecuredCommand.ProtoReflect.Descriptor instead. func (*WriteSecuredCommand) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{21} } func (x *WriteSecuredCommand) GetServerHandle() int32 { if x != nil { return x.ServerHandle } return 0 } func (x *WriteSecuredCommand) GetItemHandle() int32 { if x != nil { return x.ItemHandle } return 0 } func (x *WriteSecuredCommand) GetCurrentUserId() int32 { if x != nil { return x.CurrentUserId } return 0 } func (x *WriteSecuredCommand) GetVerifierUserId() int32 { if x != nil { return x.VerifierUserId } return 0 } func (x *WriteSecuredCommand) GetValue() *MxValue { if x != nil { return x.Value } return nil } type WriteSecured2Command struct { state protoimpl.MessageState `protogen:"open.v1"` ServerHandle int32 `protobuf:"varint,1,opt,name=server_handle,json=serverHandle,proto3" json:"server_handle,omitempty"` ItemHandle int32 `protobuf:"varint,2,opt,name=item_handle,json=itemHandle,proto3" json:"item_handle,omitempty"` CurrentUserId int32 `protobuf:"varint,3,opt,name=current_user_id,json=currentUserId,proto3" json:"current_user_id,omitempty"` VerifierUserId int32 `protobuf:"varint,4,opt,name=verifier_user_id,json=verifierUserId,proto3" json:"verifier_user_id,omitempty"` // Credential-sensitive write value. Implementations must not log this field // unless an explicit redacted value-logging path is enabled. Value *MxValue `protobuf:"bytes,5,opt,name=value,proto3" json:"value,omitempty"` TimestampValue *MxValue `protobuf:"bytes,6,opt,name=timestamp_value,json=timestampValue,proto3" json:"timestamp_value,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *WriteSecured2Command) Reset() { *x = WriteSecured2Command{} mi := &file_mxaccess_gateway_proto_msgTypes[22] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *WriteSecured2Command) String() string { return protoimpl.X.MessageStringOf(x) } func (*WriteSecured2Command) ProtoMessage() {} func (x *WriteSecured2Command) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 WriteSecured2Command.ProtoReflect.Descriptor instead. func (*WriteSecured2Command) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{22} } func (x *WriteSecured2Command) GetServerHandle() int32 { if x != nil { return x.ServerHandle } return 0 } func (x *WriteSecured2Command) GetItemHandle() int32 { if x != nil { return x.ItemHandle } return 0 } func (x *WriteSecured2Command) GetCurrentUserId() int32 { if x != nil { return x.CurrentUserId } return 0 } func (x *WriteSecured2Command) GetVerifierUserId() int32 { if x != nil { return x.VerifierUserId } return 0 } func (x *WriteSecured2Command) GetValue() *MxValue { if x != nil { return x.Value } return nil } func (x *WriteSecured2Command) GetTimestampValue() *MxValue { if x != nil { return x.TimestampValue } return nil } type AuthenticateUserCommand struct { state protoimpl.MessageState `protogen:"open.v1"` ServerHandle int32 `protobuf:"varint,1,opt,name=server_handle,json=serverHandle,proto3" json:"server_handle,omitempty"` VerifyUser string `protobuf:"bytes,2,opt,name=verify_user,json=verifyUser,proto3" json:"verify_user,omitempty"` // Raw MXAccess credential. Implementations must keep this field out of logs, // metrics labels, command lines, and diagnostics. VerifyUserPassword string `protobuf:"bytes,3,opt,name=verify_user_password,json=verifyUserPassword,proto3" json:"verify_user_password,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *AuthenticateUserCommand) Reset() { *x = AuthenticateUserCommand{} mi := &file_mxaccess_gateway_proto_msgTypes[23] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *AuthenticateUserCommand) String() string { return protoimpl.X.MessageStringOf(x) } func (*AuthenticateUserCommand) ProtoMessage() {} func (x *AuthenticateUserCommand) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 AuthenticateUserCommand.ProtoReflect.Descriptor instead. func (*AuthenticateUserCommand) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{23} } func (x *AuthenticateUserCommand) GetServerHandle() int32 { if x != nil { return x.ServerHandle } return 0 } func (x *AuthenticateUserCommand) GetVerifyUser() string { if x != nil { return x.VerifyUser } return "" } func (x *AuthenticateUserCommand) GetVerifyUserPassword() string { if x != nil { return x.VerifyUserPassword } return "" } type ArchestrAUserToIdCommand struct { state protoimpl.MessageState `protogen:"open.v1"` ServerHandle int32 `protobuf:"varint,1,opt,name=server_handle,json=serverHandle,proto3" json:"server_handle,omitempty"` UserIdGuid string `protobuf:"bytes,2,opt,name=user_id_guid,json=userIdGuid,proto3" json:"user_id_guid,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *ArchestrAUserToIdCommand) Reset() { *x = ArchestrAUserToIdCommand{} mi := &file_mxaccess_gateway_proto_msgTypes[24] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *ArchestrAUserToIdCommand) String() string { return protoimpl.X.MessageStringOf(x) } func (*ArchestrAUserToIdCommand) ProtoMessage() {} func (x *ArchestrAUserToIdCommand) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 ArchestrAUserToIdCommand.ProtoReflect.Descriptor instead. func (*ArchestrAUserToIdCommand) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{24} } func (x *ArchestrAUserToIdCommand) GetServerHandle() int32 { if x != nil { return x.ServerHandle } return 0 } func (x *ArchestrAUserToIdCommand) GetUserIdGuid() string { if x != nil { return x.UserIdGuid } return "" } type PingCommand struct { state protoimpl.MessageState `protogen:"open.v1"` Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *PingCommand) Reset() { *x = PingCommand{} mi := &file_mxaccess_gateway_proto_msgTypes[25] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *PingCommand) String() string { return protoimpl.X.MessageStringOf(x) } func (*PingCommand) ProtoMessage() {} func (x *PingCommand) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 PingCommand.ProtoReflect.Descriptor instead. func (*PingCommand) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{25} } func (x *PingCommand) GetMessage() string { if x != nil { return x.Message } return "" } type GetSessionStateCommand struct { state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *GetSessionStateCommand) Reset() { *x = GetSessionStateCommand{} mi := &file_mxaccess_gateway_proto_msgTypes[26] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *GetSessionStateCommand) String() string { return protoimpl.X.MessageStringOf(x) } func (*GetSessionStateCommand) ProtoMessage() {} func (x *GetSessionStateCommand) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 GetSessionStateCommand.ProtoReflect.Descriptor instead. func (*GetSessionStateCommand) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{26} } type GetWorkerInfoCommand struct { state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *GetWorkerInfoCommand) Reset() { *x = GetWorkerInfoCommand{} mi := &file_mxaccess_gateway_proto_msgTypes[27] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *GetWorkerInfoCommand) String() string { return protoimpl.X.MessageStringOf(x) } func (*GetWorkerInfoCommand) ProtoMessage() {} func (x *GetWorkerInfoCommand) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 GetWorkerInfoCommand.ProtoReflect.Descriptor instead. func (*GetWorkerInfoCommand) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{27} } type DrainEventsCommand struct { state protoimpl.MessageState `protogen:"open.v1"` MaxEvents uint32 `protobuf:"varint,1,opt,name=max_events,json=maxEvents,proto3" json:"max_events,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *DrainEventsCommand) Reset() { *x = DrainEventsCommand{} mi := &file_mxaccess_gateway_proto_msgTypes[28] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *DrainEventsCommand) String() string { return protoimpl.X.MessageStringOf(x) } func (*DrainEventsCommand) ProtoMessage() {} func (x *DrainEventsCommand) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 DrainEventsCommand.ProtoReflect.Descriptor instead. func (*DrainEventsCommand) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{28} } func (x *DrainEventsCommand) GetMaxEvents() uint32 { if x != nil { return x.MaxEvents } return 0 } type ShutdownWorkerCommand struct { state protoimpl.MessageState `protogen:"open.v1"` GracePeriod *durationpb.Duration `protobuf:"bytes,1,opt,name=grace_period,json=gracePeriod,proto3" json:"grace_period,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *ShutdownWorkerCommand) Reset() { *x = ShutdownWorkerCommand{} mi := &file_mxaccess_gateway_proto_msgTypes[29] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *ShutdownWorkerCommand) String() string { return protoimpl.X.MessageStringOf(x) } func (*ShutdownWorkerCommand) ProtoMessage() {} func (x *ShutdownWorkerCommand) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 ShutdownWorkerCommand.ProtoReflect.Descriptor instead. func (*ShutdownWorkerCommand) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{29} } func (x *ShutdownWorkerCommand) GetGracePeriod() *durationpb.Duration { if x != nil { return x.GracePeriod } return nil } type MxCommandReply struct { state protoimpl.MessageState `protogen:"open.v1"` SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` CorrelationId string `protobuf:"bytes,2,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"` Kind MxCommandKind `protobuf:"varint,3,opt,name=kind,proto3,enum=mxaccess_gateway.v1.MxCommandKind" json:"kind,omitempty"` ProtocolStatus *ProtocolStatus `protobuf:"bytes,4,opt,name=protocol_status,json=protocolStatus,proto3" json:"protocol_status,omitempty"` // HRESULT captured from MXAccess or a COM exception. This remains separate // from gateway protocol status so MXAccess parity details are not hidden by // transport failures. Hresult *int32 `protobuf:"varint,5,opt,name=hresult,proto3,oneof" json:"hresult,omitempty"` ReturnValue *MxValue `protobuf:"bytes,6,opt,name=return_value,json=returnValue,proto3" json:"return_value,omitempty"` Statuses []*MxStatusProxy `protobuf:"bytes,7,rep,name=statuses,proto3" json:"statuses,omitempty"` DiagnosticMessage string `protobuf:"bytes,8,opt,name=diagnostic_message,json=diagnosticMessage,proto3" json:"diagnostic_message,omitempty"` // Types that are valid to be assigned to Payload: // // *MxCommandReply_Register // *MxCommandReply_AddItem // *MxCommandReply_AddItem2 // *MxCommandReply_AddBufferedItem // *MxCommandReply_Suspend // *MxCommandReply_Activate // *MxCommandReply_AuthenticateUser // *MxCommandReply_ArchestraUserToId // *MxCommandReply_SessionState // *MxCommandReply_WorkerInfo // *MxCommandReply_DrainEvents Payload isMxCommandReply_Payload `protobuf_oneof:"payload"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *MxCommandReply) Reset() { *x = MxCommandReply{} mi := &file_mxaccess_gateway_proto_msgTypes[30] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *MxCommandReply) String() string { return protoimpl.X.MessageStringOf(x) } func (*MxCommandReply) ProtoMessage() {} func (x *MxCommandReply) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 MxCommandReply.ProtoReflect.Descriptor instead. func (*MxCommandReply) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{30} } func (x *MxCommandReply) GetSessionId() string { if x != nil { return x.SessionId } return "" } func (x *MxCommandReply) GetCorrelationId() string { if x != nil { return x.CorrelationId } return "" } func (x *MxCommandReply) GetKind() MxCommandKind { if x != nil { return x.Kind } return MxCommandKind_MX_COMMAND_KIND_UNSPECIFIED } func (x *MxCommandReply) GetProtocolStatus() *ProtocolStatus { if x != nil { return x.ProtocolStatus } return nil } func (x *MxCommandReply) GetHresult() int32 { if x != nil && x.Hresult != nil { return *x.Hresult } return 0 } func (x *MxCommandReply) GetReturnValue() *MxValue { if x != nil { return x.ReturnValue } return nil } func (x *MxCommandReply) GetStatuses() []*MxStatusProxy { if x != nil { return x.Statuses } return nil } func (x *MxCommandReply) GetDiagnosticMessage() string { if x != nil { return x.DiagnosticMessage } return "" } func (x *MxCommandReply) GetPayload() isMxCommandReply_Payload { if x != nil { return x.Payload } return nil } func (x *MxCommandReply) GetRegister() *RegisterReply { if x != nil { if x, ok := x.Payload.(*MxCommandReply_Register); ok { return x.Register } } return nil } func (x *MxCommandReply) GetAddItem() *AddItemReply { if x != nil { if x, ok := x.Payload.(*MxCommandReply_AddItem); ok { return x.AddItem } } return nil } func (x *MxCommandReply) GetAddItem2() *AddItem2Reply { if x != nil { if x, ok := x.Payload.(*MxCommandReply_AddItem2); ok { return x.AddItem2 } } return nil } func (x *MxCommandReply) GetAddBufferedItem() *AddBufferedItemReply { if x != nil { if x, ok := x.Payload.(*MxCommandReply_AddBufferedItem); ok { return x.AddBufferedItem } } return nil } func (x *MxCommandReply) GetSuspend() *SuspendReply { if x != nil { if x, ok := x.Payload.(*MxCommandReply_Suspend); ok { return x.Suspend } } return nil } func (x *MxCommandReply) GetActivate() *ActivateReply { if x != nil { if x, ok := x.Payload.(*MxCommandReply_Activate); ok { return x.Activate } } return nil } func (x *MxCommandReply) GetAuthenticateUser() *AuthenticateUserReply { if x != nil { if x, ok := x.Payload.(*MxCommandReply_AuthenticateUser); ok { return x.AuthenticateUser } } return nil } func (x *MxCommandReply) GetArchestraUserToId() *ArchestrAUserToIdReply { if x != nil { if x, ok := x.Payload.(*MxCommandReply_ArchestraUserToId); ok { return x.ArchestraUserToId } } return nil } func (x *MxCommandReply) GetSessionState() *SessionStateReply { if x != nil { if x, ok := x.Payload.(*MxCommandReply_SessionState); ok { return x.SessionState } } return nil } func (x *MxCommandReply) GetWorkerInfo() *WorkerInfoReply { if x != nil { if x, ok := x.Payload.(*MxCommandReply_WorkerInfo); ok { return x.WorkerInfo } } return nil } func (x *MxCommandReply) GetDrainEvents() *DrainEventsReply { if x != nil { if x, ok := x.Payload.(*MxCommandReply_DrainEvents); ok { return x.DrainEvents } } return nil } type isMxCommandReply_Payload interface { isMxCommandReply_Payload() } type MxCommandReply_Register struct { Register *RegisterReply `protobuf:"bytes,20,opt,name=register,proto3,oneof"` } type MxCommandReply_AddItem struct { AddItem *AddItemReply `protobuf:"bytes,21,opt,name=add_item,json=addItem,proto3,oneof"` } type MxCommandReply_AddItem2 struct { AddItem2 *AddItem2Reply `protobuf:"bytes,22,opt,name=add_item2,json=addItem2,proto3,oneof"` } type MxCommandReply_AddBufferedItem struct { AddBufferedItem *AddBufferedItemReply `protobuf:"bytes,23,opt,name=add_buffered_item,json=addBufferedItem,proto3,oneof"` } type MxCommandReply_Suspend struct { Suspend *SuspendReply `protobuf:"bytes,24,opt,name=suspend,proto3,oneof"` } type MxCommandReply_Activate struct { Activate *ActivateReply `protobuf:"bytes,25,opt,name=activate,proto3,oneof"` } type MxCommandReply_AuthenticateUser struct { AuthenticateUser *AuthenticateUserReply `protobuf:"bytes,26,opt,name=authenticate_user,json=authenticateUser,proto3,oneof"` } type MxCommandReply_ArchestraUserToId struct { ArchestraUserToId *ArchestrAUserToIdReply `protobuf:"bytes,27,opt,name=archestra_user_to_id,json=archestraUserToId,proto3,oneof"` } type MxCommandReply_SessionState struct { SessionState *SessionStateReply `protobuf:"bytes,100,opt,name=session_state,json=sessionState,proto3,oneof"` } type MxCommandReply_WorkerInfo struct { WorkerInfo *WorkerInfoReply `protobuf:"bytes,101,opt,name=worker_info,json=workerInfo,proto3,oneof"` } type MxCommandReply_DrainEvents struct { DrainEvents *DrainEventsReply `protobuf:"bytes,102,opt,name=drain_events,json=drainEvents,proto3,oneof"` } func (*MxCommandReply_Register) isMxCommandReply_Payload() {} func (*MxCommandReply_AddItem) isMxCommandReply_Payload() {} func (*MxCommandReply_AddItem2) isMxCommandReply_Payload() {} func (*MxCommandReply_AddBufferedItem) isMxCommandReply_Payload() {} func (*MxCommandReply_Suspend) isMxCommandReply_Payload() {} func (*MxCommandReply_Activate) isMxCommandReply_Payload() {} func (*MxCommandReply_AuthenticateUser) isMxCommandReply_Payload() {} func (*MxCommandReply_ArchestraUserToId) isMxCommandReply_Payload() {} func (*MxCommandReply_SessionState) isMxCommandReply_Payload() {} func (*MxCommandReply_WorkerInfo) isMxCommandReply_Payload() {} func (*MxCommandReply_DrainEvents) isMxCommandReply_Payload() {} type RegisterReply struct { state protoimpl.MessageState `protogen:"open.v1"` ServerHandle int32 `protobuf:"varint,1,opt,name=server_handle,json=serverHandle,proto3" json:"server_handle,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *RegisterReply) Reset() { *x = RegisterReply{} mi := &file_mxaccess_gateway_proto_msgTypes[31] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *RegisterReply) String() string { return protoimpl.X.MessageStringOf(x) } func (*RegisterReply) ProtoMessage() {} func (x *RegisterReply) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 RegisterReply.ProtoReflect.Descriptor instead. func (*RegisterReply) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{31} } func (x *RegisterReply) GetServerHandle() int32 { if x != nil { return x.ServerHandle } return 0 } type AddItemReply struct { state protoimpl.MessageState `protogen:"open.v1"` ItemHandle int32 `protobuf:"varint,1,opt,name=item_handle,json=itemHandle,proto3" json:"item_handle,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *AddItemReply) Reset() { *x = AddItemReply{} mi := &file_mxaccess_gateway_proto_msgTypes[32] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *AddItemReply) String() string { return protoimpl.X.MessageStringOf(x) } func (*AddItemReply) ProtoMessage() {} func (x *AddItemReply) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 AddItemReply.ProtoReflect.Descriptor instead. func (*AddItemReply) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{32} } func (x *AddItemReply) GetItemHandle() int32 { if x != nil { return x.ItemHandle } return 0 } type AddItem2Reply struct { state protoimpl.MessageState `protogen:"open.v1"` ItemHandle int32 `protobuf:"varint,1,opt,name=item_handle,json=itemHandle,proto3" json:"item_handle,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *AddItem2Reply) Reset() { *x = AddItem2Reply{} mi := &file_mxaccess_gateway_proto_msgTypes[33] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *AddItem2Reply) String() string { return protoimpl.X.MessageStringOf(x) } func (*AddItem2Reply) ProtoMessage() {} func (x *AddItem2Reply) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 AddItem2Reply.ProtoReflect.Descriptor instead. func (*AddItem2Reply) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{33} } func (x *AddItem2Reply) GetItemHandle() int32 { if x != nil { return x.ItemHandle } return 0 } type AddBufferedItemReply struct { state protoimpl.MessageState `protogen:"open.v1"` ItemHandle int32 `protobuf:"varint,1,opt,name=item_handle,json=itemHandle,proto3" json:"item_handle,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *AddBufferedItemReply) Reset() { *x = AddBufferedItemReply{} mi := &file_mxaccess_gateway_proto_msgTypes[34] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *AddBufferedItemReply) String() string { return protoimpl.X.MessageStringOf(x) } func (*AddBufferedItemReply) ProtoMessage() {} func (x *AddBufferedItemReply) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 AddBufferedItemReply.ProtoReflect.Descriptor instead. func (*AddBufferedItemReply) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{34} } func (x *AddBufferedItemReply) GetItemHandle() int32 { if x != nil { return x.ItemHandle } return 0 } type SuspendReply struct { state protoimpl.MessageState `protogen:"open.v1"` Status *MxStatusProxy `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *SuspendReply) Reset() { *x = SuspendReply{} mi := &file_mxaccess_gateway_proto_msgTypes[35] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *SuspendReply) String() string { return protoimpl.X.MessageStringOf(x) } func (*SuspendReply) ProtoMessage() {} func (x *SuspendReply) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 SuspendReply.ProtoReflect.Descriptor instead. func (*SuspendReply) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{35} } func (x *SuspendReply) GetStatus() *MxStatusProxy { if x != nil { return x.Status } return nil } type ActivateReply struct { state protoimpl.MessageState `protogen:"open.v1"` Status *MxStatusProxy `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *ActivateReply) Reset() { *x = ActivateReply{} mi := &file_mxaccess_gateway_proto_msgTypes[36] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *ActivateReply) String() string { return protoimpl.X.MessageStringOf(x) } func (*ActivateReply) ProtoMessage() {} func (x *ActivateReply) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 ActivateReply.ProtoReflect.Descriptor instead. func (*ActivateReply) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{36} } func (x *ActivateReply) GetStatus() *MxStatusProxy { if x != nil { return x.Status } return nil } type AuthenticateUserReply struct { state protoimpl.MessageState `protogen:"open.v1"` UserId int32 `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *AuthenticateUserReply) Reset() { *x = AuthenticateUserReply{} mi := &file_mxaccess_gateway_proto_msgTypes[37] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *AuthenticateUserReply) String() string { return protoimpl.X.MessageStringOf(x) } func (*AuthenticateUserReply) ProtoMessage() {} func (x *AuthenticateUserReply) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_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 AuthenticateUserReply.ProtoReflect.Descriptor instead. func (*AuthenticateUserReply) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{37} } func (x *AuthenticateUserReply) GetUserId() int32 { if x != nil { return x.UserId } return 0 } type ArchestrAUserToIdReply struct { state protoimpl.MessageState `protogen:"open.v1"` UserId int32 `protobuf:"varint,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *ArchestrAUserToIdReply) Reset() { *x = ArchestrAUserToIdReply{} mi := &file_mxaccess_gateway_proto_msgTypes[38] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *ArchestrAUserToIdReply) String() string { return protoimpl.X.MessageStringOf(x) } func (*ArchestrAUserToIdReply) ProtoMessage() {} func (x *ArchestrAUserToIdReply) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_proto_msgTypes[38] 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 ArchestrAUserToIdReply.ProtoReflect.Descriptor instead. func (*ArchestrAUserToIdReply) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{38} } func (x *ArchestrAUserToIdReply) GetUserId() int32 { if x != nil { return x.UserId } return 0 } type SessionStateReply struct { state protoimpl.MessageState `protogen:"open.v1"` State SessionState `protobuf:"varint,1,opt,name=state,proto3,enum=mxaccess_gateway.v1.SessionState" json:"state,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *SessionStateReply) Reset() { *x = SessionStateReply{} mi := &file_mxaccess_gateway_proto_msgTypes[39] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *SessionStateReply) String() string { return protoimpl.X.MessageStringOf(x) } func (*SessionStateReply) ProtoMessage() {} func (x *SessionStateReply) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_proto_msgTypes[39] 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 SessionStateReply.ProtoReflect.Descriptor instead. func (*SessionStateReply) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{39} } func (x *SessionStateReply) GetState() SessionState { if x != nil { return x.State } return SessionState_SESSION_STATE_UNSPECIFIED } type WorkerInfoReply struct { state protoimpl.MessageState `protogen:"open.v1"` WorkerProcessId int32 `protobuf:"varint,1,opt,name=worker_process_id,json=workerProcessId,proto3" json:"worker_process_id,omitempty"` WorkerVersion string `protobuf:"bytes,2,opt,name=worker_version,json=workerVersion,proto3" json:"worker_version,omitempty"` MxaccessProgid string `protobuf:"bytes,3,opt,name=mxaccess_progid,json=mxaccessProgid,proto3" json:"mxaccess_progid,omitempty"` MxaccessClsid string `protobuf:"bytes,4,opt,name=mxaccess_clsid,json=mxaccessClsid,proto3" json:"mxaccess_clsid,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *WorkerInfoReply) Reset() { *x = WorkerInfoReply{} mi := &file_mxaccess_gateway_proto_msgTypes[40] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *WorkerInfoReply) String() string { return protoimpl.X.MessageStringOf(x) } func (*WorkerInfoReply) ProtoMessage() {} func (x *WorkerInfoReply) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_proto_msgTypes[40] 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 WorkerInfoReply.ProtoReflect.Descriptor instead. func (*WorkerInfoReply) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{40} } func (x *WorkerInfoReply) GetWorkerProcessId() int32 { if x != nil { return x.WorkerProcessId } return 0 } func (x *WorkerInfoReply) GetWorkerVersion() string { if x != nil { return x.WorkerVersion } return "" } func (x *WorkerInfoReply) GetMxaccessProgid() string { if x != nil { return x.MxaccessProgid } return "" } func (x *WorkerInfoReply) GetMxaccessClsid() string { if x != nil { return x.MxaccessClsid } return "" } type DrainEventsReply struct { state protoimpl.MessageState `protogen:"open.v1"` Events []*MxEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *DrainEventsReply) Reset() { *x = DrainEventsReply{} mi := &file_mxaccess_gateway_proto_msgTypes[41] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *DrainEventsReply) String() string { return protoimpl.X.MessageStringOf(x) } func (*DrainEventsReply) ProtoMessage() {} func (x *DrainEventsReply) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_proto_msgTypes[41] 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 DrainEventsReply.ProtoReflect.Descriptor instead. func (*DrainEventsReply) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{41} } func (x *DrainEventsReply) GetEvents() []*MxEvent { if x != nil { return x.Events } return nil } type MxEvent struct { state protoimpl.MessageState `protogen:"open.v1"` Family MxEventFamily `protobuf:"varint,1,opt,name=family,proto3,enum=mxaccess_gateway.v1.MxEventFamily" json:"family,omitempty"` SessionId string `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` ServerHandle int32 `protobuf:"varint,3,opt,name=server_handle,json=serverHandle,proto3" json:"server_handle,omitempty"` ItemHandle int32 `protobuf:"varint,4,opt,name=item_handle,json=itemHandle,proto3" json:"item_handle,omitempty"` Value *MxValue `protobuf:"bytes,5,opt,name=value,proto3" json:"value,omitempty"` Quality int32 `protobuf:"varint,6,opt,name=quality,proto3" json:"quality,omitempty"` SourceTimestamp *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=source_timestamp,json=sourceTimestamp,proto3" json:"source_timestamp,omitempty"` Statuses []*MxStatusProxy `protobuf:"bytes,8,rep,name=statuses,proto3" json:"statuses,omitempty"` WorkerSequence uint64 `protobuf:"varint,9,opt,name=worker_sequence,json=workerSequence,proto3" json:"worker_sequence,omitempty"` WorkerTimestamp *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=worker_timestamp,json=workerTimestamp,proto3" json:"worker_timestamp,omitempty"` GatewayReceiveTimestamp *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=gateway_receive_timestamp,json=gatewayReceiveTimestamp,proto3" json:"gateway_receive_timestamp,omitempty"` Hresult *int32 `protobuf:"varint,12,opt,name=hresult,proto3,oneof" json:"hresult,omitempty"` RawStatus string `protobuf:"bytes,13,opt,name=raw_status,json=rawStatus,proto3" json:"raw_status,omitempty"` // Types that are valid to be assigned to Body: // // *MxEvent_OnDataChange // *MxEvent_OnWriteComplete // *MxEvent_OperationComplete // *MxEvent_OnBufferedDataChange Body isMxEvent_Body `protobuf_oneof:"body"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *MxEvent) Reset() { *x = MxEvent{} mi := &file_mxaccess_gateway_proto_msgTypes[42] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *MxEvent) String() string { return protoimpl.X.MessageStringOf(x) } func (*MxEvent) ProtoMessage() {} func (x *MxEvent) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_proto_msgTypes[42] 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 MxEvent.ProtoReflect.Descriptor instead. func (*MxEvent) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{42} } func (x *MxEvent) GetFamily() MxEventFamily { if x != nil { return x.Family } return MxEventFamily_MX_EVENT_FAMILY_UNSPECIFIED } func (x *MxEvent) GetSessionId() string { if x != nil { return x.SessionId } return "" } func (x *MxEvent) GetServerHandle() int32 { if x != nil { return x.ServerHandle } return 0 } func (x *MxEvent) GetItemHandle() int32 { if x != nil { return x.ItemHandle } return 0 } func (x *MxEvent) GetValue() *MxValue { if x != nil { return x.Value } return nil } func (x *MxEvent) GetQuality() int32 { if x != nil { return x.Quality } return 0 } func (x *MxEvent) GetSourceTimestamp() *timestamppb.Timestamp { if x != nil { return x.SourceTimestamp } return nil } func (x *MxEvent) GetStatuses() []*MxStatusProxy { if x != nil { return x.Statuses } return nil } func (x *MxEvent) GetWorkerSequence() uint64 { if x != nil { return x.WorkerSequence } return 0 } func (x *MxEvent) GetWorkerTimestamp() *timestamppb.Timestamp { if x != nil { return x.WorkerTimestamp } return nil } func (x *MxEvent) GetGatewayReceiveTimestamp() *timestamppb.Timestamp { if x != nil { return x.GatewayReceiveTimestamp } return nil } func (x *MxEvent) GetHresult() int32 { if x != nil && x.Hresult != nil { return *x.Hresult } return 0 } func (x *MxEvent) GetRawStatus() string { if x != nil { return x.RawStatus } return "" } func (x *MxEvent) GetBody() isMxEvent_Body { if x != nil { return x.Body } return nil } func (x *MxEvent) GetOnDataChange() *OnDataChangeEvent { if x != nil { if x, ok := x.Body.(*MxEvent_OnDataChange); ok { return x.OnDataChange } } return nil } func (x *MxEvent) GetOnWriteComplete() *OnWriteCompleteEvent { if x != nil { if x, ok := x.Body.(*MxEvent_OnWriteComplete); ok { return x.OnWriteComplete } } return nil } func (x *MxEvent) GetOperationComplete() *OperationCompleteEvent { if x != nil { if x, ok := x.Body.(*MxEvent_OperationComplete); ok { return x.OperationComplete } } return nil } func (x *MxEvent) GetOnBufferedDataChange() *OnBufferedDataChangeEvent { if x != nil { if x, ok := x.Body.(*MxEvent_OnBufferedDataChange); ok { return x.OnBufferedDataChange } } return nil } type isMxEvent_Body interface { isMxEvent_Body() } type MxEvent_OnDataChange struct { OnDataChange *OnDataChangeEvent `protobuf:"bytes,20,opt,name=on_data_change,json=onDataChange,proto3,oneof"` } type MxEvent_OnWriteComplete struct { OnWriteComplete *OnWriteCompleteEvent `protobuf:"bytes,21,opt,name=on_write_complete,json=onWriteComplete,proto3,oneof"` } type MxEvent_OperationComplete struct { OperationComplete *OperationCompleteEvent `protobuf:"bytes,22,opt,name=operation_complete,json=operationComplete,proto3,oneof"` } type MxEvent_OnBufferedDataChange struct { OnBufferedDataChange *OnBufferedDataChangeEvent `protobuf:"bytes,23,opt,name=on_buffered_data_change,json=onBufferedDataChange,proto3,oneof"` } func (*MxEvent_OnDataChange) isMxEvent_Body() {} func (*MxEvent_OnWriteComplete) isMxEvent_Body() {} func (*MxEvent_OperationComplete) isMxEvent_Body() {} func (*MxEvent_OnBufferedDataChange) isMxEvent_Body() {} type OnDataChangeEvent struct { state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *OnDataChangeEvent) Reset() { *x = OnDataChangeEvent{} mi := &file_mxaccess_gateway_proto_msgTypes[43] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *OnDataChangeEvent) String() string { return protoimpl.X.MessageStringOf(x) } func (*OnDataChangeEvent) ProtoMessage() {} func (x *OnDataChangeEvent) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_proto_msgTypes[43] 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 OnDataChangeEvent.ProtoReflect.Descriptor instead. func (*OnDataChangeEvent) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{43} } type OnWriteCompleteEvent struct { state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *OnWriteCompleteEvent) Reset() { *x = OnWriteCompleteEvent{} mi := &file_mxaccess_gateway_proto_msgTypes[44] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *OnWriteCompleteEvent) String() string { return protoimpl.X.MessageStringOf(x) } func (*OnWriteCompleteEvent) ProtoMessage() {} func (x *OnWriteCompleteEvent) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_proto_msgTypes[44] 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 OnWriteCompleteEvent.ProtoReflect.Descriptor instead. func (*OnWriteCompleteEvent) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{44} } type OperationCompleteEvent struct { state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *OperationCompleteEvent) Reset() { *x = OperationCompleteEvent{} mi := &file_mxaccess_gateway_proto_msgTypes[45] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *OperationCompleteEvent) String() string { return protoimpl.X.MessageStringOf(x) } func (*OperationCompleteEvent) ProtoMessage() {} func (x *OperationCompleteEvent) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_proto_msgTypes[45] 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 OperationCompleteEvent.ProtoReflect.Descriptor instead. func (*OperationCompleteEvent) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{45} } type OnBufferedDataChangeEvent struct { state protoimpl.MessageState `protogen:"open.v1"` DataType MxDataType `protobuf:"varint,1,opt,name=data_type,json=dataType,proto3,enum=mxaccess_gateway.v1.MxDataType" json:"data_type,omitempty"` QualityValues *MxArray `protobuf:"bytes,2,opt,name=quality_values,json=qualityValues,proto3" json:"quality_values,omitempty"` TimestampValues *MxArray `protobuf:"bytes,3,opt,name=timestamp_values,json=timestampValues,proto3" json:"timestamp_values,omitempty"` RawDataType int32 `protobuf:"varint,4,opt,name=raw_data_type,json=rawDataType,proto3" json:"raw_data_type,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *OnBufferedDataChangeEvent) Reset() { *x = OnBufferedDataChangeEvent{} mi := &file_mxaccess_gateway_proto_msgTypes[46] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *OnBufferedDataChangeEvent) String() string { return protoimpl.X.MessageStringOf(x) } func (*OnBufferedDataChangeEvent) ProtoMessage() {} func (x *OnBufferedDataChangeEvent) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_proto_msgTypes[46] 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 OnBufferedDataChangeEvent.ProtoReflect.Descriptor instead. func (*OnBufferedDataChangeEvent) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{46} } func (x *OnBufferedDataChangeEvent) GetDataType() MxDataType { if x != nil { return x.DataType } return MxDataType_MX_DATA_TYPE_UNSPECIFIED } func (x *OnBufferedDataChangeEvent) GetQualityValues() *MxArray { if x != nil { return x.QualityValues } return nil } func (x *OnBufferedDataChangeEvent) GetTimestampValues() *MxArray { if x != nil { return x.TimestampValues } return nil } func (x *OnBufferedDataChangeEvent) GetRawDataType() int32 { if x != nil { return x.RawDataType } return 0 } type MxStatusProxy struct { state protoimpl.MessageState `protogen:"open.v1"` Success int32 `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Category MxStatusCategory `protobuf:"varint,2,opt,name=category,proto3,enum=mxaccess_gateway.v1.MxStatusCategory" json:"category,omitempty"` DetectedBy MxStatusSource `protobuf:"varint,3,opt,name=detected_by,json=detectedBy,proto3,enum=mxaccess_gateway.v1.MxStatusSource" json:"detected_by,omitempty"` Detail int32 `protobuf:"varint,4,opt,name=detail,proto3" json:"detail,omitempty"` RawCategory int32 `protobuf:"varint,5,opt,name=raw_category,json=rawCategory,proto3" json:"raw_category,omitempty"` RawDetectedBy int32 `protobuf:"varint,6,opt,name=raw_detected_by,json=rawDetectedBy,proto3" json:"raw_detected_by,omitempty"` DiagnosticText string `protobuf:"bytes,7,opt,name=diagnostic_text,json=diagnosticText,proto3" json:"diagnostic_text,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *MxStatusProxy) Reset() { *x = MxStatusProxy{} mi := &file_mxaccess_gateway_proto_msgTypes[47] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *MxStatusProxy) String() string { return protoimpl.X.MessageStringOf(x) } func (*MxStatusProxy) ProtoMessage() {} func (x *MxStatusProxy) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_proto_msgTypes[47] 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 MxStatusProxy.ProtoReflect.Descriptor instead. func (*MxStatusProxy) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{47} } func (x *MxStatusProxy) GetSuccess() int32 { if x != nil { return x.Success } return 0 } func (x *MxStatusProxy) GetCategory() MxStatusCategory { if x != nil { return x.Category } return MxStatusCategory_MX_STATUS_CATEGORY_UNSPECIFIED } func (x *MxStatusProxy) GetDetectedBy() MxStatusSource { if x != nil { return x.DetectedBy } return MxStatusSource_MX_STATUS_SOURCE_UNSPECIFIED } func (x *MxStatusProxy) GetDetail() int32 { if x != nil { return x.Detail } return 0 } func (x *MxStatusProxy) GetRawCategory() int32 { if x != nil { return x.RawCategory } return 0 } func (x *MxStatusProxy) GetRawDetectedBy() int32 { if x != nil { return x.RawDetectedBy } return 0 } func (x *MxStatusProxy) GetDiagnosticText() string { if x != nil { return x.DiagnosticText } return "" } type MxValue struct { state protoimpl.MessageState `protogen:"open.v1"` DataType MxDataType `protobuf:"varint,1,opt,name=data_type,json=dataType,proto3,enum=mxaccess_gateway.v1.MxDataType" json:"data_type,omitempty"` VariantType string `protobuf:"bytes,2,opt,name=variant_type,json=variantType,proto3" json:"variant_type,omitempty"` IsNull bool `protobuf:"varint,3,opt,name=is_null,json=isNull,proto3" json:"is_null,omitempty"` RawDiagnostic string `protobuf:"bytes,4,opt,name=raw_diagnostic,json=rawDiagnostic,proto3" json:"raw_diagnostic,omitempty"` RawDataType int32 `protobuf:"varint,5,opt,name=raw_data_type,json=rawDataType,proto3" json:"raw_data_type,omitempty"` // Types that are valid to be assigned to Kind: // // *MxValue_BoolValue // *MxValue_Int32Value // *MxValue_Int64Value // *MxValue_FloatValue // *MxValue_DoubleValue // *MxValue_StringValue // *MxValue_TimestampValue // *MxValue_ArrayValue // *MxValue_RawValue Kind isMxValue_Kind `protobuf_oneof:"kind"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *MxValue) Reset() { *x = MxValue{} mi := &file_mxaccess_gateway_proto_msgTypes[48] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *MxValue) String() string { return protoimpl.X.MessageStringOf(x) } func (*MxValue) ProtoMessage() {} func (x *MxValue) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_proto_msgTypes[48] 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 MxValue.ProtoReflect.Descriptor instead. func (*MxValue) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{48} } func (x *MxValue) GetDataType() MxDataType { if x != nil { return x.DataType } return MxDataType_MX_DATA_TYPE_UNSPECIFIED } func (x *MxValue) GetVariantType() string { if x != nil { return x.VariantType } return "" } func (x *MxValue) GetIsNull() bool { if x != nil { return x.IsNull } return false } func (x *MxValue) GetRawDiagnostic() string { if x != nil { return x.RawDiagnostic } return "" } func (x *MxValue) GetRawDataType() int32 { if x != nil { return x.RawDataType } return 0 } func (x *MxValue) GetKind() isMxValue_Kind { if x != nil { return x.Kind } return nil } func (x *MxValue) GetBoolValue() bool { if x != nil { if x, ok := x.Kind.(*MxValue_BoolValue); ok { return x.BoolValue } } return false } func (x *MxValue) GetInt32Value() int32 { if x != nil { if x, ok := x.Kind.(*MxValue_Int32Value); ok { return x.Int32Value } } return 0 } func (x *MxValue) GetInt64Value() int64 { if x != nil { if x, ok := x.Kind.(*MxValue_Int64Value); ok { return x.Int64Value } } return 0 } func (x *MxValue) GetFloatValue() float32 { if x != nil { if x, ok := x.Kind.(*MxValue_FloatValue); ok { return x.FloatValue } } return 0 } func (x *MxValue) GetDoubleValue() float64 { if x != nil { if x, ok := x.Kind.(*MxValue_DoubleValue); ok { return x.DoubleValue } } return 0 } func (x *MxValue) GetStringValue() string { if x != nil { if x, ok := x.Kind.(*MxValue_StringValue); ok { return x.StringValue } } return "" } func (x *MxValue) GetTimestampValue() *timestamppb.Timestamp { if x != nil { if x, ok := x.Kind.(*MxValue_TimestampValue); ok { return x.TimestampValue } } return nil } func (x *MxValue) GetArrayValue() *MxArray { if x != nil { if x, ok := x.Kind.(*MxValue_ArrayValue); ok { return x.ArrayValue } } return nil } func (x *MxValue) GetRawValue() []byte { if x != nil { if x, ok := x.Kind.(*MxValue_RawValue); ok { return x.RawValue } } return nil } type isMxValue_Kind interface { isMxValue_Kind() } type MxValue_BoolValue struct { BoolValue bool `protobuf:"varint,10,opt,name=bool_value,json=boolValue,proto3,oneof"` } type MxValue_Int32Value struct { Int32Value int32 `protobuf:"varint,11,opt,name=int32_value,json=int32Value,proto3,oneof"` } type MxValue_Int64Value struct { Int64Value int64 `protobuf:"varint,12,opt,name=int64_value,json=int64Value,proto3,oneof"` } type MxValue_FloatValue struct { FloatValue float32 `protobuf:"fixed32,13,opt,name=float_value,json=floatValue,proto3,oneof"` } type MxValue_DoubleValue struct { DoubleValue float64 `protobuf:"fixed64,14,opt,name=double_value,json=doubleValue,proto3,oneof"` } type MxValue_StringValue struct { StringValue string `protobuf:"bytes,15,opt,name=string_value,json=stringValue,proto3,oneof"` } type MxValue_TimestampValue struct { TimestampValue *timestamppb.Timestamp `protobuf:"bytes,16,opt,name=timestamp_value,json=timestampValue,proto3,oneof"` } type MxValue_ArrayValue struct { ArrayValue *MxArray `protobuf:"bytes,17,opt,name=array_value,json=arrayValue,proto3,oneof"` } type MxValue_RawValue struct { RawValue []byte `protobuf:"bytes,18,opt,name=raw_value,json=rawValue,proto3,oneof"` } func (*MxValue_BoolValue) isMxValue_Kind() {} func (*MxValue_Int32Value) isMxValue_Kind() {} func (*MxValue_Int64Value) isMxValue_Kind() {} func (*MxValue_FloatValue) isMxValue_Kind() {} func (*MxValue_DoubleValue) isMxValue_Kind() {} func (*MxValue_StringValue) isMxValue_Kind() {} func (*MxValue_TimestampValue) isMxValue_Kind() {} func (*MxValue_ArrayValue) isMxValue_Kind() {} func (*MxValue_RawValue) isMxValue_Kind() {} type MxArray struct { state protoimpl.MessageState `protogen:"open.v1"` ElementDataType MxDataType `protobuf:"varint,1,opt,name=element_data_type,json=elementDataType,proto3,enum=mxaccess_gateway.v1.MxDataType" json:"element_data_type,omitempty"` VariantType string `protobuf:"bytes,2,opt,name=variant_type,json=variantType,proto3" json:"variant_type,omitempty"` Dimensions []uint32 `protobuf:"varint,3,rep,packed,name=dimensions,proto3" json:"dimensions,omitempty"` RawDiagnostic string `protobuf:"bytes,4,opt,name=raw_diagnostic,json=rawDiagnostic,proto3" json:"raw_diagnostic,omitempty"` RawElementDataType int32 `protobuf:"varint,5,opt,name=raw_element_data_type,json=rawElementDataType,proto3" json:"raw_element_data_type,omitempty"` // Types that are valid to be assigned to Values: // // *MxArray_BoolValues // *MxArray_Int32Values // *MxArray_Int64Values // *MxArray_FloatValues // *MxArray_DoubleValues // *MxArray_StringValues // *MxArray_TimestampValues // *MxArray_RawValues Values isMxArray_Values `protobuf_oneof:"values"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *MxArray) Reset() { *x = MxArray{} mi := &file_mxaccess_gateway_proto_msgTypes[49] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *MxArray) String() string { return protoimpl.X.MessageStringOf(x) } func (*MxArray) ProtoMessage() {} func (x *MxArray) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_proto_msgTypes[49] 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 MxArray.ProtoReflect.Descriptor instead. func (*MxArray) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{49} } func (x *MxArray) GetElementDataType() MxDataType { if x != nil { return x.ElementDataType } return MxDataType_MX_DATA_TYPE_UNSPECIFIED } func (x *MxArray) GetVariantType() string { if x != nil { return x.VariantType } return "" } func (x *MxArray) GetDimensions() []uint32 { if x != nil { return x.Dimensions } return nil } func (x *MxArray) GetRawDiagnostic() string { if x != nil { return x.RawDiagnostic } return "" } func (x *MxArray) GetRawElementDataType() int32 { if x != nil { return x.RawElementDataType } return 0 } func (x *MxArray) GetValues() isMxArray_Values { if x != nil { return x.Values } return nil } func (x *MxArray) GetBoolValues() *BoolArray { if x != nil { if x, ok := x.Values.(*MxArray_BoolValues); ok { return x.BoolValues } } return nil } func (x *MxArray) GetInt32Values() *Int32Array { if x != nil { if x, ok := x.Values.(*MxArray_Int32Values); ok { return x.Int32Values } } return nil } func (x *MxArray) GetInt64Values() *Int64Array { if x != nil { if x, ok := x.Values.(*MxArray_Int64Values); ok { return x.Int64Values } } return nil } func (x *MxArray) GetFloatValues() *FloatArray { if x != nil { if x, ok := x.Values.(*MxArray_FloatValues); ok { return x.FloatValues } } return nil } func (x *MxArray) GetDoubleValues() *DoubleArray { if x != nil { if x, ok := x.Values.(*MxArray_DoubleValues); ok { return x.DoubleValues } } return nil } func (x *MxArray) GetStringValues() *StringArray { if x != nil { if x, ok := x.Values.(*MxArray_StringValues); ok { return x.StringValues } } return nil } func (x *MxArray) GetTimestampValues() *TimestampArray { if x != nil { if x, ok := x.Values.(*MxArray_TimestampValues); ok { return x.TimestampValues } } return nil } func (x *MxArray) GetRawValues() *RawArray { if x != nil { if x, ok := x.Values.(*MxArray_RawValues); ok { return x.RawValues } } return nil } type isMxArray_Values interface { isMxArray_Values() } type MxArray_BoolValues struct { BoolValues *BoolArray `protobuf:"bytes,10,opt,name=bool_values,json=boolValues,proto3,oneof"` } type MxArray_Int32Values struct { Int32Values *Int32Array `protobuf:"bytes,11,opt,name=int32_values,json=int32Values,proto3,oneof"` } type MxArray_Int64Values struct { Int64Values *Int64Array `protobuf:"bytes,12,opt,name=int64_values,json=int64Values,proto3,oneof"` } type MxArray_FloatValues struct { FloatValues *FloatArray `protobuf:"bytes,13,opt,name=float_values,json=floatValues,proto3,oneof"` } type MxArray_DoubleValues struct { DoubleValues *DoubleArray `protobuf:"bytes,14,opt,name=double_values,json=doubleValues,proto3,oneof"` } type MxArray_StringValues struct { StringValues *StringArray `protobuf:"bytes,15,opt,name=string_values,json=stringValues,proto3,oneof"` } type MxArray_TimestampValues struct { TimestampValues *TimestampArray `protobuf:"bytes,16,opt,name=timestamp_values,json=timestampValues,proto3,oneof"` } type MxArray_RawValues struct { RawValues *RawArray `protobuf:"bytes,17,opt,name=raw_values,json=rawValues,proto3,oneof"` } func (*MxArray_BoolValues) isMxArray_Values() {} func (*MxArray_Int32Values) isMxArray_Values() {} func (*MxArray_Int64Values) isMxArray_Values() {} func (*MxArray_FloatValues) isMxArray_Values() {} func (*MxArray_DoubleValues) isMxArray_Values() {} func (*MxArray_StringValues) isMxArray_Values() {} func (*MxArray_TimestampValues) isMxArray_Values() {} func (*MxArray_RawValues) isMxArray_Values() {} type BoolArray struct { state protoimpl.MessageState `protogen:"open.v1"` Values []bool `protobuf:"varint,1,rep,packed,name=values,proto3" json:"values,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *BoolArray) Reset() { *x = BoolArray{} mi := &file_mxaccess_gateway_proto_msgTypes[50] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *BoolArray) String() string { return protoimpl.X.MessageStringOf(x) } func (*BoolArray) ProtoMessage() {} func (x *BoolArray) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_proto_msgTypes[50] 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 BoolArray.ProtoReflect.Descriptor instead. func (*BoolArray) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{50} } func (x *BoolArray) GetValues() []bool { if x != nil { return x.Values } return nil } type Int32Array struct { state protoimpl.MessageState `protogen:"open.v1"` Values []int32 `protobuf:"varint,1,rep,packed,name=values,proto3" json:"values,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *Int32Array) Reset() { *x = Int32Array{} mi := &file_mxaccess_gateway_proto_msgTypes[51] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *Int32Array) String() string { return protoimpl.X.MessageStringOf(x) } func (*Int32Array) ProtoMessage() {} func (x *Int32Array) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_proto_msgTypes[51] 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 Int32Array.ProtoReflect.Descriptor instead. func (*Int32Array) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{51} } func (x *Int32Array) GetValues() []int32 { if x != nil { return x.Values } return nil } type Int64Array struct { state protoimpl.MessageState `protogen:"open.v1"` Values []int64 `protobuf:"varint,1,rep,packed,name=values,proto3" json:"values,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *Int64Array) Reset() { *x = Int64Array{} mi := &file_mxaccess_gateway_proto_msgTypes[52] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *Int64Array) String() string { return protoimpl.X.MessageStringOf(x) } func (*Int64Array) ProtoMessage() {} func (x *Int64Array) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_proto_msgTypes[52] 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 Int64Array.ProtoReflect.Descriptor instead. func (*Int64Array) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{52} } func (x *Int64Array) GetValues() []int64 { if x != nil { return x.Values } return nil } type FloatArray struct { state protoimpl.MessageState `protogen:"open.v1"` Values []float32 `protobuf:"fixed32,1,rep,packed,name=values,proto3" json:"values,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *FloatArray) Reset() { *x = FloatArray{} mi := &file_mxaccess_gateway_proto_msgTypes[53] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *FloatArray) String() string { return protoimpl.X.MessageStringOf(x) } func (*FloatArray) ProtoMessage() {} func (x *FloatArray) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_proto_msgTypes[53] 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 FloatArray.ProtoReflect.Descriptor instead. func (*FloatArray) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{53} } func (x *FloatArray) GetValues() []float32 { if x != nil { return x.Values } return nil } type DoubleArray struct { state protoimpl.MessageState `protogen:"open.v1"` Values []float64 `protobuf:"fixed64,1,rep,packed,name=values,proto3" json:"values,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *DoubleArray) Reset() { *x = DoubleArray{} mi := &file_mxaccess_gateway_proto_msgTypes[54] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *DoubleArray) String() string { return protoimpl.X.MessageStringOf(x) } func (*DoubleArray) ProtoMessage() {} func (x *DoubleArray) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_proto_msgTypes[54] 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 DoubleArray.ProtoReflect.Descriptor instead. func (*DoubleArray) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{54} } func (x *DoubleArray) GetValues() []float64 { if x != nil { return x.Values } return nil } type StringArray struct { state protoimpl.MessageState `protogen:"open.v1"` Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *StringArray) Reset() { *x = StringArray{} mi := &file_mxaccess_gateway_proto_msgTypes[55] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *StringArray) String() string { return protoimpl.X.MessageStringOf(x) } func (*StringArray) ProtoMessage() {} func (x *StringArray) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_proto_msgTypes[55] 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 StringArray.ProtoReflect.Descriptor instead. func (*StringArray) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{55} } func (x *StringArray) GetValues() []string { if x != nil { return x.Values } return nil } type TimestampArray struct { state protoimpl.MessageState `protogen:"open.v1"` Values []*timestamppb.Timestamp `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *TimestampArray) Reset() { *x = TimestampArray{} mi := &file_mxaccess_gateway_proto_msgTypes[56] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *TimestampArray) String() string { return protoimpl.X.MessageStringOf(x) } func (*TimestampArray) ProtoMessage() {} func (x *TimestampArray) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_proto_msgTypes[56] 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 TimestampArray.ProtoReflect.Descriptor instead. func (*TimestampArray) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{56} } func (x *TimestampArray) GetValues() []*timestamppb.Timestamp { if x != nil { return x.Values } return nil } type RawArray struct { state protoimpl.MessageState `protogen:"open.v1"` Values [][]byte `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *RawArray) Reset() { *x = RawArray{} mi := &file_mxaccess_gateway_proto_msgTypes[57] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *RawArray) String() string { return protoimpl.X.MessageStringOf(x) } func (*RawArray) ProtoMessage() {} func (x *RawArray) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_proto_msgTypes[57] 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 RawArray.ProtoReflect.Descriptor instead. func (*RawArray) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{57} } func (x *RawArray) GetValues() [][]byte { if x != nil { return x.Values } return nil } type ProtocolStatus struct { state protoimpl.MessageState `protogen:"open.v1"` Code ProtocolStatusCode `protobuf:"varint,1,opt,name=code,proto3,enum=mxaccess_gateway.v1.ProtocolStatusCode" json:"code,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache } func (x *ProtocolStatus) Reset() { *x = ProtocolStatus{} mi := &file_mxaccess_gateway_proto_msgTypes[58] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } func (x *ProtocolStatus) String() string { return protoimpl.X.MessageStringOf(x) } func (*ProtocolStatus) ProtoMessage() {} func (x *ProtocolStatus) ProtoReflect() protoreflect.Message { mi := &file_mxaccess_gateway_proto_msgTypes[58] 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 ProtocolStatus.ProtoReflect.Descriptor instead. func (*ProtocolStatus) Descriptor() ([]byte, []int) { return file_mxaccess_gateway_proto_rawDescGZIP(), []int{58} } func (x *ProtocolStatus) GetCode() ProtocolStatusCode { if x != nil { return x.Code } return ProtocolStatusCode_PROTOCOL_STATUS_CODE_UNSPECIFIED } func (x *ProtocolStatus) GetMessage() string { if x != nil { return x.Message } return "" } var File_mxaccess_gateway_proto protoreflect.FileDescriptor const file_mxaccess_gateway_proto_rawDesc = "" + "\n" + "\x16mxaccess_gateway.proto\x12\x13mxaccess_gateway.v1\x1a\x1egoogle/protobuf/duration.proto\x1a\x1fgoogle/protobuf/timestamp.proto\"\xe9\x01\n" + "\x12OpenSessionRequest\x12+\n" + "\x11requested_backend\x18\x01 \x01(\tR\x10requestedBackend\x12.\n" + "\x13client_session_name\x18\x02 \x01(\tR\x11clientSessionName\x122\n" + "\x15client_correlation_id\x18\x03 \x01(\tR\x13clientCorrelationId\x12B\n" + "\x0fcommand_timeout\x18\x04 \x01(\v2\x19.google.protobuf.DurationR\x0ecommandTimeout\"\xb7\x03\n" + "\x10OpenSessionReply\x12\x1d\n" + "\n" + "session_id\x18\x01 \x01(\tR\tsessionId\x12!\n" + "\fbackend_name\x18\x02 \x01(\tR\vbackendName\x12*\n" + "\x11worker_process_id\x18\x03 \x01(\x05R\x0fworkerProcessId\x126\n" + "\x17worker_protocol_version\x18\x04 \x01(\rR\x15workerProtocolVersion\x12\"\n" + "\fcapabilities\x18\x05 \x03(\tR\fcapabilities\x12Q\n" + "\x17default_command_timeout\x18\x06 \x01(\v2\x19.google.protobuf.DurationR\x15defaultCommandTimeout\x12L\n" + "\x0fprotocol_status\x18\a \x01(\v2#.mxaccess_gateway.v1.ProtocolStatusR\x0eprotocolStatus\x128\n" + "\x18gateway_protocol_version\x18\b \x01(\rR\x16gatewayProtocolVersion\"h\n" + "\x13CloseSessionRequest\x12\x1d\n" + "\n" + "session_id\x18\x01 \x01(\tR\tsessionId\x122\n" + "\x15client_correlation_id\x18\x02 \x01(\tR\x13clientCorrelationId\"\xc4\x01\n" + "\x11CloseSessionReply\x12\x1d\n" + "\n" + "session_id\x18\x01 \x01(\tR\tsessionId\x12B\n" + "\vfinal_state\x18\x02 \x01(\x0e2!.mxaccess_gateway.v1.SessionStateR\n" + "finalState\x12L\n" + "\x0fprotocol_status\x18\x03 \x01(\v2#.mxaccess_gateway.v1.ProtocolStatusR\x0eprotocolStatus\"h\n" + "\x13StreamEventsRequest\x12\x1d\n" + "\n" + "session_id\x18\x01 \x01(\tR\tsessionId\x122\n" + "\x15after_worker_sequence\x18\x02 \x01(\x04R\x13afterWorkerSequence\"\x9f\x01\n" + "\x10MxCommandRequest\x12\x1d\n" + "\n" + "session_id\x18\x01 \x01(\tR\tsessionId\x122\n" + "\x15client_correlation_id\x18\x02 \x01(\tR\x13clientCorrelationId\x128\n" + "\acommand\x18\x03 \x01(\v2\x1e.mxaccess_gateway.v1.MxCommandR\acommand\"\xd5\x0e\n" + "\tMxCommand\x126\n" + "\x04kind\x18\x01 \x01(\x0e2\".mxaccess_gateway.v1.MxCommandKindR\x04kind\x12B\n" + "\bregister\x18\n" + " \x01(\v2$.mxaccess_gateway.v1.RegisterCommandH\x00R\bregister\x12H\n" + "\n" + "unregister\x18\v \x01(\v2&.mxaccess_gateway.v1.UnregisterCommandH\x00R\n" + "unregister\x12@\n" + "\badd_item\x18\f \x01(\v2#.mxaccess_gateway.v1.AddItemCommandH\x00R\aaddItem\x12C\n" + "\tadd_item2\x18\r \x01(\v2$.mxaccess_gateway.v1.AddItem2CommandH\x00R\baddItem2\x12I\n" + "\vremove_item\x18\x0e \x01(\v2&.mxaccess_gateway.v1.RemoveItemCommandH\x00R\n" + "removeItem\x12<\n" + "\x06advise\x18\x0f \x01(\v2\".mxaccess_gateway.v1.AdviseCommandH\x00R\x06advise\x12C\n" + "\tun_advise\x18\x10 \x01(\v2$.mxaccess_gateway.v1.UnAdviseCommandH\x00R\bunAdvise\x12^\n" + "\x12advise_supervisory\x18\x11 \x01(\v2-.mxaccess_gateway.v1.AdviseSupervisoryCommandH\x00R\x11adviseSupervisory\x12Y\n" + "\x11add_buffered_item\x18\x12 \x01(\v2+.mxaccess_gateway.v1.AddBufferedItemCommandH\x00R\x0faddBufferedItem\x12x\n" + "\x1cset_buffered_update_interval\x18\x13 \x01(\v25.mxaccess_gateway.v1.SetBufferedUpdateIntervalCommandH\x00R\x19setBufferedUpdateInterval\x12?\n" + "\asuspend\x18\x14 \x01(\v2#.mxaccess_gateway.v1.SuspendCommandH\x00R\asuspend\x12B\n" + "\bactivate\x18\x15 \x01(\v2$.mxaccess_gateway.v1.ActivateCommandH\x00R\bactivate\x129\n" + "\x05write\x18\x16 \x01(\v2!.mxaccess_gateway.v1.WriteCommandH\x00R\x05write\x12<\n" + "\x06write2\x18\x17 \x01(\v2\".mxaccess_gateway.v1.Write2CommandH\x00R\x06write2\x12O\n" + "\rwrite_secured\x18\x18 \x01(\v2(.mxaccess_gateway.v1.WriteSecuredCommandH\x00R\fwriteSecured\x12R\n" + "\x0ewrite_secured2\x18\x19 \x01(\v2).mxaccess_gateway.v1.WriteSecured2CommandH\x00R\rwriteSecured2\x12[\n" + "\x11authenticate_user\x18\x1a \x01(\v2,.mxaccess_gateway.v1.AuthenticateUserCommandH\x00R\x10authenticateUser\x12`\n" + "\x14archestra_user_to_id\x18\x1b \x01(\v2-.mxaccess_gateway.v1.ArchestrAUserToIdCommandH\x00R\x11archestraUserToId\x126\n" + "\x04ping\x18d \x01(\v2 .mxaccess_gateway.v1.PingCommandH\x00R\x04ping\x12Y\n" + "\x11get_session_state\x18e \x01(\v2+.mxaccess_gateway.v1.GetSessionStateCommandH\x00R\x0fgetSessionState\x12S\n" + "\x0fget_worker_info\x18f \x01(\v2).mxaccess_gateway.v1.GetWorkerInfoCommandH\x00R\rgetWorkerInfo\x12L\n" + "\fdrain_events\x18g \x01(\v2'.mxaccess_gateway.v1.DrainEventsCommandH\x00R\vdrainEvents\x12U\n" + "\x0fshutdown_worker\x18h \x01(\v2*.mxaccess_gateway.v1.ShutdownWorkerCommandH\x00R\x0eshutdownWorkerB\t\n" + "\apayload\"2\n" + "\x0fRegisterCommand\x12\x1f\n" + "\vclient_name\x18\x01 \x01(\tR\n" + "clientName\"8\n" + "\x11UnregisterCommand\x12#\n" + "\rserver_handle\x18\x01 \x01(\x05R\fserverHandle\"^\n" + "\x0eAddItemCommand\x12#\n" + "\rserver_handle\x18\x01 \x01(\x05R\fserverHandle\x12'\n" + "\x0fitem_definition\x18\x02 \x01(\tR\x0eitemDefinition\"\x82\x01\n" + "\x0fAddItem2Command\x12#\n" + "\rserver_handle\x18\x01 \x01(\x05R\fserverHandle\x12'\n" + "\x0fitem_definition\x18\x02 \x01(\tR\x0eitemDefinition\x12!\n" + "\fitem_context\x18\x03 \x01(\tR\vitemContext\"Y\n" + "\x11RemoveItemCommand\x12#\n" + "\rserver_handle\x18\x01 \x01(\x05R\fserverHandle\x12\x1f\n" + "\vitem_handle\x18\x02 \x01(\x05R\n" + "itemHandle\"U\n" + "\rAdviseCommand\x12#\n" + "\rserver_handle\x18\x01 \x01(\x05R\fserverHandle\x12\x1f\n" + "\vitem_handle\x18\x02 \x01(\x05R\n" + "itemHandle\"W\n" + "\x0fUnAdviseCommand\x12#\n" + "\rserver_handle\x18\x01 \x01(\x05R\fserverHandle\x12\x1f\n" + "\vitem_handle\x18\x02 \x01(\x05R\n" + "itemHandle\"`\n" + "\x18AdviseSupervisoryCommand\x12#\n" + "\rserver_handle\x18\x01 \x01(\x05R\fserverHandle\x12\x1f\n" + "\vitem_handle\x18\x02 \x01(\x05R\n" + "itemHandle\"\x89\x01\n" + "\x16AddBufferedItemCommand\x12#\n" + "\rserver_handle\x18\x01 \x01(\x05R\fserverHandle\x12'\n" + "\x0fitem_definition\x18\x02 \x01(\tR\x0eitemDefinition\x12!\n" + "\fitem_context\x18\x03 \x01(\tR\vitemContext\"\x89\x01\n" + " SetBufferedUpdateIntervalCommand\x12#\n" + "\rserver_handle\x18\x01 \x01(\x05R\fserverHandle\x12@\n" + "\x1cupdate_interval_milliseconds\x18\x02 \x01(\x05R\x1aupdateIntervalMilliseconds\"V\n" + "\x0eSuspendCommand\x12#\n" + "\rserver_handle\x18\x01 \x01(\x05R\fserverHandle\x12\x1f\n" + "\vitem_handle\x18\x02 \x01(\x05R\n" + "itemHandle\"W\n" + "\x0fActivateCommand\x12#\n" + "\rserver_handle\x18\x01 \x01(\x05R\fserverHandle\x12\x1f\n" + "\vitem_handle\x18\x02 \x01(\x05R\n" + "itemHandle\"\xa1\x01\n" + "\fWriteCommand\x12#\n" + "\rserver_handle\x18\x01 \x01(\x05R\fserverHandle\x12\x1f\n" + "\vitem_handle\x18\x02 \x01(\x05R\n" + "itemHandle\x122\n" + "\x05value\x18\x03 \x01(\v2\x1c.mxaccess_gateway.v1.MxValueR\x05value\x12\x17\n" + "\auser_id\x18\x04 \x01(\x05R\x06userId\"\xe9\x01\n" + "\rWrite2Command\x12#\n" + "\rserver_handle\x18\x01 \x01(\x05R\fserverHandle\x12\x1f\n" + "\vitem_handle\x18\x02 \x01(\x05R\n" + "itemHandle\x122\n" + "\x05value\x18\x03 \x01(\v2\x1c.mxaccess_gateway.v1.MxValueR\x05value\x12E\n" + "\x0ftimestamp_value\x18\x04 \x01(\v2\x1c.mxaccess_gateway.v1.MxValueR\x0etimestampValue\x12\x17\n" + "\auser_id\x18\x05 \x01(\x05R\x06userId\"\xe1\x01\n" + "\x13WriteSecuredCommand\x12#\n" + "\rserver_handle\x18\x01 \x01(\x05R\fserverHandle\x12\x1f\n" + "\vitem_handle\x18\x02 \x01(\x05R\n" + "itemHandle\x12&\n" + "\x0fcurrent_user_id\x18\x03 \x01(\x05R\rcurrentUserId\x12(\n" + "\x10verifier_user_id\x18\x04 \x01(\x05R\x0everifierUserId\x122\n" + "\x05value\x18\x05 \x01(\v2\x1c.mxaccess_gateway.v1.MxValueR\x05value\"\xa9\x02\n" + "\x14WriteSecured2Command\x12#\n" + "\rserver_handle\x18\x01 \x01(\x05R\fserverHandle\x12\x1f\n" + "\vitem_handle\x18\x02 \x01(\x05R\n" + "itemHandle\x12&\n" + "\x0fcurrent_user_id\x18\x03 \x01(\x05R\rcurrentUserId\x12(\n" + "\x10verifier_user_id\x18\x04 \x01(\x05R\x0everifierUserId\x122\n" + "\x05value\x18\x05 \x01(\v2\x1c.mxaccess_gateway.v1.MxValueR\x05value\x12E\n" + "\x0ftimestamp_value\x18\x06 \x01(\v2\x1c.mxaccess_gateway.v1.MxValueR\x0etimestampValue\"\x91\x01\n" + "\x17AuthenticateUserCommand\x12#\n" + "\rserver_handle\x18\x01 \x01(\x05R\fserverHandle\x12\x1f\n" + "\vverify_user\x18\x02 \x01(\tR\n" + "verifyUser\x120\n" + "\x14verify_user_password\x18\x03 \x01(\tR\x12verifyUserPassword\"a\n" + "\x18ArchestrAUserToIdCommand\x12#\n" + "\rserver_handle\x18\x01 \x01(\x05R\fserverHandle\x12 \n" + "\fuser_id_guid\x18\x02 \x01(\tR\n" + "userIdGuid\"'\n" + "\vPingCommand\x12\x18\n" + "\amessage\x18\x01 \x01(\tR\amessage\"\x18\n" + "\x16GetSessionStateCommand\"\x16\n" + "\x14GetWorkerInfoCommand\"3\n" + "\x12DrainEventsCommand\x12\x1d\n" + "\n" + "max_events\x18\x01 \x01(\rR\tmaxEvents\"U\n" + "\x15ShutdownWorkerCommand\x12<\n" + "\fgrace_period\x18\x01 \x01(\v2\x19.google.protobuf.DurationR\vgracePeriod\"\x80\n" + "\n" + "\x0eMxCommandReply\x12\x1d\n" + "\n" + "session_id\x18\x01 \x01(\tR\tsessionId\x12%\n" + "\x0ecorrelation_id\x18\x02 \x01(\tR\rcorrelationId\x126\n" + "\x04kind\x18\x03 \x01(\x0e2\".mxaccess_gateway.v1.MxCommandKindR\x04kind\x12L\n" + "\x0fprotocol_status\x18\x04 \x01(\v2#.mxaccess_gateway.v1.ProtocolStatusR\x0eprotocolStatus\x12\x1d\n" + "\ahresult\x18\x05 \x01(\x05H\x01R\ahresult\x88\x01\x01\x12?\n" + "\freturn_value\x18\x06 \x01(\v2\x1c.mxaccess_gateway.v1.MxValueR\vreturnValue\x12>\n" + "\bstatuses\x18\a \x03(\v2\".mxaccess_gateway.v1.MxStatusProxyR\bstatuses\x12-\n" + "\x12diagnostic_message\x18\b \x01(\tR\x11diagnosticMessage\x12@\n" + "\bregister\x18\x14 \x01(\v2\".mxaccess_gateway.v1.RegisterReplyH\x00R\bregister\x12>\n" + "\badd_item\x18\x15 \x01(\v2!.mxaccess_gateway.v1.AddItemReplyH\x00R\aaddItem\x12A\n" + "\tadd_item2\x18\x16 \x01(\v2\".mxaccess_gateway.v1.AddItem2ReplyH\x00R\baddItem2\x12W\n" + "\x11add_buffered_item\x18\x17 \x01(\v2).mxaccess_gateway.v1.AddBufferedItemReplyH\x00R\x0faddBufferedItem\x12=\n" + "\asuspend\x18\x18 \x01(\v2!.mxaccess_gateway.v1.SuspendReplyH\x00R\asuspend\x12@\n" + "\bactivate\x18\x19 \x01(\v2\".mxaccess_gateway.v1.ActivateReplyH\x00R\bactivate\x12Y\n" + "\x11authenticate_user\x18\x1a \x01(\v2*.mxaccess_gateway.v1.AuthenticateUserReplyH\x00R\x10authenticateUser\x12^\n" + "\x14archestra_user_to_id\x18\x1b \x01(\v2+.mxaccess_gateway.v1.ArchestrAUserToIdReplyH\x00R\x11archestraUserToId\x12M\n" + "\rsession_state\x18d \x01(\v2&.mxaccess_gateway.v1.SessionStateReplyH\x00R\fsessionState\x12G\n" + "\vworker_info\x18e \x01(\v2$.mxaccess_gateway.v1.WorkerInfoReplyH\x00R\n" + "workerInfo\x12J\n" + "\fdrain_events\x18f \x01(\v2%.mxaccess_gateway.v1.DrainEventsReplyH\x00R\vdrainEventsB\t\n" + "\apayloadB\n" + "\n" + "\b_hresult\"4\n" + "\rRegisterReply\x12#\n" + "\rserver_handle\x18\x01 \x01(\x05R\fserverHandle\"/\n" + "\fAddItemReply\x12\x1f\n" + "\vitem_handle\x18\x01 \x01(\x05R\n" + "itemHandle\"0\n" + "\rAddItem2Reply\x12\x1f\n" + "\vitem_handle\x18\x01 \x01(\x05R\n" + "itemHandle\"7\n" + "\x14AddBufferedItemReply\x12\x1f\n" + "\vitem_handle\x18\x01 \x01(\x05R\n" + "itemHandle\"J\n" + "\fSuspendReply\x12:\n" + "\x06status\x18\x01 \x01(\v2\".mxaccess_gateway.v1.MxStatusProxyR\x06status\"K\n" + "\rActivateReply\x12:\n" + "\x06status\x18\x01 \x01(\v2\".mxaccess_gateway.v1.MxStatusProxyR\x06status\"0\n" + "\x15AuthenticateUserReply\x12\x17\n" + "\auser_id\x18\x01 \x01(\x05R\x06userId\"1\n" + "\x16ArchestrAUserToIdReply\x12\x17\n" + "\auser_id\x18\x01 \x01(\x05R\x06userId\"L\n" + "\x11SessionStateReply\x127\n" + "\x05state\x18\x01 \x01(\x0e2!.mxaccess_gateway.v1.SessionStateR\x05state\"\xb4\x01\n" + "\x0fWorkerInfoReply\x12*\n" + "\x11worker_process_id\x18\x01 \x01(\x05R\x0fworkerProcessId\x12%\n" + "\x0eworker_version\x18\x02 \x01(\tR\rworkerVersion\x12'\n" + "\x0fmxaccess_progid\x18\x03 \x01(\tR\x0emxaccessProgid\x12%\n" + "\x0emxaccess_clsid\x18\x04 \x01(\tR\rmxaccessClsid\"H\n" + "\x10DrainEventsReply\x124\n" + "\x06events\x18\x01 \x03(\v2\x1c.mxaccess_gateway.v1.MxEventR\x06events\"\x89\b\n" + "\aMxEvent\x12:\n" + "\x06family\x18\x01 \x01(\x0e2\".mxaccess_gateway.v1.MxEventFamilyR\x06family\x12\x1d\n" + "\n" + "session_id\x18\x02 \x01(\tR\tsessionId\x12#\n" + "\rserver_handle\x18\x03 \x01(\x05R\fserverHandle\x12\x1f\n" + "\vitem_handle\x18\x04 \x01(\x05R\n" + "itemHandle\x122\n" + "\x05value\x18\x05 \x01(\v2\x1c.mxaccess_gateway.v1.MxValueR\x05value\x12\x18\n" + "\aquality\x18\x06 \x01(\x05R\aquality\x12E\n" + "\x10source_timestamp\x18\a \x01(\v2\x1a.google.protobuf.TimestampR\x0fsourceTimestamp\x12>\n" + "\bstatuses\x18\b \x03(\v2\".mxaccess_gateway.v1.MxStatusProxyR\bstatuses\x12'\n" + "\x0fworker_sequence\x18\t \x01(\x04R\x0eworkerSequence\x12E\n" + "\x10worker_timestamp\x18\n" + " \x01(\v2\x1a.google.protobuf.TimestampR\x0fworkerTimestamp\x12V\n" + "\x19gateway_receive_timestamp\x18\v \x01(\v2\x1a.google.protobuf.TimestampR\x17gatewayReceiveTimestamp\x12\x1d\n" + "\ahresult\x18\f \x01(\x05H\x01R\ahresult\x88\x01\x01\x12\x1d\n" + "\n" + "raw_status\x18\r \x01(\tR\trawStatus\x12N\n" + "\x0eon_data_change\x18\x14 \x01(\v2&.mxaccess_gateway.v1.OnDataChangeEventH\x00R\fonDataChange\x12W\n" + "\x11on_write_complete\x18\x15 \x01(\v2).mxaccess_gateway.v1.OnWriteCompleteEventH\x00R\x0fonWriteComplete\x12\\\n" + "\x12operation_complete\x18\x16 \x01(\v2+.mxaccess_gateway.v1.OperationCompleteEventH\x00R\x11operationComplete\x12g\n" + "\x17on_buffered_data_change\x18\x17 \x01(\v2..mxaccess_gateway.v1.OnBufferedDataChangeEventH\x00R\x14onBufferedDataChangeB\x06\n" + "\x04bodyB\n" + "\n" + "\b_hresult\"\x13\n" + "\x11OnDataChangeEvent\"\x16\n" + "\x14OnWriteCompleteEvent\"\x18\n" + "\x16OperationCompleteEvent\"\x8b\x02\n" + "\x19OnBufferedDataChangeEvent\x12<\n" + "\tdata_type\x18\x01 \x01(\x0e2\x1f.mxaccess_gateway.v1.MxDataTypeR\bdataType\x12C\n" + "\x0equality_values\x18\x02 \x01(\v2\x1c.mxaccess_gateway.v1.MxArrayR\rqualityValues\x12G\n" + "\x10timestamp_values\x18\x03 \x01(\v2\x1c.mxaccess_gateway.v1.MxArrayR\x0ftimestampValues\x12\"\n" + "\rraw_data_type\x18\x04 \x01(\x05R\vrawDataType\"\xbe\x02\n" + "\rMxStatusProxy\x12\x18\n" + "\asuccess\x18\x01 \x01(\x05R\asuccess\x12A\n" + "\bcategory\x18\x02 \x01(\x0e2%.mxaccess_gateway.v1.MxStatusCategoryR\bcategory\x12D\n" + "\vdetected_by\x18\x03 \x01(\x0e2#.mxaccess_gateway.v1.MxStatusSourceR\n" + "detectedBy\x12\x16\n" + "\x06detail\x18\x04 \x01(\x05R\x06detail\x12!\n" + "\fraw_category\x18\x05 \x01(\x05R\vrawCategory\x12&\n" + "\x0fraw_detected_by\x18\x06 \x01(\x05R\rrawDetectedBy\x12'\n" + "\x0fdiagnostic_text\x18\a \x01(\tR\x0ediagnosticText\"\xd1\x04\n" + "\aMxValue\x12<\n" + "\tdata_type\x18\x01 \x01(\x0e2\x1f.mxaccess_gateway.v1.MxDataTypeR\bdataType\x12!\n" + "\fvariant_type\x18\x02 \x01(\tR\vvariantType\x12\x17\n" + "\ais_null\x18\x03 \x01(\bR\x06isNull\x12%\n" + "\x0eraw_diagnostic\x18\x04 \x01(\tR\rrawDiagnostic\x12\"\n" + "\rraw_data_type\x18\x05 \x01(\x05R\vrawDataType\x12\x1f\n" + "\n" + "bool_value\x18\n" + " \x01(\bH\x00R\tboolValue\x12!\n" + "\vint32_value\x18\v \x01(\x05H\x00R\n" + "int32Value\x12!\n" + "\vint64_value\x18\f \x01(\x03H\x00R\n" + "int64Value\x12!\n" + "\vfloat_value\x18\r \x01(\x02H\x00R\n" + "floatValue\x12#\n" + "\fdouble_value\x18\x0e \x01(\x01H\x00R\vdoubleValue\x12#\n" + "\fstring_value\x18\x0f \x01(\tH\x00R\vstringValue\x12E\n" + "\x0ftimestamp_value\x18\x10 \x01(\v2\x1a.google.protobuf.TimestampH\x00R\x0etimestampValue\x12?\n" + "\varray_value\x18\x11 \x01(\v2\x1c.mxaccess_gateway.v1.MxArrayH\x00R\n" + "arrayValue\x12\x1d\n" + "\traw_value\x18\x12 \x01(\fH\x00R\brawValueB\x06\n" + "\x04kind\"\xb6\x06\n" + "\aMxArray\x12K\n" + "\x11element_data_type\x18\x01 \x01(\x0e2\x1f.mxaccess_gateway.v1.MxDataTypeR\x0felementDataType\x12!\n" + "\fvariant_type\x18\x02 \x01(\tR\vvariantType\x12\x1e\n" + "\n" + "dimensions\x18\x03 \x03(\rR\n" + "dimensions\x12%\n" + "\x0eraw_diagnostic\x18\x04 \x01(\tR\rrawDiagnostic\x121\n" + "\x15raw_element_data_type\x18\x05 \x01(\x05R\x12rawElementDataType\x12A\n" + "\vbool_values\x18\n" + " \x01(\v2\x1e.mxaccess_gateway.v1.BoolArrayH\x00R\n" + "boolValues\x12D\n" + "\fint32_values\x18\v \x01(\v2\x1f.mxaccess_gateway.v1.Int32ArrayH\x00R\vint32Values\x12D\n" + "\fint64_values\x18\f \x01(\v2\x1f.mxaccess_gateway.v1.Int64ArrayH\x00R\vint64Values\x12D\n" + "\ffloat_values\x18\r \x01(\v2\x1f.mxaccess_gateway.v1.FloatArrayH\x00R\vfloatValues\x12G\n" + "\rdouble_values\x18\x0e \x01(\v2 .mxaccess_gateway.v1.DoubleArrayH\x00R\fdoubleValues\x12G\n" + "\rstring_values\x18\x0f \x01(\v2 .mxaccess_gateway.v1.StringArrayH\x00R\fstringValues\x12P\n" + "\x10timestamp_values\x18\x10 \x01(\v2#.mxaccess_gateway.v1.TimestampArrayH\x00R\x0ftimestampValues\x12>\n" + "\n" + "raw_values\x18\x11 \x01(\v2\x1d.mxaccess_gateway.v1.RawArrayH\x00R\trawValuesB\b\n" + "\x06values\"#\n" + "\tBoolArray\x12\x16\n" + "\x06values\x18\x01 \x03(\bR\x06values\"$\n" + "\n" + "Int32Array\x12\x16\n" + "\x06values\x18\x01 \x03(\x05R\x06values\"$\n" + "\n" + "Int64Array\x12\x16\n" + "\x06values\x18\x01 \x03(\x03R\x06values\"$\n" + "\n" + "FloatArray\x12\x16\n" + "\x06values\x18\x01 \x03(\x02R\x06values\"%\n" + "\vDoubleArray\x12\x16\n" + "\x06values\x18\x01 \x03(\x01R\x06values\"%\n" + "\vStringArray\x12\x16\n" + "\x06values\x18\x01 \x03(\tR\x06values\"D\n" + "\x0eTimestampArray\x122\n" + "\x06values\x18\x01 \x03(\v2\x1a.google.protobuf.TimestampR\x06values\"\"\n" + "\bRawArray\x12\x16\n" + "\x06values\x18\x01 \x03(\fR\x06values\"g\n" + "\x0eProtocolStatus\x12;\n" + "\x04code\x18\x01 \x01(\x0e2'.mxaccess_gateway.v1.ProtocolStatusCodeR\x04code\x12\x18\n" + "\amessage\x18\x02 \x01(\tR\amessage*\xbf\x06\n" + "\rMxCommandKind\x12\x1f\n" + "\x1bMX_COMMAND_KIND_UNSPECIFIED\x10\x00\x12\x1c\n" + "\x18MX_COMMAND_KIND_REGISTER\x10\x01\x12\x1e\n" + "\x1aMX_COMMAND_KIND_UNREGISTER\x10\x02\x12\x1c\n" + "\x18MX_COMMAND_KIND_ADD_ITEM\x10\x03\x12\x1d\n" + "\x19MX_COMMAND_KIND_ADD_ITEM2\x10\x04\x12\x1f\n" + "\x1bMX_COMMAND_KIND_REMOVE_ITEM\x10\x05\x12\x1a\n" + "\x16MX_COMMAND_KIND_ADVISE\x10\x06\x12\x1d\n" + "\x19MX_COMMAND_KIND_UN_ADVISE\x10\a\x12&\n" + "\"MX_COMMAND_KIND_ADVISE_SUPERVISORY\x10\b\x12%\n" + "!MX_COMMAND_KIND_ADD_BUFFERED_ITEM\x10\t\x120\n" + ",MX_COMMAND_KIND_SET_BUFFERED_UPDATE_INTERVAL\x10\n" + "\x12\x1b\n" + "\x17MX_COMMAND_KIND_SUSPEND\x10\v\x12\x1c\n" + "\x18MX_COMMAND_KIND_ACTIVATE\x10\f\x12\x19\n" + "\x15MX_COMMAND_KIND_WRITE\x10\r\x12\x1a\n" + "\x16MX_COMMAND_KIND_WRITE2\x10\x0e\x12!\n" + "\x1dMX_COMMAND_KIND_WRITE_SECURED\x10\x0f\x12\"\n" + "\x1eMX_COMMAND_KIND_WRITE_SECURED2\x10\x10\x12%\n" + "!MX_COMMAND_KIND_AUTHENTICATE_USER\x10\x11\x12(\n" + "$MX_COMMAND_KIND_ARCHESTRA_USER_TO_ID\x10\x12\x12\x18\n" + "\x14MX_COMMAND_KIND_PING\x10d\x12%\n" + "!MX_COMMAND_KIND_GET_SESSION_STATE\x10e\x12#\n" + "\x1fMX_COMMAND_KIND_GET_WORKER_INFO\x10f\x12 \n" + "\x1cMX_COMMAND_KIND_DRAIN_EVENTS\x10g\x12#\n" + "\x1fMX_COMMAND_KIND_SHUTDOWN_WORKER\x10h*\xd0\x01\n" + "\rMxEventFamily\x12\x1f\n" + "\x1bMX_EVENT_FAMILY_UNSPECIFIED\x10\x00\x12\"\n" + "\x1eMX_EVENT_FAMILY_ON_DATA_CHANGE\x10\x01\x12%\n" + "!MX_EVENT_FAMILY_ON_WRITE_COMPLETE\x10\x02\x12&\n" + "\"MX_EVENT_FAMILY_OPERATION_COMPLETE\x10\x03\x12+\n" + "'MX_EVENT_FAMILY_ON_BUFFERED_DATA_CHANGE\x10\x04*\xa5\x03\n" + "\x10MxStatusCategory\x12\"\n" + "\x1eMX_STATUS_CATEGORY_UNSPECIFIED\x10\x00\x12\x1e\n" + "\x1aMX_STATUS_CATEGORY_UNKNOWN\x10\x01\x12\x19\n" + "\x15MX_STATUS_CATEGORY_OK\x10\x02\x12\x1e\n" + "\x1aMX_STATUS_CATEGORY_PENDING\x10\x03\x12\x1e\n" + "\x1aMX_STATUS_CATEGORY_WARNING\x10\x04\x12*\n" + "&MX_STATUS_CATEGORY_COMMUNICATION_ERROR\x10\x05\x12*\n" + "&MX_STATUS_CATEGORY_CONFIGURATION_ERROR\x10\x06\x12(\n" + "$MX_STATUS_CATEGORY_OPERATIONAL_ERROR\x10\a\x12%\n" + "!MX_STATUS_CATEGORY_SECURITY_ERROR\x10\b\x12%\n" + "!MX_STATUS_CATEGORY_SOFTWARE_ERROR\x10\t\x12\"\n" + "\x1eMX_STATUS_CATEGORY_OTHER_ERROR\x10\n" + "*\xca\x02\n" + "\x0eMxStatusSource\x12 \n" + "\x1cMX_STATUS_SOURCE_UNSPECIFIED\x10\x00\x12\x1c\n" + "\x18MX_STATUS_SOURCE_UNKNOWN\x10\x01\x12#\n" + "\x1fMX_STATUS_SOURCE_REQUESTING_LMX\x10\x02\x12#\n" + "\x1fMX_STATUS_SOURCE_RESPONDING_LMX\x10\x03\x12#\n" + "\x1fMX_STATUS_SOURCE_REQUESTING_NMX\x10\x04\x12#\n" + "\x1fMX_STATUS_SOURCE_RESPONDING_NMX\x10\x05\x121\n" + "-MX_STATUS_SOURCE_REQUESTING_AUTOMATION_OBJECT\x10\x06\x121\n" + "-MX_STATUS_SOURCE_RESPONDING_AUTOMATION_OBJECT\x10\a*\xdd\x04\n" + "\n" + "MxDataType\x12\x1c\n" + "\x18MX_DATA_TYPE_UNSPECIFIED\x10\x00\x12\x18\n" + "\x14MX_DATA_TYPE_UNKNOWN\x10\x01\x12\x18\n" + "\x14MX_DATA_TYPE_NO_DATA\x10\x02\x12\x18\n" + "\x14MX_DATA_TYPE_BOOLEAN\x10\x03\x12\x18\n" + "\x14MX_DATA_TYPE_INTEGER\x10\x04\x12\x16\n" + "\x12MX_DATA_TYPE_FLOAT\x10\x05\x12\x17\n" + "\x13MX_DATA_TYPE_DOUBLE\x10\x06\x12\x17\n" + "\x13MX_DATA_TYPE_STRING\x10\a\x12\x15\n" + "\x11MX_DATA_TYPE_TIME\x10\b\x12\x1d\n" + "\x19MX_DATA_TYPE_ELAPSED_TIME\x10\t\x12\x1f\n" + "\x1bMX_DATA_TYPE_REFERENCE_TYPE\x10\n" + "\x12\x1c\n" + "\x18MX_DATA_TYPE_STATUS_TYPE\x10\v\x12\x15\n" + "\x11MX_DATA_TYPE_ENUM\x10\f\x12-\n" + ")MX_DATA_TYPE_SECURITY_CLASSIFICATION_ENUM\x10\r\x12\"\n" + "\x1eMX_DATA_TYPE_DATA_QUALITY_TYPE\x10\x0e\x12\x1f\n" + "\x1bMX_DATA_TYPE_QUALIFIED_ENUM\x10\x0f\x12!\n" + "\x1dMX_DATA_TYPE_QUALIFIED_STRUCT\x10\x10\x12)\n" + "%MX_DATA_TYPE_INTERNATIONALIZED_STRING\x10\x11\x12\x1b\n" + "\x17MX_DATA_TYPE_BIG_STRING\x10\x12\x12\x14\n" + "\x10MX_DATA_TYPE_END\x10\x13*\xa3\x03\n" + "\x12ProtocolStatusCode\x12$\n" + " PROTOCOL_STATUS_CODE_UNSPECIFIED\x10\x00\x12\x1b\n" + "\x17PROTOCOL_STATUS_CODE_OK\x10\x01\x12(\n" + "$PROTOCOL_STATUS_CODE_INVALID_REQUEST\x10\x02\x12*\n" + "&PROTOCOL_STATUS_CODE_SESSION_NOT_FOUND\x10\x03\x12*\n" + "&PROTOCOL_STATUS_CODE_SESSION_NOT_READY\x10\x04\x12+\n" + "'PROTOCOL_STATUS_CODE_WORKER_UNAVAILABLE\x10\x05\x12 \n" + "\x1cPROTOCOL_STATUS_CODE_TIMEOUT\x10\x06\x12!\n" + "\x1dPROTOCOL_STATUS_CODE_CANCELED\x10\a\x12+\n" + "'PROTOCOL_STATUS_CODE_PROTOCOL_VIOLATION\x10\b\x12)\n" + "%PROTOCOL_STATUS_CODE_MXACCESS_FAILURE\x10\t*\xbf\x02\n" + "\fSessionState\x12\x1d\n" + "\x19SESSION_STATE_UNSPECIFIED\x10\x00\x12\x1a\n" + "\x16SESSION_STATE_CREATING\x10\x01\x12!\n" + "\x1dSESSION_STATE_STARTING_WORKER\x10\x02\x12\"\n" + "\x1eSESSION_STATE_WAITING_FOR_PIPE\x10\x03\x12\x1d\n" + "\x19SESSION_STATE_HANDSHAKING\x10\x04\x12%\n" + "!SESSION_STATE_INITIALIZING_WORKER\x10\x05\x12\x17\n" + "\x13SESSION_STATE_READY\x10\x06\x12\x19\n" + "\x15SESSION_STATE_CLOSING\x10\a\x12\x18\n" + "\x14SESSION_STATE_CLOSED\x10\b\x12\x19\n" + "\x15SESSION_STATE_FAULTED\x10\t2\x82\x03\n" + "\x0fMxAccessGateway\x12]\n" + "\vOpenSession\x12'.mxaccess_gateway.v1.OpenSessionRequest\x1a%.mxaccess_gateway.v1.OpenSessionReply\x12`\n" + "\fCloseSession\x12(.mxaccess_gateway.v1.CloseSessionRequest\x1a&.mxaccess_gateway.v1.CloseSessionReply\x12T\n" + "\x06Invoke\x12%.mxaccess_gateway.v1.MxCommandRequest\x1a#.mxaccess_gateway.v1.MxCommandReply\x12X\n" + "\fStreamEvents\x12(.mxaccess_gateway.v1.StreamEventsRequest\x1a\x1c.mxaccess_gateway.v1.MxEvent0\x01B\x1c\xaa\x02\x19MxGateway.Contracts.Protob\x06proto3" var ( file_mxaccess_gateway_proto_rawDescOnce sync.Once file_mxaccess_gateway_proto_rawDescData []byte ) func file_mxaccess_gateway_proto_rawDescGZIP() []byte { file_mxaccess_gateway_proto_rawDescOnce.Do(func() { file_mxaccess_gateway_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_mxaccess_gateway_proto_rawDesc), len(file_mxaccess_gateway_proto_rawDesc))) }) return file_mxaccess_gateway_proto_rawDescData } var file_mxaccess_gateway_proto_enumTypes = make([]protoimpl.EnumInfo, 7) var file_mxaccess_gateway_proto_msgTypes = make([]protoimpl.MessageInfo, 59) var file_mxaccess_gateway_proto_goTypes = []any{ (MxCommandKind)(0), // 0: mxaccess_gateway.v1.MxCommandKind (MxEventFamily)(0), // 1: mxaccess_gateway.v1.MxEventFamily (MxStatusCategory)(0), // 2: mxaccess_gateway.v1.MxStatusCategory (MxStatusSource)(0), // 3: mxaccess_gateway.v1.MxStatusSource (MxDataType)(0), // 4: mxaccess_gateway.v1.MxDataType (ProtocolStatusCode)(0), // 5: mxaccess_gateway.v1.ProtocolStatusCode (SessionState)(0), // 6: mxaccess_gateway.v1.SessionState (*OpenSessionRequest)(nil), // 7: mxaccess_gateway.v1.OpenSessionRequest (*OpenSessionReply)(nil), // 8: mxaccess_gateway.v1.OpenSessionReply (*CloseSessionRequest)(nil), // 9: mxaccess_gateway.v1.CloseSessionRequest (*CloseSessionReply)(nil), // 10: mxaccess_gateway.v1.CloseSessionReply (*StreamEventsRequest)(nil), // 11: mxaccess_gateway.v1.StreamEventsRequest (*MxCommandRequest)(nil), // 12: mxaccess_gateway.v1.MxCommandRequest (*MxCommand)(nil), // 13: mxaccess_gateway.v1.MxCommand (*RegisterCommand)(nil), // 14: mxaccess_gateway.v1.RegisterCommand (*UnregisterCommand)(nil), // 15: mxaccess_gateway.v1.UnregisterCommand (*AddItemCommand)(nil), // 16: mxaccess_gateway.v1.AddItemCommand (*AddItem2Command)(nil), // 17: mxaccess_gateway.v1.AddItem2Command (*RemoveItemCommand)(nil), // 18: mxaccess_gateway.v1.RemoveItemCommand (*AdviseCommand)(nil), // 19: mxaccess_gateway.v1.AdviseCommand (*UnAdviseCommand)(nil), // 20: mxaccess_gateway.v1.UnAdviseCommand (*AdviseSupervisoryCommand)(nil), // 21: mxaccess_gateway.v1.AdviseSupervisoryCommand (*AddBufferedItemCommand)(nil), // 22: mxaccess_gateway.v1.AddBufferedItemCommand (*SetBufferedUpdateIntervalCommand)(nil), // 23: mxaccess_gateway.v1.SetBufferedUpdateIntervalCommand (*SuspendCommand)(nil), // 24: mxaccess_gateway.v1.SuspendCommand (*ActivateCommand)(nil), // 25: mxaccess_gateway.v1.ActivateCommand (*WriteCommand)(nil), // 26: mxaccess_gateway.v1.WriteCommand (*Write2Command)(nil), // 27: mxaccess_gateway.v1.Write2Command (*WriteSecuredCommand)(nil), // 28: mxaccess_gateway.v1.WriteSecuredCommand (*WriteSecured2Command)(nil), // 29: mxaccess_gateway.v1.WriteSecured2Command (*AuthenticateUserCommand)(nil), // 30: mxaccess_gateway.v1.AuthenticateUserCommand (*ArchestrAUserToIdCommand)(nil), // 31: mxaccess_gateway.v1.ArchestrAUserToIdCommand (*PingCommand)(nil), // 32: mxaccess_gateway.v1.PingCommand (*GetSessionStateCommand)(nil), // 33: mxaccess_gateway.v1.GetSessionStateCommand (*GetWorkerInfoCommand)(nil), // 34: mxaccess_gateway.v1.GetWorkerInfoCommand (*DrainEventsCommand)(nil), // 35: mxaccess_gateway.v1.DrainEventsCommand (*ShutdownWorkerCommand)(nil), // 36: mxaccess_gateway.v1.ShutdownWorkerCommand (*MxCommandReply)(nil), // 37: mxaccess_gateway.v1.MxCommandReply (*RegisterReply)(nil), // 38: mxaccess_gateway.v1.RegisterReply (*AddItemReply)(nil), // 39: mxaccess_gateway.v1.AddItemReply (*AddItem2Reply)(nil), // 40: mxaccess_gateway.v1.AddItem2Reply (*AddBufferedItemReply)(nil), // 41: mxaccess_gateway.v1.AddBufferedItemReply (*SuspendReply)(nil), // 42: mxaccess_gateway.v1.SuspendReply (*ActivateReply)(nil), // 43: mxaccess_gateway.v1.ActivateReply (*AuthenticateUserReply)(nil), // 44: mxaccess_gateway.v1.AuthenticateUserReply (*ArchestrAUserToIdReply)(nil), // 45: mxaccess_gateway.v1.ArchestrAUserToIdReply (*SessionStateReply)(nil), // 46: mxaccess_gateway.v1.SessionStateReply (*WorkerInfoReply)(nil), // 47: mxaccess_gateway.v1.WorkerInfoReply (*DrainEventsReply)(nil), // 48: mxaccess_gateway.v1.DrainEventsReply (*MxEvent)(nil), // 49: mxaccess_gateway.v1.MxEvent (*OnDataChangeEvent)(nil), // 50: mxaccess_gateway.v1.OnDataChangeEvent (*OnWriteCompleteEvent)(nil), // 51: mxaccess_gateway.v1.OnWriteCompleteEvent (*OperationCompleteEvent)(nil), // 52: mxaccess_gateway.v1.OperationCompleteEvent (*OnBufferedDataChangeEvent)(nil), // 53: mxaccess_gateway.v1.OnBufferedDataChangeEvent (*MxStatusProxy)(nil), // 54: mxaccess_gateway.v1.MxStatusProxy (*MxValue)(nil), // 55: mxaccess_gateway.v1.MxValue (*MxArray)(nil), // 56: mxaccess_gateway.v1.MxArray (*BoolArray)(nil), // 57: mxaccess_gateway.v1.BoolArray (*Int32Array)(nil), // 58: mxaccess_gateway.v1.Int32Array (*Int64Array)(nil), // 59: mxaccess_gateway.v1.Int64Array (*FloatArray)(nil), // 60: mxaccess_gateway.v1.FloatArray (*DoubleArray)(nil), // 61: mxaccess_gateway.v1.DoubleArray (*StringArray)(nil), // 62: mxaccess_gateway.v1.StringArray (*TimestampArray)(nil), // 63: mxaccess_gateway.v1.TimestampArray (*RawArray)(nil), // 64: mxaccess_gateway.v1.RawArray (*ProtocolStatus)(nil), // 65: mxaccess_gateway.v1.ProtocolStatus (*durationpb.Duration)(nil), // 66: google.protobuf.Duration (*timestamppb.Timestamp)(nil), // 67: google.protobuf.Timestamp } var file_mxaccess_gateway_proto_depIdxs = []int32{ 66, // 0: mxaccess_gateway.v1.OpenSessionRequest.command_timeout:type_name -> google.protobuf.Duration 66, // 1: mxaccess_gateway.v1.OpenSessionReply.default_command_timeout:type_name -> google.protobuf.Duration 65, // 2: mxaccess_gateway.v1.OpenSessionReply.protocol_status:type_name -> mxaccess_gateway.v1.ProtocolStatus 6, // 3: mxaccess_gateway.v1.CloseSessionReply.final_state:type_name -> mxaccess_gateway.v1.SessionState 65, // 4: mxaccess_gateway.v1.CloseSessionReply.protocol_status:type_name -> mxaccess_gateway.v1.ProtocolStatus 13, // 5: mxaccess_gateway.v1.MxCommandRequest.command:type_name -> mxaccess_gateway.v1.MxCommand 0, // 6: mxaccess_gateway.v1.MxCommand.kind:type_name -> mxaccess_gateway.v1.MxCommandKind 14, // 7: mxaccess_gateway.v1.MxCommand.register:type_name -> mxaccess_gateway.v1.RegisterCommand 15, // 8: mxaccess_gateway.v1.MxCommand.unregister:type_name -> mxaccess_gateway.v1.UnregisterCommand 16, // 9: mxaccess_gateway.v1.MxCommand.add_item:type_name -> mxaccess_gateway.v1.AddItemCommand 17, // 10: mxaccess_gateway.v1.MxCommand.add_item2:type_name -> mxaccess_gateway.v1.AddItem2Command 18, // 11: mxaccess_gateway.v1.MxCommand.remove_item:type_name -> mxaccess_gateway.v1.RemoveItemCommand 19, // 12: mxaccess_gateway.v1.MxCommand.advise:type_name -> mxaccess_gateway.v1.AdviseCommand 20, // 13: mxaccess_gateway.v1.MxCommand.un_advise:type_name -> mxaccess_gateway.v1.UnAdviseCommand 21, // 14: mxaccess_gateway.v1.MxCommand.advise_supervisory:type_name -> mxaccess_gateway.v1.AdviseSupervisoryCommand 22, // 15: mxaccess_gateway.v1.MxCommand.add_buffered_item:type_name -> mxaccess_gateway.v1.AddBufferedItemCommand 23, // 16: mxaccess_gateway.v1.MxCommand.set_buffered_update_interval:type_name -> mxaccess_gateway.v1.SetBufferedUpdateIntervalCommand 24, // 17: mxaccess_gateway.v1.MxCommand.suspend:type_name -> mxaccess_gateway.v1.SuspendCommand 25, // 18: mxaccess_gateway.v1.MxCommand.activate:type_name -> mxaccess_gateway.v1.ActivateCommand 26, // 19: mxaccess_gateway.v1.MxCommand.write:type_name -> mxaccess_gateway.v1.WriteCommand 27, // 20: mxaccess_gateway.v1.MxCommand.write2:type_name -> mxaccess_gateway.v1.Write2Command 28, // 21: mxaccess_gateway.v1.MxCommand.write_secured:type_name -> mxaccess_gateway.v1.WriteSecuredCommand 29, // 22: mxaccess_gateway.v1.MxCommand.write_secured2:type_name -> mxaccess_gateway.v1.WriteSecured2Command 30, // 23: mxaccess_gateway.v1.MxCommand.authenticate_user:type_name -> mxaccess_gateway.v1.AuthenticateUserCommand 31, // 24: mxaccess_gateway.v1.MxCommand.archestra_user_to_id:type_name -> mxaccess_gateway.v1.ArchestrAUserToIdCommand 32, // 25: mxaccess_gateway.v1.MxCommand.ping:type_name -> mxaccess_gateway.v1.PingCommand 33, // 26: mxaccess_gateway.v1.MxCommand.get_session_state:type_name -> mxaccess_gateway.v1.GetSessionStateCommand 34, // 27: mxaccess_gateway.v1.MxCommand.get_worker_info:type_name -> mxaccess_gateway.v1.GetWorkerInfoCommand 35, // 28: mxaccess_gateway.v1.MxCommand.drain_events:type_name -> mxaccess_gateway.v1.DrainEventsCommand 36, // 29: mxaccess_gateway.v1.MxCommand.shutdown_worker:type_name -> mxaccess_gateway.v1.ShutdownWorkerCommand 55, // 30: mxaccess_gateway.v1.WriteCommand.value:type_name -> mxaccess_gateway.v1.MxValue 55, // 31: mxaccess_gateway.v1.Write2Command.value:type_name -> mxaccess_gateway.v1.MxValue 55, // 32: mxaccess_gateway.v1.Write2Command.timestamp_value:type_name -> mxaccess_gateway.v1.MxValue 55, // 33: mxaccess_gateway.v1.WriteSecuredCommand.value:type_name -> mxaccess_gateway.v1.MxValue 55, // 34: mxaccess_gateway.v1.WriteSecured2Command.value:type_name -> mxaccess_gateway.v1.MxValue 55, // 35: mxaccess_gateway.v1.WriteSecured2Command.timestamp_value:type_name -> mxaccess_gateway.v1.MxValue 66, // 36: mxaccess_gateway.v1.ShutdownWorkerCommand.grace_period:type_name -> google.protobuf.Duration 0, // 37: mxaccess_gateway.v1.MxCommandReply.kind:type_name -> mxaccess_gateway.v1.MxCommandKind 65, // 38: mxaccess_gateway.v1.MxCommandReply.protocol_status:type_name -> mxaccess_gateway.v1.ProtocolStatus 55, // 39: mxaccess_gateway.v1.MxCommandReply.return_value:type_name -> mxaccess_gateway.v1.MxValue 54, // 40: mxaccess_gateway.v1.MxCommandReply.statuses:type_name -> mxaccess_gateway.v1.MxStatusProxy 38, // 41: mxaccess_gateway.v1.MxCommandReply.register:type_name -> mxaccess_gateway.v1.RegisterReply 39, // 42: mxaccess_gateway.v1.MxCommandReply.add_item:type_name -> mxaccess_gateway.v1.AddItemReply 40, // 43: mxaccess_gateway.v1.MxCommandReply.add_item2:type_name -> mxaccess_gateway.v1.AddItem2Reply 41, // 44: mxaccess_gateway.v1.MxCommandReply.add_buffered_item:type_name -> mxaccess_gateway.v1.AddBufferedItemReply 42, // 45: mxaccess_gateway.v1.MxCommandReply.suspend:type_name -> mxaccess_gateway.v1.SuspendReply 43, // 46: mxaccess_gateway.v1.MxCommandReply.activate:type_name -> mxaccess_gateway.v1.ActivateReply 44, // 47: mxaccess_gateway.v1.MxCommandReply.authenticate_user:type_name -> mxaccess_gateway.v1.AuthenticateUserReply 45, // 48: mxaccess_gateway.v1.MxCommandReply.archestra_user_to_id:type_name -> mxaccess_gateway.v1.ArchestrAUserToIdReply 46, // 49: mxaccess_gateway.v1.MxCommandReply.session_state:type_name -> mxaccess_gateway.v1.SessionStateReply 47, // 50: mxaccess_gateway.v1.MxCommandReply.worker_info:type_name -> mxaccess_gateway.v1.WorkerInfoReply 48, // 51: mxaccess_gateway.v1.MxCommandReply.drain_events:type_name -> mxaccess_gateway.v1.DrainEventsReply 54, // 52: mxaccess_gateway.v1.SuspendReply.status:type_name -> mxaccess_gateway.v1.MxStatusProxy 54, // 53: mxaccess_gateway.v1.ActivateReply.status:type_name -> mxaccess_gateway.v1.MxStatusProxy 6, // 54: mxaccess_gateway.v1.SessionStateReply.state:type_name -> mxaccess_gateway.v1.SessionState 49, // 55: mxaccess_gateway.v1.DrainEventsReply.events:type_name -> mxaccess_gateway.v1.MxEvent 1, // 56: mxaccess_gateway.v1.MxEvent.family:type_name -> mxaccess_gateway.v1.MxEventFamily 55, // 57: mxaccess_gateway.v1.MxEvent.value:type_name -> mxaccess_gateway.v1.MxValue 67, // 58: mxaccess_gateway.v1.MxEvent.source_timestamp:type_name -> google.protobuf.Timestamp 54, // 59: mxaccess_gateway.v1.MxEvent.statuses:type_name -> mxaccess_gateway.v1.MxStatusProxy 67, // 60: mxaccess_gateway.v1.MxEvent.worker_timestamp:type_name -> google.protobuf.Timestamp 67, // 61: mxaccess_gateway.v1.MxEvent.gateway_receive_timestamp:type_name -> google.protobuf.Timestamp 50, // 62: mxaccess_gateway.v1.MxEvent.on_data_change:type_name -> mxaccess_gateway.v1.OnDataChangeEvent 51, // 63: mxaccess_gateway.v1.MxEvent.on_write_complete:type_name -> mxaccess_gateway.v1.OnWriteCompleteEvent 52, // 64: mxaccess_gateway.v1.MxEvent.operation_complete:type_name -> mxaccess_gateway.v1.OperationCompleteEvent 53, // 65: mxaccess_gateway.v1.MxEvent.on_buffered_data_change:type_name -> mxaccess_gateway.v1.OnBufferedDataChangeEvent 4, // 66: mxaccess_gateway.v1.OnBufferedDataChangeEvent.data_type:type_name -> mxaccess_gateway.v1.MxDataType 56, // 67: mxaccess_gateway.v1.OnBufferedDataChangeEvent.quality_values:type_name -> mxaccess_gateway.v1.MxArray 56, // 68: mxaccess_gateway.v1.OnBufferedDataChangeEvent.timestamp_values:type_name -> mxaccess_gateway.v1.MxArray 2, // 69: mxaccess_gateway.v1.MxStatusProxy.category:type_name -> mxaccess_gateway.v1.MxStatusCategory 3, // 70: mxaccess_gateway.v1.MxStatusProxy.detected_by:type_name -> mxaccess_gateway.v1.MxStatusSource 4, // 71: mxaccess_gateway.v1.MxValue.data_type:type_name -> mxaccess_gateway.v1.MxDataType 67, // 72: mxaccess_gateway.v1.MxValue.timestamp_value:type_name -> google.protobuf.Timestamp 56, // 73: mxaccess_gateway.v1.MxValue.array_value:type_name -> mxaccess_gateway.v1.MxArray 4, // 74: mxaccess_gateway.v1.MxArray.element_data_type:type_name -> mxaccess_gateway.v1.MxDataType 57, // 75: mxaccess_gateway.v1.MxArray.bool_values:type_name -> mxaccess_gateway.v1.BoolArray 58, // 76: mxaccess_gateway.v1.MxArray.int32_values:type_name -> mxaccess_gateway.v1.Int32Array 59, // 77: mxaccess_gateway.v1.MxArray.int64_values:type_name -> mxaccess_gateway.v1.Int64Array 60, // 78: mxaccess_gateway.v1.MxArray.float_values:type_name -> mxaccess_gateway.v1.FloatArray 61, // 79: mxaccess_gateway.v1.MxArray.double_values:type_name -> mxaccess_gateway.v1.DoubleArray 62, // 80: mxaccess_gateway.v1.MxArray.string_values:type_name -> mxaccess_gateway.v1.StringArray 63, // 81: mxaccess_gateway.v1.MxArray.timestamp_values:type_name -> mxaccess_gateway.v1.TimestampArray 64, // 82: mxaccess_gateway.v1.MxArray.raw_values:type_name -> mxaccess_gateway.v1.RawArray 67, // 83: mxaccess_gateway.v1.TimestampArray.values:type_name -> google.protobuf.Timestamp 5, // 84: mxaccess_gateway.v1.ProtocolStatus.code:type_name -> mxaccess_gateway.v1.ProtocolStatusCode 7, // 85: mxaccess_gateway.v1.MxAccessGateway.OpenSession:input_type -> mxaccess_gateway.v1.OpenSessionRequest 9, // 86: mxaccess_gateway.v1.MxAccessGateway.CloseSession:input_type -> mxaccess_gateway.v1.CloseSessionRequest 12, // 87: mxaccess_gateway.v1.MxAccessGateway.Invoke:input_type -> mxaccess_gateway.v1.MxCommandRequest 11, // 88: mxaccess_gateway.v1.MxAccessGateway.StreamEvents:input_type -> mxaccess_gateway.v1.StreamEventsRequest 8, // 89: mxaccess_gateway.v1.MxAccessGateway.OpenSession:output_type -> mxaccess_gateway.v1.OpenSessionReply 10, // 90: mxaccess_gateway.v1.MxAccessGateway.CloseSession:output_type -> mxaccess_gateway.v1.CloseSessionReply 37, // 91: mxaccess_gateway.v1.MxAccessGateway.Invoke:output_type -> mxaccess_gateway.v1.MxCommandReply 49, // 92: mxaccess_gateway.v1.MxAccessGateway.StreamEvents:output_type -> mxaccess_gateway.v1.MxEvent 89, // [89:93] is the sub-list for method output_type 85, // [85:89] is the sub-list for method input_type 85, // [85:85] is the sub-list for extension type_name 85, // [85:85] is the sub-list for extension extendee 0, // [0:85] is the sub-list for field type_name } func init() { file_mxaccess_gateway_proto_init() } func file_mxaccess_gateway_proto_init() { if File_mxaccess_gateway_proto != nil { return } file_mxaccess_gateway_proto_msgTypes[6].OneofWrappers = []any{ (*MxCommand_Register)(nil), (*MxCommand_Unregister)(nil), (*MxCommand_AddItem)(nil), (*MxCommand_AddItem2)(nil), (*MxCommand_RemoveItem)(nil), (*MxCommand_Advise)(nil), (*MxCommand_UnAdvise)(nil), (*MxCommand_AdviseSupervisory)(nil), (*MxCommand_AddBufferedItem)(nil), (*MxCommand_SetBufferedUpdateInterval)(nil), (*MxCommand_Suspend)(nil), (*MxCommand_Activate)(nil), (*MxCommand_Write)(nil), (*MxCommand_Write2)(nil), (*MxCommand_WriteSecured)(nil), (*MxCommand_WriteSecured2)(nil), (*MxCommand_AuthenticateUser)(nil), (*MxCommand_ArchestraUserToId)(nil), (*MxCommand_Ping)(nil), (*MxCommand_GetSessionState)(nil), (*MxCommand_GetWorkerInfo)(nil), (*MxCommand_DrainEvents)(nil), (*MxCommand_ShutdownWorker)(nil), } file_mxaccess_gateway_proto_msgTypes[30].OneofWrappers = []any{ (*MxCommandReply_Register)(nil), (*MxCommandReply_AddItem)(nil), (*MxCommandReply_AddItem2)(nil), (*MxCommandReply_AddBufferedItem)(nil), (*MxCommandReply_Suspend)(nil), (*MxCommandReply_Activate)(nil), (*MxCommandReply_AuthenticateUser)(nil), (*MxCommandReply_ArchestraUserToId)(nil), (*MxCommandReply_SessionState)(nil), (*MxCommandReply_WorkerInfo)(nil), (*MxCommandReply_DrainEvents)(nil), } file_mxaccess_gateway_proto_msgTypes[42].OneofWrappers = []any{ (*MxEvent_OnDataChange)(nil), (*MxEvent_OnWriteComplete)(nil), (*MxEvent_OperationComplete)(nil), (*MxEvent_OnBufferedDataChange)(nil), } file_mxaccess_gateway_proto_msgTypes[48].OneofWrappers = []any{ (*MxValue_BoolValue)(nil), (*MxValue_Int32Value)(nil), (*MxValue_Int64Value)(nil), (*MxValue_FloatValue)(nil), (*MxValue_DoubleValue)(nil), (*MxValue_StringValue)(nil), (*MxValue_TimestampValue)(nil), (*MxValue_ArrayValue)(nil), (*MxValue_RawValue)(nil), } file_mxaccess_gateway_proto_msgTypes[49].OneofWrappers = []any{ (*MxArray_BoolValues)(nil), (*MxArray_Int32Values)(nil), (*MxArray_Int64Values)(nil), (*MxArray_FloatValues)(nil), (*MxArray_DoubleValues)(nil), (*MxArray_StringValues)(nil), (*MxArray_TimestampValues)(nil), (*MxArray_RawValues)(nil), } type x struct{} out := protoimpl.TypeBuilder{ File: protoimpl.DescBuilder{ GoPackagePath: reflect.TypeOf(x{}).PkgPath(), RawDescriptor: unsafe.Slice(unsafe.StringData(file_mxaccess_gateway_proto_rawDesc), len(file_mxaccess_gateway_proto_rawDesc)), NumEnums: 7, NumMessages: 59, NumExtensions: 0, NumServices: 1, }, GoTypes: file_mxaccess_gateway_proto_goTypes, DependencyIndexes: file_mxaccess_gateway_proto_depIdxs, EnumInfos: file_mxaccess_gateway_proto_enumTypes, MessageInfos: file_mxaccess_gateway_proto_msgTypes, }.Build() File_mxaccess_gateway_proto = out.File file_mxaccess_gateway_proto_goTypes = nil file_mxaccess_gateway_proto_depIdxs = nil }