Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  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

leikari

package module

Go to main page

Versions in this module

v0

v0.1.7

Dec 23, 2021

v0.1.6

Dec 23, 2021

v0.1.5

Dec 20, 2021

v0.1.4

Dec 19, 2021

v0.1.3

Dec 19, 2021

v0.1.2

Dec 10, 2021

v0.1.1

Dec 5, 2021

v0.1.0

Nov 21, 2021

Changes in this version

+ func GenerateName() string

type Actor

+ Name string

+ func (a Actor) ActorName() string

+ type HandlerSettings struct

+ Async bool

+ Log Logger

+ MessageQueue int

+ Name string

+ WorkerPool int

type Logger

+ func NewSysLogger(logger log.Logger) Logger

+ func SysLogger() Logger

+ type NamedActor interface

+ ActorName func() string

type Option

+ func Log(log Logger) Option

+ func Name(name string) Option

+ type Pusher interface

+ Push func(Message) error

type Ref

+ func NewRef(pusher Pusher) Ref

v0.0.1

Dec 31, 2021

Changes in this version

+ var ActorContextType = reflect.TypeOf((*ActorContext)(nil)).Elem()

+ var ErrUnknownCommand = Errorln("", "unknown command")

+ var ErrorType = reflect.TypeOf((*error)(nil)).Elem()

+ var MessageType = reflect.TypeOf((*Message)(nil)).Elem()

+ func CheckImplements(atype reflect.Type, btype reflect.Type) bool

+ func CheckImplementsOneOf(atype reflect.Type, types ...reflect.Type) bool

+ func CheckIn(ftype reflect.Type, params ...reflect.Type) bool

+ func CheckOut(ftype reflect.Type, params ...reflect.Type) bool

+ func CompareType(atype reflect.Type, btype reflect.Type) bool

+ func IsActorContextType(gtype reflect.Type) bool

+ func IsErrorType(gtype reflect.Type) bool

+ func IsMessageType(gtype reflect.Type) bool

+ func MethodByName(v interface{}, name string) (reflect.Value, bool)

+ func PostStopFunc(v interface{}) func(ActorContext) error

+ func PostStopMethod(v interface{}) (reflect.Value, bool)

+ func PreStartFunc(v interface{}) func(ActorContext) error

+ func PreStartMethod(v interface{}) (reflect.Value, bool)

+ func PtrValue(gvalue reflect.Value) reflect.Value

+ func ReceiveFunc(v interface{}) func(ActorContext, Message)

+ func ReceiveMethod(v interface{}) (reflect.Value, bool)

+ type Actor struct

+ Async bool

+ OnReceive func(ActorContext, Message)

+ OnStart func(ActorContext) error

+ OnStop func(ActorContext) error

+ func NewActor(v interface{}) Actor

+ func (a Actor) AsyncActor() bool

+ func (a Actor) PostStop(ctx ActorContext) error

+ func (a Actor) PreStart(ctx ActorContext) error

+ func (a Actor) Receive(ctx ActorContext, msg Message)

+ type ActorContext interface

+ Add func(string, interface{}) error

+ Done func() <-chan struct{}

+ Get func(string) (interface{}, bool)

+ Handler func() ActorHandler

+ Log func() Logger

+ Name func() string

+ Replace func(string, interface{}) error

+ Self func() Ref

+ Set func(string, interface{})

+ Settings func() Settings

+ System func() System

+ type ActorExecutor interface

+ At func(string) (Ref, bool)

+ Execute func(Receiver, string, ...Option) (Ref, error)

+ type ActorHandler interface

+ Cache func() Cache

+ Child func(string) (ActorHandler, bool)

+ Children func() []ActorHandler

+ Close func()

+ CreateRef func() Ref

+ Log func() Logger

+ Name func() string

+ Parent func() (ActorHandler, bool)

+ Path func() string

+ Root func() ActorHandler

+ Settings func() Settings

+ System func() System

+ type ActorHandlerExecutor interface

+ At func(string) (ActorHandler, bool)

+ ExecuteHandler func(Receiver, string, ...Option) (ActorHandler, error)

+ type ActorSettings interface

+ Async func() bool

+ MessageQueueSize func() int

+ WorkerPoolSize func() int

+ type AsyncActor interface

+ AsyncActor func() bool

+ type Cache interface

+ Add func(key string, value interface{}) error

+ Get func(key string) (interface{}, bool)

+ Replace func(key string, value interface{}) error

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

+ func NewCache() Cache

+ type DoneEvent struct

+ func Done() DoneEvent

+ type Error struct

+ Code string

+ Description string

+ Message string

+ Status int

+ func Errorf(code string, format string, v ...interface{}) *Error

+ func Errorln(code string, v ...interface{}) *Error

+ func MapError(code string, err error) *Error

