elio

package module

Go to main page

Versions in this module

v0

v0.2.5

Sep 8, 2022

v0.2.4

Sep 7, 2022

v0.2.3

Sep 1, 2022

v0.2.2

Sep 1, 2022

v0.2.1

Aug 31, 2022

v0.2.0

Aug 29, 2022

v0.1.7

Sep 1, 2021

v0.1.6

Sep 1, 2021

Changes in this version

+ type MqttClient struct

+ func NewMqttClient(broker string, onConnect mqtt.OnConnectHandler) (m *MqttClient)

+ func (m *MqttClient) Close()

+ func (m *MqttClient) Connect() (err error)

+ func (m *MqttClient) IsConnected() bool

+ func (m *MqttClient) Publish(topic string, retained bool, payload []byte) (err error)

+ func (m *MqttClient) PublishNoWait(topic string, retained bool, payload []byte)

+ func (m *MqttClient) SafeClose()

+ func (m *MqttClient) String() string

+ func (m *MqttClient) Subscribe(topic string, callback mqtt.MessageHandler) (err error)

+ func (m *MqttClient) SubscribeMulti(topics map[string]byte, callback mqtt.MessageHandler) (err error)

+ func (m *MqttClient) SubscribeMultiNoWait(topics map[string]byte, callback mqtt.MessageHandler)

+ func (m *MqttClient) SubscribeNoWait(topic string, callback mqtt.MessageHandler)

+ func (m *MqttClient) Unsubscribe(topics ...string) (err error)

+ func (m *MqttClient) UnsubscribeNoWait(topics ...string)

v0.1.5

Jul 30, 2021

Changes in this version

type App

+ func (a *App) Config() *Config

v0.1.3

Jul 21, 2021

v0.1.2

Jul 21, 2021

Changes in this version

type Io

+ Config ConfigIo

+ Host *IoHost

+ InAddr atomic.String

+ InCount atomic.Int32

+ Listener *Listener

+ Service Service

+ func NewIo(h *IoHost, c ConfigIo, s Service) *Io

+ func ProvideIo(h *IoHost, c ConfigIo, s Service) *Io

+ func (i *Io) GetIoModel() IoModel

+ func (i *Io) Init()

+ func (i *Io) SetIoModel(ioModel IoModel)

+ func (i *Io) String() string

+ func (i *Io) Terminate()

type IoHost

+ Ios []*Io

+ type IoModel interface

+ Close func(n *Session) error

+ CloseAll func()

+ End func()

+ GetIo func() *Io

+ Listen func(addr string) bool

+ PostWrite func(n *Session, out []byte) (sent int, err error)

+ Read func(n *Session, in []byte) (receipt int, err error)

+ Run func() bool

+ SetIo func(c *Io)

+ Shut func()

+ Shutdown func(n *Session, how int) error

+ Trigger func(job interface{}) error

+ Write func(n *Session, out []byte) (sent int, err error)

+ func GenIO(io string) IoModel

type Session

+ func (n *Session) GetIo() *Io

v0.1.1

Jul 19, 2021

v0.1.0

Jul 18, 2021

Changes in this version

+ const CaptureInterval

+ const CurlSuccess

+ const DefaultCapacity

+ const DefaultDefIOInCount

+ const DefaultInterval

+ const DefaultPollInCount

+ const DevLogger

+ const Duration5m

+ const ErrAlreadyLoginUser

+ const ErrFailToFindRoom

+ const ErrNotExistInRoom

+ const ErrNotLoggedon

+ const ExamLogger

+ const FlagAllout

+ const FlagNone

+ const FlagSafeTerminate

+ const FlagStop

+ const FlagTerminate

+ const FlagTerminateAfter5m

+ const InvalidDivIndex

+ const LogCode

+ const LogContext

+ const LogDump

+ const LogErrorCode

+ const LogGitHash

+ const LogHost

+ const LogIP

+ const LogMatchKey

+ const LogName

+ const LogObject

+ const LogPayload

+ const LogProject

+ const LogRecover

+ const LogRoom

+ const LogService

+ const LogSession

+ const LogStage

+ const LogState

+ const LogSuid

