Artifex

May 2, 2024

Changes in this version

type Adapter

+ func (adp *Adapter) OnDisconnect(terminates ...func(adp IAdapter))

+ func (adp *Adapter) RawSend(messages ...*Message) error

type IAdapter

+ OnDisconnect func(terminates ...func(adp IAdapter))

type Lifecycle

+ func (life *Lifecycle) OnConnect(inits ...func(adp IAdapter) error) *Lifecycle

+ func (life *Lifecycle) OnDisconnect(terminates ...func(adp IAdapter)) *Lifecycle

type Producer

+ RawSend func(messages ...*Message) error

May 1, 2024

Changes in this version

type HandleFunc

+ func UseAdHocFunc(AdHoc func(message *Message, dep any) error) HandleFunc

type Message

+ func (msg *Message) Copy() *Message

type Middleware

+ func UseAsync() Middleware

+ type SafeConcurrencyKind int

+ const SafeConcurrency_Copy

+ const SafeConcurrency_Mutex

+ const SafeConcurrency_Skip

Apr 30, 2024

Changes in this version

+ func AnyToString(v any) string

+ func CtxWithLogger(ctx context.Context, dep any, v Logger) context.Context

+ func CtxWithPingPong(ctx context.Context, v WaitPingPong) context.Context

+ func PutMessage(message *Message)

type HandleFunc

+ func Link(handler HandleFunc, middlewares ...Middleware) HandleFunc

+ func UsePrintDetail() HandleFunc

+ func (h HandleFunc) Link(middlewares ...Middleware) HandleFunc

type Logger

+ func CtxGetLogger(ctx context.Context, dep any) Logger

type Message

+ Ctx context.Context

+ Mutex sync.Mutex

+ func GetMessage() *Message

+ func (msg *Message) UpdateContext(updates ...func(ctx context.Context) context.Context) context.Context

type Middleware

+ func UseExclude(subjects []string) Middleware

+ func UseHowMuchTime() Middleware

+ func UseInclude(subjects []string) Middleware

+ func UsePrintResult() Middleware

+ func UseRecover() Middleware

+ func (mw Middleware) Link(handler HandleFunc) HandleFunc

type Mux

+ func (mux *Mux) EnableMessagePool() *Mux

+ type WaitPingPong chan struct

+ func CtxGetPingPong(ctx context.Context) WaitPingPong

+ func NewWaitPingPong() WaitPingPong

+ func (wait WaitPingPong) Ack()

Apr 27, 2024

Changes in this version

+ func UseLogger(withMsgId, attachToMessage bool) func(message *Message, dep any) Logger

+ func UseSkipMessage() func(message *Message, dep any) error

type Adapter

+ func (adp *Adapter) RawInfra() any

type AdapterOption

+ func NewAdapterOption() (opt *AdapterOption)

+ func (opt *AdapterOption) RawInfra(infra any) *AdapterOption

+ type Consumer interface

+ Listen func() (err error)

type IAdapter

+ RawInfra func() any

+ type Message struct

+ Body any

+ Bytes []byte

+ Logger Logger

+ Metadata maputil.Data

+ RawInfra any

+ RouteParam maputil.Data

+ Subject string

+ func NewMessage() *Message

+ func NewMessageWithBody(subject string, body any) *Message

+ func NewMessageWithBytes(subject string, bBody []byte) *Message

+ func NewNumberSubjectMessageWithBody(number int, delimiter string, body any) *Message

+ func NewNumberSubjectMessageWithBytes(number int, delimiter string, bBody []byte) *Message

+ func (msg *Message) Context() context.Context

+ func (msg *Message) MsgId() string

+ func (msg *Message) SetContext(ctx context.Context)

+ func (msg *Message) SetMsgId(msgId string)

+ func (msg *Message) SwapContext(swaps ...func(ctx1 context.Context) (ctx2 context.Context)) context.Context

type Middleware

+ func UseExcludedSubject(subjects []string) Middleware

+ func UseRetry(retryMaxSecond int) Middleware

+ type Producer interface

+ Send func(messages ...*Message) error

+ type Prosumer interface

+ Listen func() (err error)

+ Send func(messages ...*Message) error

+ type Use struct

+ Logger func(message *Message, dep any) Logger

+ func (use Use) PrintDetail(newBody func(subject string) (body any, found bool), ...) HandleFunc

