pb

package
v0.7.0 Latest Latest
Warning

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

 Go to latest Published: Sep 27, 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) (Backend_FetchMatchesClient, 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(*FetchMatchesRequest, Backend_FetchMatchesServer) 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 Backend_FetchMatchesClient added in v0.7.0 

type Backend_FetchMatchesClient interface {
	Recv() (*FetchMatchesResponse, error)
	grpc.ClientStream
}

type Backend_FetchMatchesServer added in v0.7.0 

type Backend_FetchMatchesServer interface {
	Send(*FetchMatchesResponse) error
	grpc.ServerStream
}

type BoolEqualsFilter added in v0.7.0 

type BoolEqualsFilter struct {
	Attribute            string   `protobuf:"bytes,1,opt,name=attribute,proto3" json:"attribute,omitempty"`
	Value                bool     `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Filters boolean values. 

attribute: "foo"
value: false

matches: 

{"foo": false}

does not match: 

{"foo": true}
{"foo": "bar"}
{"foo": 1}
{"foo": "false"}
{"foo": [false]}
{"foo": null}
{}

func (*BoolEqualsFilter) Descriptor added in v0.7.0 

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

func (*BoolEqualsFilter) GetAttribute added in v0.7.0 

func (m *BoolEqualsFilter) GetAttribute() string

func (*BoolEqualsFilter) GetValue added in v0.7.0 

func (m *BoolEqualsFilter) GetValue() bool

func (*BoolEqualsFilter) ProtoMessage added in v0.7.0 

func (*BoolEqualsFilter) ProtoMessage()

func (*BoolEqualsFilter) Reset added in v0.7.0 

func (m *BoolEqualsFilter) Reset()

func (*BoolEqualsFilter) String added in v0.7.0 

func (m *BoolEqualsFilter) String() string

func (*BoolEqualsFilter) XXX_DiscardUnknown added in v0.7.0 

func (m *BoolEqualsFilter) XXX_DiscardUnknown()

func (*BoolEqualsFilter) XXX_Marshal added in v0.7.0 

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

func (*BoolEqualsFilter) XXX_Merge added in v0.7.0 

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

func (*BoolEqualsFilter) XXX_Size added in v0.7.0 

func (m *BoolEqualsFilter) XXX_Size() int

func (*BoolEqualsFilter) XXX_Unmarshal added in v0.7.0 

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

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.
	Match                *Match   `protobuf:"bytes,1,opt,name=match,proto3" json:"match,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EvaluateRequest) Descriptor 

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

func (*EvaluateRequest) GetMatch added in v0.7.0 

func (m *EvaluateRequest) GetMatch() *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.
	Match                *Match   `protobuf:"bytes,1,opt,name=match,proto3" json:"match,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EvaluateResponse) Descriptor 

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

func (*EvaluateResponse) GetMatch added in v0.7.0 

func (m *EvaluateResponse) GetMatch() *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, opts ...grpc.CallOption) (Evaluator_EvaluateClient, 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(Evaluator_EvaluateServer) error
}

EvaluatorServer is the server API for Evaluator service.

type Evaluator_EvaluateClient added in v0.7.0 

type Evaluator_EvaluateClient interface {
	Send(*EvaluateRequest) error
	Recv() (*EvaluateResponse, error)
	grpc.ClientStream
}

type Evaluator_EvaluateServer added in v0.7.0 

type Evaluator_EvaluateServer interface {
	Send(*EvaluateResponse) error
	Recv() (*EvaluateRequest, error)
	grpc.ServerStream
}

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.
	Match                *Match   `protobuf:"bytes,1,opt,name=match,proto3" json:"match,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FetchMatchesResponse) Descriptor 

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

func (*FetchMatchesResponse) GetMatch added in v0.7.0 

func (m *FetchMatchesResponse) GetMatch() *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 FloatRangeFilter added in v0.7.0 

type FloatRangeFilter 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:"-"`
}

Filters numerical values to only those within a range. 

attribute: "foo"
max: 10
min: 5

matches: 

{"foo": 5}
{"foo": 7.5}
{"foo": 10}

does not match: 

{"foo": 4}
{"foo": 10.01}
{"foo": "7.5"}
{"foo": true}
{"foo": [7.5]}
{"foo": null}
{}

func (*FloatRangeFilter) Descriptor added in v0.7.0 

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

func (*FloatRangeFilter) GetAttribute added in v0.7.0 

func (m *FloatRangeFilter) GetAttribute() string

func (*FloatRangeFilter) GetMax added in v0.7.0 

func (m *FloatRangeFilter) GetMax() float64

func (*FloatRangeFilter) GetMin added in v0.7.0 

func (m *FloatRangeFilter) GetMin() float64

func (*FloatRangeFilter) ProtoMessage added in v0.7.0 

func (*FloatRangeFilter) ProtoMessage()

func (*FloatRangeFilter) Reset added in v0.7.0 

func (m *FloatRangeFilter) Reset()

func (*FloatRangeFilter) String added in v0.7.0 

func (m *FloatRangeFilter) String() string

func (*FloatRangeFilter) XXX_DiscardUnknown added in v0.7.0 

func (m *FloatRangeFilter) XXX_DiscardUnknown()

func (*FloatRangeFilter) XXX_Marshal added in v0.7.0 

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

func (*FloatRangeFilter) XXX_Merge added in v0.7.0 

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

func (*FloatRangeFilter) XXX_Size added in v0.7.0 

func (m *FloatRangeFilter) XXX_Size() int

func (*FloatRangeFilter) XXX_Unmarshal added in v0.7.0 

func (m *FloatRangeFilter) 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=openmatch.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) (MatchFunction_RunClient, 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(*RunRequest, MatchFunction_RunServer) error
}

MatchFunctionServer is the server API for MatchFunction service.

type MatchFunction_RunClient added in v0.7.0 

type MatchFunction_RunClient interface {
	Recv() (*RunResponse, error)
	grpc.ClientStream
}

type MatchFunction_RunServer added in v0.7.0 

type MatchFunction_RunServer interface {
	Send(*RunResponse) error
	grpc.ServerStream
}

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.
	FloatRangeFilters    []*FloatRangeFilter   `protobuf:"bytes,2,rep,name=float_range_filters,json=floatRangeFilters,proto3" json:"float_range_filters,omitempty"`
	BoolEqualsFilters    []*BoolEqualsFilter   `protobuf:"bytes,3,rep,name=bool_equals_filters,json=boolEqualsFilters,proto3" json:"bool_equals_filters,omitempty"`
	StringEqualsFilters  []*StringEqualsFilter `protobuf:"bytes,4,rep,name=string_equals_filters,json=stringEqualsFilters,proto3" json:"string_equals_filters,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*Pool) Descriptor 

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

func (*Pool) GetBoolEqualsFilters added in v0.7.0 

func (m *Pool) GetBoolEqualsFilters() []*BoolEqualsFilter

func (*Pool) GetFloatRangeFilters added in v0.7.0 

func (m *Pool) GetFloatRangeFilters() []*FloatRangeFilter

func (*Pool) GetName 

func (m *Pool) GetName() string

func (*Pool) GetStringEqualsFilters added in v0.7.0 

func (m *Pool) GetStringEqualsFilters() []*StringEqualsFilter

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.
	Proposal             *Match   `protobuf:"bytes,1,opt,name=proposal,proto3" json:"proposal,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RunResponse) Descriptor 

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

func (*RunResponse) GetProposal added in v0.7.0 

func (m *RunResponse) GetProposal() *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 StringEqualsFilter added in v0.7.0 

type StringEqualsFilter struct {
	Attribute            string   `protobuf:"bytes,1,opt,name=attribute,proto3" json:"attribute,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Filters strings exactly equaling a value. 

attribute: "foo"
value: "bar"

matches: 

{"foo": "bar"}

does not match: 

{"foo": "baz"}
{"foo": true}
{"foo": 5}
{"foo": ["bar"]}
{"foo": null}
{}

func (*StringEqualsFilter) Descriptor added in v0.7.0 

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

func (*StringEqualsFilter) GetAttribute added in v0.7.0 

func (m *StringEqualsFilter) GetAttribute() string

func (*StringEqualsFilter) GetValue added in v0.7.0 

func (m *StringEqualsFilter) GetValue() string

func (*StringEqualsFilter) ProtoMessage added in v0.7.0 

func (*StringEqualsFilter) ProtoMessage()

func (*StringEqualsFilter) Reset added in v0.7.0 

func (m *StringEqualsFilter) Reset()

func (*StringEqualsFilter) String added in v0.7.0 

func (m *StringEqualsFilter) String() string

func (*StringEqualsFilter) XXX_DiscardUnknown added in v0.7.0 

func (m *StringEqualsFilter) XXX_DiscardUnknown()

func (*StringEqualsFilter) XXX_Marshal added in v0.7.0 

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

func (*StringEqualsFilter) XXX_Merge added in v0.7.0 

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

func (*StringEqualsFilter) XXX_Size added in v0.7.0 

func (m *StringEqualsFilter) XXX_Size() int

func (*StringEqualsFilter) XXX_Unmarshal added in v0.7.0 

func (m *StringEqualsFilter) 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

type UnimplementedBackendServer added in v0.7.0 

type UnimplementedBackendServer struct {
}

UnimplementedBackendServer can be embedded to have forward compatible implementations.

func (*UnimplementedBackendServer) AssignTickets added in v0.7.0 

func (*UnimplementedBackendServer) AssignTickets(ctx context.Context, req *AssignTicketsRequest) (*AssignTicketsResponse, error)

func (*UnimplementedBackendServer) FetchMatches added in v0.7.0 

func (*UnimplementedBackendServer) FetchMatches(req *FetchMatchesRequest, srv Backend_FetchMatchesServer) error

type UnimplementedEvaluatorServer added in v0.7.0 

type UnimplementedEvaluatorServer struct {
}

UnimplementedEvaluatorServer can be embedded to have forward compatible implementations.

func (*UnimplementedEvaluatorServer) Evaluate added in v0.7.0 

func (*UnimplementedEvaluatorServer) Evaluate(srv Evaluator_EvaluateServer) error

type UnimplementedFrontendServer added in v0.7.0 

type UnimplementedFrontendServer struct {
}

UnimplementedFrontendServer can be embedded to have forward compatible implementations.

func (*UnimplementedFrontendServer) CreateTicket added in v0.7.0 

func (*UnimplementedFrontendServer) CreateTicket(ctx context.Context, req *CreateTicketRequest) (*CreateTicketResponse, error)

func (*UnimplementedFrontendServer) DeleteTicket added in v0.7.0 

func (*UnimplementedFrontendServer) DeleteTicket(ctx context.Context, req *DeleteTicketRequest) (*DeleteTicketResponse, error)

func (*UnimplementedFrontendServer) GetAssignments added in v0.7.0 

func (*UnimplementedFrontendServer) GetAssignments(req *GetAssignmentsRequest, srv Frontend_GetAssignmentsServer) error

func (*UnimplementedFrontendServer) GetTicket added in v0.7.0 

func (*UnimplementedFrontendServer) GetTicket(ctx context.Context, req *GetTicketRequest) (*Ticket, error)

type UnimplementedMatchFunctionServer added in v0.7.0 

type UnimplementedMatchFunctionServer struct {
}

UnimplementedMatchFunctionServer can be embedded to have forward compatible implementations.

func (*UnimplementedMatchFunctionServer) Run added in v0.7.0 

func (*UnimplementedMatchFunctionServer) Run(req *RunRequest, srv MatchFunction_RunServer) error

type UnimplementedMmLogicServer added in v0.7.0 

type UnimplementedMmLogicServer struct {
}

UnimplementedMmLogicServer can be embedded to have forward compatible implementations.

func (*UnimplementedMmLogicServer) QueryTickets added in v0.7.0 

func (*UnimplementedMmLogicServer) QueryTickets(req *QueryTicketsRequest, srv MmLogic_QueryTicketsServer) 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.