gira

type AdminClient interface {
	// 广播所有节点重载资源
	BroadcastReloadResource(ctx context.Context, name string) (result BroadcastReloadResourceResult, err error)
}

type AdminConfig struct {
	None string `yaml:"none"`
}

type AdminService interface {
	ResourceReload() error
}

type Application interface {
	// ======= 生命周期回调 ===========
	// 配置加载完成后接收通知
	OnConfigLoad(c *Config) error
	OnCreate() error
	OnStart() error
	OnStop() error
}

type ApplicationArgs struct {
	AppType             string /// 服务名
	AppId               int32  /// 服务id
	BuildTime           int64
	AppVersion          string
	RespositoryVersion1 string
	Application         Application
}

type ApplicationFramework interface {
	OnFrameworkInit() []Framework
}

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

type BehaviorConfig struct {
	SyncInterval int64 `yaml:"sync-interval"`
	BatchInsert  int   `yaml:"batch-insert"`
}

type BroadcastReloadResourceResult interface {
	SuccessPeer(index int) *Peer
	ErrorPeer(index int) *Peer
	PeerCount() int
	SuccessCount() int
	ErrorCount() int
	Errors(index int) error
	Error() error
}

type Component interface {
	GetObject() *Object
	SetObject(object *Object) error
	Create() error
	Awake() error
	Start() error
	Destory() error
	GetComponents(t reflect.Type) []Component
	AddComponent(c Component) error
}

type Config struct {
	Raw         []byte
	Thread      int         `yaml:"thread"`
	Env         string      `yaml:"env"`
	Zone        string      `yaml:"zone"`
	Log         *LogConfig  `yaml:"log"`
	CoreLog     *LogConfig  `yaml:"core-log"`
	BehaviorLog *LogConfig  `yaml:"behavior-log"`
	Pprof       PprofConfig `yaml:"pprof"`
	Sandbox     int         `yaml:"sandbox"`
	Db          map[string]*DbConfig
	Resource    ResourceConfig `yaml:"resource"`
	Module      struct {
		Behavior   *BehaviorConfig   `yaml:"behavior"`
		Http       *HttpConfig       `yaml:"http,omitempty"`
		Etcd       *EtcdConfig       `yaml:"etcd"`
		EtcdClient *EtcdClientConfig `yaml:"etcd-client"`
		Grpc       *GrpcConfig       `yaml:"grpc"`
		Plat       *PlatformConfig   `yaml:"plat"`
		Jwt        *JwtConfig        `yaml:"jwt"`
		Gateway    *GatewayConfig    `yaml:"gateway"`
		Admin      *AdminConfig      `yaml:"admin"`
	} `yaml:"module"`
}

type Cron interface {
	AddFunc(spec string, cmd func()) error
}

type DbClient interface {
	Uri() string
}

type DbClientComponent interface {
	GetGameDbClient() DbClient
	GetStatDbClient() DbClient
	GetAccountDbClient() DbClient
	GetResourceDbClient() DbClient
	GetAdminDbClient() DbClient
	GetAccountCacheClient() DbClient
	GetGameCacheClient() DbClient
	GetLogDbClient() DbClient
	GetBehaviorDbClient() DbClient
	GetAdminCacheClient() DbClient
}

type DbConfig struct {
	Driver          string        `yaml:"driver"`
	Host            string        `yaml:"host"`
	Port            int           `yaml:"port"`
	User            string        `yaml:"user"`
	Password        string        `yaml:"password"`
	Db              string        `yaml:"db"`
	Query           string        `yaml:"query"`
	MaxOpenConns    int           `yaml:"max-open-conns"`
	MaxIdleConns    int           `yaml:"max-idle-conns"`
	ConnMaxIdleTime time.Duration `yaml:"conn-max-idle-time"`
	ConnMaxLifetime time.Duration `yaml:"conn-max-lifetime"`
	ConnnectTimeout time.Duration `yaml:"connect-timeout"`
}

type DbDao interface {
	UseClient(client DbClient) error
}

type DouyinPlatformConfig struct {
	Secret string `yaml:"secret"`
}

type EtcdClientConfig struct {
	Endpoints []struct {
		Host string `yaml:"host"`
		Port int    `yaml:"port"`
	} `yaml:"endpoints"`
	Username     string `yaml:"username"`
	Password     string `yaml:"password"`
	DialTimeout  int    `yaml:"dial-timeout"`
	LeaseTimeout int64  `yaml:"lease-timeout"`
	Address      string `yaml:"address"`
}