+ func (use Use) PrintError() func(message *Message, dep any, err error) error

+ func (use Use) Recover() Middleware

Apr 25, 2024

Changes in this version

type Mux

+ func (mux *Mux[Message]) DefaultHandler(h HandleFunc[Message], mw ...Middleware[Message]) *Mux[Message]

+ func (mux *Mux[Message]) ErrorHandler(handleError Middleware[Message]) *Mux[Message]

+ func (mux *Mux[Message]) MessagePool(pool *sync.Pool, reset func(*Message)) *Mux[Message]

+ func (mux *Mux[Message]) NotFoundHandler(h HandleFunc[Message]) *Mux[Message]

type Shutdown

+ func (s *Shutdown) Notify(cause error)

+ func (s *Shutdown) Serve(ctx context.Context)

+ func (s *Shutdown) StopService(name string, action func() error) *Shutdown

+ func (s *Shutdown) WaitFinish() chan struct{}

Apr 24, 2024

Changes in this version

type AdapterOption

+ func (opt *AdapterOption[Ingress, Egress]) EgressMux(mux *Mux[Egress]) *AdapterOption[Ingress, Egress]

+ func (opt *AdapterOption[Ingress, Egress]) IngressMux(mux *Mux[Ingress]) *AdapterOption[Ingress, Egress]

type HandleFunc

+ func HandlePrintDetail[Message any](getSubject NewSubjectFunc[Message], newBody func(subject string) (any, bool), ...) HandleFunc[Message]

+ func HandleSkip[Message any]() HandleFunc[Message]

type Hub

+ func (hub *Hub[T]) IsShutdown() bool

+ func (hub *Hub[T]) WaitShutdown() chan struct{}

type MW

+ func (mw MW[Message]) ExcludedSubject(excludeSubjects []string, getSubject NewSubjectFunc[Message]) Middleware[Message]

+ func (mw MW[Message]) Retry(retryMaxSecond int) Middleware[Message]

type Middleware

+ func (mw Middleware[Message]) HandleFunc() HandleFunc[Message]

Apr 22, 2024

Changes in this version

type Hub

+ func (hub *Hub[T]) Shutdown()

Apr 21, 2024

Changes in this version

type Adapter

+ func (adp *Adapter[Ingress, Egress]) Log() Logger

+ func (adp *Adapter[Ingress, Egress]) SetLog(logger Logger)

type AdapterOption

+ func (opt *AdapterOption[Ingress, Egress]) Logger(logger Logger) *AdapterOption[Ingress, Egress]

type IAdapter

+ Log func() Logger

+ SetLog func(Logger)

Apr 21, 2024

Changes in this version

type AdapterHub

+ Join func(adapterId string, adp IAdapter) error

+ RemoveOne func(filter func(IAdapter) bool)

type AdapterOption

+ func (opt *AdapterOption[Ingress, Egress]) AdapterHub(hub AdapterHub) *AdapterOption[Ingress, Egress]

Apr 21, 2024

Changes in this version

type AdapterOption

+ func (opt *AdapterOption[Ingress, Egress]) DecorateAdapter(wrap func(IAdapter) IAdapter) *AdapterOption[Ingress, Egress]

Apr 21, 2024

Changes in this version

+ func HasAppData[T any](adp IAdapter, lock bool, appKey string, filter func(data T) bool) bool

Apr 21, 2024

Changes in this version

+ func CreateAppData[T any](adp IAdapter, appKey string, data T)

+ func DeleteAppData[T any](adp IAdapter, appKey string)

+ func GetAppData[T any](adp IAdapter, lock bool, appKey string, filter func(data T) bool) (data T, found bool)

+ func UpdateAppData[T any](adp IAdapter, appKey string, update func(data T))

Apr 20, 2024

Changes in this version

type AdapterOption

+ func (opt *AdapterOption[Ingress, Egress]) Build() (*Adapter[Ingress, Egress], error)

Apr 20, 2024

Changes in this version

type Adapter

+ func (adp *Adapter[Ingress, Egress]) QueryRLock(query func(id string, appData maputil.Data))

type IAdapter

+ QueryRLock func(query func(id string, appData maputil.Data))

Apr 19, 2024

Changes in this version

type Logger

+ func NewWriterLogger(w io.Writer, printPath bool, level LogLevel) Logger

Apr 19, 2024

