service

Documentation

Index

• func Run(app Service)
• func Since() time.Duration
• type BasicService
  • func NewBasicService(self Service, cfg config.Configurator) *BasicService
  • func (app *BasicService) AddModule(mod module.Module) module.Module
  • func (app *BasicService) Busy() bool
  • func (app *BasicService) Discovery() discovery.Discovery
  • func (app *BasicService) ID() int64
  • func (app *BasicService) Init() error
  • func (app *BasicService) MQ() mq.Conn
  • func (app *BasicService) Name() string
  • func (app *BasicService) SetState(state State) error
  • func (app *BasicService) Shutdown() error
  • func (app *BasicService) Start() error
  • func (app *BasicService) State() State
  • func (app *BasicService) UUID() string
  • func (app *BasicService) Update(now time.Time, dt time.Duration)
• type ConfigRewriter
• type DiscoveryContent
• type Meta
• type Service
• type State
  • func (state State) String() string

Functions

func Run

func Run(app Service)

Run runs the service

func Since

func Since() time.Duration

Since returns duration since started time

Types

type BasicService

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

BasicService implements Service

func NewBasicService

func NewBasicService(self Service, cfg config.Configurator) *BasicService

NewBasicService creates a BasicService

func (*BasicService) AddModule

func (app *BasicService) AddModule(mod module.Module) module.Module

AddModule adds a module to service

func (*BasicService) Busy

func (app *BasicService) Busy() bool

Busy implements Service Busy method

func (*BasicService) Discovery

func (app *BasicService) Discovery() discovery.Discovery

Discovery returns the discovery engine

func (*BasicService) ID

func (app *BasicService) ID() int64

ID implements Service ID method

func (*BasicService) Init

func (app *BasicService) Init() error

Init implements Service Init method

func (*BasicService) MQ

func (app *BasicService) MQ() mq.Conn

MQ returns the mq engine

func (*BasicService) Name

func (app *BasicService) Name() string

Name implements Service Name method

func (*BasicService) SetState

func (app *BasicService) SetState(state State) error

SetState implements Service SetState method

func (*BasicService) Shutdown

func (app *BasicService) Shutdown() error

Shutdown implements Service Shutdown method

func (*BasicService) Start

func (app *BasicService) Start() error

Start implements Service Start method

func (*BasicService) State

func (app *BasicService) State() State

State returns state of service

func (*BasicService) UUID

func (app *BasicService) UUID() string

UUID implements service UUID method

func (*BasicService) Update

func (app *BasicService) Update(now time.Time, dt time.Duration)

Update updates per frame

type ConfigRewriter

type ConfigRewriter interface {
	RewriteConfig(unsafe.Pointer)
}

ConfigRewriter rewrites Config

type DiscoveryContent

type DiscoveryContent struct {
	Config any `json:"config"` // config of service
	State  struct {
		Updated int64  `json:"updated"`
		PID     int    `json:"pid"`   // process id
		State   State  `json:"state"` // run state
		UUID    string `json:"uuid"`  // instance uuid
	} `json:"state"` // runtime state of service
}

DiscoveryContent is the content for registering

type Meta

type Meta interface {
	// ID returns id of service
	ID() int64
	// Name of service
	Name() string
	// Global unique instance id of service
	UUID() string
	// Busy reports whether the service is busy
	Busy() bool
	// State returns state of service
	State() State
}

Meta represents metadata of service

type Service

type Service interface {
	Meta

	// SetState sets state of service
	SetState(state State) error
	// Init initializes the service
	Init() error
	// Start starts the service
	Start() error
	// Shutdown shutdowns the service
	Shutdown() error
}

Service represents a process

type State

type State int

State represents service state

const (
	Closed   State = iota // Closed service
	Running               // Running service
	Stopping              // Stopping service
)

func (State) String

func (state State) String() string