Joseph Doherty
5481 lines
177 KiB
Go
5481 lines
177 KiB
Go
// 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
|
|
}
|