Changes in this version

type Logger

+ LogLevel func() LogLevel

Apr 18, 2024

Changes in this version

+ func GenerateUlid() string

Apr 18, 2024

Changes in this version

type Mux

+ func (mux *Mux[Message]) PrintEndpoints(print func(subject, fn string))

Apr 17, 2024

Changes in this version

type Adapter

+ func (adp *Adapter[rMessage, sMessage]) IsStopped() bool

type IAdapter

+ IsStopped func() bool

Apr 16, 2024

Changes in this version

type Adapter

+ func (adp *Adapter[rMessage, sMessage]) OnStop(terminates ...func(adp IAdapter))

type IAdapter

+ OnStop func(terminates ...func(adp IAdapter))

type Lifecycle

+ func (life *Lifecycle) OnOpen(inits ...func(adp IAdapter) error) *Lifecycle

+ func (life *Lifecycle) OnStop(terminates ...func(adp IAdapter)) *Lifecycle

Apr 9, 2024

Changes in this version

type Mux

+ func DefaultMux[Message any](getSubject NewSubjectFunc[Message]) *Mux[Message]

Apr 9, 2024

Changes in this version

type MW

+ func (mw MW[Message]) PrintError(getSubject NewSubjectFunc[Message]) Middleware[Message]

Apr 8, 2024

Changes in this version

type AdapterOption

+ func (opt *AdapterOption[rMessage, sMessage]) BuildPubSub() (*Adapter[rMessage, sMessage], error)

+ func (opt *AdapterOption[rMessage, sMessage]) BuildPublisher() (*Adapter[rMessage, sMessage], error)

+ func (opt *AdapterOption[rMessage, sMessage]) BuildSubscriber() (*Adapter[rMessage, sMessage], error)

Apr 7, 2024

Changes in this version

+ type MW struct

+ Logger Logger

+ func (mw MW[Message]) HandleError(getSubject NewSubjectFunc[Message]) Middleware[Message]

+ func (mw MW[Message]) Recover() Middleware[Message]

type Mux

+ func (mux *Mux[Message]) SetHandleError(handleError Middleware[Message]) *Mux[Message]

Apr 7, 2024

Changes in this version

+ var ErrNotFoundSubject = NewCustomError(2101, "not found subject mux")

type Middleware

+ func MW_Error[Message any](getSubject NewSubjectFunc[Message]) Middleware[Message]

+ func MW_Recover[Message any]() Middleware[Message]

type Mux

+ func (mux *Mux[Message]) Endpoints() [][2]string

+ func (mux *Mux[Message]) SetMessagePool(pool *sync.Pool, reset func(*Message)) *Mux[Message]

Apr 3, 2024

Changes in this version

type Adapter

+ func (adp *Adapter[rMessage, sMessage]) WaitStop() chan struct{}

type Hub

+ func (hub *Hub[T]) WaitStopAll() chan struct{}

type IAdapter

+ WaitStop func() chan struct{}

Apr 1, 2024

Changes in this version

type Adapter

+ func (adp *Adapter[rMessage, sMessage]) AddTerminate(terminates ...func(adp IAdapter))

type AdapterOption

+ func (opt *AdapterOption[rMessage, sMessage]) NewLifecycle(newFunc func() *Lifecycle) *AdapterOption[rMessage, sMessage]

type IAdapter

+ AddTerminate func(terminates ...func(adp IAdapter))

type Lifecycle

+ func (life *Lifecycle) AddInitialize(inits ...func(adp IAdapter) error) *Lifecycle

+ func (life *Lifecycle) AddTerminate(terminates ...func(adp IAdapter)) *Lifecycle

+ func (life *Lifecycle) InitQty() int

+ func (life *Lifecycle) TerminateQty() int

Mar 31, 2024

Changes in this version

type AdapterOption

+ func (opt *AdapterOption[rMessage, sMessage]) Lifecycle(setup func(life *Lifecycle))

Mar 31, 2024

Changes in this version

type Lifecycle

+ func (life *Lifecycle) AsyncUninstall()

+ func (life *Lifecycle) Install() error

+ func (life *Lifecycle) Uninstall()

+ func (life *Lifecycle) Wait()

Mar 31, 2024

Changes in this version

type Adapter

+ func (adp *Adapter[rMessage, sMessage]) Lifecycle(setup func(life *Lifecycle))