type EtcdConfig struct {
	Endpoints []struct {
		Host string `yaml:"host"`
		Port int    `yaml:"port"`
	} `yaml:"endpoints"`
	Username     string `yaml:"username"`
	Password     string `yaml:"password"`
	DialTimeout  int    `yaml:"dial-timeout"`
	LeaseTimeout int64  `yaml:"lease-timeout"`
	Address      string `yaml:"address"`
	Advertise    []struct {
		Name  string `yaml:"name"`
		Value string `yaml:"value"`
	} `yaml:"advertise"`
}

type Framework interface {
	OnFrameworkConfigLoad(c *Config) error
	OnFrameworkCreate() error
	OnFrameworkStart() error
	OnFrameworkStop() error
}

type GatewayClient interface {
	Recv(ctx context.Context) (typ int, route string, reqId uint64, data []byte, err error)
	Notify(route string, data []byte) error
	Request(route string, reqId uint64, data []byte) error
	Close() error
}

type GatewayConfig struct {
	IsWebsocket      bool          `yaml:"is-websocket"`
	Bind             string        `yaml:"bind"`
	Address          string        `yaml:"address"`
	Debug            bool          `yaml:"debug"`
	Ssl              bool          `yaml:"ssl"`
	CertFile         string        `yaml:"cert-file"`
	KeyFile          string        `yaml:"key-file"`
	WsPath           string        `yaml:"ws-path"`
	RecvBuffSize     int           `yaml:"recv-buff-size"`
	RecvBacklog      int           `yaml:"recv-backlog"`
	SendBacklog      int           `yaml:"send-backlog"`
	HandshakeTimeout time.Duration `yaml:"handshake-timeout"`
	Heartbeat        time.Duration `yaml:"heartbeat"`
}

type GatewayConn interface {
	Id() uint64
	Close() error
	Kick(reason string)
	SendServerSuspend(reason string)
	SendServerResume(reason string)
	SendServerMaintain(reason string)
	SendServerDown(reason string)
	Recv(ctx context.Context) (GatewayMessage, error)
	Push(route string, data []byte) error
	Response(mid uint64, data []byte) error
	Value(key string) interface{}
	Set(key string, value interface{})
	Uint64(key string) uint64
	Int32(key string) int32
	SetUserData(value interface{})
	UserData() interface{}
}

type GatewayHandler interface {
	ServeClientStream(conn GatewayConn)
}

type GatewayMessage interface {
	Response(data []byte) error
	Payload() []byte
	ReqId() uint64
	Session() GatewayConn
	Push(route string, data []byte) error
}

type GrpcConfig struct {
	Address      string `yaml:"address"`
	Workers      uint32 `yaml:"workers"`
	Resolver     bool   `yaml:"resolver"` // 是否开启resolver
	Admin        bool   `yaml:"admin"`
	EnabledTrace bool   `yaml:"enabled-trace"`
}

type GrpcServer interface {
	RegisterService(desc *grpc.ServiceDesc, impl interface{})
	GetServer(name string) (svr interface{}, ok bool)
}

type HttpConfig struct {
	Addr         string `yaml:"addr"`
	ReadTimeout  int64  `yaml:"read-timeout"`
	WriteTimeout int64  `yaml:"write-timeout"`
	Ssl          bool   `yaml:"ssl"`
	CertFile     string `yaml:"cert-file"`
	KeyFile      string `yaml:"key-file"`
}

type HttpHandler interface {
	HttpHandler() http.Handler
}

type JwtConfig struct {
	Secret            string `yaml:"secret"`
	Expiretime        int64  `yaml:"expiretime"`
	RefreshExpiretime int64  `yaml:"refresh-expiretime"`
}

type LocalPlayer struct {
	UserId         string
	LoginTime      int64
	CreateRevision int64
}

type LocalPlayerWatchHandler interface {
	OnLocalPlayerAdd(player *LocalPlayer)
	OnLocalPlayerDelete(player *LocalPlayer)
	OnLocalPlayerUpdate(player *LocalPlayer)
}

type LogConfig struct {
	Console         bool   `yaml:"console"`
	Db              bool   `yaml:"db"`
	Level           string `yaml:"level"` // ERROR|WARN|INFO|DEBUG
	DbLevel         string `yaml:"db-level"`
	TraceErrorStack bool   `yaml:"trace-error-stack"`
	// 输出到文件
	Files []struct {
		Level      string `yaml:"level"`  // 大于level的都会被输出
		Filter     string `yaml:"filter"` // 等于filter的才会被输出, filter比level优先级更高
		MaxSize    int    `yaml:"max-size"`
		MaxBackups int    `yaml:"max-backups"`
		MaxAge     int    `yaml:"max-age"`
		Compress   bool   `yaml:"compress"`
		Path       string `yaml:"path"`
		Format     string `yaml:"format"` // json|console
	} `yaml:"files"`
}

