Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

river

package module

Go to main page

Versions in this module

v1

v1.1.7

Nov 8, 2025

v1.1.6

Nov 2, 2025

Changes in this version

type DefaultApp

+ func (this *DefaultApp) OnServiceBreak(_func func(moduleName, serverId string)) error

v1.1.5

Nov 2, 2025

v1.1.4

Nov 2, 2025

v1.1.3

Nov 2, 2025

v1.1.2

Nov 2, 2025

v1.1.1

Oct 31, 2025

Changes in this version

+ func CreateApp(opts ...app.Option) app.IApp

+ func NewApp(opts ...app.Option) app.IApp

+ type DefaultApp struct

+ func (this *DefaultApp) Call(ctx context.Context, moduleType, _func string, param mqrpc.ParamOption, ...) (result any, err error)

+ func (this *DefaultApp) CallBroadcast(ctx context.Context, moduleName, _func string, params ...any)

+ func (this *DefaultApp) CallNR(ctx context.Context, moduleType, _func string, params ...any) (err error)

+ func (this *DefaultApp) Config() conf.Config

+ func (this *DefaultApp) GetModuleInited() func(module app.IModule)

+ func (this *DefaultApp) GetProcessEnv() string

+ func (this *DefaultApp) GetRouteServer(service string, opts ...selector.SelectOption) (app.IServerSession, error)

+ func (this *DefaultApp) GetServerByID(serverID string) (app.IServerSession, error)

+ func (this *DefaultApp) GetServerBySelector(moduleType string, opts ...selector.SelectOption) (app.IServerSession, error)

+ func (this *DefaultApp) GetServersByType(moduleType string) []app.IServerSession

+ func (this *DefaultApp) OnConfigurationLoaded(_func func()) error

+ func (this *DefaultApp) OnDestroy() error

+ func (this *DefaultApp) OnInit() error

+ func (this *DefaultApp) OnModuleInited(_func func(module app.IModule)) error

+ func (this *DefaultApp) OnServiceDeleted(_func func(moduleName, serverId string)) error

+ func (this *DefaultApp) OnStartup(_func func()) error

+ func (this *DefaultApp) Options() app.Options

+ func (this *DefaultApp) Registrar() registry.Registry

+ func (this *DefaultApp) Run(mods ...app.IModule) error

+ func (this *DefaultApp) SetServiceRoute(fn func(route string) string) error

+ func (this *DefaultApp) Transporter() *nats.Conn

+ func (this *DefaultApp) UpdateOptions(opts ...app.Option) error

+ func (this *DefaultApp) Watcher(node *registry.Node)

+ func (this *DefaultApp) WorkDir() string