+ func (adp *Adapter[rMessage, sMessage]) RegisterStop() <-chan error

+ type IAdapter interface

+ Identifier func() string

+ IsStop func() bool

+ Lifecycle func(setup func(life *Lifecycle))

+ Query func(query func(id string, appData maputil.Data))

+ RegisterStop func() <-chan error

+ Stop func() error

+ Update func(update func(id *string, appData maputil.Data))

type Lifecycle

+ func (life *Lifecycle) AddInstall(installs ...func() error)

+ func (life *Lifecycle) AddUninstall(uninstalls ...func())

+ func (life *Lifecycle) DoInstall() error

+ func (life *Lifecycle) DoUninstall()

+ func (life *Lifecycle) InstallQty() int

+ func (life *Lifecycle) UninstallQty() int

Mar 29, 2024

Changes in this version

+ type Adapter struct

+ func NewPubSub[rMessage, sMessage any](opt *AdapterOption[rMessage, sMessage]) (pubsub *Adapter[rMessage, sMessage])

+ func NewPublisher[sMessage any](opt *AdapterOption[struct{}, sMessage]) (publisher *Adapter[struct{}, sMessage])

+ func NewSubscriber[rMessage any](opt *AdapterOption[rMessage, struct{}]) (subscriber *Adapter[rMessage, struct{}])

+ func (adp *Adapter[rMessage, sMessage]) AddExitHandler(exitHandlers ...func() error) *Adapter[rMessage, sMessage]

+ func (adp *Adapter[rMessage, sMessage]) AddSpawnHandler(spawnHandlers ...func() error) *Adapter[rMessage, sMessage]

+ func (adp *Adapter[rMessage, sMessage]) Identifier() string

+ func (adp *Adapter[rMessage, sMessage]) IsStop() bool

+ func (adp *Adapter[rMessage, sMessage]) Listen() (err error)

+ func (adp *Adapter[rMessage, sMessage]) NotifyStop() <-chan error

+ func (adp *Adapter[rMessage, sMessage]) Query(query func(identifier string, appData maputil.Data))

+ func (adp *Adapter[rMessage, sMessage]) Send(message *sMessage) error

+ func (adp *Adapter[rMessage, sMessage]) Stop() error

+ func (adp *Adapter[rMessage, sMessage]) StopWithMessage(message *sMessage) error

+ func (adp *Adapter[rMessage, sMessage]) Update(update func(identifier *string, appData maputil.Data))

+ type AdapterOption struct

+ func NewPubSubOption[rMessage, sMessage any]() (opt *AdapterOption[rMessage, sMessage])

+ func NewPublisherOption[sMessage any]() (opt *AdapterOption[struct{}, sMessage])

+ func NewSubscriberOption[rMessage any]() (opt *AdapterOption[rMessage, struct{}])

+ func (opt *AdapterOption[rMessage, sMessage]) AdapterFixup(maxRetrySecond int, adapterFixup func() error) *AdapterOption[rMessage, sMessage]

+ func (opt *AdapterOption[rMessage, sMessage]) AdapterRecv(adapterRecv func(adp *Adapter[rMessage, sMessage]) (*rMessage, error)) *AdapterOption[rMessage, sMessage]

+ func (opt *AdapterOption[rMessage, sMessage]) AdapterSend(adapterSend func(adp *Adapter[rMessage, sMessage], egress *sMessage) error) *AdapterOption[rMessage, sMessage]

+ func (opt *AdapterOption[rMessage, sMessage]) AdapterStop(adapterStop func(adp *Adapter[rMessage, sMessage], egress *sMessage) error) *AdapterOption[rMessage, sMessage]

+ func (opt *AdapterOption[rMessage, sMessage]) HandleRecv(handleRecv HandleFunc[rMessage]) *AdapterOption[rMessage, sMessage]

+ func (opt *AdapterOption[rMessage, sMessage]) Identifier(identifier string) *AdapterOption[rMessage, sMessage]

+ func (opt *AdapterOption[rMessage, sMessage]) SendPing(sendPing func() error, waitPong chan error, waitSecond int) *AdapterOption[rMessage, sMessage]

+ func (opt *AdapterOption[rMessage, sMessage]) WaitPing(sendPong func() error, waitPing chan error, waitSecond int) *AdapterOption[rMessage, sMessage]

Mar 29, 2024

