server

Jul 4, 2025

Changes in this version

+ func AdaptCodec[T any](codec Codec[T], o Options) transport.Codec[core.Result, core.Cmd[T]]

type SetOption

+ func WithCore(ops ...csrv.SetOption) SetOption

type TransportFactory

+ func NewTransportFactory[T any](codec transport.Codec[core.Result, core.Cmd[T]], ops ...transport.SetOption) *TransportFactory[T]

Mar 25, 2025

Changes in this version

+ var ServerInfo = []byte("default")

+ func Apply(ops []SetOption, o *Options)

type Invoker

+ func NewInvoker[T any](receiver T) Invoker[T]

+ type Options struct

+ Base []bser.SetOption

+ Delegate []dser.SetOption

+ Handler []handler.SetOption

+ Info delegate.ServerInfo

+ Transport []tcom.SetOption

+ type SetOption func(o *Options)

+ func WithBase(ops ...bser.SetOption) SetOption

+ func WithDelegate(ops ...dser.SetOption) SetOption

+ func WithHandler(ops ...handler.SetOption) SetOption

+ func WithServerInfo(info delegate.ServerInfo) SetOption

+ func WithTransport(ops ...tcom.SetOption) SetOption

type TransportFactory

+ Ops []tcom.SetOption

Jan 27, 2025

Changes in this version

+ var DefaultServerInfo = []byte("default")

+ func Default[T any](codec Codec[T], receiver T) *bser.Server

Dec 15, 2024

Changes in this version

+ type Invoker struct

+ func (i Invoker[T]) Invoke(ctx context.Context, at time.Time, seq base.Seq, cmd base.Cmd[T], ...) error

Dec 5, 2024

Changes in this version

+ const DefWorkersCount

+ var DefConf = Conf

+ var DefServerInfo = []byte("default")

+ func NewDef[T any](codec Codec[T], receiver T) *base_server.Server

+ func NewWith(conf base_server.Conf, delegate base.ServerDelegate) *base_server.Server

+ func New[T any](info delegate.ServerInfo, settings delegate.ServerSettings, conf Conf, ...) *base_server.Server

+ type Codec interface

+ Decode func(r transport.Reader) (cmd base.Cmd[T], err error)

+ Encode func(result base.Result, w transport.Writer) (err error)

+ type Conf struct

+ Base base_server.Conf

+ Delegate delegate_server.Conf

+ Handler handler.Conf

+ Transport transport_common.Conf

+ type DefInvoker struct

+ func (i DefInvoker[T]) Invoke(ctx context.Context, at time.Time, seq base.Seq, cmd base.Cmd[T], ...) error

+ type TransportFactory struct

+ Codec transport.Codec[base.Result, base.Cmd[T]]

+ Conf transport_common.Conf

+ func (f TransportFactory[T]) New(conn net.Conn) delegate.ServerTransport[T]