service

Documentation

Index

• Constants
• Variables
• func Run()
• type Command
  • func (c *Command) Startup() error
• type ComponentTemplate
  • func (c *ComponentTemplate) Shutdown() error
  • func (c *ComponentTemplate) Startup() error
• type Factorio
  • func (f *Factorio) Reset() error
  • func (f *Factorio) Restart() error
  • func (f *Factorio) Shutdown() error
  • func (f *Factorio) Startup() error
  • func (f *Factorio) Status() string
• type LogHandler
  • func (s *LogHandler) Enabled(ctx context.Context, level slog.Level) bool
  • func (s *LogHandler) Handle(ctx context.Context, record slog.Record) error
  • func (s *LogHandler) WithAttrs(attrs []slog.Attr) slog.Handler
  • func (s *LogHandler) WithGroup(name string) slog.Handler
• type Nats
  • func (n *Nats) Publish(s string, bytes []byte)
  • func (n *Nats) PublishMsg(m *nats.Msg)
  • func (n *Nats) Reply(in *nats.Msg, payload []byte, err error)
  • func (n *Nats) Shutdown() error
  • func (n *Nats) Startup() error
  • func (n *Nats) Subscribe(subject string, handler nats.MsgHandler) error
• type Rcon
  • func (r *Rcon) Shutdown() error
  • func (r *Rcon) Startup() error
• type Service
  • func (sv *Service) Start(s kservice.Service) error
  • func (sv *Service) Stop(_ kservice.Service) error
• type Settings
  • func (s *Settings) Startup() error
• type SoftMod
  • func (sm *SoftMod) Apply(data []byte) error
• type UDPBridge
  • func (u *UDPBridge) Shutdown() error
  • func (u *UDPBridge) Startup() error
• type WebServer
  • func (w *WebServer) ServeHTTP(writer http.ResponseWriter, request *http.Request)
  • func (w *WebServer) Shutdown() error
  • func (w *WebServer) Startup() error

Constants

const (
	SettingsDirectory = "/opt/factorio/settings"
	FactOpSettings    = SettingsDirectory + "/factop-settings.json"
	ServerSettings    = SettingsDirectory + "/server-settings.json"
	MapGenSettings    = SettingsDirectory + "/map-gen-settings.json"
	ServerAdminList   = SettingsDirectory + "/server-adminlist.json"
	ServerBanList     = SettingsDirectory + "/server-banlist.json"
)

const CreateSaveOutput = SaveLocation + "/create-save.log"

const CurrentSoftMod = SaveLocation + "/softmod.zip"

const FactorioBinary = FactorioDirectory + "/bin/x64/factorio"

const FactorioDirectory = "/opt/factorio/current"

const NewLine = "\n"

const NewSave = SaveLocation + "/newSave.zip"

const RconStartupMarker = "Starting RCON interface at IP ADDR"

const SaveFile = SaveLocation + "/save.zip"

const SaveLocation = "/opt/factorio/saves"

Variables

var IgnorePattern = regexp.MustCompile(`(\d{4}-\d{2}-\d{2} \d{2}:\d{2}:\d{2}) \[(\w+)] (.+)`)

Functions

func Run

func Run()

Types

type Command

type Command struct {
	slog.Logger
	Nats     *Nats
	Factorio *Factorio
}

func (*Command) Startup

func (c *Command) Startup() error

type ComponentTemplate

type ComponentTemplate struct {
	slog.Logger
}

ComponentTemplate is a template for creating new components

func (*ComponentTemplate) Shutdown

func (c *ComponentTemplate) Shutdown() error

func (*ComponentTemplate) Startup

func (c *ComponentTemplate) Startup() error

type Factorio

type Factorio struct {
	slog.Logger
	Nats    *Nats
	SoftMod *SoftMod

	Port         int
	RconBind     string
	RconPassword string
	// contains filtered or unexported fields
}

func (*Factorio) Reset

func (f *Factorio) Reset() error

func (*Factorio) Restart

func (f *Factorio) Restart() error

func (*Factorio) Shutdown

func (f *Factorio) Shutdown() error

func (*Factorio) Startup

func (f *Factorio) Startup() error

func (*Factorio) Status

func (f *Factorio) Status() string

type LogHandler

type LogHandler struct {
	Logger service.Logger
}

func (*LogHandler) Enabled

func (s *LogHandler) Enabled(ctx context.Context, level slog.Level) bool

func (*LogHandler) Handle

func (s *LogHandler) Handle(ctx context.Context, record slog.Record) error

func (*LogHandler) WithAttrs

func (s *LogHandler) WithAttrs(attrs []slog.Attr) slog.Handler

func (*LogHandler) WithGroup

func (s *LogHandler) WithGroup(name string) slog.Handler

type Nats

type Nats struct {
	slog.Logger
	// contains filtered or unexported fields
}

func (*Nats) Publish

func (n *Nats) Publish(s string, bytes []byte)

func (*Nats) PublishMsg

func (n *Nats) PublishMsg(m *nats.Msg)

func (*Nats) Reply

func (n *Nats) Reply(in *nats.Msg, payload []byte, err error)

func (*Nats) Shutdown

func (n *Nats) Shutdown() error

func (*Nats) Startup

func (n *Nats) Startup() error

func (*Nats) Subscribe

func (n *Nats) Subscribe(subject string, handler nats.MsgHandler) error

type Rcon

type Rcon struct {
	slog.Logger
	Nats     *Nats
	Factorio *Factorio
	// contains filtered or unexported fields
}

func (*Rcon) Shutdown

func (r *Rcon) Shutdown() error

func (*Rcon) Startup

func (r *Rcon) Startup() error

type Service

type Service struct {
	servicego.Defaults

	Context context.Context
	Cancel  context.CancelFunc
	// contains filtered or unexported fields
}

func (*Service) Start

func (sv *Service) Start(s kservice.Service) error

func (*Service) Stop

func (sv *Service) Stop(_ kservice.Service) error

type Settings

type Settings struct{}

func (*Settings) Startup

func (s *Settings) Startup() error

type SoftMod

type SoftMod struct {
	slog.Logger
}

func (*SoftMod) Apply

func (sm *SoftMod) Apply(data []byte) error

type UDPBridge

type UDPBridge struct {
	slog.Logger
	Context context.Context
	Nats    *Nats
	// contains filtered or unexported fields
}

UDPBridge bridges factorio udp_send and udp_rec traffic to and from NATS

func (*UDPBridge) Shutdown

func (u *UDPBridge) Shutdown() error

func (*UDPBridge) Startup

func (u *UDPBridge) Startup() error

type WebServer

type WebServer struct {
	slog.Logger
	// contains filtered or unexported fields
}

func (*WebServer) ServeHTTP

func (w *WebServer) ServeHTTP(writer http.ResponseWriter, request *http.Request)

func (*WebServer) Shutdown

func (w *WebServer) Shutdown() error

func (*WebServer) Startup

func (w *WebServer) Startup() error