type Logger interface {
	Infow(msg string, kvs ...interface{})
	Errorw(msg string, kvs ...interface{})
	Debugw(msg string, kvs ...interface{})
	Fatalw(msg string, kvs ...interface{})
	Warnw(msg string, kvs ...interface{})
	Info(args ...interface{})
	Error(args ...interface{})
	Debug(args ...interface{})
	Fatal(args ...interface{})
	Warn(args ...interface{})
	Infof(format string, args ...interface{})
	Errorf(format string, args ...interface{})
	Debugf(format string, args ...interface{})
	Fatalf(format string, args ...interface{})
	Warnf(format string, args ...interface{})
	Named(s string) Logger
}

type MongoClient interface {
	DbClient
	GetMongoClient() *mongo.Client
	GetMongoDatabase() *mongo.Database
}

type MysqlClient interface {
	DbClient
	GetMysqlClient() *sql.DB
}

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

type Peer struct {
	Name     string // 服务类型
	Id       int32  // 服务id
	FullName string // 服务全名
	Address  string // grpc地址
	Url      string
	Metadata map[string]string // /server/account_1/ 下的键
}

type PeerWatchHandler interface {
	OnPeerAdd(peer *Peer)
	OnPeerDelete(peer *Peer)
	OnPeerUpdate(peer *Peer)
}

type PlatformConfig struct {
	Test   *TestPlatformConfig   `yaml:"test"`
	Pwd    *PwdPlatformConfig    `yaml:"pwd"`
	Ultra  *UltraPlatformConfig  `yaml:"ultra"`
	Douyin *DouyinPlatformConfig `yaml:"douyin"`
}

type PlatformSdk interface {
	// 登录
	Login(accountPlat string, openId string, token string, authUrl string, appId string, appSecret string) (*SdkAccount, error)
	// 检测支付订单是否有效
	PayOrderCheck(accountPlat string, args map[string]interface{}, paySecret string) (*SdkPayOrder, error)
}

type PprofConfig struct {
	Port         int    `yaml:"port"`
	Bind         string `yaml:"bind"`
	EnabledTrace bool   `yaml:"enabled-trace"`
}

type Proto interface {

	// request解码
	RequestEncode(name string, session int32, req interface{}) (data []byte, err error)
	// response编码
	ResponseEncode(name string, session int32, response interface{}) (data []byte, err error)
	// push解码
	PushEncode(req ProtoPush) (data []byte, err error)
	// struct编码
	StructEncode(req interface{}) (data []byte, err error)

	// request解码
	RequestDecode(packed []byte) (route string, session int32, resp ProtoRequest, err error)
	// response解码
	ResponseDecode(packed []byte) (route string, session int32, resp ProtoResponse, err error)
	// push解码
	PushDecode(packed []byte) (route string, session int32, resp ProtoPush, err error)
	// struct编码
	StructDecode(data []byte, req interface{}) error

	// 创建response
	NewResponse(req ProtoRequest) (resp ProtoResponse, err error)
	// 生成handler
	RegisterHandler(handler interface{}) ProtoHandler
	// 将request路由到handler的相应方法
	RequestDispatch(ctx context.Context, handler ProtoHandler, receiver interface{}, route string, session int32, req interface{}, traceDebugMsg bool) (dataResp []byte, pushArr []ProtoPush, err error)
	// 将push路由到handler的相应方法
	PushDispatch(ctx context.Context, handler ProtoHandler, receiver interface{}, route string, req ProtoPush) error
}

type ProtoHandler interface {
	HasRoute(route string) bool
	// 将push路由到handler的相应方法
	PushDispatch(ctx context.Context, receiver interface{}, route string, r interface{}) (err error)
	// 将request路由到handler的相应方法
	RequestDispatch(ctx context.Context, receiver interface{}, route string, r interface{}) (resp interface{}, push []ProtoPush, err error)
}

type ProtoPush interface {
	GetPushName() string
}

type ProtoRequest interface {
	GetRequestName() string
}

type ProtoResponse interface {
	SetErrorCode(v int32)
	SetErrorMsg(v string)
	SetDebugMsg(v string)
}