Changes in this version

type Hub

+ func (hub *Hub[T]) FindMulti(filter func(T) bool) (all []T, found bool)

+ func (hub *Hub[T]) FindMultiByKey(keys []string) (all []T, found bool)

+ func (hub *Hub[T]) FindOne(filter func(T) bool) (obj T, found bool)

+ func (hub *Hub[T]) RemoveByKey(key string)

+ func (hub *Hub[T]) RemoveMulti(filter func(T) bool)

+ func (hub *Hub[T]) RemoveMultiByKey(keys []string)

+ func (hub *Hub[T]) RemoveOne(filter func(T) bool)

+ func (hub *Hub[T]) UpdateByOldKey(oldKey string, update func(T) (freshKey string, err error)) error

Mar 29, 2024

Changes in this version

type Mux

+ func (mux *Mux[Message]) EnableRecover() *Mux[Message]

+ func (mux *Mux[Message]) GetSubjectAndHandler() (subjects, functions []string)

+ func (mux *Mux[Message]) GroupByNumber(groupName int) *Mux[Message]

+ func (mux *Mux[Message]) HandlerByNumber(subject int, h HandleFunc[Message]) *Mux[Message]

Mar 28, 2024

Changes in this version

+ var ErrNotFoundSubjectOfMux = NewCustomError(2101, "not found subject mux")

type Mux

+ func (mux *Mux[Subject, Message]) SetAutoDelimiter(atLeft bool) *Mux[Subject, Message]

+ func (mux *Mux[Subject, Message]) SetErrorAndRecoverHandler(errorAndRecover func(*Message, *RouteParam, error) error) *Mux[Subject, Message]

+ func (mux *Mux[Subject, Message]) SetSubjectFunc(getSubject NewSubjectFunc[Message]) *Mux[Subject, Message]

Mar 27, 2024

Changes in this version

type Shutdown

+ func (s *Shutdown) Listen(ctx context.Context) *Shutdown

Mar 27, 2024

Changes in this version

type Shutdown

+ Logger Logger

+ func NewShutdown() Shutdown

+ func (s *Shutdown) NotifyStop(cause error)

+ func (s *Shutdown) SetStopAction(name string, action func()) *Shutdown

+ func (s *Shutdown) WaitAfterWithContext(ctx context.Context, waitSecond int)

+ func (s *Shutdown) WaitWithContext(ctx context.Context)

Mar 27, 2024

Changes in this version

+ type Hub struct

+ func NewHub[T any](stopObj func(*T) error) *Hub[T]

+ func (hub *Hub[T]) Count(filter func(*T) bool) int

+ func (hub *Hub[T]) DoAsync(action func(*T))

+ func (hub *Hub[T]) DoSync(action func(*T) (stop bool))

+ func (hub *Hub[T]) Find(filter func(*T) bool) (obj *T, found bool)

+ func (hub *Hub[T]) FindAll(filter func(*T) bool) (all []*T, found bool)

+ func (hub *Hub[T]) FindAllByKey(keys []string) (all []*T, found bool)

+ func (hub *Hub[T]) FindByKey(key string) (obj *T, found bool)

+ func (hub *Hub[T]) Join(key string, obj *T) error

+ func (hub *Hub[T]) Remove(key string)

+ func (hub *Hub[T]) SetConcurrencyQty(concurrencyQty int)

+ func (hub *Hub[T]) StopAll()

+ func (hub *Hub[T]) Total() int

+ func (hub *Hub[T]) UpdateByKey(key string, update func(*T)) error

+ func (hub *Hub[T]) UpdateKeyAndObj(oldKey string, update func(*T) (freshKey string)) error

type Lifecycle

+ func (life *Lifecycle) NotifyExit()

Mar 25, 2024

Changes in this version

type Logger

+ WithKeyValue func(key string, v string) Logger

type Shutdown

+ func (s Shutdown) WaitAfter(waitSecond int)

Mar 24, 2024

Changes in this version

+ type AdapterHub struct

+ func NewAdapterHub[Adapter any](stop func(*Adapter) error) *AdapterHub[Adapter]

+ func (hub *AdapterHub[Adapter]) Count(filter func(*Adapter) bool) int

+ func (hub *AdapterHub[Adapter]) DoAsync(action func(*Adapter))

+ func (hub *AdapterHub[Adapter]) DoSync(action func(*Adapter) (stop bool))