+ const LogUuid

+ const LogWalltime

+ const MetricAppIoInCountf

+ const MetricAppIoInSizef

+ const MetricAppIoOutCountf

+ const MetricAppIoOutSizef

+ const MetricAppSessionsf

+ const MetricPubAppStatesf

+ const MetricPubEchosf

+ const MetricSubAppStatesf

+ const MetricSubEchosf

+ const ProdLogger

+ const QueueCapacity

+ const ResponseCodeAlreadyInTheRoom

+ const ResponseCodeAlreadyLoggedOn

+ const ResponseCodeDuplicateLogin

+ const ResponseCodeFailToEnterRoom

+ const ResponseCodeFailToLogoff

+ const ResponseCodeFailToLogon

+ const ResponseCodeFailToReadyPvPGame

+ const ResponseCodeFailToReqPvPRandomMatching

+ const ResponseCodeHttpError

+ const ResponseCodeMarshalError

+ const ResponseCodeNotInTheRoom

+ const ResponseCodeNotLoggedIn

+ const ResponseCodeNotWaitingRoom

+ const ResponseCodeUnpackError

+ const ShutRd — linux/amd64, windows/amd64

+ const ShutRdWr — linux/amd64, windows/amd64

+ const ShutWr — linux/amd64, windows/amd64

+ const SigInt — linux/amd64, windows/amd64

+ const SigTerm — linux/amd64, windows/amd64

+ const StatsDAddress

+ const StatsDInterval

+ const Success

+ var GetByteBuffer = bytebufferpool.Get

+ var PutByteBuffer = func(b *ByteBuffer)

+ var UIDInvalid = UID(0)

+ func AppDebug() *zerolog.Event

+ func AppError() *zerolog.Event

+ func AppFatal() *zerolog.Event

+ func AppInfo() *zerolog.Event

+ func AppPanic() *zerolog.Event

+ func AppTrace() *zerolog.Event

+ func AppWarn() *zerolog.Event

+ func DebugEnabled() bool

+ func DeleteSession(n *Session)

+ func DumpDebug() *zerolog.Event

+ func DumpError() *zerolog.Event

+ func DumpFatal() *zerolog.Event

+ func DumpInfo() *zerolog.Event

+ func DumpPanic() *zerolog.Event

+ func DumpTrace() *zerolog.Event

+ func DumpWarn() *zerolog.Event

+ func ErrorEnabled() bool

+ func FatalEnabled() bool

+ func GetBaseAndConfig() (base string, config string)

+ func GetBasename(path string) string

+ func GetBasepath(path string) string

+ func GetFdFromConn(conn net.Conn) int

+ func GetFdFromLisener(listener net.Listener) int

+ func GetMaxInCount(io string) (c int) — linux/amd64, windows/amd64

+ func InfoEnabled() bool

+ func InitLog(level string, outs []string, json bool)

+ func LogDebug(name string) *zerolog.Event

+ func LogError(name string) *zerolog.Event

+ func LogFatal(name string) *zerolog.Event

+ func LogInfo(name string) *zerolog.Event

+ func LogPanic(name string) *zerolog.Event

+ func LogParams() *logParams

+ func LogTrace(name string) *zerolog.Event

+ func LogWarn(name string) *zerolog.Event

+ func NewIoDefault() *ioDefault

+ func NewIoPoll() *ioPoll — linux/amd64

+ func PacketDebug() *zerolog.Event

+ func PacketError() *zerolog.Event

+ func PacketFatal() *zerolog.Event

+ func PacketInfo() *zerolog.Event

+ func PacketPanic() *zerolog.Event

+ func PacketTrace() *zerolog.Event

+ func PacketWarn() *zerolog.Event

+ func PanicEnabled() bool

+ func PanicParse() (string, error)

+ func SetLimit() (err error) — linux/amd64, windows/amd64

+ func StackParse(in string) (out string, err error)

+ func StartUp()

+ func StopDown(exit func())

+ func T2PParse(in []byte) (out []string)

+ func T2pOnParse(in []byte) (lenParsed, lenDelimit int, ok bool)

+ func T2pParseCommand(in []byte) (out []byte)

