node

package

Go to main page

Versions in this module

v2

v2.2.5

Feb 19, 2025

v2.2.4

Jan 21, 2025

Changes in this version

type Actor

+ func (a *Actor) AfterFunc(d time.Duration, f func()) *Timer

+ func (a *Actor) AfterInvoke(d time.Duration, f func()) *Timer

type ActorOption

+ func WithActorKind(kind string) ActorOption

+ func WithActorNonDispatch() ActorOption

type Context

+ AfterFunc func(d time.Duration, f func()) *Timer

+ AfterInvoke func(d time.Duration, f func()) *Timer

+ Invoke func(fn func())

+ NewMeshClient func(target string) (transport.Client, error)

type Option

+ func WithWeight(weight int) Option

type Proxy

+ func (p *Proxy) AfterFunc(d time.Duration, f func()) *Timer

+ func (p *Proxy) AfterInvoke(d time.Duration, f func()) *Timer

+ type Timer struct

+ func (t *Timer) Stop() (ok bool)

v2.2.3

Nov 20, 2024

Changes in this version

type ActorOption

+ func WithActorNonWait() ActorOption

type Node

+ func (n *Node) Close()

v2.2.2

Nov 14, 2024

v2.2.1

Nov 11, 2024

Changes in this version

type Actor

+ func (a *Actor) Push(uid int64, message *cluster.Message) error

type Context

+ Deliver func(args *cluster.DeliverArgs) error

v2.2.0

Oct 25, 2024

Changes in this version

+ type Actor struct

+ func (a *Actor) AddEventHandler(event cluster.Event, handler EventHandler)

+ func (a *Actor) AddRouteHandler(route int32, handler RouteHandler)

+ func (a *Actor) Deliver(uid int64, message *cluster.Message)

+ func (a *Actor) Destroy()

+ func (a *Actor) ID() string

+ func (a *Actor) Invoke(fn func())

+ func (a *Actor) Kind() string

+ func (a *Actor) Next(ctx Context)

+ func (a *Actor) PID() string

+ func (a *Actor) Proxy() *Proxy

+ func (a *Actor) Spawn(creator Creator, opts ...ActorOption) (*Actor, error)

+ type ActorOption func(o *actorOptions)

+ func WithActorArgs(args ...any) ActorOption

+ func WithActorID(id string) ActorOption

+ type BaseProcessor struct

+ func (b *BaseProcessor) Destroy()

+ func (b *BaseProcessor) Init()

+ func (b *BaseProcessor) Kind() string

+ func (b *BaseProcessor) Start()

type Context

+ Actor func(kind, id string) (*Actor, bool)

+ BindActor func(kind, id string) error

+ Cancel func()

+ Defer func(fn func(), bottom ...bool)

+ Kill func(kind, id string) bool

+ Kind func() Kind

+ Next func() error

+ Spawn func(creator Creator, opts ...ActorOption) (*Actor, error)

+ UnbindActor func(kind string)

+ type Creator func(actor *Actor, args ...any) Processor

+ type Engine struct

+ type Kind int

+ type Processor interface

+ Destroy func()

+ Init func()

+ Kind func() string

+ Start func()

type Proxy

+ func (p *Proxy) Actor(kind, id string) (*Actor, bool)

+ func (p *Proxy) AddServiceProvider(name string, desc interface{}, provider interface{})

+ func (p *Proxy) BindActor(uid int64, kind, id string) error

+ func (p *Proxy) HasGate(gid string) bool

+ func (p *Proxy) HasNode(nid string) bool

+ func (p *Proxy) Kill(kind, id string) bool

+ func (p *Proxy) PackBuffer(message any) ([]byte, error)

+ func (p *Proxy) PackMessage(message *cluster.Message) ([]byte, error)

+ func (p *Proxy) Spawn(creator Creator, opts ...ActorOption) (*Actor, error)

+ func (p *Proxy) UnbindActor(uid int64, kind string)

+ type Scheduler struct

v2.1.1

Aug 13, 2024

v2.1.0

Aug 5, 2024

Changes in this version

type Context

+ CID func() int64

+ Clone func() Context

+ Event func() cluster.Event

+ GID func() string

+ NID func() string

+ Parse func(v interface{}) error

+ Reply func(message *cluster.Message) error

+ Route func() int32

+ Seq func() int32

+ Task func(fn func(ctx Context))

+ UID func() int64

+ type HookHandler func(proxy *Proxy)

type Option

+ func WithAddr(addr string) Option

type Proxy

+ func (p *Proxy) AddEventHandler(event cluster.Event, handler EventHandler)

+ func (p *Proxy) AddHookListener(hook cluster.Hook, handler HookHandler)

+ func (p *Proxy) AddInternalRouteHandler(route int32, stateful bool, handler RouteHandler, ...)

+ func (p *Proxy) AddRouteHandler(route int32, stateful bool, handler RouteHandler, ...)

+ func (p *Proxy) GetID() string

+ func (p *Proxy) GetName() string

+ func (p *Proxy) GetState() cluster.State

+ func (p *Proxy) IsOnline(ctx context.Context, args *cluster.IsOnlineArgs) (bool, error)

+ func (p *Proxy) NewMeshClient(target string) (transport.Client, error)

+ func (p *Proxy) RouteGroup(groups ...func(group *RouterGroup)) *RouterGroup

+ func (p *Proxy) SetDefaultRouteHandler(handler RouteHandler)

+ func (p *Proxy) SetState(state cluster.State) error

+ func (p *Proxy) Trigger() *Trigger

+ type RouteOptions struct

+ Internal bool

+ Middlewares []MiddlewareHandler

+ Restricted bool

+ Stateful bool

type Router

+ func (r *Router) AddInternalRouteHandler(route int32, stateful bool, handler RouteHandler, ...)

