pb

package
v0.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 2, 2019 License: Apache-2.0 Imports: 16 Imported by: 60

Documentation

Overview

Package pb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package pb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package pb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package pb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package pb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var FunctionConfig_Type_name = map[int32]string{
	0: "GRPC",
	1: "REST",
}
View Source 
var FunctionConfig_Type_value = map[string]int32{
	"GRPC": 0,
	"REST": 1,
}

Functions

func RegisterBackendHandler 

func RegisterBackendHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterBackendHandler registers the http handlers for service Backend to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterBackendHandlerClient 

func RegisterBackendHandlerClient(ctx context.Context, mux *runtime.ServeMux, client BackendClient) error

RegisterBackendHandlerClient registers the http handlers for service Backend to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "BackendClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "BackendClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "BackendClient" to call the correct interceptors.

func RegisterBackendHandlerFromEndpoint 

func RegisterBackendHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterBackendHandlerFromEndpoint is same as RegisterBackendHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterBackendServer 

func RegisterBackendServer(s *grpc.Server, srv BackendServer)

func RegisterEvaluatorHandler 

func RegisterEvaluatorHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterEvaluatorHandler registers the http handlers for service Evaluator to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterEvaluatorHandlerClient 

func RegisterEvaluatorHandlerClient(ctx context.Context, mux *runtime.ServeMux, client EvaluatorClient) error

RegisterEvaluatorHandlerClient registers the http handlers for service Evaluator to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "EvaluatorClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "EvaluatorClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "EvaluatorClient" to call the correct interceptors.

func RegisterEvaluatorHandlerFromEndpoint 

func RegisterEvaluatorHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterEvaluatorHandlerFromEndpoint is same as RegisterEvaluatorHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterEvaluatorServer 

func RegisterEvaluatorServer(s *grpc.Server, srv EvaluatorServer)

func RegisterFrontendHandler 

func RegisterFrontendHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterFrontendHandler registers the http handlers for service Frontend to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterFrontendHandlerClient 

func RegisterFrontendHandlerClient(ctx context.Context, mux *runtime.ServeMux, client FrontendClient) error

RegisterFrontendHandlerClient registers the http handlers for service Frontend to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "FrontendClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "FrontendClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "FrontendClient" to call the correct interceptors.

func RegisterFrontendHandlerFromEndpoint 

func RegisterFrontendHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterFrontendHandlerFromEndpoint is same as RegisterFrontendHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterFrontendServer 

func RegisterFrontendServer(s *grpc.Server, srv FrontendServer)

func RegisterMatchFunctionHandler 

func RegisterMatchFunctionHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterMatchFunctionHandler registers the http handlers for service MatchFunction to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterMatchFunctionHandlerClient 

func RegisterMatchFunctionHandlerClient(ctx context.Context, mux *runtime.ServeMux, client MatchFunctionClient) error

RegisterMatchFunctionHandlerClient registers the http handlers for service MatchFunction to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "MatchFunctionClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "MatchFunctionClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "MatchFunctionClient" to call the correct interceptors.

func RegisterMatchFunctionHandlerFromEndpoint 

func RegisterMatchFunctionHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterMatchFunctionHandlerFromEndpoint is same as RegisterMatchFunctionHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterMatchFunctionServer 

func RegisterMatchFunctionServer(s *grpc.Server, srv MatchFunctionServer)

func RegisterMmLogicHandler 

func RegisterMmLogicHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterMmLogicHandler registers the http handlers for service MmLogic to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterMmLogicHandlerClient 

func RegisterMmLogicHandlerClient(ctx context.Context, mux *runtime.ServeMux, client MmLogicClient) error

RegisterMmLogicHandlerClient registers the http handlers for service MmLogic to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "MmLogicClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "MmLogicClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "MmLogicClient" to call the correct interceptors.

func RegisterMmLogicHandlerFromEndpoint 

func RegisterMmLogicHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterMmLogicHandlerFromEndpoint is same as RegisterMmLogicHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterMmLogicServer 

func RegisterMmLogicServer(s *grpc.Server, srv MmLogicServer)

Types

type AssignTicketsRequest 