+ func TraceEnabled() bool

+ func WarnEnabled() bool

+ func WithLevel(level zerolog.Level) *zerolog.Event

+ type Action int

+ const Close

+ const CloseAll

+ const Listen

+ const None

+ const SafeTermiate

+ const Shut

+ const Termiate

+ const TermiateAfter5m

+ type Alarm interface

+ Check func(t time.Time, d time.Duration) bool

+ Reset func()

+ Ring func(name string, t time.Time, c *Clock) bool

+ type App struct

+ func Elio() *App

+ func NewApp() *App

+ func (a *App) End()

+ func (a *App) MetricCounter(name string) metrics.Counter

+ func (a *App) MetricGauge(name string) metrics.Gauge

+ func (a *App) MetricMeter(name string) metrics.Meter

+ func (a *App) Metrics() *AppMetrics

+ func (a *App) Register(s Service)

+ func (a *App) Run()

+ func (a *App) String() string

+ func (a *App) Wait()

+ type AppMetrics struct

+ Registry metrics.Registry

+ func (m *AppMetrics) GetOrRegisterCounter(name string) metrics.Counter

+ func (m *AppMetrics) GetOrRegisterEwma(name string) metrics.EWMA

+ func (m *AppMetrics) GetOrRegisterGauge(name string) metrics.Gauge

+ func (m *AppMetrics) GetOrRegisterGaugeFloat64(name string) metrics.GaugeFloat64

+ func (m *AppMetrics) GetOrRegisterHistogram(name string, s metrics.Sample) metrics.Histogram

+ func (m *AppMetrics) GetOrRegisterMeter(name string) metrics.Meter

+ func (m *AppMetrics) GetOrRegisterTimer(name string) metrics.Timer

+ func (m *AppMetrics) Init(inMetric int)

+ func (m *AppMetrics) String() string

+ type Buffer struct

+ func (b *Buffer) Begin(pos int) []byte

+ func (b *Buffer) Bytes() []byte

+ func (b *Buffer) Clear(pos int)

+ func (b *Buffer) Get(begin, end int) []byte

+ func (b *Buffer) GetFrom(begin int) []byte

+ func (b *Buffer) GetTo(end int) []byte

+ func (b *Buffer) Len() int

+ func (b *Buffer) Put(data []byte) ([]byte, int)

+ type ByteBuffer = bytebufferpool.ByteBuffer

+ type Clock struct

+ func NewClock() *Clock

+ func (c *Clock) Count() int

+ func (c *Clock) Register(name string, alarm Alarm) bool

+ func (c *Clock) RegisterWithTime(name string, alarm Alarm, t time.Time) bool

+ func (c *Clock) Reset(name string) bool

+ func (c *Clock) Unregister(name string) bool

+ func (c *Clock) UnregisterAll()

+ func (c *Clock) Update(t time.Time)

+ type Config struct

+ func NewConfig() (c *Config)

+ func (c *Config) Exists(path string) bool

+ func (c *Config) Get(key string) interface{}

+ func (c *Config) GetBool(key string) bool

+ func (c *Config) GetBoolOrDefault(key string, d bool) (bool, bool)

+ func (c *Config) GetFloat64(key string) float64

+ func (c *Config) GetFloat64OrDefault(key string, d float64) (float64, bool)

+ func (c *Config) GetInt(key string) int

+ func (c *Config) GetInt32(key string) int32

+ func (c *Config) GetInt32OrDefault(key string, d int32) (int32, bool)

+ func (c *Config) GetInt64(key string) int64

+ func (c *Config) GetInt64OrDefault(key string, d int64) (int64, bool)

+ func (c *Config) GetIntOrDefault(key string, d int) (int, bool)

+ func (c *Config) GetOrDefault(key string, d interface{}) (interface{}, bool)

+ func (c *Config) GetString(key string) string

+ func (c *Config) GetStringOrDefault(key string, d string) (string, bool)

+ func (c *Config) GetUint(key string) uint

+ func (c *Config) GetUint32(key string) uint32

+ func (c *Config) GetUint32OrDefault(key string, d uint32) (uint32, bool)

+ func (c *Config) GetUint64(key string) uint64

