wings/server/events.go

56 lines
1.7 KiB
Go
Raw Permalink Normal View History

package server
2019-12-01 01:08:11 +00:00
import (
"github.com/pterodactyl/wings/events"
2022-02-03 00:16:34 +00:00
"github.com/pterodactyl/wings/system"
2019-12-01 01:08:11 +00:00
)
2022-11-15 01:25:01 +00:00
// Defines all the possible output events for a server.
const (
DaemonMessageEvent = "daemon message"
InstallOutputEvent = "install output"
InstallStartedEvent = "install started"
InstallCompletedEvent = "install completed"
ConsoleOutputEvent = "console output"
StatusEvent = "status"
StatsEvent = "stats"
BackupRestoreCompletedEvent = "backup restore completed"
BackupCompletedEvent = "backup completed"
TransferLogsEvent = "transfer logs"
TransferStatusEvent = "transfer status"
2022-11-15 01:25:01 +00:00
DeletedEvent = "deleted"
)
2022-02-03 00:16:34 +00:00
// Events returns the server's emitter instance.
2022-01-18 03:23:29 +00:00
func (s *Server) Events() *events.Bus {
s.emitterLock.Lock()
defer s.emitterLock.Unlock()
if s.emitter == nil {
2022-01-18 03:23:29 +00:00
s.emitter = events.NewBus()
}
return s.emitter
}
2022-02-03 00:16:34 +00:00
// Sink returns the instantiated and named sink for a server. If the sink has
// not been configured yet this function will cause a panic condition.
func (s *Server) Sink(name system.SinkName) *system.SinkPool {
sink, ok := s.sinks[name]
if !ok {
s.Log().Fatalf("attempt to access nil sink: %s", name)
}
return sink
}
// DestroyAllSinks iterates over all of the sinks configured for the server and
// destroys their instances. Note that this will cause a panic if you attempt
// to call Server.Sink() again after. This function is only used when a server
// is being deleted from the system.
func (s *Server) DestroyAllSinks() {
s.Log().Info("destroying all registered sinks for server instance")
for _, sink := range s.sinks {
sink.Destroy()
}
2022-02-23 22:01:03 +00:00
}