+ func (hub *AdapterHub[Adapter]) FindAdapter(filter func(*Adapter) bool) (adapter *Adapter, found bool)

+ func (hub *AdapterHub[Adapter]) FindAdapterByName(name string) (adapter *Adapter, found bool)

+ func (hub *AdapterHub[Adapter]) FindAdapters(filter func(*Adapter) bool) (adapters []*Adapter, found bool)

+ func (hub *AdapterHub[Adapter]) FindAdaptersByName(names []string) (adapters []*Adapter, found bool)

+ func (hub *AdapterHub[Adapter]) JoinAdapter(name string, adapter *Adapter) error

+ func (hub *AdapterHub[Adapter]) RemoveAdapter(name string)

+ func (hub *AdapterHub[Adapter]) SetConcurrencyQty(concurrencyQty int)

+ func (hub *AdapterHub[Adapter]) Stop()

+ func (hub *AdapterHub[Adapter]) Total() int

+ func (hub *AdapterHub[Adapter]) UpdateAdapterName(oldName string, updateName func(*Adapter) (freshName string)) error

type Lifecycle

+ func (life *Lifecycle) AddExitHandler(exitHandlers ...func() error)

+ func (life *Lifecycle) AddSpawnHandler(spawnHandlers ...func() error)

+ func (life *Lifecycle) Execute() error

type PingPong

+ IsSendPingWaitPong bool

+ type PubSub struct

+ AdapterRecv func() (*rMessage, error)

+ AdapterSend func(*sMessage) error

+ AdapterStop func(*sMessage) error

+ AppData maputil.Data

+ Fixup func() error

+ FixupMaxRetrySecond int

+ HandleRecv HandleFunc[rMessage]

+ Identifier string

+ Lifecycle Lifecycle

+ Mutex sync.RWMutex

+ func (pubsub *PubSub[rMessage, sMessage]) IsStop() bool

+ func (pubsub *PubSub[rMessage, sMessage]) Listen() error

+ func (pubsub *PubSub[rMessage, sMessage]) PingPong(pp PingPong) error

+ func (pubsub *PubSub[rMessage, sMessage]) Send(message *sMessage) error

+ func (pubsub *PubSub[rMessage, sMessage]) Stop() error

+ func (pubsub *PubSub[rMessage, sMessage]) StopWithMessage(message *sMessage) error

+ type PubSubFactory interface

+ CreatePubSub func() (*PubSub[rMessage, sMessage], error)

+ type Publisher struct

+ AdapterSend func(*sMessage) error

+ AdapterStop func() error

+ AppData maputil.Data

+ Fixup func() error

+ FixupMaxRetrySecond int

+ Identifier string

+ Lifecycle Lifecycle

+ Mutex sync.RWMutex

+ func (pub *Publisher[sMessage]) IsStop() bool

+ func (pub *Publisher[sMessage]) PingPong(pp PingPong) error

+ func (pub *Publisher[sMessage]) Send(message *sMessage) error

+ func (pub *Publisher[sMessage]) Stop() error

+ type PublisherFactory interface

+ CreatePublisher func() (*Publisher[sMessage], error)

+ type Subscriber struct

+ AdapterRecv func() (*rMessage, error)

+ AdapterStop func() error

+ AppData maputil.Data

+ Fixup func() error

+ FixupMaxRetrySecond int

+ HandleRecv HandleFunc[rMessage]

+ Identifier string

+ Lifecycle Lifecycle

+ Mutex sync.RWMutex

+ func (sub *Subscriber[rMessage]) IsStop() bool

+ func (sub *Subscriber[rMessage]) Listen() error

+ func (sub *Subscriber[rMessage]) PingPong(pp PingPong) error

+ func (sub *Subscriber[rMessage]) Stop() error

+ type SubscriberFactory interface

+ CreateSubscriber func() (*Subscriber[rMessage], error)

Mar 22, 2024

Changes in this version

+ var ErrClosed = NewCustomError(2000, "service has been closed")

+ var ErrInvalidParameter = NewCustomError(2200, "invalid parameter")

+ var ErrNotFound = NewCustomError(2100, "not found")

+ var ErrTimeout = NewCustomError(2300, "timeout")

+ var ErrUniversal = NewCustomError(2000, "universal error")

+ func ConvertErrNetwork(err error) error

