Functions — github.com/Octops/agones-discover-openmatch

hub / github.com/Octops/agones-discover-openmatch / functions

Functions106 in github.com/Octops/agones-discover-openmatch

⨍ Functions 106◇ Types & classes 45

↓ 13 callersFunctionLogger

()

internal/runtime/log.go:27

↓ 11 callersMethodRun

(*pb.RunRequest, pb.MatchFunction_RunServer)

pkg/matchfunction/server.go:19

↓ 7 callersFunctionNewLogger

(verbose bool)

internal/runtime/log.go:10

↓ 6 callersFunctionOpenMatch

()

pkg/config/grpc_conn.go:16

↓ 4 callersMethodAllocate

(ctx context.Context, req *pb.AssignTicketsRequest)

pkg/allocator/types.go:21

↓ 4 callersMethodAny

()

pkg/extensions/allocator_filter.go:18

↓ 4 callersMethodMap

()

pkg/extensions/allocator_filter.go:24

↓ 4 callersFunctionValueIsEmpty

(value string, err error)

pkg/allocator/agones_allocator.go:71

↓ 3 callersMethodFindGameServers

(ctx context.Context, filters map[string]string)

pkg/allocator/agones_discover.go:87

↓ 3 callersFunctionSetupSignal

(cancel context.CancelFunc)

internal/runtime/signal.go:10

↓ 2 callersMethodAllocate

Allocate will only assign a GameServer to an Assignment if the Capacity (Players.Status.Capacity - Players.Stats.Count) is <= the number of the Ticket

pkg/allocator/agones_discover.go:28

↓ 2 callersFunctionCleanUpAssignmentsWithoutConnection

(group []*pb.AssignmentGroup)

pkg/director/openmatch/openmatch.go:176

↓ 2 callersMethodCreateMatchmakingRequests

()

pkg/simulators/players/time_interval.go:147

↓ 2 callersMethodCreatePlayers

(count int)

pkg/simulators/players/time_interval.go:95

↓ 2 callersFunctionDoubleRangeFilterFromSlice

(tags []*pb.DoubleRangeFilter)

pkg/director/openmatch/openmatch.go:283

↓ 2 callersFunctionEncodeFilter

(filter map[string]string)

pkg/allocator/agones_discover_client.go:63

↓ 2 callersFunctionExtractFilterFromExtensions

(extension map[string]*any.Any)

pkg/extensions/allocator_filter.go:32

↓ 2 callersFunctionMatchByGamePlayersCapacity

* Criteria for Matches - Number or tickets should not exceed the PlayerCapacity set by the Status.Players.Capacity field from the GS */

pkg/matchfunction/functions/player_capacity.go:26

↓ 2 callersFunctionNewAgonesDiscoverClientHTTP

(serverURI string)

pkg/allocator/agones_discover_client.go:22

↓ 2 callersFunctionNewAllocatorService

(service GameServerAllocator)

pkg/allocator/types.go:48

↓ 2 callersMethodRequestMatchForPlayers

(players []*Player)

pkg/simulators/players/time_interval.go:115

↓ 2 callersFunctionTagFromFloatSlice

(tags []float64)

pkg/simulators/players/time_interval.go:205

↓ 2 callersFunctionTagFromStringSlice

(tags []string)

pkg/simulators/players/time_interval.go:198

↓ 2 callersFunctionassignTickets

(ctx context.Context, req *pb.AssignTicketsRequest, assigner Assigner)

pkg/director/openmatch/openmatch.go:152

↓ 2 callersFunctioncreateGameServersResponse

(gameservers []*GameServer)

pkg/allocator/agones_discover_test.go:304

↓ 2 callersFunctioncreateGameServersWithCapacity

(count, playerCapacity, playerCount int, labels map[string]string)

pkg/allocator/agones_discover_test.go:317

↓ 2 callersFunctionjoinMapValues

(list map[string]string)

pkg/extensions/allocator_filter.go:62

↓ 1 callersMethodAddPlayers

(players []*Player)

pkg/simulators/players/time_interval.go:140

↓ 1 callersFunctionAssignTickets

(client pb.BackendServiceClient, allocatorService *allocator.AllocatorService)

pkg/director/openmatch/openmatch.go:122

↓ 1 callersMethodAssignTickets

(ctx context.Context, in *pb.AssignTicketsRequest, opts ...grpc.CallOption)

pkg/director/openmatch/openmatch.go:22

↓ 1 callersFunctionBuildAgonesAllocatorService

(mode string)

cmd/director.go:73

↓ 1 callersFunctionBuildQueryParams

(path string, filter map[string]string)

pkg/allocator/agones_discover_client.go:55

