Update protobuf definitions

This commit is contained in:
Jeremy Edwards
2019-03-26 16:14:51 -07:00
parent eaa811f9ac
commit e5538401f6
8 changed files with 698 additions and 470 deletions

@ -1,18 +1,5 @@
# Generated by the protocol buffer compiler. DO NOT EDIT!
# source: api/protobuf-spec/messages.proto
#Copyright 2018 Google LLC
#Licensed under the Apache License, Version 2.0 (the "License");
#you may not use this file except in compliance with the License.
#You may obtain a copy of the License at
#
# https://www.apache.org/licenses/LICENSE-2.0
#
#Unless required by applicable law or agreed to in writing, software
#distributed under the License is distributed on an "AS IS" BASIS,
#WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
#See the License for the specific language governing permissions and
#limitations under the License.
import sys
_b=sys.version_info[0]<3 and (lambda x:x) or (lambda x:x.encode('latin1'))
@ -32,64 +19,12 @@ DESCRIPTOR = _descriptor.FileDescriptor(
package='messages',
syntax='proto3',
serialized_options=_b('Z5github.com/GoogleCloudPlatform/open-match/internal/pb'),
serialized_pb=_b('\n api/protobuf-spec/messages.proto\x12\x08messages\"\\\n\x07Profile\x12\n\n\x02id\x18\x01 \x01(\t\x12\x12\n\nproperties\x18\x02 \x01(\t\x12\x0c\n\x04name\x18\x03 \x01(\t\x12#\n\x05pools\x18\x04 \x03(\x0b\x32\x14.messages.PlayerPool\"\x84\x01\n\x0bMatchObject\x12\n\n\x02id\x18\x01 \x01(\t\x12\x12\n\nproperties\x18\x02 \x01(\t\x12\r\n\x05\x65rror\x18\x03 \x01(\t\x12!\n\x07rosters\x18\x04 \x03(\x0b\x32\x10.messages.Roster\x12#\n\x05pools\x18\x05 \x03(\x0b\x32\x14.messages.PlayerPool\"9\n\x06Roster\x12\x0c\n\x04name\x18\x01 \x01(\t\x12!\n\x07players\x18\x02 \x03(\x0b\x32\x10.messages.Player\"e\n\x06\x46ilter\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x11\n\tattribute\x18\x02 \x01(\t\x12\x0c\n\x04maxv\x18\x03 \x01(\x03\x12\x0c\n\x04minv\x18\x04 \x01(\x03\x12\x1e\n\x05stats\x18\x05 \x01(\x0b\x32\x0f.messages.Stats\"\'\n\x05Stats\x12\r\n\x05\x63ount\x18\x01 \x01(\x03\x12\x0f\n\x07\x65lapsed\x18\x02 \x01(\x01\"\x7f\n\nPlayerPool\x12\x0c\n\x04name\x18\x01 \x01(\t\x12!\n\x07\x66ilters\x18\x02 \x03(\x0b\x32\x10.messages.Filter\x12 \n\x06roster\x18\x03 \x01(\x0b\x32\x10.messages.Roster\x12\x1e\n\x05stats\x18\x04 \x01(\x0b\x32\x0f.messages.Stats\"\x90\x01\n\x06Player\x12\n\n\x02id\x18\x01 \x01(\t\x12\x12\n\nproperties\x18\x02 \x01(\t\x12\x0c\n\x04pool\x18\x03 \x01(\t\x12.\n\nattributes\x18\x04 \x03(\x0b\x32\x1a.messages.Player.Attribute\x1a(\n\tAttribute\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\x03\"(\n\x06Result\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\r\n\x05\x65rror\x18\x02 \x01(\t\"\t\n\x07IlInput\"\x17\n\tTimestamp\x12\n\n\x02ts\x18\x01 \x01(\x03\"+\n\x0e\x43onnectionInfo\x12\x19\n\x11\x63onnection_string\x18\x01 \x01(\t\"c\n\x0b\x41ssignments\x12!\n\x07rosters\x18\x01 \x03(\x0b\x32\x10.messages.Roster\x12\x31\n\x0f\x63onnection_info\x18\x02 \x01(\x0b\x32\x18.messages.ConnectionInfoB7Z5github.com/GoogleCloudPlatform/open-match/internal/pbb\x06proto3')
serialized_pb=_b('\n api/protobuf-spec/messages.proto\x12\x08messages\"\x94\x01\n\x0bMatchObject\x12\n\n\x02id\x18\x01 \x01(\t\x12\x12\n\nproperties\x18\x02 \x01(\t\x12\r\n\x05\x65rror\x18\x03 \x01(\t\x12!\n\x07rosters\x18\x04 \x03(\x0b\x32\x10.messages.Roster\x12#\n\x05pools\x18\x05 \x03(\x0b\x32\x14.messages.PlayerPool\x12\x0e\n\x06status\x18\x06 \x01(\t\"9\n\x06Roster\x12\x0c\n\x04name\x18\x01 \x01(\t\x12!\n\x07players\x18\x02 \x03(\x0b\x32\x10.messages.Player\"e\n\x06\x46ilter\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x11\n\tattribute\x18\x02 \x01(\t\x12\x0c\n\x04maxv\x18\x03 \x01(\x03\x12\x0c\n\x04minv\x18\x04 \x01(\x03\x12\x1e\n\x05stats\x18\x05 \x01(\x0b\x32\x0f.messages.Stats\"\'\n\x05Stats\x12\r\n\x05\x63ount\x18\x01 \x01(\x03\x12\x0f\n\x07\x65lapsed\x18\x02 \x01(\x01\"\x7f\n\nPlayerPool\x12\x0c\n\x04name\x18\x01 \x01(\t\x12!\n\x07\x66ilters\x18\x02 \x03(\x0b\x32\x10.messages.Filter\x12 \n\x06roster\x18\x03 \x01(\x0b\x32\x10.messages.Roster\x12\x1e\n\x05stats\x18\x04 \x01(\x0b\x32\x0f.messages.Stats\"\xc3\x01\n\x06Player\x12\n\n\x02id\x18\x01 \x01(\t\x12\x12\n\nproperties\x18\x02 \x01(\t\x12\x0c\n\x04pool\x18\x03 \x01(\t\x12.\n\nattributes\x18\x04 \x03(\x0b\x32\x1a.messages.Player.Attribute\x12\x12\n\nassignment\x18\x05 \x01(\t\x12\x0e\n\x06status\x18\x06 \x01(\t\x12\r\n\x05\x65rror\x18\x07 \x01(\t\x1a(\n\tAttribute\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\x03\"(\n\x06Result\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\r\n\x05\x65rror\x18\x02 \x01(\t\"\t\n\x07IlInput\"D\n\x0b\x41ssignments\x12!\n\x07rosters\x18\x01 \x03(\x0b\x32\x10.messages.Roster\x12\x12\n\nassignment\x18\n \x01(\t\"k\n\x07Request\x12\x12\n\nprofile_id\x18\x01 \x01(\t\x12\x13\n\x0bproposal_id\x18\x02 \x01(\t\x12\x12\n\nrequest_id\x18\x03 \x01(\t\x12\x10\n\x08\x65rror_id\x18\x04 \x01(\t\x12\x11\n\ttimestamp\x18\x05 \x01(\t\"[\n\tArguments\x12\"\n\x07request\x18\x01 \x01(\x0b\x32\x11.messages.Request\x12*\n\x0bmatchobject\x18\x02 \x01(\x0b\x32\x15.messages.MatchObjectB7Z5github.com/GoogleCloudPlatform/open-match/internal/pbb\x06proto3')
)
_PROFILE = _descriptor.Descriptor(
name='Profile',
full_name='messages.Profile',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='id', full_name='messages.Profile.id', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='properties', full_name='messages.Profile.properties', index=1,
number=2, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='name', full_name='messages.Profile.name', index=2,
number=3, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='pools', full_name='messages.Profile.pools', index=3,
number=4, type=11, cpp_type=10, label=3,
has_default_value=False, default_value=[],
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, file=DESCRIPTOR),
],
extensions=[
],
nested_types=[],
enum_types=[
],
serialized_options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=46,
serialized_end=138,
)
_MATCHOBJECT = _descriptor.Descriptor(
name='MatchObject',
full_name='messages.MatchObject',
@ -132,6 +67,13 @@ _MATCHOBJECT = _descriptor.Descriptor(
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='status', full_name='messages.MatchObject.status', index=5,
number=6, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, file=DESCRIPTOR),
],
extensions=[
],
@ -144,8 +86,8 @@ _MATCHOBJECT = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
serialized_start=141,
serialized_end=273,
serialized_start=47,
serialized_end=195,
)
@ -182,8 +124,8 @@ _ROSTER = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
serialized_start=275,
serialized_end=332,
serialized_start=197,
serialized_end=254,
)
@ -241,8 +183,8 @@ _FILTER = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
serialized_start=334,
serialized_end=435,
serialized_start=256,
serialized_end=357,
)
@ -279,8 +221,8 @@ _STATS = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
serialized_start=437,
serialized_end=476,
serialized_start=359,
serialized_end=398,
)
@ -331,8 +273,8 @@ _PLAYERPOOL = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
serialized_start=478,
serialized_end=605,
serialized_start=400,
serialized_end=527,
)
@ -369,8 +311,8 @@ _PLAYER_ATTRIBUTE = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
serialized_start=712,
serialized_end=752,
serialized_start=685,
serialized_end=725,
)
_PLAYER = _descriptor.Descriptor(
@ -408,6 +350,27 @@ _PLAYER = _descriptor.Descriptor(
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='assignment', full_name='messages.Player.assignment', index=4,
number=5, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='status', full_name='messages.Player.status', index=5,
number=6, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='error', full_name='messages.Player.error', index=6,
number=7, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, file=DESCRIPTOR),
],
extensions=[
],
@ -420,8 +383,8 @@ _PLAYER = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
serialized_start=608,
serialized_end=752,
serialized_start=530,
serialized_end=725,
)
@ -458,8 +421,8 @@ _RESULT = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
serialized_start=754,
serialized_end=794,
serialized_start=727,
serialized_end=767,
)
@ -482,70 +445,8 @@ _ILINPUT = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
serialized_start=796,
serialized_end=805,
)
_TIMESTAMP = _descriptor.Descriptor(
name='Timestamp',
full_name='messages.Timestamp',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='ts', full_name='messages.Timestamp.ts', index=0,
number=1, type=3, cpp_type=2, label=1,
has_default_value=False, default_value=0,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, file=DESCRIPTOR),
],
extensions=[
],
nested_types=[],
enum_types=[
],
serialized_options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=807,
serialized_end=830,
)
_CONNECTIONINFO = _descriptor.Descriptor(
name='ConnectionInfo',
full_name='messages.ConnectionInfo',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='connection_string', full_name='messages.ConnectionInfo.connection_string', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, file=DESCRIPTOR),
],
extensions=[
],
nested_types=[],
enum_types=[
],
serialized_options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=832,
serialized_end=875,
serialized_start=769,
serialized_end=778,
)
@ -564,7 +465,104 @@ _ASSIGNMENTS = _descriptor.Descriptor(
is_extension=False, extension_scope=None,
serialized_options=None, file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='connection_info', full_name='messages.Assignments.connection_info', index=1,
name='assignment', full_name='messages.Assignments.assignment', index=1,
number=10, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, file=DESCRIPTOR),
],
extensions=[
],
nested_types=[],
enum_types=[
],
serialized_options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=780,
serialized_end=848,
)
_REQUEST = _descriptor.Descriptor(
name='Request',
full_name='messages.Request',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='profile_id', full_name='messages.Request.profile_id', index=0,
number=1, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='proposal_id', full_name='messages.Request.proposal_id', index=1,
number=2, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='request_id', full_name='messages.Request.request_id', index=2,
number=3, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='error_id', full_name='messages.Request.error_id', index=3,
number=4, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='timestamp', full_name='messages.Request.timestamp', index=4,
number=5, type=9, cpp_type=9, label=1,
has_default_value=False, default_value=_b("").decode('utf-8'),
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, file=DESCRIPTOR),
],
extensions=[
],
nested_types=[],
enum_types=[
],
serialized_options=None,
is_extendable=False,
syntax='proto3',
extension_ranges=[],
oneofs=[
],
serialized_start=850,
serialized_end=957,
)
_ARGUMENTS = _descriptor.Descriptor(
name='Arguments',
full_name='messages.Arguments',
filename=None,
file=DESCRIPTOR,
containing_type=None,
fields=[
_descriptor.FieldDescriptor(
name='request', full_name='messages.Arguments.request', index=0,
number=1, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
is_extension=False, extension_scope=None,
serialized_options=None, file=DESCRIPTOR),
_descriptor.FieldDescriptor(
name='matchobject', full_name='messages.Arguments.matchobject', index=1,
number=2, type=11, cpp_type=10, label=1,
has_default_value=False, default_value=None,
message_type=None, enum_type=None, containing_type=None,
@ -582,11 +580,10 @@ _ASSIGNMENTS = _descriptor.Descriptor(
extension_ranges=[],
oneofs=[
],
serialized_start=877,
serialized_end=976,
serialized_start=959,
serialized_end=1050,
)
_PROFILE.fields_by_name['pools'].message_type = _PLAYERPOOL
_MATCHOBJECT.fields_by_name['rosters'].message_type = _ROSTER
_MATCHOBJECT.fields_by_name['pools'].message_type = _PLAYERPOOL
_ROSTER.fields_by_name['players'].message_type = _PLAYER
@ -597,8 +594,8 @@ _PLAYERPOOL.fields_by_name['stats'].message_type = _STATS
_PLAYER_ATTRIBUTE.containing_type = _PLAYER
_PLAYER.fields_by_name['attributes'].message_type = _PLAYER_ATTRIBUTE
_ASSIGNMENTS.fields_by_name['rosters'].message_type = _ROSTER
_ASSIGNMENTS.fields_by_name['connection_info'].message_type = _CONNECTIONINFO
DESCRIPTOR.message_types_by_name['Profile'] = _PROFILE
_ARGUMENTS.fields_by_name['request'].message_type = _REQUEST
_ARGUMENTS.fields_by_name['matchobject'].message_type = _MATCHOBJECT
DESCRIPTOR.message_types_by_name['MatchObject'] = _MATCHOBJECT
DESCRIPTOR.message_types_by_name['Roster'] = _ROSTER
DESCRIPTOR.message_types_by_name['Filter'] = _FILTER
@ -607,18 +604,11 @@ DESCRIPTOR.message_types_by_name['PlayerPool'] = _PLAYERPOOL
DESCRIPTOR.message_types_by_name['Player'] = _PLAYER
DESCRIPTOR.message_types_by_name['Result'] = _RESULT
DESCRIPTOR.message_types_by_name['IlInput'] = _ILINPUT
DESCRIPTOR.message_types_by_name['Timestamp'] = _TIMESTAMP
DESCRIPTOR.message_types_by_name['ConnectionInfo'] = _CONNECTIONINFO
DESCRIPTOR.message_types_by_name['Assignments'] = _ASSIGNMENTS
DESCRIPTOR.message_types_by_name['Request'] = _REQUEST
DESCRIPTOR.message_types_by_name['Arguments'] = _ARGUMENTS
_sym_db.RegisterFileDescriptor(DESCRIPTOR)
Profile = _reflection.GeneratedProtocolMessageType('Profile', (_message.Message,), dict(
DESCRIPTOR = _PROFILE,
__module__ = 'api.protobuf_spec.messages_pb2'
# @@protoc_insertion_point(class_scope:messages.Profile)
))
_sym_db.RegisterMessage(Profile)
MatchObject = _reflection.GeneratedProtocolMessageType('MatchObject', (_message.Message,), dict(
DESCRIPTOR = _MATCHOBJECT,
__module__ = 'api.protobuf_spec.messages_pb2'
@ -683,20 +673,6 @@ IlInput = _reflection.GeneratedProtocolMessageType('IlInput', (_message.Message,
))
_sym_db.RegisterMessage(IlInput)
Timestamp = _reflection.GeneratedProtocolMessageType('Timestamp', (_message.Message,), dict(
DESCRIPTOR = _TIMESTAMP,
__module__ = 'api.protobuf_spec.messages_pb2'
# @@protoc_insertion_point(class_scope:messages.Timestamp)
))
_sym_db.RegisterMessage(Timestamp)
ConnectionInfo = _reflection.GeneratedProtocolMessageType('ConnectionInfo', (_message.Message,), dict(
DESCRIPTOR = _CONNECTIONINFO,
__module__ = 'api.protobuf_spec.messages_pb2'
# @@protoc_insertion_point(class_scope:messages.ConnectionInfo)
))
_sym_db.RegisterMessage(ConnectionInfo)
Assignments = _reflection.GeneratedProtocolMessageType('Assignments', (_message.Message,), dict(
DESCRIPTOR = _ASSIGNMENTS,
__module__ = 'api.protobuf_spec.messages_pb2'
@ -704,6 +680,20 @@ Assignments = _reflection.GeneratedProtocolMessageType('Assignments', (_message.
))
_sym_db.RegisterMessage(Assignments)
Request = _reflection.GeneratedProtocolMessageType('Request', (_message.Message,), dict(
DESCRIPTOR = _REQUEST,
__module__ = 'api.protobuf_spec.messages_pb2'
# @@protoc_insertion_point(class_scope:messages.Request)
))
_sym_db.RegisterMessage(Request)
Arguments = _reflection.GeneratedProtocolMessageType('Arguments', (_message.Message,), dict(
DESCRIPTOR = _ARGUMENTS,
__module__ = 'api.protobuf_spec.messages_pb2'
# @@protoc_insertion_point(class_scope:messages.Arguments)
))
_sym_db.RegisterMessage(Arguments)
DESCRIPTOR._options = None
# @@protoc_insertion_point(module_scope)

@ -1,16 +1,3 @@
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
#Copyright 2018 Google LLC
#Licensed under the Apache License, Version 2.0 (the "License");
#you may not use this file except in compliance with the License.
#You may obtain a copy of the License at
#
# https://www.apache.org/licenses/LICENSE-2.0
#
#Unless required by applicable law or agreed to in writing, software
#distributed under the License is distributed on an "AS IS" BASIS,
#WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
#See the License for the specific language governing permissions and
#limitations under the License.
import grpc

@ -1,17 +1,5 @@
# Generated by the protocol buffer compiler. DO NOT EDIT!
# source: api/protobuf-spec/mmlogic.proto
#Copyright 2018 Google LLC
#Licensed under the Apache License, Version 2.0 (the "License");
#you may not use this file except in compliance with the License.
#You may obtain a copy of the License at
#
# https://www.apache.org/licenses/LICENSE-2.0
#
#Unless required by applicable law or agreed to in writing, software
#distributed under the License is distributed on an "AS IS" BASIS,
#WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
#See the License for the specific language governing permissions and
#limitations under the License.
import sys
_b=sys.version_info[0]<3 and (lambda x:x) or (lambda x:x.encode('latin1'))
@ -32,7 +20,7 @@ DESCRIPTOR = _descriptor.FileDescriptor(
package='api',
syntax='proto3',
serialized_options=_b('Z5github.com/GoogleCloudPlatform/open-match/internal/pb'),
serialized_pb=_b('\n\x1f\x61pi/protobuf-spec/mmlogic.proto\x12\x03\x61pi\x1a api/protobuf-spec/messages.proto2\xf6\x02\n\x07MmLogic\x12<\n\nGetProfile\x12\x15.messages.MatchObject\x1a\x15.messages.MatchObject\"\x00\x12;\n\x0e\x43reateProposal\x12\x15.messages.MatchObject\x1a\x10.messages.Result\"\x00\x12\x33\n\x0bReturnError\x12\x10.messages.Result\x1a\x10.messages.Result\"\x00\x12?\n\rGetPlayerPool\x12\x14.messages.PlayerPool\x1a\x14.messages.PlayerPool\"\x00\x30\x01\x12=\n\x14GetAllIgnoredPlayers\x12\x11.messages.IlInput\x1a\x10.messages.Roster\"\x00\x12;\n\x12ListIgnoredPlayers\x12\x11.messages.IlInput\x1a\x10.messages.Roster\"\x00\x42\x37Z5github.com/GoogleCloudPlatform/open-match/internal/pbb\x06proto3')
serialized_pb=_b('\n\x1f\x61pi/protobuf-spec/mmlogic.proto\x12\x03\x61pi\x1a api/protobuf-spec/messages.proto2\xc1\x02\n\x07MmLogic\x12<\n\nGetProfile\x12\x15.messages.MatchObject\x1a\x15.messages.MatchObject\"\x00\x12;\n\x0e\x43reateProposal\x12\x15.messages.MatchObject\x1a\x10.messages.Result\"\x00\x12?\n\rGetPlayerPool\x12\x14.messages.PlayerPool\x1a\x14.messages.PlayerPool\"\x00\x30\x01\x12=\n\x14GetAllIgnoredPlayers\x12\x11.messages.IlInput\x1a\x10.messages.Roster\"\x00\x12;\n\x12ListIgnoredPlayers\x12\x11.messages.IlInput\x1a\x10.messages.Roster\"\x00\x42\x37Z5github.com/GoogleCloudPlatform/open-match/internal/pbb\x06proto3')
,
dependencies=[api_dot_protobuf__spec_dot_messages__pb2.DESCRIPTOR,])
@ -50,7 +38,7 @@ _MMLOGIC = _descriptor.ServiceDescriptor(
index=0,
serialized_options=None,
serialized_start=75,
serialized_end=449,
serialized_end=396,
methods=[
_descriptor.MethodDescriptor(
name='GetProfile',
@ -70,19 +58,10 @@ _MMLOGIC = _descriptor.ServiceDescriptor(
output_type=api_dot_protobuf__spec_dot_messages__pb2._RESULT,
serialized_options=None,
),
_descriptor.MethodDescriptor(
name='ReturnError',
full_name='api.MmLogic.ReturnError',
index=2,
containing_service=None,
input_type=api_dot_protobuf__spec_dot_messages__pb2._RESULT,
output_type=api_dot_protobuf__spec_dot_messages__pb2._RESULT,
serialized_options=None,
),
_descriptor.MethodDescriptor(
name='GetPlayerPool',
full_name='api.MmLogic.GetPlayerPool',
index=3,
index=2,
containing_service=None,
input_type=api_dot_protobuf__spec_dot_messages__pb2._PLAYERPOOL,
output_type=api_dot_protobuf__spec_dot_messages__pb2._PLAYERPOOL,
@ -91,7 +70,7 @@ _MMLOGIC = _descriptor.ServiceDescriptor(
_descriptor.MethodDescriptor(
name='GetAllIgnoredPlayers',
full_name='api.MmLogic.GetAllIgnoredPlayers',
index=4,
index=3,
containing_service=None,
input_type=api_dot_protobuf__spec_dot_messages__pb2._ILINPUT,
output_type=api_dot_protobuf__spec_dot_messages__pb2._ROSTER,
@ -100,7 +79,7 @@ _MMLOGIC = _descriptor.ServiceDescriptor(
_descriptor.MethodDescriptor(
name='ListIgnoredPlayers',
full_name='api.MmLogic.ListIgnoredPlayers',
index=5,
index=4,
containing_service=None,
input_type=api_dot_protobuf__spec_dot_messages__pb2._ILINPUT,
output_type=api_dot_protobuf__spec_dot_messages__pb2._ROSTER,

@ -1,25 +1,14 @@
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
#Copyright 2018 Google LLC
#Licensed under the Apache License, Version 2.0 (the "License");
#you may not use this file except in compliance with the License.
#You may obtain a copy of the License at
#
# https://www.apache.org/licenses/LICENSE-2.0
#
#Unless required by applicable law or agreed to in writing, software
#distributed under the License is distributed on an "AS IS" BASIS,
#WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
#See the License for the specific language governing permissions and
#limitations under the License.
import grpc
from api.protobuf_spec import messages_pb2 as api_dot_protobuf__spec_dot_messages__pb2
class MmLogicStub(object):
"""Profile and match object functions
If your matchmaking logic makes a match, it should CreateProposal. If it
cannot, it should ReturnError.
"""The MMLogic API provides utility functions for common MMF functionality, such
as retreiving profiles and players from state storage, writing results to state storage,
and exposing metrics and statistics.
Profile and match object functions
"""
def __init__(self, channel):
@ -38,11 +27,6 @@ class MmLogicStub(object):
request_serializer=api_dot_protobuf__spec_dot_messages__pb2.MatchObject.SerializeToString,
response_deserializer=api_dot_protobuf__spec_dot_messages__pb2.Result.FromString,
)
self.ReturnError = channel.unary_unary(
'/api.MmLogic/ReturnError',
request_serializer=api_dot_protobuf__spec_dot_messages__pb2.Result.SerializeToString,
response_deserializer=api_dot_protobuf__spec_dot_messages__pb2.Result.FromString,
)
self.GetPlayerPool = channel.unary_stream(
'/api.MmLogic/GetPlayerPool',
request_serializer=api_dot_protobuf__spec_dot_messages__pb2.PlayerPool.SerializeToString,
@ -61,9 +45,10 @@ class MmLogicStub(object):
class MmLogicServicer(object):
"""Profile and match object functions
If your matchmaking logic makes a match, it should CreateProposal. If it
cannot, it should ReturnError.
"""The MMLogic API provides utility functions for common MMF functionality, such
as retreiving profiles and players from state storage, writing results to state storage,
and exposing metrics and statistics.
Profile and match object functions
"""
def GetProfile(self, request, context):
@ -77,27 +62,49 @@ class MmLogicServicer(object):
raise NotImplementedError('Method not implemented!')
def CreateProposal(self, request, context):
"""CreateProposal does the following:
- adds all players in the Roster to the proposed player ignore list
"""CreateProposal is called by MMFs that wish to write their results to
a proposed MatchObject, that can be sent out the Backend API once it has
been approved (by default, by the evaluator process).
- adds all players in all Rosters to the proposed player ignore list
- writes the proposed match to the provided key
- adds that key to the list of proposals to be considered
INPUT:
* TO RETURN A MATCHOBJECT AFTER A SUCCESSFUL MMF RUN
To create a match MatchObject message with these fields populated:
- id, set to the value of the MMF_PROPOSAL_ID env var
- properties
- error. You must explicitly set this to an empty string if your MMF
- roster, with the playerIDs filled in the 'players' repeated field.
- [optional] pools, set to the output from the 'GetPlayerPools' call,
will populate the pools with stats about how many players the filters
matched and how long the filters took to run, which will be sent out
the backend api along with your match results.
was successful.
* TO RETURN AN ERROR
To report a failure or error, send a MatchObject message with these
these fields populated:
- id, set to the value of the MMF_ERROR_ID env var.
- error, set to a string value describing the error your MMF encountered.
- [optional] properties, anything you put here is returned to the
backend along with your error.
- [optional] rosters, anything you put here is returned to the
backend along with your error.
- [optional] pools, set to the output from the 'GetPlayerPools' call,
will populate the pools with stats about how many players the filters
matched and how long the filters took to run, which will be sent out
the backend api along with your match results.
OUTPUT: a Result message with a boolean success value and an error string
if an error was encountered
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def ReturnError(self, request, context):
# missing associated documentation comment in .proto file
pass
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def GetPlayerPool(self, request, context):
"""Player listing and filtering functions
RetrievePlayerPool gets the list of players for every Filter in the
PlayerPool, and then removes all players it finds in the ignore list. It
RetrievePlayerPool gets the list of players that match every Filter in the
PlayerPool, .excluding players in any configured ignore lists. It
combines the results, and returns the resulting player pool.
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
@ -114,8 +121,8 @@ class MmLogicServicer(object):
raise NotImplementedError('Method not implemented!')
def ListIgnoredPlayers(self, request, context):
"""RetrieveIgnoreList retrieves players from the ignore list specified in the
config file under 'ignoreLists.proposedPlayers.key'.
"""ListIgnoredPlayers retrieves players from the ignore list specified in the
config file under 'ignoreLists.proposed.name'.
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
@ -134,11 +141,6 @@ def add_MmLogicServicer_to_server(servicer, server):
request_deserializer=api_dot_protobuf__spec_dot_messages__pb2.MatchObject.FromString,
response_serializer=api_dot_protobuf__spec_dot_messages__pb2.Result.SerializeToString,
),
'ReturnError': grpc.unary_unary_rpc_method_handler(
servicer.ReturnError,
request_deserializer=api_dot_protobuf__spec_dot_messages__pb2.Result.FromString,
response_serializer=api_dot_protobuf__spec_dot_messages__pb2.Result.SerializeToString,
),
'GetPlayerPool': grpc.unary_stream_rpc_method_handler(
servicer.GetPlayerPool,
request_deserializer=api_dot_protobuf__spec_dot_messages__pb2.PlayerPool.FromString,

@ -1,38 +1,14 @@
// Code generated by protoc-gen-go. DO NOT EDIT.
// source: api/protobuf-spec/backend.proto
/*
Package pb is a generated protocol buffer package.
It is generated from these files:
api/protobuf-spec/backend.proto
api/protobuf-spec/frontend.proto
api/protobuf-spec/function.proto
api/protobuf-spec/mmlogic.proto
api/protobuf-spec/messages.proto
It has these top-level messages:
MatchObject
Roster
Filter
Stats
PlayerPool
Player
Result
IlInput
Assignments
Request
Arguments
*/
package pb
import proto "github.com/golang/protobuf/proto"
import fmt "fmt"
import math "math"
import (
context "golang.org/x/net/context"
context "context"
fmt "fmt"
proto "github.com/golang/protobuf/proto"
grpc "google.golang.org/grpc"
math "math"
)
// Reference imports to suppress errors if they are not otherwise used.
@ -44,7 +20,28 @@ var _ = math.Inf
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package
const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
func init() { proto.RegisterFile("api/protobuf-spec/backend.proto", fileDescriptor_92161ae1f6f50f7a) }
var fileDescriptor_92161ae1f6f50f7a = []byte{
// 240 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x94, 0x91, 0x3f, 0x4b, 0x04, 0x31,
0x10, 0x47, 0xfd, 0x03, 0x0a, 0xd9, 0xc6, 0x0b, 0xd8, 0x5c, 0xa3, 0xd8, 0xdf, 0x46, 0x14, 0x51,
0x0b, 0x15, 0xef, 0x04, 0x1b, 0x45, 0xb1, 0xb4, 0x4b, 0x72, 0x73, 0x7b, 0xd1, 0x24, 0x13, 0x32,
0xb3, 0x5f, 0xcf, 0xcf, 0x26, 0xbb, 0x01, 0x5d, 0x71, 0x41, 0x6c, 0x1f, 0xef, 0xf1, 0x9b, 0x10,
0x71, 0xa0, 0x93, 0x53, 0x29, 0x23, 0xa3, 0x69, 0x57, 0x33, 0x4a, 0x60, 0x95, 0xd1, 0xf6, 0x1d,
0xe2, 0xb2, 0xee, 0xa9, 0xdc, 0xd6, 0xc9, 0x4d, 0x0f, 0x7f, 0x5b, 0x01, 0x88, 0x74, 0x03, 0x54,
0xb4, 0x93, 0x8f, 0x2d, 0xb1, 0x3b, 0x2f, 0xa1, 0xbc, 0x12, 0xd5, 0x22, 0x83, 0x66, 0x78, 0xd4,
0x6c, 0xd7, 0x72, 0xbf, 0xfe, 0x72, 0x7b, 0xf0, 0x64, 0xde, 0xc0, 0xf2, 0x74, 0x1c, 0x1f, 0x6d,
0xc8, 0x1b, 0x51, 0x3d, 0x38, 0xe2, 0x1e, 0x02, 0xfd, 0x37, 0x3f, 0xde, 0x94, 0x17, 0xa2, 0xba,
0x03, 0x0f, 0x7f, 0xec, 0xef, 0x7d, 0xe3, 0x17, 0xa0, 0xd6, 0x77, 0xd3, 0xd7, 0x62, 0x52, 0x2e,
0xbf, 0x25, 0x72, 0x4d, 0x0c, 0x10, 0xf9, 0xc7, 0x01, 0x03, 0x3c, 0xda, 0x5f, 0x8a, 0x49, 0x59,
0x1e, 0xf6, 0x43, 0x11, 0x89, 0x21, 0x8f, 0xa5, 0xf3, 0xf3, 0xd7, 0xb3, 0xc6, 0xf1, 0xba, 0x35,
0xb5, 0xc5, 0xa0, 0xee, 0x11, 0x1b, 0x0f, 0x0b, 0x8f, 0xed, 0xf2, 0xd9, 0x6b, 0x5e, 0x61, 0x0e,
0x0a, 0x13, 0xc4, 0x59, 0xe8, 0x5e, 0xa0, 0x5c, 0x64, 0xc8, 0x51, 0x7b, 0x95, 0x8c, 0xd9, 0xe9,
0x3f, 0xe0, 0xf4, 0x33, 0x00, 0x00, 0xff, 0xff, 0x33, 0x3a, 0x1e, 0x0d, 0xca, 0x01, 0x00, 0x00,
}
// Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
@ -54,8 +51,9 @@ var _ grpc.ClientConn
// is compatible with the grpc package it is being compiled against.
const _ = grpc.SupportPackageIsVersion4
// Client API for Backend service
// BackendClient is the client API for Backend service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
type BackendClient interface {
// Run MMF once. Return a matchobject that fits this profile.
// INPUT: MatchObject message with these fields populated:
@ -110,7 +108,7 @@ func NewBackendClient(cc *grpc.ClientConn) BackendClient {
func (c *backendClient) CreateMatch(ctx context.Context, in *MatchObject, opts ...grpc.CallOption) (*MatchObject, error) {
out := new(MatchObject)
err := grpc.Invoke(ctx, "/api.Backend/CreateMatch", in, out, c.cc, opts...)
err := c.cc.Invoke(ctx, "/api.Backend/CreateMatch", in, out, opts...)
if err != nil {
return nil, err
}
@ -118,7 +116,7 @@ func (c *backendClient) CreateMatch(ctx context.Context, in *MatchObject, opts .
}
func (c *backendClient) ListMatches(ctx context.Context, in *MatchObject, opts ...grpc.CallOption) (Backend_ListMatchesClient, error) {
stream, err := grpc.NewClientStream(ctx, &_Backend_serviceDesc.Streams[0], c.cc, "/api.Backend/ListMatches", opts...)
stream, err := c.cc.NewStream(ctx, &_Backend_serviceDesc.Streams[0], "/api.Backend/ListMatches", opts...)
if err != nil {
return nil, err
}
@ -151,7 +149,7 @@ func (x *backendListMatchesClient) Recv() (*MatchObject, error) {
func (c *backendClient) DeleteMatch(ctx context.Context, in *MatchObject, opts ...grpc.CallOption) (*Result, error) {
out := new(Result)
err := grpc.Invoke(ctx, "/api.Backend/DeleteMatch", in, out, c.cc, opts...)
err := c.cc.Invoke(ctx, "/api.Backend/DeleteMatch", in, out, opts...)
if err != nil {
return nil, err
}
@ -160,7 +158,7 @@ func (c *backendClient) DeleteMatch(ctx context.Context, in *MatchObject, opts .
func (c *backendClient) CreateAssignments(ctx context.Context, in *Assignments, opts ...grpc.CallOption) (*Result, error) {
out := new(Result)
err := grpc.Invoke(ctx, "/api.Backend/CreateAssignments", in, out, c.cc, opts...)
err := c.cc.Invoke(ctx, "/api.Backend/CreateAssignments", in, out, opts...)
if err != nil {
return nil, err
}
@ -169,15 +167,14 @@ func (c *backendClient) CreateAssignments(ctx context.Context, in *Assignments,
func (c *backendClient) DeleteAssignments(ctx context.Context, in *Roster, opts ...grpc.CallOption) (*Result, error) {
out := new(Result)
err := grpc.Invoke(ctx, "/api.Backend/DeleteAssignments", in, out, c.cc, opts...)
err := c.cc.Invoke(ctx, "/api.Backend/DeleteAssignments", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
// Server API for Backend service
// BackendServer is the server API for Backend service.
type BackendServer interface {
// Run MMF once. Return a matchobject that fits this profile.
// INPUT: MatchObject message with these fields populated:
@ -349,24 +346,3 @@ var _Backend_serviceDesc = grpc.ServiceDesc{
},
Metadata: "api/protobuf-spec/backend.proto",
}
func init() { proto.RegisterFile("api/protobuf-spec/backend.proto", fileDescriptor0) }
var fileDescriptor0 = []byte{
// 240 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x94, 0x91, 0x3f, 0x4b, 0x04, 0x31,
0x10, 0x47, 0xfd, 0x03, 0x0a, 0xd9, 0xc6, 0x0b, 0xd8, 0x5c, 0xa3, 0xd8, 0xdf, 0x46, 0x14, 0x51,
0x0b, 0x15, 0xef, 0x04, 0x1b, 0x45, 0xb1, 0xb4, 0x4b, 0x72, 0x73, 0x7b, 0xd1, 0x24, 0x13, 0x32,
0xb3, 0x5f, 0xcf, 0xcf, 0x26, 0xbb, 0x01, 0x5d, 0x71, 0x41, 0x6c, 0x1f, 0xef, 0xf1, 0x9b, 0x10,
0x71, 0xa0, 0x93, 0x53, 0x29, 0x23, 0xa3, 0x69, 0x57, 0x33, 0x4a, 0x60, 0x95, 0xd1, 0xf6, 0x1d,
0xe2, 0xb2, 0xee, 0xa9, 0xdc, 0xd6, 0xc9, 0x4d, 0x0f, 0x7f, 0x5b, 0x01, 0x88, 0x74, 0x03, 0x54,
0xb4, 0x93, 0x8f, 0x2d, 0xb1, 0x3b, 0x2f, 0xa1, 0xbc, 0x12, 0xd5, 0x22, 0x83, 0x66, 0x78, 0xd4,
0x6c, 0xd7, 0x72, 0xbf, 0xfe, 0x72, 0x7b, 0xf0, 0x64, 0xde, 0xc0, 0xf2, 0x74, 0x1c, 0x1f, 0x6d,
0xc8, 0x1b, 0x51, 0x3d, 0x38, 0xe2, 0x1e, 0x02, 0xfd, 0x37, 0x3f, 0xde, 0x94, 0x17, 0xa2, 0xba,
0x03, 0x0f, 0x7f, 0xec, 0xef, 0x7d, 0xe3, 0x17, 0xa0, 0xd6, 0x77, 0xd3, 0xd7, 0x62, 0x52, 0x2e,
0xbf, 0x25, 0x72, 0x4d, 0x0c, 0x10, 0xf9, 0xc7, 0x01, 0x03, 0x3c, 0xda, 0x5f, 0x8a, 0x49, 0x59,
0x1e, 0xf6, 0x43, 0x11, 0x89, 0x21, 0x8f, 0xa5, 0xf3, 0xf3, 0xd7, 0xb3, 0xc6, 0xf1, 0xba, 0x35,
0xb5, 0xc5, 0xa0, 0xee, 0x11, 0x1b, 0x0f, 0x0b, 0x8f, 0xed, 0xf2, 0xd9, 0x6b, 0x5e, 0x61, 0x0e,
0x0a, 0x13, 0xc4, 0x59, 0xe8, 0x5e, 0xa0, 0x5c, 0x64, 0xc8, 0x51, 0x7b, 0x95, 0x8c, 0xd9, 0xe9,
0x3f, 0xe0, 0xf4, 0x33, 0x00, 0x00, 0xff, 0xff, 0x33, 0x3a, 0x1e, 0x0d, 0xca, 0x01, 0x00, 0x00,
}

@ -3,13 +3,12 @@
package pb
import proto "github.com/golang/protobuf/proto"
import fmt "fmt"
import math "math"
import (
context "golang.org/x/net/context"
context "context"
fmt "fmt"
proto "github.com/golang/protobuf/proto"
grpc "google.golang.org/grpc"
math "math"
)
// Reference imports to suppress errors if they are not otherwise used.
@ -17,6 +16,29 @@ var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf
// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
func init() { proto.RegisterFile("api/protobuf-spec/function.proto", fileDescriptor_949a68f1f25eb768) }
var fileDescriptor_949a68f1f25eb768 = []byte{
// 168 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x6c, 0xcd, 0x31, 0x0b, 0xc2, 0x30,
0x10, 0xc5, 0x71, 0xa1, 0x20, 0xd2, 0x49, 0xea, 0xd6, 0x49, 0xdc, 0x9b, 0x80, 0x22, 0x82, 0x9b,
0x0a, 0xba, 0x4a, 0x47, 0xb7, 0x24, 0x5e, 0xd3, 0x40, 0x92, 0x0b, 0xc9, 0xdd, 0xf7, 0x17, 0xaa,
0xe8, 0xe2, 0xfa, 0xe7, 0xf7, 0x78, 0xf5, 0x5a, 0x25, 0x27, 0x53, 0x46, 0x42, 0xcd, 0x43, 0x57,
0x12, 0x18, 0x39, 0x70, 0x34, 0xe4, 0x30, 0x8a, 0x29, 0x37, 0x95, 0x4a, 0xae, 0xfd, 0xc3, 0x02,
0x94, 0xa2, 0x2c, 0x94, 0x37, 0xdb, 0x1e, 0xeb, 0xc5, 0xf5, 0x33, 0x6c, 0x44, 0x5d, 0xf5, 0x1c,
0x9b, 0x95, 0xf8, 0x9a, 0x53, 0xb6, 0x1c, 0x20, 0x52, 0x69, 0x97, 0xbf, 0xd8, 0x43, 0x61, 0x4f,
0x9b, 0xd9, 0xf9, 0xf0, 0xd8, 0x5b, 0x47, 0x23, 0x6b, 0x61, 0x30, 0xc8, 0x1b, 0xa2, 0xf5, 0x70,
0xf1, 0xc8, 0xcf, 0xbb, 0x57, 0x34, 0x60, 0x0e, 0x12, 0x13, 0xc4, 0x2e, 0x28, 0x32, 0xa3, 0x74,
0x91, 0x20, 0x47, 0xe5, 0x65, 0xd2, 0x7a, 0x3e, 0x7d, 0xef, 0x5e, 0x01, 0x00, 0x00, 0xff, 0xff,
0x72, 0xee, 0x1f, 0xa8, 0xc6, 0x00, 0x00, 0x00,
}
// Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
var _ grpc.ClientConn
@ -25,8 +47,9 @@ var _ grpc.ClientConn
// is compatible with the grpc package it is being compiled against.
const _ = grpc.SupportPackageIsVersion4
// Client API for Function service
// FunctionClient is the client API for Function service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
type FunctionClient interface {
// The assumption is that there will be one service for each MMF that is
// being served. Build your MMF in the appropriate serving harness, deploy it
@ -45,15 +68,14 @@ func NewFunctionClient(cc *grpc.ClientConn) FunctionClient {
func (c *functionClient) Run(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Result, error) {
out := new(Result)
err := grpc.Invoke(ctx, "/api.Function/Run", in, out, c.cc, opts...)
err := c.cc.Invoke(ctx, "/api.Function/Run", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
// Server API for Function service
// FunctionServer is the server API for Function service.
type FunctionServer interface {
// The assumption is that there will be one service for each MMF that is
// being served. Build your MMF in the appropriate serving harness, deploy it
@ -96,20 +118,3 @@ var _Function_serviceDesc = grpc.ServiceDesc{
Streams: []grpc.StreamDesc{},
Metadata: "api/protobuf-spec/function.proto",
}
func init() { proto.RegisterFile("api/protobuf-spec/function.proto", fileDescriptor2) }
var fileDescriptor2 = []byte{
// 168 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x6c, 0xcd, 0x31, 0x0b, 0xc2, 0x30,
0x10, 0xc5, 0x71, 0xa1, 0x20, 0xd2, 0x49, 0xea, 0xd6, 0x49, 0xdc, 0x9b, 0x80, 0x22, 0x82, 0x9b,
0x0a, 0xba, 0x4a, 0x47, 0xb7, 0x24, 0x5e, 0xd3, 0x40, 0x92, 0x0b, 0xc9, 0xdd, 0xf7, 0x17, 0xaa,
0xe8, 0xe2, 0xfa, 0xe7, 0xf7, 0x78, 0xf5, 0x5a, 0x25, 0x27, 0x53, 0x46, 0x42, 0xcd, 0x43, 0x57,
0x12, 0x18, 0x39, 0x70, 0x34, 0xe4, 0x30, 0x8a, 0x29, 0x37, 0x95, 0x4a, 0xae, 0xfd, 0xc3, 0x02,
0x94, 0xa2, 0x2c, 0x94, 0x37, 0xdb, 0x1e, 0xeb, 0xc5, 0xf5, 0x33, 0x6c, 0x44, 0x5d, 0xf5, 0x1c,
0x9b, 0x95, 0xf8, 0x9a, 0x53, 0xb6, 0x1c, 0x20, 0x52, 0x69, 0x97, 0xbf, 0xd8, 0x43, 0x61, 0x4f,
0x9b, 0xd9, 0xf9, 0xf0, 0xd8, 0x5b, 0x47, 0x23, 0x6b, 0x61, 0x30, 0xc8, 0x1b, 0xa2, 0xf5, 0x70,
0xf1, 0xc8, 0xcf, 0xbb, 0x57, 0x34, 0x60, 0x0e, 0x12, 0x13, 0xc4, 0x2e, 0x28, 0x32, 0xa3, 0x74,
0x91, 0x20, 0x47, 0xe5, 0x65, 0xd2, 0x7a, 0x3e, 0x7d, 0xef, 0x5e, 0x01, 0x00, 0x00, 0xff, 0xff,
0x72, 0xee, 0x1f, 0xa8, 0xc6, 0x00, 0x00, 0x00,
}

@ -3,15 +3,23 @@
package pb
import proto "github.com/golang/protobuf/proto"
import fmt "fmt"
import math "math"
import (
fmt "fmt"
proto "github.com/golang/protobuf/proto"
math "math"
)
// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf
// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
// Open Match's internal representation and wire protocol format for "MatchObjects".
// In order to request a match using the Backend API, your backend code should generate
// a new MatchObject with an ID and properties filled in (for more details about valid
@ -24,18 +32,41 @@ var _ = math.Inf
// MatchObject as input only require a few of them to be filled in. Check the
// gRPC function in question for more details.
type MatchObject struct {
Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
Properties string `protobuf:"bytes,2,opt,name=properties" json:"properties,omitempty"`
Error string `protobuf:"bytes,3,opt,name=error" json:"error,omitempty"`
Rosters []*Roster `protobuf:"bytes,4,rep,name=rosters" json:"rosters,omitempty"`
Pools []*PlayerPool `protobuf:"bytes,5,rep,name=pools" json:"pools,omitempty"`
Status string `protobuf:"bytes,6,opt,name=status" json:"status,omitempty"`
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Properties string `protobuf:"bytes,2,opt,name=properties,proto3" json:"properties,omitempty"`
Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
Rosters []*Roster `protobuf:"bytes,4,rep,name=rosters,proto3" json:"rosters,omitempty"`
Pools []*PlayerPool `protobuf:"bytes,5,rep,name=pools,proto3" json:"pools,omitempty"`
Status string `protobuf:"bytes,6,opt,name=status,proto3" json:"status,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *MatchObject) Reset() { *m = MatchObject{} }
func (m *MatchObject) String() string { return proto.CompactTextString(m) }
func (*MatchObject) ProtoMessage() {}
func (*MatchObject) Descriptor() ([]byte, []int) { return fileDescriptor4, []int{0} }
func (m *MatchObject) Reset() { *m = MatchObject{} }
func (m *MatchObject) String() string { return proto.CompactTextString(m) }
func (*MatchObject) ProtoMessage() {}
func (*MatchObject) Descriptor() ([]byte, []int) {
return fileDescriptor_ec5e45ff8e70c33d, []int{0}
}
func (m *MatchObject) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_MatchObject.Unmarshal(m, b)
}
func (m *MatchObject) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_MatchObject.Marshal(b, m, deterministic)
}
func (m *MatchObject) XXX_Merge(src proto.Message) {
xxx_messageInfo_MatchObject.Merge(m, src)
}
func (m *MatchObject) XXX_Size() int {
return xxx_messageInfo_MatchObject.Size(m)
}
func (m *MatchObject) XXX_DiscardUnknown() {
xxx_messageInfo_MatchObject.DiscardUnknown(m)
}
var xxx_messageInfo_MatchObject proto.InternalMessageInfo
func (m *MatchObject) GetId() string {
if m != nil {
@ -81,14 +112,37 @@ func (m *MatchObject) GetStatus() string {
// Data structure to hold a list of players in a match.
type Roster struct {
Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
Players []*Player `protobuf:"bytes,2,rep,name=players" json:"players,omitempty"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Players []*Player `protobuf:"bytes,2,rep,name=players,proto3" json:"players,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *Roster) Reset() { *m = Roster{} }
func (m *Roster) String() string { return proto.CompactTextString(m) }
func (*Roster) ProtoMessage() {}
func (*Roster) Descriptor() ([]byte, []int) { return fileDescriptor4, []int{1} }
func (m *Roster) Reset() { *m = Roster{} }
func (m *Roster) String() string { return proto.CompactTextString(m) }
func (*Roster) ProtoMessage() {}
func (*Roster) Descriptor() ([]byte, []int) {
return fileDescriptor_ec5e45ff8e70c33d, []int{1}
}
func (m *Roster) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_Roster.Unmarshal(m, b)
}
func (m *Roster) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_Roster.Marshal(b, m, deterministic)
}
func (m *Roster) XXX_Merge(src proto.Message) {
xxx_messageInfo_Roster.Merge(m, src)
}
func (m *Roster) XXX_Size() int {
return xxx_messageInfo_Roster.Size(m)
}
func (m *Roster) XXX_DiscardUnknown() {
xxx_messageInfo_Roster.DiscardUnknown(m)
}
var xxx_messageInfo_Roster proto.InternalMessageInfo
func (m *Roster) GetName() string {
if m != nil {
@ -106,17 +160,40 @@ func (m *Roster) GetPlayers() []*Player {
// A 'hard' filter to apply to the player pool.
type Filter struct {
Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
Attribute string `protobuf:"bytes,2,opt,name=attribute" json:"attribute,omitempty"`
Maxv int64 `protobuf:"varint,3,opt,name=maxv" json:"maxv,omitempty"`
Minv int64 `protobuf:"varint,4,opt,name=minv" json:"minv,omitempty"`
Stats *Stats `protobuf:"bytes,5,opt,name=stats" json:"stats,omitempty"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Attribute string `protobuf:"bytes,2,opt,name=attribute,proto3" json:"attribute,omitempty"`
Maxv int64 `protobuf:"varint,3,opt,name=maxv,proto3" json:"maxv,omitempty"`
Minv int64 `protobuf:"varint,4,opt,name=minv,proto3" json:"minv,omitempty"`
Stats *Stats `protobuf:"bytes,5,opt,name=stats,proto3" json:"stats,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *Filter) Reset() { *m = Filter{} }
func (m *Filter) String() string { return proto.CompactTextString(m) }
func (*Filter) ProtoMessage() {}
func (*Filter) Descriptor() ([]byte, []int) { return fileDescriptor4, []int{2} }
func (m *Filter) Reset() { *m = Filter{} }
func (m *Filter) String() string { return proto.CompactTextString(m) }
func (*Filter) ProtoMessage() {}
func (*Filter) Descriptor() ([]byte, []int) {
return fileDescriptor_ec5e45ff8e70c33d, []int{2}
}
func (m *Filter) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_Filter.Unmarshal(m, b)
}
func (m *Filter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_Filter.Marshal(b, m, deterministic)
}
func (m *Filter) XXX_Merge(src proto.Message) {
xxx_messageInfo_Filter.Merge(m, src)
}
func (m *Filter) XXX_Size() int {
return xxx_messageInfo_Filter.Size(m)
}
func (m *Filter) XXX_DiscardUnknown() {
xxx_messageInfo_Filter.DiscardUnknown(m)
}
var xxx_messageInfo_Filter proto.InternalMessageInfo
func (m *Filter) GetName() string {
if m != nil {
@ -155,14 +232,37 @@ func (m *Filter) GetStats() *Stats {
// Holds statistics
type Stats struct {
Count int64 `protobuf:"varint,1,opt,name=count" json:"count,omitempty"`
Elapsed float64 `protobuf:"fixed64,2,opt,name=elapsed" json:"elapsed,omitempty"`
Count int64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
Elapsed float64 `protobuf:"fixed64,2,opt,name=elapsed,proto3" json:"elapsed,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *Stats) Reset() { *m = Stats{} }
func (m *Stats) String() string { return proto.CompactTextString(m) }
func (*Stats) ProtoMessage() {}
func (*Stats) Descriptor() ([]byte, []int) { return fileDescriptor4, []int{3} }
func (m *Stats) Reset() { *m = Stats{} }
func (m *Stats) String() string { return proto.CompactTextString(m) }
func (*Stats) ProtoMessage() {}
func (*Stats) Descriptor() ([]byte, []int) {
return fileDescriptor_ec5e45ff8e70c33d, []int{3}
}
func (m *Stats) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_Stats.Unmarshal(m, b)
}
func (m *Stats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_Stats.Marshal(b, m, deterministic)
}
func (m *Stats) XXX_Merge(src proto.Message) {
xxx_messageInfo_Stats.Merge(m, src)
}
func (m *Stats) XXX_Size() int {
return xxx_messageInfo_Stats.Size(m)
}
func (m *Stats) XXX_DiscardUnknown() {
xxx_messageInfo_Stats.DiscardUnknown(m)
}
var xxx_messageInfo_Stats proto.InternalMessageInfo
func (m *Stats) GetCount() int64 {
if m != nil {
@ -185,16 +285,39 @@ func (m *Stats) GetElapsed() float64 {
// PlayerPool as input only require a few of them to be filled in. Check the
// gRPC function in question for more details.
type PlayerPool struct {
Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
Filters []*Filter `protobuf:"bytes,2,rep,name=filters" json:"filters,omitempty"`
Roster *Roster `protobuf:"bytes,3,opt,name=roster" json:"roster,omitempty"`
Stats *Stats `protobuf:"bytes,4,opt,name=stats" json:"stats,omitempty"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Filters []*Filter `protobuf:"bytes,2,rep,name=filters,proto3" json:"filters,omitempty"`
Roster *Roster `protobuf:"bytes,3,opt,name=roster,proto3" json:"roster,omitempty"`
Stats *Stats `protobuf:"bytes,4,opt,name=stats,proto3" json:"stats,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *PlayerPool) Reset() { *m = PlayerPool{} }
func (m *PlayerPool) String() string { return proto.CompactTextString(m) }
func (*PlayerPool) ProtoMessage() {}
func (*PlayerPool) Descriptor() ([]byte, []int) { return fileDescriptor4, []int{4} }
func (m *PlayerPool) Reset() { *m = PlayerPool{} }
func (m *PlayerPool) String() string { return proto.CompactTextString(m) }
func (*PlayerPool) ProtoMessage() {}
func (*PlayerPool) Descriptor() ([]byte, []int) {
return fileDescriptor_ec5e45ff8e70c33d, []int{4}
}
func (m *PlayerPool) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_PlayerPool.Unmarshal(m, b)
}
func (m *PlayerPool) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_PlayerPool.Marshal(b, m, deterministic)
}
func (m *PlayerPool) XXX_Merge(src proto.Message) {
xxx_messageInfo_PlayerPool.Merge(m, src)
}
func (m *PlayerPool) XXX_Size() int {
return xxx_messageInfo_PlayerPool.Size(m)
}
func (m *PlayerPool) XXX_DiscardUnknown() {
xxx_messageInfo_PlayerPool.DiscardUnknown(m)
}
var xxx_messageInfo_PlayerPool proto.InternalMessageInfo
func (m *PlayerPool) GetName() string {
if m != nil {
@ -233,19 +356,42 @@ func (m *PlayerPool) GetStats() *Stats {
// Player as input only require a few of them to be filled in. Check the
// gRPC function in question for more details.
type Player struct {
Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
Properties string `protobuf:"bytes,2,opt,name=properties" json:"properties,omitempty"`
Pool string `protobuf:"bytes,3,opt,name=pool" json:"pool,omitempty"`
Attributes []*Player_Attribute `protobuf:"bytes,4,rep,name=attributes" json:"attributes,omitempty"`
Assignment string `protobuf:"bytes,5,opt,name=assignment" json:"assignment,omitempty"`
Status string `protobuf:"bytes,6,opt,name=status" json:"status,omitempty"`
Error string `protobuf:"bytes,7,opt,name=error" json:"error,omitempty"`
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Properties string `protobuf:"bytes,2,opt,name=properties,proto3" json:"properties,omitempty"`
Pool string `protobuf:"bytes,3,opt,name=pool,proto3" json:"pool,omitempty"`
Attributes []*Player_Attribute `protobuf:"bytes,4,rep,name=attributes,proto3" json:"attributes,omitempty"`
Assignment string `protobuf:"bytes,5,opt,name=assignment,proto3" json:"assignment,omitempty"`
Status string `protobuf:"bytes,6,opt,name=status,proto3" json:"status,omitempty"`
Error string `protobuf:"bytes,7,opt,name=error,proto3" json:"error,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *Player) Reset() { *m = Player{} }
func (m *Player) String() string { return proto.CompactTextString(m) }
func (*Player) ProtoMessage() {}
func (*Player) Descriptor() ([]byte, []int) { return fileDescriptor4, []int{5} }
func (m *Player) Reset() { *m = Player{} }
func (m *Player) String() string { return proto.CompactTextString(m) }
func (*Player) ProtoMessage() {}
func (*Player) Descriptor() ([]byte, []int) {
return fileDescriptor_ec5e45ff8e70c33d, []int{5}
}
func (m *Player) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_Player.Unmarshal(m, b)
}
func (m *Player) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_Player.Marshal(b, m, deterministic)
}
func (m *Player) XXX_Merge(src proto.Message) {
xxx_messageInfo_Player.Merge(m, src)
}
func (m *Player) XXX_Size() int {
return xxx_messageInfo_Player.Size(m)
}
func (m *Player) XXX_DiscardUnknown() {
xxx_messageInfo_Player.DiscardUnknown(m)
}
var xxx_messageInfo_Player proto.InternalMessageInfo
func (m *Player) GetId() string {
if m != nil {
@ -297,14 +443,37 @@ func (m *Player) GetError() string {
}
type Player_Attribute struct {
Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
Value int64 `protobuf:"varint,2,opt,name=value" json:"value,omitempty"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Value int64 `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *Player_Attribute) Reset() { *m = Player_Attribute{} }
func (m *Player_Attribute) String() string { return proto.CompactTextString(m) }
func (*Player_Attribute) ProtoMessage() {}
func (*Player_Attribute) Descriptor() ([]byte, []int) { return fileDescriptor4, []int{5, 0} }
func (m *Player_Attribute) Reset() { *m = Player_Attribute{} }
func (m *Player_Attribute) String() string { return proto.CompactTextString(m) }
func (*Player_Attribute) ProtoMessage() {}
func (*Player_Attribute) Descriptor() ([]byte, []int) {
return fileDescriptor_ec5e45ff8e70c33d, []int{5, 0}
}
func (m *Player_Attribute) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_Player_Attribute.Unmarshal(m, b)
}
func (m *Player_Attribute) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_Player_Attribute.Marshal(b, m, deterministic)
}
func (m *Player_Attribute) XXX_Merge(src proto.Message) {
xxx_messageInfo_Player_Attribute.Merge(m, src)
}
func (m *Player_Attribute) XXX_Size() int {
return xxx_messageInfo_Player_Attribute.Size(m)
}
func (m *Player_Attribute) XXX_DiscardUnknown() {
xxx_messageInfo_Player_Attribute.DiscardUnknown(m)
}
var xxx_messageInfo_Player_Attribute proto.InternalMessageInfo
func (m *Player_Attribute) GetName() string {
if m != nil {
@ -322,14 +491,37 @@ func (m *Player_Attribute) GetValue() int64 {
// Simple message to return success/failure and error status.
type Result struct {
Success bool `protobuf:"varint,1,opt,name=success" json:"success,omitempty"`
Error string `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *Result) Reset() { *m = Result{} }
func (m *Result) String() string { return proto.CompactTextString(m) }
func (*Result) ProtoMessage() {}
func (*Result) Descriptor() ([]byte, []int) { return fileDescriptor4, []int{6} }
func (m *Result) Reset() { *m = Result{} }
func (m *Result) String() string { return proto.CompactTextString(m) }
func (*Result) ProtoMessage() {}
func (*Result) Descriptor() ([]byte, []int) {
return fileDescriptor_ec5e45ff8e70c33d, []int{6}
}
func (m *Result) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_Result.Unmarshal(m, b)
}
func (m *Result) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_Result.Marshal(b, m, deterministic)
}
func (m *Result) XXX_Merge(src proto.Message) {
xxx_messageInfo_Result.Merge(m, src)
}
func (m *Result) XXX_Size() int {
return xxx_messageInfo_Result.Size(m)
}
func (m *Result) XXX_DiscardUnknown() {
xxx_messageInfo_Result.DiscardUnknown(m)
}
var xxx_messageInfo_Result proto.InternalMessageInfo
func (m *Result) GetSuccess() bool {
if m != nil {
@ -347,22 +539,68 @@ func (m *Result) GetError() string {
// IlInput is an empty message reserved for future use.
type IlInput struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *IlInput) Reset() { *m = IlInput{} }
func (m *IlInput) String() string { return proto.CompactTextString(m) }
func (*IlInput) ProtoMessage() {}
func (*IlInput) Descriptor() ([]byte, []int) { return fileDescriptor4, []int{7} }
func (m *IlInput) Reset() { *m = IlInput{} }
func (m *IlInput) String() string { return proto.CompactTextString(m) }
func (*IlInput) ProtoMessage() {}
func (*IlInput) Descriptor() ([]byte, []int) {
return fileDescriptor_ec5e45ff8e70c33d, []int{7}
}
func (m *IlInput) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_IlInput.Unmarshal(m, b)
}
func (m *IlInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_IlInput.Marshal(b, m, deterministic)
}
func (m *IlInput) XXX_Merge(src proto.Message) {
xxx_messageInfo_IlInput.Merge(m, src)
}
func (m *IlInput) XXX_Size() int {
return xxx_messageInfo_IlInput.Size(m)
}
func (m *IlInput) XXX_DiscardUnknown() {
xxx_messageInfo_IlInput.DiscardUnknown(m)
}
var xxx_messageInfo_IlInput proto.InternalMessageInfo
type Assignments struct {
Rosters []*Roster `protobuf:"bytes,1,rep,name=rosters" json:"rosters,omitempty"`
Assignment string `protobuf:"bytes,10,opt,name=assignment" json:"assignment,omitempty"`
Rosters []*Roster `protobuf:"bytes,1,rep,name=rosters,proto3" json:"rosters,omitempty"`
Assignment string `protobuf:"bytes,10,opt,name=assignment,proto3" json:"assignment,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *Assignments) Reset() { *m = Assignments{} }
func (m *Assignments) String() string { return proto.CompactTextString(m) }
func (*Assignments) ProtoMessage() {}
func (*Assignments) Descriptor() ([]byte, []int) { return fileDescriptor4, []int{8} }
func (m *Assignments) Reset() { *m = Assignments{} }
func (m *Assignments) String() string { return proto.CompactTextString(m) }
func (*Assignments) ProtoMessage() {}
func (*Assignments) Descriptor() ([]byte, []int) {
return fileDescriptor_ec5e45ff8e70c33d, []int{8}
}
func (m *Assignments) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_Assignments.Unmarshal(m, b)
}
func (m *Assignments) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_Assignments.Marshal(b, m, deterministic)
}
func (m *Assignments) XXX_Merge(src proto.Message) {
xxx_messageInfo_Assignments.Merge(m, src)
}
func (m *Assignments) XXX_Size() int {
return xxx_messageInfo_Assignments.Size(m)
}
func (m *Assignments) XXX_DiscardUnknown() {
xxx_messageInfo_Assignments.DiscardUnknown(m)
}
var xxx_messageInfo_Assignments proto.InternalMessageInfo
func (m *Assignments) GetRosters() []*Roster {
if m != nil {
@ -382,17 +620,40 @@ func (m *Assignments) GetAssignment() string {
// to a matchmaking function; used so it knows which records to
// write/update in state storage.
type Request struct {
ProfileId string `protobuf:"bytes,1,opt,name=profile_id,json=profileId" json:"profile_id,omitempty"`
ProposalId string `protobuf:"bytes,2,opt,name=proposal_id,json=proposalId" json:"proposal_id,omitempty"`
RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId" json:"request_id,omitempty"`
ErrorId string `protobuf:"bytes,4,opt,name=error_id,json=errorId" json:"error_id,omitempty"`
Timestamp string `protobuf:"bytes,5,opt,name=timestamp" json:"timestamp,omitempty"`
ProfileId string `protobuf:"bytes,1,opt,name=profile_id,json=profileId,proto3" json:"profile_id,omitempty"`
ProposalId string `protobuf:"bytes,2,opt,name=proposal_id,json=proposalId,proto3" json:"proposal_id,omitempty"`
RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
ErrorId string `protobuf:"bytes,4,opt,name=error_id,json=errorId,proto3" json:"error_id,omitempty"`
Timestamp string `protobuf:"bytes,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *Request) Reset() { *m = Request{} }
func (m *Request) String() string { return proto.CompactTextString(m) }
func (*Request) ProtoMessage() {}
func (*Request) Descriptor() ([]byte, []int) { return fileDescriptor4, []int{9} }
func (m *Request) Reset() { *m = Request{} }
func (m *Request) String() string { return proto.CompactTextString(m) }
func (*Request) ProtoMessage() {}
func (*Request) Descriptor() ([]byte, []int) {
return fileDescriptor_ec5e45ff8e70c33d, []int{9}
}
func (m *Request) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_Request.Unmarshal(m, b)
}
func (m *Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_Request.Marshal(b, m, deterministic)
}
func (m *Request) XXX_Merge(src proto.Message) {
xxx_messageInfo_Request.Merge(m, src)
}
func (m *Request) XXX_Size() int {
return xxx_messageInfo_Request.Size(m)
}
func (m *Request) XXX_DiscardUnknown() {
xxx_messageInfo_Request.DiscardUnknown(m)
}
var xxx_messageInfo_Request proto.InternalMessageInfo
func (m *Request) GetProfileId() string {
if m != nil {
@ -432,14 +693,37 @@ func (m *Request) GetTimestamp() string {
// The message for passing all the necessary arguments to a
// matchmaking function.
type Arguments struct {
Request *Request `protobuf:"bytes,1,opt,name=request" json:"request,omitempty"`
Matchobject *MatchObject `protobuf:"bytes,2,opt,name=matchobject" json:"matchobject,omitempty"`
Request *Request `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
Matchobject *MatchObject `protobuf:"bytes,2,opt,name=matchobject,proto3" json:"matchobject,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *Arguments) Reset() { *m = Arguments{} }
func (m *Arguments) String() string { return proto.CompactTextString(m) }
func (*Arguments) ProtoMessage() {}
func (*Arguments) Descriptor() ([]byte, []int) { return fileDescriptor4, []int{10} }
func (m *Arguments) Reset() { *m = Arguments{} }
func (m *Arguments) String() string { return proto.CompactTextString(m) }
func (*Arguments) ProtoMessage() {}
func (*Arguments) Descriptor() ([]byte, []int) {
return fileDescriptor_ec5e45ff8e70c33d, []int{10}
}
func (m *Arguments) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_Arguments.Unmarshal(m, b)
}
func (m *Arguments) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_Arguments.Marshal(b, m, deterministic)
}
func (m *Arguments) XXX_Merge(src proto.Message) {
xxx_messageInfo_Arguments.Merge(m, src)
}
func (m *Arguments) XXX_Size() int {
return xxx_messageInfo_Arguments.Size(m)
}
func (m *Arguments) XXX_DiscardUnknown() {
xxx_messageInfo_Arguments.DiscardUnknown(m)
}
var xxx_messageInfo_Arguments proto.InternalMessageInfo
func (m *Arguments) GetRequest() *Request {
if m != nil {
@ -470,9 +754,9 @@ func init() {
proto.RegisterType((*Arguments)(nil), "messages.Arguments")
}
func init() { proto.RegisterFile("api/protobuf-spec/messages.proto", fileDescriptor4) }
func init() { proto.RegisterFile("api/protobuf-spec/messages.proto", fileDescriptor_ec5e45ff8e70c33d) }
var fileDescriptor4 = []byte{
var fileDescriptor_ec5e45ff8e70c33d = []byte{
// 655 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x94, 0x54, 0xcd, 0x6e, 0xd4, 0x3c,
0x14, 0x55, 0xe6, 0x27, 0x69, 0x6e, 0xa4, 0xef, 0x03, 0xab, 0xa0, 0x50, 0xf1, 0x53, 0x45, 0x42,

@ -3,13 +3,12 @@
package pb
import proto "github.com/golang/protobuf/proto"
import fmt "fmt"
import math "math"
import (
context "golang.org/x/net/context"
context "context"
fmt "fmt"
proto "github.com/golang/protobuf/proto"
grpc "google.golang.org/grpc"
math "math"
)
// Reference imports to suppress errors if they are not otherwise used.
@ -17,6 +16,35 @@ var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf
// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
func init() { proto.RegisterFile("api/protobuf-spec/mmlogic.proto", fileDescriptor_5b986081864e12b4) }
var fileDescriptor_5b986081864e12b4 = []byte{
// 263 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x9c, 0x91, 0x41, 0x4b, 0xf4, 0x30,
0x10, 0x40, 0xf7, 0xfb, 0x04, 0x85, 0x80, 0xa2, 0x61, 0xbd, 0xf4, 0xa2, 0xec, 0x7d, 0x1b, 0x51,
0xc4, 0x83, 0x8a, 0xe8, 0x1e, 0x4a, 0x61, 0x17, 0x8b, 0x47, 0x6f, 0x69, 0x9d, 0x76, 0x23, 0x93,
0x4e, 0x48, 0x26, 0x07, 0x7f, 0x9e, 0xff, 0x4c, 0xd2, 0x05, 0x8b, 0x50, 0x2f, 0x5e, 0x5f, 0xde,
0x9b, 0x09, 0x89, 0x38, 0xd3, 0xce, 0x28, 0xe7, 0x89, 0xa9, 0x8e, 0xed, 0x32, 0x38, 0x68, 0x94,
0xb5, 0x48, 0x9d, 0x69, 0xf2, 0x81, 0xca, 0x3d, 0xed, 0x4c, 0x76, 0x3e, 0x61, 0x41, 0x08, 0xba,
0x83, 0xb0, 0xd3, 0x2e, 0x3f, 0xff, 0x8b, 0x83, 0x8d, 0x5d, 0xa7, 0x50, 0xde, 0x09, 0x51, 0x00,
0x57, 0x9e, 0x5a, 0x83, 0x20, 0x4f, 0xf3, 0x6f, 0x75, 0xa3, 0xb9, 0xd9, 0x3e, 0xd7, 0xef, 0xd0,
0x70, 0x36, 0x8d, 0x17, 0x33, 0x79, 0x2b, 0x8e, 0x56, 0x1e, 0x34, 0x43, 0xe5, 0xc9, 0x51, 0xd0,
0xf8, 0xdb, 0x84, 0xe3, 0x11, 0xbf, 0x40, 0x88, 0x98, 0xe2, 0x07, 0x71, 0x98, 0x56, 0xa3, 0xfe,
0x00, 0x5f, 0x11, 0xa1, 0x9c, 0x8f, 0xd2, 0x48, 0xb3, 0x49, 0xba, 0x98, 0x5d, 0xfc, 0x93, 0xf7,
0x62, 0x5e, 0x00, 0x3f, 0x22, 0x96, 0x5d, 0x4f, 0x1e, 0xde, 0x76, 0xc7, 0x41, 0x9e, 0x8c, 0x45,
0x89, 0x65, 0xef, 0xe2, 0xcf, 0xfd, 0x14, 0x18, 0xfc, 0x70, 0x79, 0xb9, 0x36, 0x81, 0xff, 0x14,
0x3f, 0xdd, 0xbc, 0x5e, 0x77, 0x86, 0xb7, 0xb1, 0xce, 0x1b, 0xb2, 0xaa, 0x20, 0xea, 0x10, 0x56,
0x48, 0x31, 0xcd, 0xe1, 0x96, 0xbc, 0x55, 0xe4, 0xa0, 0x5f, 0xda, 0xf4, 0x06, 0xca, 0xf4, 0x0c,
0xbe, 0xd7, 0xa8, 0x5c, 0x5d, 0xef, 0x0f, 0x7f, 0x70, 0xf5, 0x15, 0x00, 0x00, 0xff, 0xff, 0xf5,
0xe5, 0x29, 0xa6, 0xcd, 0x01, 0x00, 0x00,
}
// Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
var _ grpc.ClientConn
@ -25,8 +53,9 @@ var _ grpc.ClientConn
// is compatible with the grpc package it is being compiled against.
const _ = grpc.SupportPackageIsVersion4
// Client API for MmLogic service
// MmLogicClient is the client API for MmLogic service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
type MmLogicClient interface {
// Send GetProfile a match object with the ID field populated, it will return a
// 'filled' one.
@ -92,7 +121,7 @@ func NewMmLogicClient(cc *grpc.ClientConn) MmLogicClient {
func (c *mmLogicClient) GetProfile(ctx context.Context, in *MatchObject, opts ...grpc.CallOption) (*MatchObject, error) {
out := new(MatchObject)
err := grpc.Invoke(ctx, "/api.MmLogic/GetProfile", in, out, c.cc, opts...)
err := c.cc.Invoke(ctx, "/api.MmLogic/GetProfile", in, out, opts...)
if err != nil {
return nil, err
}
@ -101,7 +130,7 @@ func (c *mmLogicClient) GetProfile(ctx context.Context, in *MatchObject, opts ..
func (c *mmLogicClient) CreateProposal(ctx context.Context, in *MatchObject, opts ...grpc.CallOption) (*Result, error) {
out := new(Result)
err := grpc.Invoke(ctx, "/api.MmLogic/CreateProposal", in, out, c.cc, opts...)
err := c.cc.Invoke(ctx, "/api.MmLogic/CreateProposal", in, out, opts...)
if err != nil {
return nil, err
}
@ -109,7 +138,7 @@ func (c *mmLogicClient) CreateProposal(ctx context.Context, in *MatchObject, opt
}
func (c *mmLogicClient) GetPlayerPool(ctx context.Context, in *PlayerPool, opts ...grpc.CallOption) (MmLogic_GetPlayerPoolClient, error) {
stream, err := grpc.NewClientStream(ctx, &_MmLogic_serviceDesc.Streams[0], c.cc, "/api.MmLogic/GetPlayerPool", opts...)
stream, err := c.cc.NewStream(ctx, &_MmLogic_serviceDesc.Streams[0], "/api.MmLogic/GetPlayerPool", opts...)
if err != nil {
return nil, err
}
@ -142,7 +171,7 @@ func (x *mmLogicGetPlayerPoolClient) Recv() (*PlayerPool, error) {
func (c *mmLogicClient) GetAllIgnoredPlayers(ctx context.Context, in *IlInput, opts ...grpc.CallOption) (*Roster, error) {
out := new(Roster)
err := grpc.Invoke(ctx, "/api.MmLogic/GetAllIgnoredPlayers", in, out, c.cc, opts...)
err := c.cc.Invoke(ctx, "/api.MmLogic/GetAllIgnoredPlayers", in, out, opts...)
if err != nil {
return nil, err
}
@ -151,15 +180,14 @@ func (c *mmLogicClient) GetAllIgnoredPlayers(ctx context.Context, in *IlInput, o
func (c *mmLogicClient) ListIgnoredPlayers(ctx context.Context, in *IlInput, opts ...grpc.CallOption) (*Roster, error) {
out := new(Roster)
err := grpc.Invoke(ctx, "/api.MmLogic/ListIgnoredPlayers", in, out, c.cc, opts...)
err := c.cc.Invoke(ctx, "/api.MmLogic/ListIgnoredPlayers", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
// Server API for MmLogic service
// MmLogicServer is the server API for MmLogic service.
type MmLogicServer interface {
// Send GetProfile a match object with the ID field populated, it will return a
// 'filled' one.
@ -342,26 +370,3 @@ var _MmLogic_serviceDesc = grpc.ServiceDesc{
},
Metadata: "api/protobuf-spec/mmlogic.proto",
}
func init() { proto.RegisterFile("api/protobuf-spec/mmlogic.proto", fileDescriptor3) }
var fileDescriptor3 = []byte{
// 263 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x9c, 0x91, 0x41, 0x4b, 0xf4, 0x30,
0x10, 0x40, 0xf7, 0xfb, 0x04, 0x85, 0x80, 0xa2, 0x61, 0xbd, 0xf4, 0xa2, 0xec, 0x7d, 0x1b, 0x51,
0xc4, 0x83, 0x8a, 0xe8, 0x1e, 0x4a, 0x61, 0x17, 0x8b, 0x47, 0x6f, 0x69, 0x9d, 0x76, 0x23, 0x93,
0x4e, 0x48, 0x26, 0x07, 0x7f, 0x9e, 0xff, 0x4c, 0xd2, 0x05, 0x8b, 0x50, 0x2f, 0x5e, 0x5f, 0xde,
0x9b, 0x09, 0x89, 0x38, 0xd3, 0xce, 0x28, 0xe7, 0x89, 0xa9, 0x8e, 0xed, 0x32, 0x38, 0x68, 0x94,
0xb5, 0x48, 0x9d, 0x69, 0xf2, 0x81, 0xca, 0x3d, 0xed, 0x4c, 0x76, 0x3e, 0x61, 0x41, 0x08, 0xba,
0x83, 0xb0, 0xd3, 0x2e, 0x3f, 0xff, 0x8b, 0x83, 0x8d, 0x5d, 0xa7, 0x50, 0xde, 0x09, 0x51, 0x00,
0x57, 0x9e, 0x5a, 0x83, 0x20, 0x4f, 0xf3, 0x6f, 0x75, 0xa3, 0xb9, 0xd9, 0x3e, 0xd7, 0xef, 0xd0,
0x70, 0x36, 0x8d, 0x17, 0x33, 0x79, 0x2b, 0x8e, 0x56, 0x1e, 0x34, 0x43, 0xe5, 0xc9, 0x51, 0xd0,
0xf8, 0xdb, 0x84, 0xe3, 0x11, 0xbf, 0x40, 0x88, 0x98, 0xe2, 0x07, 0x71, 0x98, 0x56, 0xa3, 0xfe,
0x00, 0x5f, 0x11, 0xa1, 0x9c, 0x8f, 0xd2, 0x48, 0xb3, 0x49, 0xba, 0x98, 0x5d, 0xfc, 0x93, 0xf7,
0x62, 0x5e, 0x00, 0x3f, 0x22, 0x96, 0x5d, 0x4f, 0x1e, 0xde, 0x76, 0xc7, 0x41, 0x9e, 0x8c, 0x45,
0x89, 0x65, 0xef, 0xe2, 0xcf, 0xfd, 0x14, 0x18, 0xfc, 0x70, 0x79, 0xb9, 0x36, 0x81, 0xff, 0x14,
0x3f, 0xdd, 0xbc, 0x5e, 0x77, 0x86, 0xb7, 0xb1, 0xce, 0x1b, 0xb2, 0xaa, 0x20, 0xea, 0x10, 0x56,
0x48, 0x31, 0xcd, 0xe1, 0x96, 0xbc, 0x55, 0xe4, 0xa0, 0x5f, 0xda, 0xf4, 0x06, 0xca, 0xf4, 0x0c,
0xbe, 0xd7, 0xa8, 0x5c, 0x5d, 0xef, 0x0f, 0x7f, 0x70, 0xf5, 0x15, 0x00, 0x00, 0xff, 0xff, 0xf5,
0xe5, 0x29, 0xa6, 0xcd, 0x01, 0x00, 0x00,
}