+ func DecryptECB(key, ciphertext []byte) ([]byte, error)

+ func EncryptECB(key, plaintext []byte) ([]byte, error)

+ func ErrorExtractCode(err error) int

+ func ErrorJoin3rdParty(myErr error, Err3rd error) error

+ func ErrorJoin3rdPartyWithMsg(myErr error, Err3rd error, msg string, args ...any) error

+ func ErrorWrapWithMessage(myErr error, msg string, args ...any) error

+ func GenerateRandomCode(length int) string

+ func LoadFileByLocal[T any](decode Unmarshal[T], path, defaultEnv, defaultFileName string) (T, error)

+ func LoadJsonFileByLocal[T any](path, defaultEnv, defaultName string) (T, error)

+ func LookupLogLevel(level LogLevel) string

+ func ReliableTask(task func() error, allowStop func() bool, fixup func() error, ...)

+ func SendPingWaitPong(ping func() error, pong <-chan error, isStop func() bool, pongWaitSecond int) error

+ func SetDefaultLogger(l Logger)

+ func WaitPingSendPong(waitPing <-chan error, sendPong func() error, isStop func() bool, ...) error

+ type Artist struct

+ func NewArtist[Subject constraints.Ordered, rMessage, sMessage any]() *Artist[Subject, rMessage, sMessage]

+ func (hub *Artist[Subject, rMessage, sMessage]) Broadcast(msg sMessage)

+ func (hub *Artist[Subject, rMessage, sMessage]) BroadcastFilter(msg sMessage, filter func(*Session[Subject, rMessage, sMessage]) bool)

+ func (hub *Artist[Subject, rMessage, sMessage]) BroadcastOther(msg sMessage, self *Session[Subject, rMessage, sMessage])

+ func (hub *Artist[Subject, rMessage, sMessage]) Count(filter func(*Session[Subject, rMessage, sMessage]) bool) int

+ func (hub *Artist[Subject, rMessage, sMessage]) DoAsync(action func(*Session[Subject, rMessage, sMessage]))

+ func (hub *Artist[Subject, rMessage, sMessage]) DoSync(action func(*Session[Subject, rMessage, sMessage]) (stop bool))

+ func (hub *Artist[Subject, rMessage, sMessage]) FindSession(filter func(*Session[Subject, rMessage, sMessage]) bool) (session *Session[Subject, rMessage, sMessage], found bool)

+ func (hub *Artist[Subject, rMessage, sMessage]) FindSessions(filter func(*Session[Subject, rMessage, sMessage]) bool) (sessions []*Session[Subject, rMessage, sMessage], found bool)

+ func (hub *Artist[Subject, rMessage, sMessage]) JoinSession(factory SessionFactory[Subject, rMessage, sMessage]) (*Session[Subject, rMessage, sMessage], error)

+ func (hub *Artist[Subject, rMessage, sMessage]) SetConcurrencyQty(concurrencyQty int)

+ func (hub *Artist[Subject, rMessage, sMessage]) Stop()

+ func (hub *Artist[Subject, rMessage, sMessage]) Total() int

+ type CustomError struct

+ func NewCustomError(myCode int, title string) *CustomError

+ func (c *CustomError) CustomError()

+ func (c *CustomError) Error() string

+ func (c *CustomError) MyCode() int

+ type HandleFunc func(message Message, route *RouteParam) error

+ func LinkMiddlewares[Message any](handler HandleFunc[Message], middlewares ...Middleware[Message]) HandleFunc[Message]

+ func (h HandleFunc[Message]) LinkMiddlewares(middlewares ...Middleware[Message]) HandleFunc[Message]

+ func (h HandleFunc[Message]) PostMiddleware() Middleware[Message]

+ func (h HandleFunc[Message]) PreMiddleware() Middleware[Message]

+ type Lifecycle struct

+ ExitHandlers []func(sess *Session[Subject, rMessage, sMessage]) error

+ SpawnHandlers []func(sess *Session[Subject, rMessage, sMessage]) error

+ type LogLevel uint8

+ const LogLevelDebug

+ const LogLevelError

+ const LogLevelFatal

+ const LogLevelInfo

+ const LogLevelWarn

+ type Logger interface

+ Copy func() Logger

+ Debug func(format string, a ...interface{})

+ Error func(format string, a ...interface{})

+ Fatal func(format string, a ...interface{})

+ Info func(format string, a ...interface{})

+ SetLogLevel func(level LogLevel)

+ Warn func(format string, a ...interface{})

+ WithCallDepth func(externalDepth uint) Logger

+ WithMessageId func(msgId string) Logger

+ WithSessionId func(sessId string) Logger

+ func DefaultLogger() Logger

+ func NewLogger(printPath bool, level LogLevel) Logger

+ func SilentLogger() Logger

+ type Marshal func(v any) ([]byte, error)

+ type Middleware func(next HandleFunc[Message]) HandleFunc[Message]

+ type Mux struct

+ func NewMux[Subject constraints.Ordered, Message any](getSubject NewSubjectFunc[Message]) *Mux[Subject, Message]

+ func (mux *Mux[Subject, Message]) Group(s Subject) *Mux[Subject, Message]

+ func (mux *Mux[Subject, Message]) HandleMessage(message Message, route *RouteParam) (err error)

+ func (mux *Mux[Subject, Message]) Handler(s Subject, h HandleFunc[Message]) *Mux[Subject, Message]

+ func (mux *Mux[Subject, Message]) Middleware(middlewares ...Middleware[Message]) *Mux[Subject, Message]

+ func (mux *Mux[Subject, Message]) PostMiddleware(handleFuncs ...HandleFunc[Message]) *Mux[Subject, Message]

+ func (mux *Mux[Subject, Message]) PreMiddleware(handleFuncs ...HandleFunc[Message]) *Mux[Subject, Message]

+ func (mux *Mux[Subject, Message]) SetCleanSubject(cleanSubject bool) *Mux[Subject, Message]

+ func (mux *Mux[Subject, Message]) SetDefaultHandler(h HandleFunc[Message]) *Mux[Subject, Message]

+ func (mux *Mux[Subject, Message]) SetDelimiter(delimiter byte, atLeft bool) *Mux[Subject, Message]

+ func (mux *Mux[Subject, Message]) SetErrorHandler(errorHandler func(Message, *RouteParam, error) error) *Mux[Subject, Message]

+ func (mux *Mux[Subject, Message]) SetNotFoundHandler(h HandleFunc[Message]) *Mux[Subject, Message]

+ func (mux *Mux[Subject, Message]) SubjectFunc(getSubject NewSubjectFunc[Message]) *Mux[Subject, Message]

+ func (mux *Mux[Subject, Message]) Subjects() (result []string)

+ func (mux *Mux[Subject, Message]) Transform(transforms ...HandleFunc[Message]) *Mux[Subject, Message]

+ type NewSubjectFunc func(Message) (string, error)

+ type PingPong struct

+ Enable bool

+ IsWaitPingSendPong bool

+ SendFunc func() error

+ WaitNotify chan error

+ WaitSecond int

+ func (pp PingPong) Execute(allowStop func() bool) error

+ type RouteParam struct

+ func (r *RouteParam) Reset()

+ type Session struct

+ AdapterRecv func() (rMessage, error)

+ AdapterSend func(sMessage) error

+ AdapterStop func(sMessage) error

+ AppData maputil.Data

+ Context context.Context

+ Fixup func() error

+ Identifier string

+ Lifecycle Lifecycle[Subject, rMessage, sMessage]

+ Locker sync.RWMutex

+ Mux *Mux[Subject, rMessage]

+ PingPong PingPong

+ RetryMaxMinute int

+ func (sess *Session[Subject, rMessage, sMessage]) IsStop() bool

+ func (sess *Session[Subject, rMessage, sMessage]) Listen() error

+ func (sess *Session[Subject, rMessage, sMessage]) NotifyStop() <-chan error

+ func (sess *Session[Subject, rMessage, sMessage]) Send(message sMessage) error

+ func (sess *Session[Subject, rMessage, sMessage]) Stop()

+ func (sess *Session[Subject, rMessage, sMessage]) StopWithMessage(message sMessage)

+ type SessionFactory interface

+ CreateSession func() (*Session[Subject, rMessage, sMessage], error)

+ type Shutdown struct

+ func SetupShutdown(ctx1 context.Context, stopActions ...func() (serviceName string)) Shutdown

+ func (s Shutdown) Stop(cause error) Shutdown

+ func (s Shutdown) Wait(waitSecond int)

+ type Unmarshal func(data []byte, v *T) error