core

package

v0.0.2 Latest Latest Go to latest Published: Jul 8, 2025 License: MIT Imports: 19 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/go-pantheon/roma

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func NewResponser(sendFunc life.SendFunc) life.Responsive
func SendFunc(stream intrav1.TunnelService_TunnelServer, p xnet.TunnelMessage) error
type Context
type Manager
- func NewManager(logger log.Logger, rt *self.SelfRouteTable, userDo *domain.UserDomain, ...) (*Manager, func())
type UserPersister

Constants ¶

View Source

const (
	EventStorageItemUpdated           = life.WorkerEventType(iota + 1) // storage updated. args: item IDs
	EventStoragePackUpdated                                            // storage updated. args: pack IDs
	WorkerEventTypeHeroUpdated                                         // hero updated. args: none
	WorkerEventTypeEffectParamUpdated                                  // effect param updated. args: none
)

Variables ¶

View Source

var (
	ArgKeyStorageItemIDs = argKeyStorageItemIDs{}
	ArgKeyStoragePackIDs = argKeyStoragePackIDs{}
	ArgKeyHeroIDs        = argKeyHeroIDs{}
	ArgKeyEffectParamIDs = argKeyEffectParamIDs{}
)

View Source

var ProviderSet = wire.NewSet(NewManager, data.ProviderSet)

Functions ¶

func NewResponser ¶

func NewResponser(sendFunc life.SendFunc) life.Responsive

func SendFunc ¶

func SendFunc(stream intrav1.TunnelService_TunnelServer, p xnet.TunnelMessage) error

Types ¶

type Context ¶

type Context interface {
	life.Context

	User() *userobj.User
}

type Manager ¶

type Manager struct {
	*life.Manager
}

func NewManager ¶

func NewManager(logger log.Logger, rt *self.SelfRouteTable, userDo *domain.UserDomain, pusher *data.PushRepo) (*Manager, func())

func (*Manager) ExecuteEvent ¶

func (m *Manager) ExecuteEvent(ctx context.Context, uid int64, f life.EventFunc) (err error)

func (*Manager) RegisterEvent ¶

func (m *Manager) RegisterEvent(et life.WorkerEventType, f eventFunc)

func (*Manager) RegisterMinuteTick ¶

func (m *Manager) RegisterMinuteTick(f func(ctx Context) error)

func (*Manager) RegisterOnCreatedEvent ¶

func (m *Manager) RegisterOnCreatedEvent(f func(ctx Context) error)

func (*Manager) RegisterOnLoadEvent ¶

func (m *Manager) RegisterOnLoadEvent(f func(ctx Context) error)

func (*Manager) RegisterSecondTick ¶

func (m *Manager) RegisterSecondTick(f func(ctx Context) error)

type UserPersister ¶

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

func (*UserPersister) AllModuleKeys ¶

func (s *UserPersister) AllModuleKeys() []life.ModuleKey

func (*UserPersister) ID ¶

func (s *UserPersister) ID() int64

func (*UserPersister) IncVersion ¶

func (s *UserPersister) IncVersion(ctx context.Context, uid int64) (err error)

func (*UserPersister) Lock ¶

func (s *UserPersister) Lock(f func() error) error

func (*UserPersister) OnStop ¶

func (s *UserPersister) OnStop(ctx context.Context, id int64, p life.VersionProto) (err error)

func (*UserPersister) Persist ¶

func (s *UserPersister) Persist(ctx context.Context, uid int64, proto life.VersionProto) (err error)

func (*UserPersister) PrepareToPersist ¶

func (s *UserPersister) PrepareToPersist(ctx context.Context, modules []life.ModuleKey) (ret life.VersionProto, err error)

func (*UserPersister) Refresh ¶

func (s *UserPersister) Refresh(ctx context.Context) (err error)

func (*UserPersister) Snapshot ¶

func (s *UserPersister) Snapshot() life.VersionProto

func (*UserPersister) UnsafeObject ¶

func (s *UserPersister) UnsafeObject() any

func (*UserPersister) Version ¶

func (s *UserPersister) Version() int64

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL