internal

Documentation

Index

• Variables
• type Director
  • func CreateDirector(logger *zap.Logger, backendUrl string, funcHost string, funcPort int32, ...) *Director
  • func (d *Director) FetchMatch(game string, mode string) error
• type Service
  • func CreateService(logger *zap.Logger, omFrontend, omBackend string, funcUrl string, ...) (*Service, error)
  • func (s *Service) Match(request *matchmaking.MatchRequest, ...) error
  • func (s *Service) RegisterWithGrpcServer(server siface.IGrpcServer) error

Variables

var Module = fx.Provide(
	func(
		logger *zap.Logger,
		setting mmfx.MatchmakingSettingParams,
		agonesClient agonesfx.AllocateParams,
		awsConfig cloudfx.AWSConfigParams,
	) (out sfx.GrpcServiceResult, err error) {

		if svc, e := CreateService(
			logger,
			setting.OMFrontendUrl,
			setting.OMBackendUrl,
			setting.OMFuncUrl,
			setting.OMFuncPort,
			agonesClient.AllocateClient,
			globalaccelerator.NewFromConfig(awsConfig.Config),
			setting.AWSVPCSubnets,
		); e != nil {
			err = e
		} else {
			out.GrpcService = svc
		}
		return
	})

Types

type Director

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

func CreateDirector

func CreateDirector(
	logger *zap.Logger,
	backendUrl string,
	funcHost string,
	funcPort int32,
	aCli *agones.Allocator,
) *Director

func (*Director) FetchMatch

func (d *Director) FetchMatch(game string, mode string) error

type Service

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

func CreateService

func CreateService(
	logger *zap.Logger,
	omFrontend, omBackend string,
	funcUrl string,
	funcPort int32,
	agonesClient allocation.AllocationServiceClient,
	accCli *globalaccelerator.Client,
	subNet string,
) (*Service, error)

func (*Service) Match

func (s *Service) Match(request *matchmaking.MatchRequest, server grpc.ServerStreamingServer[matchmaking.MatchResponse]) error

func (*Service) RegisterWithGrpcServer

func (s *Service) RegisterWithGrpcServer(server siface.IGrpcServer) error