type AssignTicketsRequest struct {
	// List of Ticket IDs for which the Assignment is to be made.
	TicketIds []string `protobuf:"bytes,1,rep,name=ticket_ids,json=ticketIds,proto3" json:"ticket_ids,omitempty"`
	// Assignment to be associated with the Ticket IDs.
	Assignment           *Assignment `protobuf:"bytes,2,opt,name=assignment,proto3" json:"assignment,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*AssignTicketsRequest) Descriptor 

func (*AssignTicketsRequest) Descriptor() ([]byte, []int)

func (*AssignTicketsRequest) GetAssignment 

func (m *AssignTicketsRequest) GetAssignment() *Assignment

func (*AssignTicketsRequest) GetTicketIds 

func (m *AssignTicketsRequest) GetTicketIds() []string

func (*AssignTicketsRequest) ProtoMessage 

func (*AssignTicketsRequest) ProtoMessage()

func (*AssignTicketsRequest) Reset 

func (m *AssignTicketsRequest) Reset()

func (*AssignTicketsRequest) String 

func (m *AssignTicketsRequest) String() string

func (*AssignTicketsRequest) XXX_DiscardUnknown 

func (m *AssignTicketsRequest) XXX_DiscardUnknown()

func (*AssignTicketsRequest) XXX_Marshal 

func (m *AssignTicketsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AssignTicketsRequest) XXX_Merge 

func (m *AssignTicketsRequest) XXX_Merge(src proto.Message)

func (*AssignTicketsRequest) XXX_Size 

func (m *AssignTicketsRequest) XXX_Size() int

func (*AssignTicketsRequest) XXX_Unmarshal 

func (m *AssignTicketsRequest) XXX_Unmarshal(b []byte) error

type AssignTicketsResponse 

type AssignTicketsResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AssignTicketsResponse) Descriptor 

func (*AssignTicketsResponse) Descriptor() ([]byte, []int)

func (*AssignTicketsResponse) ProtoMessage 

func (*AssignTicketsResponse) ProtoMessage()

func (*AssignTicketsResponse) Reset 

func (m *AssignTicketsResponse) Reset()

func (*AssignTicketsResponse) String 

func (m *AssignTicketsResponse) String() string

func (*AssignTicketsResponse) XXX_DiscardUnknown 

func (m *AssignTicketsResponse) XXX_DiscardUnknown()

func (*AssignTicketsResponse) XXX_Marshal 

func (m *AssignTicketsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AssignTicketsResponse) XXX_Merge 

func (m *AssignTicketsResponse) XXX_Merge(src proto.Message)

func (*AssignTicketsResponse) XXX_Size 

func (m *AssignTicketsResponse) XXX_Size() int

func (*AssignTicketsResponse) XXX_Unmarshal 

func (m *AssignTicketsResponse) XXX_Unmarshal(b []byte) error

type Assignment 

type Assignment struct {
	// Connection information for this Assignment.
	Connection string `protobuf:"bytes,1,opt,name=connection,proto3" json:"connection,omitempty"`
	// Other details to be sent to the players.
	Properties *_struct.Struct `protobuf:"bytes,2,opt,name=properties,proto3" json:"properties,omitempty"`
	// Error when finding an Assignment for this Ticket.
	Error                *status.Status `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

An Assignment object represents the assignment associated with a Ticket. Open match does not require or inspect any fields on assignment.

func (*Assignment) Descriptor 

func (*Assignment) Descriptor() ([]byte, []int)

func (*Assignment) GetConnection 

func (m *Assignment) GetConnection() string

func (*Assignment) GetError 

func (m *Assignment) GetError() *status.Status

func (*Assignment) GetProperties 

func (m *Assignment) GetProperties() *_struct.Struct

func (*Assignment) ProtoMessage 

func (*Assignment) ProtoMessage()

func (*Assignment) Reset 

func (m *Assignment) Reset()

func (*Assignment) String 

func (m *Assignment) String() string

func (*Assignment) XXX_DiscardUnknown 

func (m *Assignment) XXX_DiscardUnknown()

func (*Assignment) XXX_Marshal 

func (m *Assignment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Assignment) XXX_Merge 

func (m *Assignment) XXX_Merge(src proto.Message)

func (*Assignment) XXX_Size 

func (m *Assignment) XXX_Size() int

func (*Assignment) XXX_Unmarshal 

func (m *Assignment) XXX_Unmarshal(b []byte) error

type BackendClient 

type BackendClient interface {
	// FetchMatch triggers execution of the specfied MatchFunction for each of the
	// specified MatchProfiles. Each MatchFunction execution returns a set of
	// proposals which are then evaluated to generate results. FetchMatch method
	// streams these results back to the caller.
	FetchMatches(ctx context.Context, in *FetchMatchesRequest, opts ...grpc.CallOption) (*FetchMatchesResponse, error)
	// AssignTickets sets the specified Assignment on the Tickets for the Ticket
	// IDs passed.
	AssignTickets(ctx context.Context, in *AssignTicketsRequest, opts ...grpc.CallOption) (*AssignTicketsResponse, error)
}

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.

func NewBackendClient 

func NewBackendClient(cc *grpc.ClientConn) BackendClient

type BackendServer 

type BackendServer interface {
	// FetchMatch triggers execution of the specfied MatchFunction for each of the
	// specified MatchProfiles. Each MatchFunction execution returns a set of
	// proposals which are then evaluated to generate results. FetchMatch method
	// streams these results back to the caller.
	FetchMatches(context.Context, *FetchMatchesRequest) (*FetchMatchesResponse, error)
	// AssignTickets sets the specified Assignment on the Tickets for the Ticket
	// IDs passed.
	AssignTickets(context.Context, *AssignTicketsRequest) (*AssignTicketsResponse, error)
}

BackendServer is the server API for Backend service.

type CreateTicketRequest 

type CreateTicketRequest struct {
	// Ticket object with the properties of the Ticket to be created.
	Ticket               *Ticket  `protobuf:"bytes,1,opt,name=ticket,proto3" json:"ticket,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateTicketRequest) Descriptor 

func (*CreateTicketRequest) Descriptor() ([]byte, []int)

func (*CreateTicketRequest) GetTicket 

func (m *CreateTicketRequest) GetTicket() *Ticket

func (*CreateTicketRequest) ProtoMessage 

func (*CreateTicketRequest) ProtoMessage()

func (*CreateTicketRequest) Reset 

func (m *CreateTicketRequest) Reset()

func (*CreateTicketRequest) String 

func (m *CreateTicketRequest) String() string

func (*CreateTicketRequest) XXX_DiscardUnknown 

func (m *CreateTicketRequest) XXX_DiscardUnknown()

func (*CreateTicketRequest) XXX_Marshal 

func (m *CreateTicketRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateTicketRequest) XXX_Merge 

func (m *CreateTicketRequest) XXX_Merge(src proto.Message)

func (*CreateTicketRequest) XXX_Size 

func (m *CreateTicketRequest) XXX_Size() int

func (*CreateTicketRequest) XXX_Unmarshal 

func (m *CreateTicketRequest) XXX_Unmarshal(b []byte) error

type CreateTicketResponse 

type CreateTicketResponse struct {
	// Ticket object for the created Ticket - with the ticket ID populated.
	Ticket               *Ticket  `protobuf:"bytes,1,opt,name=ticket,proto3" json:"ticket,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateTicketResponse) Descriptor 

func (*CreateTicketResponse) Descriptor() ([]byte, []int)

func (*CreateTicketResponse) GetTicket 

func (m *CreateTicketResponse) GetTicket() *Ticket

func (*CreateTicketResponse) ProtoMessage 

func (*CreateTicketResponse) ProtoMessage()

func (*CreateTicketResponse) Reset 

func (m *CreateTicketResponse) Reset()

func (*CreateTicketResponse) String 

func (m *CreateTicketResponse) String() string

func (*CreateTicketResponse) XXX_DiscardUnknown 

func (m *CreateTicketResponse) XXX_DiscardUnknown()

func (*CreateTicketResponse) XXX_Marshal 

func (m *CreateTicketResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateTicketResponse) XXX_Merge 

func (m *CreateTicketResponse) XXX_Merge(src proto.Message)

func (*CreateTicketResponse) XXX_Size 

func (m *CreateTicketResponse) XXX_Size() int

func (*CreateTicketResponse) XXX_Unmarshal 

func (m *CreateTicketResponse) XXX_Unmarshal(b []byte) error

type DeleteTicketRequest 

type DeleteTicketRequest struct {
	// Ticket ID of the Ticket to be deleted.
	TicketId             string   `protobuf:"bytes,1,opt,name=ticket_id,json=ticketId,proto3" json:"ticket_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteTicketRequest) Descriptor 

func (*DeleteTicketRequest) Descriptor() ([]byte, []int)

func (*DeleteTicketRequest) GetTicketId 

func (m *DeleteTicketRequest) GetTicketId() string

func (*DeleteTicketRequest) ProtoMessage 

func (*DeleteTicketRequest) ProtoMessage()

func (*DeleteTicketRequest) Reset 

func (m *DeleteTicketRequest) Reset()

func (*DeleteTicketRequest) String 

func (m *DeleteTicketRequest) String() string

func (*DeleteTicketRequest) XXX_DiscardUnknown 

func (m *DeleteTicketRequest) XXX_DiscardUnknown()

func (*DeleteTicketRequest) XXX_Marshal 

func (m *DeleteTicketRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteTicketRequest) XXX_Merge 

func (m *DeleteTicketRequest) XXX_Merge(src proto.Message)

func (*DeleteTicketRequest) XXX_Size 

func (m *DeleteTicketRequest) XXX_Size() int

func (*DeleteTicketRequest) XXX_Unmarshal 

func (m *DeleteTicketRequest) XXX_Unmarshal(b []byte) error

type DeleteTicketResponse 

type DeleteTicketResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteTicketResponse) Descriptor 

func (*DeleteTicketResponse) Descriptor() ([]byte, []int)

func (*DeleteTicketResponse) ProtoMessage 

func (*DeleteTicketResponse) ProtoMessage()

func (*DeleteTicketResponse) Reset 

func (m *DeleteTicketResponse) Reset()

func (*DeleteTicketResponse) String 

func (m *DeleteTicketResponse) String() string

func (*DeleteTicketResponse) XXX_DiscardUnknown 

func (m *DeleteTicketResponse) XXX_DiscardUnknown()

func (*DeleteTicketResponse) XXX_Marshal 

func (m *DeleteTicketResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteTicketResponse) XXX_Merge 

func (m *DeleteTicketResponse) XXX_Merge(src proto.Message)

func (*DeleteTicketResponse) XXX_Size 

func (m *DeleteTicketResponse) XXX_Size() int

func (*DeleteTicketResponse) XXX_Unmarshal 

func (m *DeleteTicketResponse) XXX_Unmarshal(b []byte) error

type EvaluateRequest 

type EvaluateRequest struct {
	// List of Matches to evaluate.
	Matches              []*Match `protobuf:"bytes,1,rep,name=matches,proto3" json:"matches,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EvaluateRequest) Descriptor 

func (*EvaluateRequest) Descriptor() ([]byte, []int)

func (*EvaluateRequest) GetMatches 

func (m *EvaluateRequest) GetMatches() []*Match

func (*EvaluateRequest) ProtoMessage 

func (*EvaluateRequest) ProtoMessage()

func (*EvaluateRequest) Reset 

func (m *EvaluateRequest) Reset()

func (*EvaluateRequest) String 

func (m *EvaluateRequest) String() string

func (*EvaluateRequest) XXX_DiscardUnknown 

func (m *EvaluateRequest) XXX_DiscardUnknown()

func (*EvaluateRequest) XXX_Marshal 

func (m *EvaluateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EvaluateRequest) XXX_Merge 

func (m *EvaluateRequest) XXX_Merge(src proto.Message)

func (*EvaluateRequest) XXX_Size 

func (m *EvaluateRequest) XXX_Size() int

func (*EvaluateRequest) XXX_Unmarshal 

func (m *EvaluateRequest) XXX_Unmarshal(b []byte) error

type EvaluateResponse 

type EvaluateResponse struct {
	// Accepted list of Matches.
	Matches              []*Match `protobuf:"bytes,1,rep,name=matches,proto3" json:"matches,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EvaluateResponse) Descriptor 

func (*EvaluateResponse) Descriptor() ([]byte, []int)

func (*EvaluateResponse) GetMatches 

func (m *EvaluateResponse) GetMatches() []*Match

func (*EvaluateResponse) ProtoMessage 

func (*EvaluateResponse) ProtoMessage()

func (*EvaluateResponse) Reset 

func (m *EvaluateResponse) Reset()

func (*EvaluateResponse) String 

func (m *EvaluateResponse) String() string

func (*EvaluateResponse) XXX_DiscardUnknown 

func (m *EvaluateResponse) XXX_DiscardUnknown()

func (*EvaluateResponse) XXX_Marshal 

func (m *EvaluateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EvaluateResponse) XXX_Merge 

func (m *EvaluateResponse) XXX_Merge(src proto.Message)

func (*EvaluateResponse) XXX_Size 

func (m *EvaluateResponse) XXX_Size() int

func (*EvaluateResponse) XXX_Unmarshal 

func (m *EvaluateResponse) XXX_Unmarshal(b []byte) error

type EvaluatorClient 

type EvaluatorClient interface {
	// Evaluate accepts a list of proposed matches, evaluates them for quality,
	// collisions etc. and returns matches that should be accepted as results.
	Evaluate(ctx context.Context, in *EvaluateRequest, opts ...grpc.CallOption) (*EvaluateResponse, error)
}

EvaluatorClient is the client API for Evaluator service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewEvaluatorClient 

func NewEvaluatorClient(cc *grpc.ClientConn) EvaluatorClient

type EvaluatorServer 

type EvaluatorServer interface {
	// Evaluate accepts a list of proposed matches, evaluates them for quality,
	// collisions etc. and returns matches that should be accepted as results.
	Evaluate(context.Context, *EvaluateRequest) (*EvaluateResponse, error)
}

EvaluatorServer is the server API for Evaluator service.

type FetchMatchesRequest 

type FetchMatchesRequest struct {
	// Configuration of the MatchFunction to be executed for the given list of MatchProfiles
	Config *FunctionConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// MatchProfiles for which this MatchFunction should be executed.
	Profiles             []*MatchProfile `protobuf:"bytes,2,rep,name=profiles,proto3" json:"profiles,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*FetchMatchesRequest) Descriptor 

func (*FetchMatchesRequest) Descriptor() ([]byte, []int)

func (*FetchMatchesRequest) GetConfig 

func (m *FetchMatchesRequest) GetConfig() *FunctionConfig

func (*FetchMatchesRequest) GetProfiles 

func (m *FetchMatchesRequest) GetProfiles() []*MatchProfile

func (*FetchMatchesRequest) ProtoMessage 

func (*FetchMatchesRequest) ProtoMessage()

func (*FetchMatchesRequest) Reset 

func (m *FetchMatchesRequest) Reset()

func (*FetchMatchesRequest) String 

func (m *FetchMatchesRequest) String() string

func (*FetchMatchesRequest) XXX_DiscardUnknown 

func (m *FetchMatchesRequest) XXX_DiscardUnknown()

func (*FetchMatchesRequest) XXX_Marshal 

func (m *FetchMatchesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FetchMatchesRequest) XXX_Merge 

func (m *FetchMatchesRequest) XXX_Merge(src proto.Message)

func (*FetchMatchesRequest) XXX_Size 

func (m *FetchMatchesRequest) XXX_Size() int

func (*FetchMatchesRequest) XXX_Unmarshal 

func (m *FetchMatchesRequest) XXX_Unmarshal(b []byte) error

type FetchMatchesResponse 

type FetchMatchesResponse struct {
	// Result Match for the requested MatchProfile.
	// Note that OpenMatch will validate the proposals, a valid match should contain at least one ticket.
	Matches              []*Match `protobuf:"bytes,1,rep,name=matches,proto3" json:"matches,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FetchMatchesResponse) Descriptor 

func (*FetchMatchesResponse) Descriptor() ([]byte, []int)

func (*FetchMatchesResponse) GetMatches 

func (m *FetchMatchesResponse) GetMatches() []*Match

func (*FetchMatchesResponse) ProtoMessage 

func (*FetchMatchesResponse) ProtoMessage()

func (*FetchMatchesResponse) Reset 

func (m *FetchMatchesResponse) Reset()

func (*FetchMatchesResponse) String 

func (m *FetchMatchesResponse) String() string

func (*FetchMatchesResponse) XXX_DiscardUnknown 

func (m *FetchMatchesResponse) XXX_DiscardUnknown()

func (*FetchMatchesResponse) XXX_Marshal 

func (m *FetchMatchesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FetchMatchesResponse) XXX_Merge 

func (m *FetchMatchesResponse) XXX_Merge(src proto.Message)

func (*FetchMatchesResponse) XXX_Size 

func (m *FetchMatchesResponse) XXX_Size() int

func (*FetchMatchesResponse) XXX_Unmarshal 

func (m *FetchMatchesResponse) XXX_Unmarshal(b []byte) error

type Filter 

type Filter struct {
	// Name of the ticket attribute this Filter operates on.
	Attribute string `protobuf:"bytes,1,opt,name=attribute,proto3" json:"attribute,omitempty"`
	// Maximum value. Defaults to positive infinity (any value above minv).
	Max float64 `protobuf:"fixed64,2,opt,name=max,proto3" json:"max,omitempty"`
	// Minimum value. Defaults to 0.
	Min                  float64  `protobuf:"fixed64,3,opt,name=min,proto3" json:"min,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A hard filter used to query a subset of Tickets meeting the filtering criteria.

func (*Filter) Descriptor 

func (*Filter) Descriptor() ([]byte, []int)

func (*Filter) GetAttribute 

func (m *Filter) GetAttribute() string

func (*Filter) GetMax 

func (m *Filter) GetMax() float64

func (*Filter) GetMin 

func (m *Filter) GetMin() float64

func (*Filter) ProtoMessage 

func (*Filter) ProtoMessage()

func (*Filter) Reset 

func (m *Filter) Reset()

func (*Filter) String 

func (m *Filter) String() string

func (*Filter) XXX_DiscardUnknown 

func (m *Filter) XXX_DiscardUnknown()

func (*Filter) XXX_Marshal 

func (m *Filter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Filter) XXX_Merge 

func (m *Filter) XXX_Merge(src proto.Message)

func (*Filter) XXX_Size 

func (m *Filter) XXX_Size() int

func (*Filter) XXX_Unmarshal 

func (m *Filter) XXX_Unmarshal(b []byte) error

type FrontendClient 

type FrontendClient interface {
	// CreateTicket will create a new ticket, assign a Ticket ID to it and put the
	// Ticket in state storage. It will then look through the 'properties' field
	// for the attributes defined as indices the matchmakaking config. If the
	// attributes exist and are valid integers, they will be indexed. Creating a
	// ticket adds the Ticket to the pool of Tickets considered for matchmaking.
	CreateTicket(ctx context.Context, in *CreateTicketRequest, opts ...grpc.CallOption) (*CreateTicketResponse, error)
	// DeleteTicket removes the Ticket from state storage and from corresponding
	// configured indices and lazily removes the ticket from state storage.
	// Deleting a ticket immediately stops the ticket from being
	// considered for future matchmaking requests, yet when the ticket itself will be deleted
	// is undeterministic. Users may still be able to assign/get a ticket after calling DeleteTicket on it.
	DeleteTicket(ctx context.Context, in *DeleteTicketRequest, opts ...grpc.CallOption) (*DeleteTicketResponse, error)
	// GetTicket fetches the ticket associated with the specified Ticket ID.
	GetTicket(ctx context.Context, in *GetTicketRequest, opts ...grpc.CallOption) (*Ticket, error)
	// GetAssignments streams matchmaking results from Open Match for the
	// provided Ticket ID.
	GetAssignments(ctx context.Context, in *GetAssignmentsRequest, opts ...grpc.CallOption) (Frontend_GetAssignmentsClient, error)
}

FrontendClient is the client API for Frontend service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewFrontendClient 

func NewFrontendClient(cc *grpc.ClientConn) FrontendClient

type FrontendServer 

type FrontendServer interface {
	// CreateTicket will create a new ticket, assign a Ticket ID to it and put the
	// Ticket in state storage. It will then look through the 'properties' field
	// for the attributes defined as indices the matchmakaking config. If the
	// attributes exist and are valid integers, they will be indexed. Creating a
	// ticket adds the Ticket to the pool of Tickets considered for matchmaking.
	CreateTicket(context.Context, *CreateTicketRequest) (*CreateTicketResponse, error)
	// DeleteTicket removes the Ticket from state storage and from corresponding
	// configured indices and lazily removes the ticket from state storage.
	// Deleting a ticket immediately stops the ticket from being
	// considered for future matchmaking requests, yet when the ticket itself will be deleted
	// is undeterministic. Users may still be able to assign/get a ticket after calling DeleteTicket on it.
	DeleteTicket(context.Context, *DeleteTicketRequest) (*DeleteTicketResponse, error)
	// GetTicket fetches the ticket associated with the specified Ticket ID.
	GetTicket(context.Context, *GetTicketRequest) (*Ticket, error)
	// GetAssignments streams matchmaking results from Open Match for the
	// provided Ticket ID.
	GetAssignments(*GetAssignmentsRequest, Frontend_GetAssignmentsServer) error
}

FrontendServer is the server API for Frontend service.

type Frontend_GetAssignmentsClient 

type Frontend_GetAssignmentsClient interface {
	Recv() (*GetAssignmentsResponse, error)
	grpc.ClientStream
}

type Frontend_GetAssignmentsServer 

type Frontend_GetAssignmentsServer interface {
	Send(*GetAssignmentsResponse) error
	grpc.ServerStream
}

type FunctionConfig 

type FunctionConfig struct {
	Host                 string              `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Port                 int32               `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	Type                 FunctionConfig_Type `protobuf:"varint,3,opt,name=type,proto3,enum=api.FunctionConfig_Type" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

Configuration for the Match Function to be triggered by Open Match to generate proposals.

func (*FunctionConfig) Descriptor 

func (*FunctionConfig) Descriptor() ([]byte, []int)

func (*FunctionConfig) GetHost 

func (m *FunctionConfig) GetHost() string

func (*FunctionConfig) GetPort 

func (m *FunctionConfig) GetPort() int32

func (*FunctionConfig) GetType 

func (m *FunctionConfig) GetType() FunctionConfig_Type

func (*FunctionConfig) ProtoMessage 

func (*FunctionConfig) ProtoMessage()

func (*FunctionConfig) Reset 

func (m *FunctionConfig) Reset()

func (*FunctionConfig) String 

func (m *FunctionConfig) String() string

func (*FunctionConfig) XXX_DiscardUnknown 

func (m *FunctionConfig) XXX_DiscardUnknown()

func (*FunctionConfig) XXX_Marshal 

func (m *FunctionConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FunctionConfig) XXX_Merge 

func (m *FunctionConfig) XXX_Merge(src proto.Message)

func (*FunctionConfig) XXX_Size 

func (m *FunctionConfig) XXX_Size() int

func (*FunctionConfig) XXX_Unmarshal 

func (m *FunctionConfig) XXX_Unmarshal(b []byte) error

type FunctionConfig_Type 

type FunctionConfig_Type int32
const (
	FunctionConfig_GRPC FunctionConfig_Type = 0
	FunctionConfig_REST FunctionConfig_Type = 1
)

func (FunctionConfig_Type) EnumDescriptor 

func (FunctionConfig_Type) EnumDescriptor() ([]byte, []int)

func (FunctionConfig_Type) String 

func (x FunctionConfig_Type) String() string

type GetAssignmentsRequest 

type GetAssignmentsRequest struct {
	// Ticket ID of the Ticket to get updates on.
	TicketId             string   `protobuf:"bytes,1,opt,name=ticket_id,json=ticketId,proto3" json:"ticket_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetAssignmentsRequest) Descriptor 

func (*GetAssignmentsRequest) Descriptor() ([]byte, []int)

func (*GetAssignmentsRequest) GetTicketId 

func (m *GetAssignmentsRequest) GetTicketId() string

func (*GetAssignmentsRequest) ProtoMessage 

func (*GetAssignmentsRequest) ProtoMessage()

func (*GetAssignmentsRequest) Reset 

func (m *GetAssignmentsRequest) Reset()

func (*GetAssignmentsRequest) String 

func (m *GetAssignmentsRequest) String() string

func (*GetAssignmentsRequest) XXX_DiscardUnknown 

func (m *GetAssignmentsRequest) XXX_DiscardUnknown()

func (*GetAssignmentsRequest) XXX_Marshal 

func (m *GetAssignmentsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetAssignmentsRequest) XXX_Merge 

func (m *GetAssignmentsRequest) XXX_Merge(src proto.Message)

func (*GetAssignmentsRequest) XXX_Size 

func (m *GetAssignmentsRequest) XXX_Size() int

func (*GetAssignmentsRequest) XXX_Unmarshal 

func (m *GetAssignmentsRequest) XXX_Unmarshal(b []byte) error

type GetAssignmentsResponse 

type GetAssignmentsResponse struct {
	// The updated Ticket object.
	Assignment           *Assignment `protobuf:"bytes,1,opt,name=assignment,proto3" json:"assignment,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*GetAssignmentsResponse) Descriptor 

func (*GetAssignmentsResponse) Descriptor() ([]byte, []int)

func (*GetAssignmentsResponse) GetAssignment 

func (m *GetAssignmentsResponse) GetAssignment() *Assignment

func (*GetAssignmentsResponse) ProtoMessage 

func (*GetAssignmentsResponse) ProtoMessage()

func (*GetAssignmentsResponse) Reset 

func (m *GetAssignmentsResponse) Reset()

func (*GetAssignmentsResponse) String 

func (m *GetAssignmentsResponse) String() string

func (*GetAssignmentsResponse) XXX_DiscardUnknown 

func (m *GetAssignmentsResponse) XXX_DiscardUnknown()

func (*GetAssignmentsResponse) XXX_Marshal 

func (m *GetAssignmentsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetAssignmentsResponse) XXX_Merge 

func (m *GetAssignmentsResponse) XXX_Merge(src proto.Message)

func (*GetAssignmentsResponse) XXX_Size 

func (m *GetAssignmentsResponse) XXX_Size() int

func (*GetAssignmentsResponse) XXX_Unmarshal 

func (m *GetAssignmentsResponse) XXX_Unmarshal(b []byte) error

type GetTicketRequest 

type GetTicketRequest struct {
	// Ticket ID of the Ticket to fetch.
	TicketId             string   `protobuf:"bytes,1,opt,name=ticket_id,json=ticketId,proto3" json:"ticket_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetTicketRequest) Descriptor 

func (*GetTicketRequest) Descriptor() ([]byte, []int)

func (*GetTicketRequest) GetTicketId 

func (m *GetTicketRequest) GetTicketId() string

func (*GetTicketRequest) ProtoMessage 

func (*GetTicketRequest) ProtoMessage()

func (*GetTicketRequest) Reset 

func (m *GetTicketRequest) Reset()

func (*GetTicketRequest) String 

func (m *GetTicketRequest) String() string

func (*GetTicketRequest) XXX_DiscardUnknown 

func (m *GetTicketRequest) XXX_DiscardUnknown()

func (*GetTicketRequest) XXX_Marshal 

func (m *GetTicketRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetTicketRequest) XXX_Merge 

func (m *GetTicketRequest) XXX_Merge(src proto.Message)

func (*GetTicketRequest) XXX_Size 

func (m *GetTicketRequest) XXX_Size() int

func (*GetTicketRequest) XXX_Unmarshal 

func (m *GetTicketRequest) XXX_Unmarshal(b []byte) error

type Match 

type Match struct {
	// A Match ID that should be passed through the stack for tracing.
	MatchId string `protobuf:"bytes,1,opt,name=match_id,json=matchId,proto3" json:"match_id,omitempty"`
	// Name of the match profile that generated this Match.
	MatchProfile string `protobuf:"bytes,2,opt,name=match_profile,json=matchProfile,proto3" json:"match_profile,omitempty"`
	// Name of the match function that generated this Match.
	MatchFunction string `protobuf:"bytes,3,opt,name=match_function,json=matchFunction,proto3" json:"match_function,omitempty"`
	// Tickets belonging to this match.
	Tickets []*Ticket `protobuf:"bytes,4,rep,name=tickets,proto3" json:"tickets,omitempty"`
	// Set of Rosters that comprise this Match
	Rosters []*Roster `protobuf:"bytes,5,rep,name=rosters,proto3" json:"rosters,omitempty"`
	// Match properties for this Match. Open Match does not interpret this field.
	Properties           *_struct.Struct `protobuf:"bytes,6,opt,name=properties,proto3" json:"properties,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

A Match is used to represent a completed match object. It can be generated by a MatchFunction as a proposal or can be returned by OpenMatch as a result in response to the FetchMatches call. When a match is returned by the FetchMatches call, it should contain at least one ticket to be considered as valid.

func (*Match) Descriptor 

func (*Match) Descriptor() ([]byte, []int)

func (*Match) GetMatchFunction 

func (m *Match) GetMatchFunction() string

func (*Match) GetMatchId 

func (m *Match) GetMatchId() string

func (*Match) GetMatchProfile 

func (m *Match) GetMatchProfile() string

func (*Match) GetProperties 

func (m *Match) GetProperties() *_struct.Struct

func (*Match) GetRosters 

func (m *Match) GetRosters() []*Roster

func (*Match) GetTickets 

func (m *Match) GetTickets() []*Ticket

func (*Match) ProtoMessage 

func (*Match) ProtoMessage()

func (*Match) Reset 

func (m *Match) Reset()

func (*Match) String 

func (m *Match) String() string

func (*Match) XXX_DiscardUnknown 

func (m *Match) XXX_DiscardUnknown()

func (*Match) XXX_Marshal 

func (m *Match) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Match) XXX_Merge 

func (m *Match) XXX_Merge(src proto.Message)

func (*Match) XXX_Size 

func (m *Match) XXX_Size() int

func (*Match) XXX_Unmarshal 

func (m *Match) XXX_Unmarshal(b []byte) error

type MatchFunctionClient 

type MatchFunctionClient interface {
	// This is the function that is executed when by the Open Match backend to
	// generate Match proposals.
	Run(ctx context.Context, in *RunRequest, opts ...grpc.CallOption) (*RunResponse, error)
}

MatchFunctionClient is the client API for MatchFunction service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMatchFunctionClient 

func NewMatchFunctionClient(cc *grpc.ClientConn) MatchFunctionClient

type MatchFunctionServer 

type MatchFunctionServer interface {
	// This is the function that is executed when by the Open Match backend to
	// generate Match proposals.
	Run(context.Context, *RunRequest) (*RunResponse, error)
}

MatchFunctionServer is the server API for MatchFunction service.

type MatchProfile 

type MatchProfile struct {
	// Name of this match profile.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Set of properties associated with this MatchProfile. (Optional)
	// Open Match does not interpret these properties but passes them through to
	// the MatchFunction.
	Properties *_struct.Struct `protobuf:"bytes,2,opt,name=properties,proto3" json:"properties,omitempty"`
	// Set of pools to be queried when generating a match for this MatchProfile.
	// The pool names can be used in empty Rosters to specify composition of a
	// match.
	Pools []*Pool `protobuf:"bytes,3,rep,name=pools,proto3" json:"pools,omitempty"`
	// Set of Rosters for this match request. Could be empty Rosters used to
	// indicate the composition of the generated Match or they could be partially
	// pre-populated Ticket list to be used in scenarios such as backfill / join
	// in progress.
	Rosters              []*Roster `protobuf:"bytes,4,rep,name=rosters,proto3" json:"rosters,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

A MatchProfile is Open Match's representation of a Match specification. It is used to indicate the criteria for selecting players for a match. A MatchProfile is the input to the API to get matches and is passed to the MatchFunction. It contains all the information required by the MatchFunction to generate match proposals.

func (*MatchProfile) Descriptor 

func (*MatchProfile) Descriptor() ([]byte, []int)

func (*MatchProfile) GetName 

func (m *MatchProfile) GetName() string

func (*MatchProfile) GetPools 

func (m *MatchProfile) GetPools() []*Pool

func (*MatchProfile) GetProperties 

func (m *MatchProfile) GetProperties() *_struct.Struct

func (*MatchProfile) GetRosters 

func (m *MatchProfile) GetRosters() []*Roster

func (*MatchProfile) ProtoMessage 

func (*MatchProfile) ProtoMessage()

func (*MatchProfile) Reset 

func (m *MatchProfile) Reset()

func (*MatchProfile) String 

func (m *MatchProfile) String() string

func (*MatchProfile) XXX_DiscardUnknown 

func (m *MatchProfile) XXX_DiscardUnknown()

func (*MatchProfile) XXX_Marshal 

func (m *MatchProfile) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MatchProfile) XXX_Merge 

func (m *MatchProfile) XXX_Merge(src proto.Message)

func (*MatchProfile) XXX_Size 

func (m *MatchProfile) XXX_Size() int

func (*MatchProfile) XXX_Unmarshal 

func (m *MatchProfile) XXX_Unmarshal(b []byte) error

type MmLogicClient 

type MmLogicClient interface {
	// QueryTickets gets the list of Tickets that match every Filter in the
	// specified Pool.
	QueryTickets(ctx context.Context, in *QueryTicketsRequest, opts ...grpc.CallOption) (MmLogic_QueryTicketsClient, error)
}

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.

func NewMmLogicClient 

func NewMmLogicClient(cc *grpc.ClientConn) MmLogicClient

type MmLogicServer 

type MmLogicServer interface {
	// QueryTickets gets the list of Tickets that match every Filter in the
	// specified Pool.
	QueryTickets(*QueryTicketsRequest, MmLogic_QueryTicketsServer) error
}

MmLogicServer is the server API for MmLogic service.

type MmLogic_QueryTicketsClient 

type MmLogic_QueryTicketsClient interface {
	Recv() (*QueryTicketsResponse, error)
	grpc.ClientStream
}

type MmLogic_QueryTicketsServer 

type MmLogic_QueryTicketsServer interface {
	Send(*QueryTicketsResponse) error
	grpc.ServerStream
}

type Pool 

type Pool struct {
	// A developer-chosen human-readable name for this Pool.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Set of Filters indicating the filtering criteria. Selected players must
	// match every Filter.
	Filters              []*Filter `protobuf:"bytes,2,rep,name=filters,proto3" json:"filters,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*Pool) Descriptor 

func (*Pool) Descriptor() ([]byte, []int)

func (*Pool) GetFilters 

func (m *Pool) GetFilters() []*Filter

func (*Pool) GetName 

func (m *Pool) GetName() string

func (*Pool) ProtoMessage 

func (*Pool) ProtoMessage()

func (*Pool) Reset 

func (m *Pool) Reset()

func (*Pool) String 

func (m *Pool) String() string

func (*Pool) XXX_DiscardUnknown 

func (m *Pool) XXX_DiscardUnknown()

func (*Pool) XXX_Marshal 

func (m *Pool) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Pool) XXX_Merge 

func (m *Pool) XXX_Merge(src proto.Message)

func (*Pool) XXX_Size 

func (m *Pool) XXX_Size() int

func (*Pool) XXX_Unmarshal 

func (m *Pool) XXX_Unmarshal(b []byte) error

type QueryTicketsRequest 

type QueryTicketsRequest struct {
	// The Pool representing the set of Filters to be queried.
	Pool                 *Pool    `protobuf:"bytes,1,opt,name=pool,proto3" json:"pool,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QueryTicketsRequest) Descriptor 

func (*QueryTicketsRequest) Descriptor() ([]byte, []int)

func (*QueryTicketsRequest) GetPool 

func (m *QueryTicketsRequest) GetPool() *Pool

func (*QueryTicketsRequest) ProtoMessage 

func (*QueryTicketsRequest) ProtoMessage()

func (*QueryTicketsRequest) Reset 

func (m *QueryTicketsRequest) Reset()

func (*QueryTicketsRequest) String 

func (m *QueryTicketsRequest) String() string

func (*QueryTicketsRequest) XXX_DiscardUnknown 

func (m *QueryTicketsRequest) XXX_DiscardUnknown()

func (*QueryTicketsRequest) XXX_Marshal 

func (m *QueryTicketsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryTicketsRequest) XXX_Merge 

func (m *QueryTicketsRequest) XXX_Merge(src proto.Message)

func (*QueryTicketsRequest) XXX_Size 

func (m *QueryTicketsRequest) XXX_Size() int

func (*QueryTicketsRequest) XXX_Unmarshal 

func (m *QueryTicketsRequest) XXX_Unmarshal(b []byte) error

type QueryTicketsResponse 

type QueryTicketsResponse struct {
	// The Tickets that meet the Filter criteria requested by the Pool.
	Tickets              []*Ticket `protobuf:"bytes,1,rep,name=tickets,proto3" json:"tickets,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*QueryTicketsResponse) Descriptor 

func (*QueryTicketsResponse) Descriptor() ([]byte, []int)

func (*QueryTicketsResponse) GetTickets 

func (m *QueryTicketsResponse) GetTickets() []*Ticket

func (*QueryTicketsResponse) ProtoMessage 

func (*QueryTicketsResponse) ProtoMessage()

func (*QueryTicketsResponse) Reset 

func (m *QueryTicketsResponse) Reset()

func (*QueryTicketsResponse) String 

func (m *QueryTicketsResponse) String() string

func (*QueryTicketsResponse) XXX_DiscardUnknown 

func (m *QueryTicketsResponse) XXX_DiscardUnknown()

func (*QueryTicketsResponse) XXX_Marshal 

func (m *QueryTicketsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryTicketsResponse) XXX_Merge 

func (m *QueryTicketsResponse) XXX_Merge(src proto.Message)

func (*QueryTicketsResponse) XXX_Size 

func (m *QueryTicketsResponse) XXX_Size() int

func (*QueryTicketsResponse) XXX_Unmarshal 

func (m *QueryTicketsResponse) XXX_Unmarshal(b []byte) error

type Roster 

type Roster struct {
	// A developer-chosen human-readable name for this Roster.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Tickets belonging to this Roster.
	TicketIds            []string `protobuf:"bytes,2,rep,name=ticket_ids,json=ticketIds,proto3" json:"ticket_ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A Roster is a named collection of Ticket IDs. It exists so that a Tickets associated with a Match can be labelled to belong to a team, sub-team etc. It can also be used to represent the current state of a Match in scenarios such as backfill, join-in-progress etc.

func (*Roster) Descriptor 

func (*Roster) Descriptor() ([]byte, []int)

func (*Roster) GetName 

func (m *Roster) GetName() string

func (*Roster) GetTicketIds 

func (m *Roster) GetTicketIds() []string

func (*Roster) ProtoMessage 

func (*Roster) ProtoMessage()

func (*Roster) Reset 

func (m *Roster) Reset()

func (*Roster) String 

func (m *Roster) String() string

func (*Roster) XXX_DiscardUnknown 

func (m *Roster) XXX_DiscardUnknown()

func (*Roster) XXX_Marshal 

func (m *Roster) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Roster) XXX_Merge 

func (m *Roster) XXX_Merge(src proto.Message)

func (*Roster) XXX_Size 

func (m *Roster) XXX_Size() int

func (*Roster) XXX_Unmarshal 

func (m *Roster) XXX_Unmarshal(b []byte) error

type RunRequest 

type RunRequest struct {
	// The MatchProfile that describes the Match that this MatchFunction needs to
	// generate proposals for.
	Profile              *MatchProfile `protobuf:"bytes,1,opt,name=profile,proto3" json:"profile,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*RunRequest) Descriptor 

func (*RunRequest) Descriptor() ([]byte, []int)

func (*RunRequest) GetProfile 

func (m *RunRequest) GetProfile() *MatchProfile

func (*RunRequest) ProtoMessage 

func (*RunRequest) ProtoMessage()

func (*RunRequest) Reset 

func (m *RunRequest) Reset()

func (*RunRequest) String 

func (m *RunRequest) String() string

func (*RunRequest) XXX_DiscardUnknown 

func (m *RunRequest) XXX_DiscardUnknown()

func (*RunRequest) XXX_Marshal 

func (m *RunRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RunRequest) XXX_Merge 

func (m *RunRequest) XXX_Merge(src proto.Message)

func (*RunRequest) XXX_Size 

func (m *RunRequest) XXX_Size() int

func (*RunRequest) XXX_Unmarshal 

func (m *RunRequest) XXX_Unmarshal(b []byte) error

type RunResponse 

type RunResponse struct {
	// The proposal generated by this MatchFunction Run.
	// Note that OpenMatch will validate the proposals, a valid match should contain at least one ticket.
	Proposals            []*Match `protobuf:"bytes,1,rep,name=proposals,proto3" json:"proposals,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RunResponse) Descriptor 

func (*RunResponse) Descriptor() ([]byte, []int)

func (*RunResponse) GetProposals 

func (m *RunResponse) GetProposals() []*Match

func (*RunResponse) ProtoMessage 

func (*RunResponse) ProtoMessage()

func (*RunResponse) Reset 

func (m *RunResponse) Reset()

func (*RunResponse) String 

func (m *RunResponse) String() string

func (*RunResponse) XXX_DiscardUnknown 

func (m *RunResponse) XXX_DiscardUnknown()

func (*RunResponse) XXX_Marshal 

func (m *RunResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RunResponse) XXX_Merge 

func (m *RunResponse) XXX_Merge(src proto.Message)

func (*RunResponse) XXX_Size 

func (m *RunResponse) XXX_Size() int

func (*RunResponse) XXX_Unmarshal 

func (m *RunResponse) XXX_Unmarshal(b []byte) error

type Ticket 

type Ticket struct {
	// The Ticket ID generated by Open Match.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Properties contains custom info about the ticket.  Top level values can be
	// used in indexing and filtering to find tickets.
	Properties *_struct.Struct `protobuf:"bytes,2,opt,name=properties,proto3" json:"properties,omitempty"`
	// Assignment associated with the Ticket.
	Assignment           *Assignment `protobuf:"bytes,3,opt,name=assignment,proto3" json:"assignment,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

A Ticket is a basic matchmaking entity in Open Match. In order to enter matchmaking using Open Match, the client should generate a Ticket, passing in the properties to be associated with this Ticket. Open Match will generate an ID for a Ticket during creation. A Ticket could be used to represent an individual 'Player' or a 'Group' of players. Open Match will not interpret what the Ticket represents but just treat it as a matchmaking unit with a set of properties. Open Match stores the Ticket in state storage and enables an Assignment to be associated with this Ticket.

func (*Ticket) Descriptor 

func (*Ticket) Descriptor() ([]byte, []int)

func (*Ticket) GetAssignment 

func (m *Ticket) GetAssignment() *Assignment

func (*Ticket) GetId 

func (m *Ticket) GetId() string

func (*Ticket) GetProperties 

func (m *Ticket) GetProperties() *_struct.Struct

func (*Ticket) ProtoMessage 

func (*Ticket) ProtoMessage()

func (*Ticket) Reset 

func (m *Ticket) Reset()

func (*Ticket) String 

func (m *Ticket) String() string

func (*Ticket) XXX_DiscardUnknown 

func (m *Ticket) XXX_DiscardUnknown()

func (*Ticket) XXX_Marshal 

func (m *Ticket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Ticket) XXX_Merge 

func (m *Ticket) XXX_Merge(src proto.Message)

func (*Ticket) XXX_Size 

func (m *Ticket) XXX_Size() int

func (*Ticket) XXX_Unmarshal 

func (m *Ticket) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.