type RouterGroup

+ func (g *RouterGroup) AddInternalRouteHandler(route int32, stateful bool, handler RouteHandler, ...) *RouterGroup

+ type SchedulingModel string

+ type Trigger struct

+ func (e *Trigger) AddEventHandler(event cluster.Event, handler EventHandler)

v2.0.0

Oct 20, 2023

Changes in this version

+ type BroadcastArgs = link.BroadcastArgs

+ type Context struct

+ Middleware *Middleware

+ Proxy *Proxy

+ Request *Request

+ func (c *Context) BindGate(uid int64) error

+ func (c *Context) BindNode() error

+ func (c *Context) Context() context.Context

+ func (c *Context) Disconnect(isForce ...bool) error

+ func (c *Context) GetIP() (string, error)

+ func (c *Context) Response(message interface{}) error

+ func (c *Context) UnbindGate() error

+ func (c *Context) UnbindNode() error

+ type DeliverArgs struct

+ Message *Message

+ NID string

+ UID int64

+ type DisconnectArgs = link.DisconnectArgs

+ type Event struct

+ CID int64

+ Event cluster.Event

+ GID string

+ Proxy *Proxy

+ UID int64

+ type EventHandler func(event *Event)

+ type Events struct

+ func (e *Events) AddEventHandler(event cluster.Event, handler EventHandler)

+ type GetIPArgs = link.GetIPArgs

+ type Message = link.Message

+ type Middleware struct

+ func (m *Middleware) Next(ctx *Context)

+ func (m *Middleware) Skip(ctx *Context, skip int)

+ type MiddlewareHandler func(ctx *Context)

+ type MulticastArgs = link.MulticastArgs

+ type Node struct

+ func NewNode(opts ...Option) *Node

+ func (n *Node) Destroy()

+ func (n *Node) Init()

+ func (n *Node) Name() string

+ func (n *Node) Proxy() *Proxy

+ func (n *Node) Start()

+ type Option func(o *options)

+ func WithCodec(codec encoding.Codec) Option

+ func WithContext(ctx context.Context) Option

+ func WithEncryptor(encryptor crypto.Encryptor) Option

+ func WithID(id string) Option

+ func WithLocator(locator locate.Locator) Option

+ func WithName(name string) Option

+ func WithRegistry(r registry.Registry) Option

+ func WithTimeout(timeout time.Duration) Option

+ func WithTransporter(transporter transport.Transporter) Option

+ type Proxy struct

+ func (p *Proxy) AskGate(ctx context.Context, uid int64, gid string) (string, bool, error)

+ func (p *Proxy) AskNode(ctx context.Context, uid int64, name, nid string) (string, bool, error)

+ func (p *Proxy) BindGate(ctx context.Context, uid int64, gid string, cid int64) error

+ func (p *Proxy) BindNode(ctx context.Context, uid int64, nameAndNID ...string) error

+ func (p *Proxy) Broadcast(ctx context.Context, args *BroadcastArgs) (int64, error)

+ func (p *Proxy) Deliver(ctx context.Context, args *DeliverArgs) error

+ func (p *Proxy) Disconnect(ctx context.Context, args *DisconnectArgs) error

+ func (p *Proxy) Events() *Events

+ func (p *Proxy) FetchGateList(ctx context.Context, states ...cluster.State) ([]*registry.ServiceInstance, error)

+ func (p *Proxy) FetchNodeList(ctx context.Context, states ...cluster.State) ([]*registry.ServiceInstance, error)

+ func (p *Proxy) GetIP(ctx context.Context, args *GetIPArgs) (string, error)

+ func (p *Proxy) GetNodeID() string

+ func (p *Proxy) GetNodeName() string

+ func (p *Proxy) GetNodeState() cluster.State

+ func (p *Proxy) Invoke(fn func())

+ func (p *Proxy) LocateGate(ctx context.Context, uid int64) (string, error)

+ func (p *Proxy) LocateNode(ctx context.Context, uid int64, name string) (string, error)

+ func (p *Proxy) Multicast(ctx context.Context, args *MulticastArgs) (int64, error)

+ func (p *Proxy) NewServiceClient(target string) (transport.ServiceClient, error)

+ func (p *Proxy) Push(ctx context.Context, args *PushArgs) error

+ func (p *Proxy) Response(ctx context.Context, req *Request, message interface{}) error

+ func (p *Proxy) Router() *Router

+ func (p *Proxy) SetNodeState(state cluster.State)

+ func (p *Proxy) Stat(ctx context.Context, kind session.Kind) (int64, error)

+ func (p *Proxy) UnbindGate(ctx context.Context, uid int64) error

+ func (p *Proxy) UnbindNode(ctx context.Context, uid int64, nameAndNID ...string) error

+ type PushArgs = link.PushArgs

+ type Request struct

+ CID int64

+ GID string

+ Message *Message

+ NID string

+ UID int64

+ func (r *Request) Parse(v interface{}) error

+ type RouteHandler func(ctx *Context)

+ type Router struct

+ func (r *Router) AddRouteHandler(route int32, stateful bool, handler RouteHandler, ...)

+ func (r *Router) CheckRouteStateful(route int32) (stateful bool, exist bool)

+ func (r *Router) Group(groups ...func(group *RouterGroup)) *RouterGroup

+ func (r *Router) HasDefaultRouteHandler() bool

+ func (r *Router) SetDefaultRouteHandler(handler RouteHandler)

+ type RouterGroup struct

+ func (g *RouterGroup) AddRouteHandler(route int32, stateful bool, handler RouteHandler, ...) *RouterGroup

+ func (g *RouterGroup) Middleware(middlewares ...MiddlewareHandler) *RouterGroup

Other modules containing this package

github.com/dobyte/due

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