pkg

Documentation

Index

• Constants
• type Allocator
  • func NewAllocator(options *Options) (allocator *Allocator, err error)
  • func (a *Allocator) Run(loopStopCh <-chan struct{}, loopDoneCh chan<- struct{})
• type ConnectInfo
• type Options
  • func (o *Options) GetBackendConn() (string, error)
  • func (o *Options) GetFrontendConn() (string, error)

Constants

const (
	BackfillConnectionKey     = "game.kruise.io/connection"
	BackfillConnectedTag      = "game.kruise.io/connected"
	OpenMatchLabelSelectorKey = "game.kruise.io/owner-gss"
	AssignmentGsNameKey       = "game.kruise.io/gs-name"
	GameServerMatchIdKey      = "gs-sync/match-id"
	GameNameProfileKey        = "game_name"
	ClusterHostName           = "Host"
)

Types

type Allocator

type Allocator struct {
	GameServerListers map[string]v1alpha1Lister.GameServerLister
	GameServerClients map[string]v1alpha1client.Interface

	BackendClient  pb.BackendServiceClient
	BackendConn    *grpc.ClientConn
	FrontendClient pb.FrontendServiceClient
	FrontendConn   *grpc.ClientConn

	MatchFunctionEndpoint string
	MatchFunctionPort     int32

	GameServerLabelSelector string
	ProfileName             string
	GameServerSetNames      string
	ClusterNames            []string

	//GameServersReSyncInterval time.Duration
	MatchPullingInterval time.Duration
	// contains filtered or unexported fields
}

func NewAllocator

func NewAllocator(options *Options) (allocator *Allocator, err error)

func (*Allocator) Run

func (a *Allocator) Run(loopStopCh <-chan struct{}, loopDoneCh chan<- struct{})

type ConnectInfo

type ConnectInfo struct {
	// contains filtered or unexported fields
}

type Options

type Options struct {
	MatchFunctionEndpoint     string
	MatchFunctionPort         int
	BackendEndpoint           string
	BackendPort               int
	FrontendEndpoint          string
	FrontendPort              int
	Config                    *rest.Config
	GameServerLabelSelector   string
	GameServersReSyncInterval time.Duration
	MatchPullingInterval      time.Duration
	ProfileName               string
	SlaveClustersNames        string
	Namespace                 string
	GameServerSetNames        string
}

func (*Options) GetBackendConn

func (o *Options) GetBackendConn() (string, error)

GetBackendConn return backend conn of open-match service

func (*Options) GetFrontendConn

func (o *Options) GetFrontendConn() (string, error)

GetFrontendConn return backend conn of open-match service