↓ 1 callersFunctionCreateAssignTicketRequestForMatch

(match *pb.Match)

pkg/director/openmatch/openmatch.go:189

↓ 1 callersFunctionCreateDoubleArgs

()

pkg/simulators/players/time_interval.go:163

↓ 1 callersFunctionCreateMatchForTickets

(matchID, profileName string, extensions map[string]*any.Any, tickets ...*pb.Ticket)

pkg/matchfunction/functions/player_capacity.go:82

↓ 1 callersFunctionCreateStringArgs

()

pkg/simulators/players/time_interval.go:175

↓ 1 callersMethodDialQueryService

(addr string)

pkg/matchfunction/server.go:37

↓ 1 callersFunctionExecute

Execute adds all child commands to the root command and sets flags appropriately. This is called by main.main(). It only needs to happen once to the r

cmd/root.go:49

↓ 1 callersMethodExtensions

()

pkg/extensions/extension.go:49

↓ 1 callersFunctionFetchMatches

(client pb.BackendServiceClient, matchFunctionServer MatchFunctionServer)

pkg/director/openmatch/openmatch.go:62

↓ 1 callersMethodFinalizer

()

pkg/matchfunction/server.go:91

↓ 1 callersFunctionFrontEndConn

()

pkg/frontend/conn.go:9

↓ 1 callersFunctionGenerateProfiles

generateProfiles generates profiles for every world assigning region, latency and skill randomly

pkg/director/openmatch/openmatch.go:211

↓ 1 callersFunctionHasCapacity

(group *pb.AssignmentGroup, gs *GameServer)

pkg/allocator/agones_discover.go:103

↓ 1 callersFunctionInfo

()

internal/version/version.go:30

↓ 1 callersFunctionIsAssignmentGroupValidForAllocation

(group *pb.AssignmentGroup)

pkg/allocator/agones_discover.go:91

↓ 1 callersMethodListGameServers

(ctx context.Context, filter map[string]string)

pkg/allocator/agones_discover_client.go:36

↓ 1 callersMethodListGameServers

(ctx context.Context, filter map[string]string)

pkg/allocator/agones_discover.go:15

↓ 1 callersMethodListGameServers

(ctx context.Context, filter *extensions.AllocatorFilterExtension)

pkg/allocator/agones_discover.go:68

↓ 1 callersFunctionNewAgonesAllocatorClient

(config *AgonesAllocatorClientConfig)

pkg/allocator/agones_allocator_client.go:40

↓ 1 callersFunctionNewFrontEndService

(conn *grpc.ClientConn)

pkg/frontend/frontend.go:17

↓ 1 callersFunctionNewServer

()

pkg/matchfunction/server.go:29

↓ 1 callersFunctionNewTimeIntervalPlayerSimulator

(interval string, playersPool int, requestMatchFunc RequestMatchFunc)

pkg/simulators/players/time_interval.go:47

↓ 1 callersFunctionParseGameServersResponse

(resp []byte)

pkg/allocator/agones_discover.go:114

↓ 1 callersMethodRegisterMatchFunction