+ func (c *Config) GetUint64OrDefault(key string, d uint64) (uint64, bool)

+ func (c *Config) GetUintOrDefault(key string, d uint) (uint, bool)

+ func (c *Config) Load(path string) (err error)

+ func (c *Config) Set(key string, value interface{})

+ func (c *Config) SetBool(key string, value bool)

+ func (c *Config) String() string

+ type ConfigIo struct

+ InCount int

+ InModel string

+ InNoDelay bool

+ InRcvBuff int

+ InRecvTimeo int

+ InReusePort bool

+ InSndBuff int

+ InURL string

+ InWaitCount int

+ ReadBufferLen int

+ func ProvideConfigIo(name string, config *Config) ConfigIo

+ type Context struct

+ Session *Session

+ func NewContext(n *Session) *Context

+ func (c *Context) GetSession() *Session

+ func (c *Context) SetSession(s *Session)

+ func (c *Context) String() string

+ type Contexter interface

+ GetSession func() *Session

+ String func() string

+ type DivCallback func(t time.Time, v interface{}) error

+ type DivMap struct

+ func NewDivMap(l uint32) *DivMap

+ func (d *DivMap) Count() int

+ func (d *DivMap) Del(i uint32, k uint64) (v interface{}, ok bool)

+ func (d *DivMap) Get(i uint32) (s *UnsafeMap, err error)

+ func (d *DivMap) GetCounts() []int

+ func (d *DivMap) GetCurrent() (c uint32, s *UnsafeMap)

+ func (d *DivMap) GetLeast() (i uint32, s *UnsafeMap)

+ func (d *DivMap) IsValidIndex(i uint32) bool

+ func (d *DivMap) Set(k uint64, v interface{}) (uint32, *UnsafeMap)

+ type EnvApp struct

+ type Event interface

+ Handle func()

+ String func() string

+ type EventQueue struct

+ func NewEventQueue() *EventQueue

+ func (q *EventQueue) AppendAll(events ...interface{})

+ func (q *EventQueue) Convey() int

+ func (q *EventQueue) ConveySlice(s ...interface{})

+ func (q *EventQueue) Dispatching(t time.Time, l int) (int, int)

+ func (q *EventQueue) GetClock() *Clock

+ func (q *EventQueue) Inject(event interface{})

+ func (q *EventQueue) InjectToAwait(event interface{})

+ func (q *EventQueue) Paste(events []interface{})

+ type Fnv32 uint32

+ func (f *Fnv32) FromString(k string)

+ func (f *Fnv32) FromUint32(v uint32)

+ func (f *Fnv32) ToUint32() uint32

+ type Fnv64 uint64

+ func (f *Fnv64) FromPointer(p unsafe.Pointer)

+ func (f *Fnv64) FromString(k string)

+ func (f *Fnv64) FromUint64(v uint64)

+ func (f *Fnv64) ToUint64() uint64

+ type IOs int

+ const IoAuto

+ const IoDefault

+ const IoPoll

+ func GetCurrentIO(io string) IOs

+ func IOsFromString(m string) IOs

+ func (i IOs) String() string

+ type Io interface

+ Close func(n *Session) error

+ CloseAll func()

+ End func()

+ GetIoCore func() *IoCore

+ Listen func(addr string) bool

+ PostWrite func(n *Session, out []byte) (sent int, err error)

+ Read func(n *Session, in []byte) (receipt int, err error)

+ Run func() bool

+ SetIoCore func(c *IoCore)

+ Shut func()

+ Shutdown func(n *Session, how int) error

+ Trigger func(job interface{}) error

+ Write func(n *Session, out []byte) (sent int, err error)

+ func GenIO(io string) Io

+ type IoCore struct

+ Config ConfigIo

+ Host *IoHost

+ InAddr atomic.String

+ InCount atomic.Int32

+ Listener *Listener

+ Service Service

+ func NewIoCore(c ConfigIo, s Service) *IoCore

+ func ProvideIoCore(c ConfigIo, s Service) *IoCore

+ func (c *IoCore) End()

+ func (c *IoCore) GetIo() Io

+ func (c *IoCore) Init()