+ func New(code string, msg string) *Error

+ func NewOf(code string, err error) *Error

+ func (e *Error) Error() string

+ func (e *Error) StatusCode() int

+ func (e *Error) String() string

+ func (e *Error) WithDescription(desc string) *Error

+ func (e *Error) WithStatusCode(status int) *Error

+ type LogLevel int

+ const LEVEL_DEBUG

+ const LEVEL_ERROR

+ const LEVEL_FATAL

+ const LEVEL_INFO

+ const LEVEL_PANIC

+ const LEVEL_WARN

+ type Logger interface

+ Debug func(...interface{})

+ Debugf func(string, ...interface{})

+ Error func(...interface{})

+ Errorf func(string, ...interface{})

+ Fatal func(...interface{})

+ Fatalf func(string, ...interface{})

+ ForName func(string) Logger

+ Info func(...interface{})

+ Infof func(string, ...interface{})

+ Panic func(...interface{})

+ Panicf func(string, ...interface{})

+ Warn func(...interface{})

+ Warnf func(string, ...interface{})

+ func Empty() Logger

+ type Message interface

+ Reply func(interface{})

+ Value func() interface{}

+ func Request(reply chan<- interface{}, v interface{}) Message

+ func Send(v interface{}) Message

+ type Option struct

+ Name string

+ Value interface{}

+ func Async() Option

+ func MessageQueue(size int) Option

+ func NoSignature() Option

+ func WorkerPool(size int) Option

+ func (opt Option) Bool() (bool, bool)

+ func (opt Option) Duration() (time.Duration, bool)

+ func (opt Option) Float32() (float32, bool)

+ func (opt Option) Float64() (float64, bool)

+ func (opt Option) Int() (int, bool)

+ func (opt Option) Int16() (int16, bool)

+ func (opt Option) Int32() (int32, bool)

+ func (opt Option) Int64() (int64, bool)

+ func (opt Option) Int8() (int8, bool)

+ func (opt Option) String() string

+ func (opt Option) Time() (time.Time, bool)

+ func (opt Option) Uint() (uint, bool)

+ func (opt Option) Uint16() (uint16, bool)

+ func (opt Option) Uint32() (uint32, bool)

+ func (opt Option) Uint64() (uint64, bool)

+ func (opt Option) Uint8() (uint8, bool)

+ type PubSub interface

+ Publish func(interface{})

+ Subscribe func(Ref, func(interface{}) bool)

+ Unsubscribe func(Ref)

+ type Publish struct

+ Content interface{}

+ type Receiver interface

+ Receive func(ActorContext, Message)

+ type ReceiverFunc func(ActorContext, Message)

+ func (f ReceiverFunc) Receive(ctx ActorContext, msg Message)

+ type Ref interface

+ Request func(interface{}) (interface{}, error)

+ RequestChan func(interface{}) <-chan interface{}

+ RequestContext func(context.Context, interface{}) (interface{}, error)

+ Send func(interface{}) error

+ type ServiceExecutor interface

+ ExecuteService func(Receiver, string, ...Option) (ActorHandler, error)

+ type Settings interface

+ AllSettings func() map[string]interface{}

+ Get func(string) interface{}

+ GetBool func(string) bool

+ GetDefault func(string, interface{}) interface{}

+ GetDefaultBool func(string, bool) bool

+ GetDefaultDuration func(string, time.Duration) time.Duration

+ GetDefaultFloat64 func(string, float64) float64

+ GetDefaultInt func(string, int) int

+ GetDefaultIntSlice func(string, ...int) []int

+ GetDefaultString func(string, string) string

+ GetDefaultStringSlice func(string, ...string) []string

+ GetDefaultTime func(string, time.Time) time.Time

+ GetDuration func(string) time.Duration

+ GetFloat64 func(string) float64

+ GetInt func(string) int

+ GetIntSlice func(string) []int

+ GetString func(string) string

+ GetStringSlice func(string) []string

+ GetSub func(string, ...Option) Settings

+ GetTime func(string) time.Time

+ IsSet func(string) bool

+ Set func(string, interface{})

+ type Startable interface

+ PreStart func(ActorContext) error

+ type Stopable interface

+ PostStop func(ActorContext) error

+ type Subscribe struct

+ Filter func(interface{}) bool

+ Ref Ref

+ type System interface

+ Log func() Logger

+ Run func()

+ Settings func() SystemSettings

+ Terminate func()

+ Terminated func() <-chan int

+ Ticker func(time.Duration, func(time.Time)) *time.Ticker

+ Timer func(time.Duration, func(time.Time)) *time.Timer

+ func NewSystem(opts ...Option) System

+ type SystemSettings interface

+ GetActorSettings func(string, ...Option) ActorSettings

+ NoSignature func() bool

+ type Unsubscribe struct

+ Ref Ref