type PwdPlatformConfig struct {
	Secret string `yaml:"secret"`
}

type RedisClient interface {
	DbClient
	GetRedisClient() *redis.Client
}

type Registry interface {
	// 如果失败，则返回当前所在的节点
	LockLocalUser(userId string) (*Peer, error)
	UnlockLocalUser(userId string) (*Peer, error)
	ListLocalUser() []string
	WhereIsUser(userId string) (*Peer, error)
	RangePeers(f func(k any, v any) bool)
	NewServiceName(serviceName string, opt ...service_options.RegisterOption) string
	// 注册服务
	RegisterService(serviceName string, opt ...service_options.RegisterOption) (*Peer, error)
	// 反注册服务
	UnregisterService(serviceName string) (*Peer, error)
	// 查找服务
	WhereIsService(serviceName string, opt ...service_options.WhereOption) ([]*Peer, error)
	// 查找节点
	WhereIsPeer(appFullName string) (*Peer, error)
	// 自身节点
	SelfPeer() *Peer
}

type RegistryClient interface {
	NewServiceName(serviceName string, opt ...service_options.RegisterOption) string
	WhereIsUser(userId string) (*Peer, error)
	// 查找服务
	WhereIsService(serviceName string, opt ...service_options.WhereOption) ([]*Peer, error)
	UnregisterPeer(appFullName string) error
	ListPeerKvs() (peers map[string]string, err error)
	ListServiceKvs() (services map[string][]string, err error)
	// 查找节点
	WhereIsPeer(appFullName string) (*Peer, error)
}

type ResourceConfig struct {
	Compress bool `yaml:"compress"`
}

type ResourceHandler interface {
	OnResourcePreLoad(reload bool)
	OnResourcePostLoad(reload bool)
}

type ResourceLoader interface {
	// 加载资源
	LoadResource(ctx context.Context, client DbClient, dir string, compress bool) error
	// 加载资源
	ReloadResource(ctx context.Context, client DbClient, dir string, compress bool) error
	// 配置版本
	GetResVersion() string
	// loader版本
	GetLoaderVersion() string
}

type ResourceSource interface {
	// 返回资源加载器
	GetResourceLoader() ResourceLoader
	OnResourcePreLoad(reload bool)
	// 资源加载完成
	OnResourcePostLoad(reload bool)
}

type Runtime interface {
	// ======= 状态数据 ===========
	GetConfig() *Config
	GetAppType() string
	GetAppName() string
	GetAppFullName() string
	GetEnv() string
	GetZone() string
	GetAppId() int32
	GetLogDir() string
	GetWorkDir() string
	GetAppVersion() string
	GetBuildTime() int64
	GetUpTime() int64

	// ======= 同步接口 ===========
	Wait() error
	Stop() error
	Context() context.Context
	Go(f func() error)
	Done() <-chan struct{}

	Frameworks() []Framework
	Application() Application

	// ======= 组件 ===========
	GetServiceContainer() ServiceContainer
	GetPlatformSdk() PlatformSdk
	GetCron() Cron
	GetGrpcServer() GrpcServer
	GetRegistry() Registry
	GetRegistryClient() RegistryClient
}

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

type SdkAccount struct {
	UnionId         string
	OpenId          string
	AccessToken     string // access token
	RefreshToken    string // refresh token
	TokenExpireTime int64  // token过期时间
	NickName        string // 昵称
	Gender          int32  // 性别
	SmallPic        string // 小头像地址
	LargePic        string // 大头像地址
}

type SdkPayOrder struct {
	CporderId  string
	OrderId    string
	PayTime    int64
	Amount     int64 // 单位 分
	UserDefine string
	Response   string
}

type Service interface {
	// 服务启动
	OnStart(ctx context.Context) error
	// 服务函数
	Serve() error
	// 服务停止
	OnStop() error
}

type ServiceContainer interface {
	// 启动服务
	StartService(name string, service Service) error
	// 停止服务
	StopService(service Service) error
}

type ServiceName struct {
	// <<GroupName>>/<<ShortName>>
	Peer            *Peer
	ServiceFullName string
	ServiceTypeName string
	IsSelf          bool
	CreateRevision  int64
}

type ServiceWatchHandler interface {
	OnServiceAdd(service *ServiceName)
	OnServiceDelete(service *ServiceName)
	OnServiceUpdate(service *ServiceName)
}

type TestPlatformConfig struct {
	Secret string `yaml:"secret"`
}

type UltraPlatformConfig struct {
	Secret string `yaml:"secret"`
}