+ func (c *IoCore) Listen(addr *net.TCPAddr) (ok bool)

+ func (c *IoCore) Run(addr *net.TCPAddr) (ok bool)

+ func (c *IoCore) SetIo(io Io)

+ func (c *IoCore) Shut()

+ func (c *IoCore) Shutdown(n *Session, how int) error

+ func (c *IoCore) String() string

+ func (c *IoCore) Terminate()

+ type IoHost struct

+ DivChecked uint32

+ Divs *DivMap

+ EventQueue *EventQueue

+ IoCores []*IoCore

+ Rooms map[string]interface{}

+ Url *net.TCPAddr

+ Users map[UID]interface{}

+ Wg *sync.WaitGroup

+ func Host(config ConfigIo, service Service) (host *IoHost, err error)

+ func NewIoHost(divs int) (h *IoHost)

+ func (h *IoHost) AddRoom(key string, room interface{})

+ func (h *IoHost) CountUser() int

+ func (h *IoHost) DelDivision(d uint32, k uint64) (ok bool)

+ func (h *IoHost) DelRoom(key string) bool

+ func (h *IoHost) Dispatching(t time.Time, limit int) (int, int)

+ func (h *IoHost) End()

+ func (h *IoHost) EnterUser(uid UID, i interface{})

+ func (h *IoHost) FindOrEnterUser(uid UID, i interface{}) bool

+ func (h *IoHost) FindRoom(key string) interface{}

+ func (h *IoHost) FindUser(uid UID) (interface{}, bool)

+ func (h *IoHost) GetDivision() *DivMap

+ func (h *IoHost) GetEventQueue() *EventQueue

+ func (h *IoHost) LeaveUser(uid UID)

+ func (h *IoHost) ListUser() (out string)

+ func (h *IoHost) PostAllToQueue(l []interface{})

+ func (h *IoHost) PostToQueue(i interface{})

+ func (h *IoHost) Register(p unsafe.Pointer, v interface{}) (d uint32, ok bool)

+ func (h *IoHost) RunDivision(t time.Time, callback DivCallback)

+ func (h *IoHost) SetDivision(k uint64, v interface{}) (d uint32, ok bool)

+ func (h *IoHost) String() string

+ func (h *IoHost) Terminate(safe bool)

+ func (h *IoHost) Unregister(p unsafe.Pointer, d uint32) (ok bool)

+ type Job interface

+ String func() string

+ Work func() error

+ type Listener struct

+ func (l *Listener) Close()

+ func (l *Listener) Listen(network, address string) (err error)

+ func (l *Listener) String() string

+ func (l *Listener) ToFd() int

+ func (l *Listener) ToFile() (err error)

+ type OnFilter func(x interface{}) bool

+ type Poll struct — linux/amd64

+ func NewPoll() (p *Poll)

+ func (p *Poll) Begin() (err error)

+ func (p *Poll) ControlAdd(fd int, events uint32) error

+ func (p *Poll) ControlDel(fd int, events uint32) error

+ func (p *Poll) ControlMod(fd int, events uint32) error

+ func (p *Poll) End()

+ func (p *Poll) String() string

+ func (p *Poll) Trigger(job interface{}) error

+ func (p *Poll) Wait(events []unix.EpollEvent, timeout int) (waits int, err error)

+ type PollEvent struct — linux/amd64

+ Session *Session

+ type SafeSlice struct

+ func NewSafeSlice(c int) *SafeSlice

+ func (s *SafeSlice) Append(item interface{})

+ func (s *SafeSlice) AppendAll(items ...interface{})

+ func (s *SafeSlice) AppendSlice(ss *SafeSlice)

+ func (s *SafeSlice) Count() int

+ func (s *SafeSlice) Fetch() []interface{}

+ func (s *SafeSlice) FetchWithLimit(limit int) []interface{}

+ func (s *SafeSlice) FilterOut(f OnFilter) []interface{}

+ func (s *SafeSlice) Iterate() <-chan SafeSliceItem

+ func (s *SafeSlice) Paste(items []interface{})

+ func (s *SafeSlice) Prepend(item interface{})