(factory func(client pb.QueryServiceClient, makeMatchesFunc functions.MakeMatchesFunc) pb.MatchFunctionServer,

pkg/matchfunction/server.go:53

↓ 1 callersFunctionRun

(interval string)

pkg/director/director.go:20

↓ 1 callersMethodRun

(ctx context.Context)

pkg/simulators/players/time_interval.go:63

↓ 1 callersFunctionRunDirector

(ctx context.Context, logger *logrus.Entry, dial ConnFunc, interval string, allocatorService *allocator.Alloca

pkg/director/openmatch/openmatch.go:37

↓ 1 callersFunctionRunPlayerSimulator

(logger *logrus.Entry, ctx context.Context, interval string, playersPool int)

pkg/app/simulate.go:11

↓ 1 callersMethodServe

(ctx context.Context, port int32)

pkg/matchfunction/server.go:58

↓ 1 callersFunctionToAny

Reference: https://stackoverflow.com/a/62585911

pkg/extensions/extension.go:15

↓ 1 callersFunctionToFilter

(obj *any.Any)

pkg/extensions/allocator_filter.go:45

↓ 1 callersFunctionValidateMatchFunArguments

(playerCapacity int, profile *pb.MatchProfile, poolTickets map[string][]*pb.Ticket)

pkg/matchfunction/functions/player_capacity.go:92

↓ 1 callersFunctionWithAny

(anyMap map[string]*any.Any)

pkg/extensions/extension.go:33

↓ 1 callersFunctioncreateRawGameServersWithLabels

(count int, labels map[string]string)

pkg/allocator/agones_discover_test.go:334

↓ 1 callersFunctioncreateRemoteClusterDialOption

createRemoteClusterDialOption creates a grpc client dial option with TLS configuration.

pkg/allocator/agones_allocator_client.go:129

↓ 1 callersFunctionfetchMatches

(ctx context.Context, client pb.BackendServiceClient, profile *pb.MatchProfile, matchFunctionServer MatchFunct

pkg/director/openmatch/openmatch.go:84

↓ 1 callersFunctiongenerateAddress

()

pkg/allocator/agones_discover_test.go:373

↓ 1 callersFunctiongenerateAssignments

(count int, tickets []string, filter *extensions.AllocatorFilterExtension)

pkg/allocator/agones_discover_test.go:280

↓ 1 callersFunctiongenerateTicketsIds

(count int)

pkg/allocator/agones_discover_test.go:364

↓ 1 callersFunctionloadCertificates

(config *AgonesAllocatorClientConfig)

pkg/allocator/agones_allocator_client.go:107

↓ 1 callersFunctionvalidateClientConfig

(config *AgonesAllocatorClientConfig)

pkg/allocator/agones_allocator_client.go:77

↓ 1 callersFunctionvalidateInterval

(interval string)

pkg/director/director.go:69

MethodAllocate

(ctx context.Context, req *pb.AssignTicketsRequest)

pkg/allocator/types.go:39

MethodAllocate

(ctx context.Context, req *pb.AssignTicketsRequest)

pkg/allocator/types.go:55

MethodAllocate

(ctx context.Context, request *pb.AllocationRequest)

pkg/allocator/agones_allocator_client.go:61

MethodAllocate

(ctx context.Context, req *pb.AssignTicketsRequest)

pkg/allocator/agones_allocator.go:28

MethodAssignTickets

(ctx context.Context, in *pb.AssignTicketsRequest, opts ...grpc.CallOption)

pkg/director/openmatch/openmatch_test.go:232

FunctionConnFuncInsecure

()

pkg/director/openmatch/conn.go:8

FunctionConnFuncSecure

TODO: Implement secure dialer

pkg/director/openmatch/conn.go:18

MethodCreateTicket

(ctx context.Context, ticket *pb.CreateTicketRequest, opts ...grpc.CallOption)

pkg/frontend/frontend.go:28

MethodFindGameServers

(ctx context.Context, filters map[string]string)

pkg/allocator/types.go:45

MethodListGameServers

(ctx context.Context, filter map[string]string)

pkg/allocator/agones_discover_test.go:299

FunctionNewAgonesAllocator

(client *AgonesAllocatorClient)

pkg/allocator/agones_allocator.go:24

FunctionNewMatchFunctionService

(queryServiceClient pb.QueryServiceClient, makeMatchesFunc functions.MakeMatchesFunc)

pkg/matchfunction/service/service.go:18

MethodRun

(req *pb.RunRequest, stream pb.MatchFunction_RunServer)

pkg/matchfunction/service/service.go:26

FunctionTagFromStringSlice

(tags []string)

pkg/director/openmatch/openmatch.go:276

FunctionTestAgonesDiscoverAllocator_Allocate

(t *testing.T)

pkg/allocator/agones_discover_test.go:134

FunctionTestAgonesDiscoverAllocator_Call_FindGameServer

(t *testing.T)

pkg/allocator/agones_discover_test.go:106

FunctionTestAgonesDiscoverAllocator_SetConnection

(t *testing.T)

pkg/allocator/agones_discover_test.go:19

FunctionTestAgonesDiscoverClientHTTP_ListGameServers_Filters

(t *testing.T)

pkg/allocator/agones_discover_client_test.go:11

FunctionTestAssignTickets_assignTickets

(t *testing.T)

pkg/director/openmatch/openmatch_test.go:117

FunctionTestCleanUpAssignmentsWithoutConnection

(t *testing.T)

pkg/director/openmatch/openmatch_test.go:13

FunctionTestEncodeFilter

(t *testing.T)

pkg/allocator/agones_discover_client_test.go:81

FunctionTestMatchByGamePlayersCapacity

* - PlayerCapacity <= 0 return error PlayerCapacity can't be lower than zero - Profile == nil return error Profile is nil - PoolTickets == nil return

pkg/matchfunction/functions/player_capacity_test.go:20

FunctionTestTimeIntervalPlayerSimulator_CreatePlayers

(t *testing.T)

pkg/simulators/players/time_interval_test.go:14

FunctionTestTimeIntervalPlayerSimulator_RequestMatchForPlayers

(t *testing.T)

pkg/simulators/players/time_interval_test.go:63

MethodWithAny

(anyMap map[string]*any.Any)

pkg/extensions/extension.go:37

next →1–100 of 106, ranked by callers