+ func (s *SafeSlice) Shift() (front interface{}, count int)

+ type SafeSliceItem struct

+ Index int

+ Value interface{}

+ type Service interface

+ Name func() string

+ OnClose func(s *Session, err error)

+ OnError func(s *Session, err error)

+ OnExit func()

+ OnInit func(ctx context.Context, cancel context.CancelFunc) error

+ OnLoop func(host *IoHost, t time.Time, d time.Duration)

+ OnOpen func(s *Session) error

+ OnRead func(s *Session, in []byte) int

+ OnWrite func(s *Session, out []byte)

+ type Session struct

+ func NewSession(f int, c net.Conn, i *IoCore) *Session

+ func (n *Session) Close() error

+ func (n *Session) CountOutQueue() int

+ func (n *Session) DecRef() int32

+ func (n *Session) GetAddr() (addr string, ok bool)

+ func (n *Session) GetAddr() (string, bool)

+ func (n *Session) GetConn() net.Conn

+ func (n *Session) GetContext() interface{}

+ func (n *Session) GetFd() int

+ func (n *Session) GetIoCore() *IoCore

+ func (n *Session) GetKeepBuffer() *Buffer

+ func (n *Session) GetRemoteIP() string

+ func (n *Session) GetStats() interface{}

+ func (n *Session) IncRef() int32

+ func (n *Session) PostWrite(out []byte) (sent int, err error)

+ func (n *Session) SetContext(c interface{})

+ func (n *Session) SetStats(s interface{})

+ func (n *Session) Shutdown(how int) error

+ func (n *Session) String() string

+ func (n *Session) SubRef(ref int32) int32

+ func (n *Session) Write(out []byte) (sent int, err error)

+ type Sockaddr interface — windows/amd64

+ type Sockaddr unix.Sockaddr — linux/amd64

+ type UID int64

+ func (u *UID) FromInt(i int64)

+ func (u *UID) FromString(s string)

+ func (u *UID) ToInt() int64

+ func (u *UID) ToString() string

+ func (u UID) IsInvalid() bool

+ type UnsafeMap struct

+ Map map[uint64]interface{}

+ func NewUnsafeMap() *UnsafeMap

+ func (m *UnsafeMap) Count() int

+ func (m *UnsafeMap) Del(key uint64)

+ func (m *UnsafeMap) Fetch() map[uint64]interface{}

+ func (m *UnsafeMap) Get(key uint64) (interface{}, bool)

+ func (m *UnsafeMap) Init()

+ func (m *UnsafeMap) Iterate() <-chan UnsafeMapItem

+ func (m *UnsafeMap) MarshalJSON() ([]byte, error)

+ func (m *UnsafeMap) Set(key uint64, value interface{})

+ func (m *UnsafeMap) ToSlice() []UnsafeMapItem

+ func (m *UnsafeMap) Upsert(key uint64, new interface{}, callback cmap.UpsertCb) (value interface{})

+ type UnsafeMapItem struct

+ Key uint64

+ Value interface{}

+ type UnsafeSlice struct

+ func NewUnsafeSlice(c int) *UnsafeSlice

+ func (s *UnsafeSlice) Append(item interface{})

+ func (s *UnsafeSlice) AppendAll(items ...interface{})

+ func (s *UnsafeSlice) AppendSlice(ss *UnsafeSlice)

+ func (s *UnsafeSlice) Count() int

+ func (s *UnsafeSlice) Fetch() []interface{}

+ func (s *UnsafeSlice) FetchWithLimit(limit int) []interface{}

+ func (s *UnsafeSlice) FilterOut(f OnFilter) []interface{}

+ func (s *UnsafeSlice) Iterate() <-chan UnsafeSliceItem

+ func (s *UnsafeSlice) Paste(items []interface{})

+ func (s *UnsafeSlice) Prepend(item interface{})

+ func (s *UnsafeSlice) Shift() (front interface{}, count int)

+ type UnsafeSliceItem struct

+ Index int

+ Value interface{}

+ type WaitResult struct — linux/amd64

+ type WriteJob struct

+ func (j *WriteJob) String() string

+ func (j *WriteJob) Work() (err error)

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