art

package module

Go to main page

Versions in this module

v1

v1.1.0

Jun 29, 2024

Changes in this version

type Shutdown

+ func NewShutdownWithoutTimeout() *Shutdown

+ func (s *Shutdown) WaitChannel() <-chan struct{}

v1.0.0

May 30, 2024

v0

v0.52.0

May 19, 2024

v0.51.0

May 17, 2024

v0.50.0

May 4, 2024

Changes in this version

type Middleware

+ func UseCopyMessage() Middleware

v0.49.4

May 4, 2024

v0.49.3

May 4, 2024

v0.49.2

May 4, 2024

Changes in this version

type AdapterOption

+ func (opt *AdapterOption) RawFixup(maxRetrySecond int, fixup func(IAdapter) error) *AdapterOption

+ func (opt *AdapterOption) RawRecv(recv func(logger Logger) (message *Message, err error)) *AdapterOption

+ func (opt *AdapterOption) RawSend(send func(logger Logger, message *Message) error) *AdapterOption

+ func (opt *AdapterOption) RawStop(stop func(logger Logger) error) *AdapterOption

v0.49.1

May 3, 2024

v0.49.0

May 3, 2024

Changes in this version

type UsePrintResult

+ func (use UsePrintResult) IgnoreErrSubjects(subjects ...string) UsePrintResult

+ func (use UsePrintResult) IgnoreErrors(errs ...error) UsePrintResult

+ func (use UsePrintResult) IgnoreOkSubjects(subjects ...string) UsePrintResult

+ func (use UsePrintResult) PostMiddleware(next HandleFunc) HandleFunc

+ func (use UsePrintResult) PrintEgress() UsePrintResult

+ func (use UsePrintResult) PrintIngress() UsePrintResult

v0.48.0

May 3, 2024

Changes in this version

type HandleFunc

+ func UseGenericFunc[Dep any, H func(*Message, *Dep) error](handler H) HandleFunc

v0.47.0

May 2, 2024

Changes in this version

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

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

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

+ 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 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 GenerateUlid() string

+ func LookupLogLevel(level LogLevel) string

+ func PutMessage(message *Message)

+ func ReliableTask(task func() error, allowStop func() bool, retryMaxSecond int, ...) error

+ func SendPingWaitPong(sendPingSeconds int, sendPing func() error, waitPong WaitPingPong, ...) error

+ func SetDefaultLogger(l Logger)

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

+ func WaitPingSendPong(waitPingSeconds int, waitPing WaitPingPong, sendPong func() error, ...) error

+ type Adapter struct

+ func (adp *Adapter) Identifier() string

+ func (adp *Adapter) IsStopped() bool

+ func (adp *Adapter) Listen() (err error)

+ func (adp *Adapter) Log() Logger

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

+ func (adp *Adapter) RawInfra() any

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

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

+ func (adp *Adapter) SetLog(logger Logger)

+ func (adp *Adapter) Stop() error

+ func (adp *Adapter) WaitStop() chan struct{}

+ type AdapterHub interface

+ Join func(adapterId string, adp IAdapter) error

+ RemoveOne func(filter func(IAdapter) bool)

+ type AdapterOption struct

+ func NewAdapterOption() (opt *AdapterOption)

+ func (opt *AdapterOption) AdapterFixup(maxRetrySecond int, adapterFixup func(IAdapter) error) *AdapterOption

+ func (opt *AdapterOption) AdapterHub(hub AdapterHub) *AdapterOption

+ func (opt *AdapterOption) AdapterRecv(adapterRecv func(logger Logger) (message *Message, err error)) *AdapterOption

+ func (opt *AdapterOption) AdapterSend(adapterSend func(logger Logger, message *Message) error) *AdapterOption

+ func (opt *AdapterOption) AdapterStop(adapterStop func(logger Logger) error) *AdapterOption

+ func (opt *AdapterOption) Build() (adp IAdapter, err error)

+ func (opt *AdapterOption) DecorateAdapter(wrap func(adapter IAdapter) (application IAdapter)) *AdapterOption

+ func (opt *AdapterOption) EgressMux(mux *Mux) *AdapterOption

+ func (opt *AdapterOption) Identifier(identifier string) *AdapterOption

+ func (opt *AdapterOption) IngressMux(mux *Mux) *AdapterOption

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

+ func (opt *AdapterOption) Logger(logger Logger) *AdapterOption

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

+ func (opt *AdapterOption) SendPing(sendPingSeconds int, waitPong WaitPingPong, sendPing func(IAdapter) error) *AdapterOption

+ func (opt *AdapterOption) WaitPing(waitPingSeconds int, waitPing WaitPingPong, sendPong func(IAdapter) error) *AdapterOption

+ type Consumer interface

+ Listen func() (err error)

+ 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, dep any) error

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

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

+ func UsePrintDetail() HandleFunc

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

+ func (h HandleFunc) PostMiddleware() Middleware

+ func (h HandleFunc) PreMiddleware() Middleware

+ type Hub struct

+ func NewHub() *Hub

+ func (hub *Hub) Count(filter func(IAdapter) bool) int

+ func (hub *Hub) DoAsync(action func(IAdapter))

+ func (hub *Hub) DoSync(action func(IAdapter) (stop bool))

+ func (hub *Hub) FindByKey(key string) (adp IAdapter, found bool)

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

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

+ func (hub *Hub) FindOne(filter func(IAdapter) bool) (adp IAdapter, found bool)

+ func (hub *Hub) IsShutdown() bool

+ func (hub *Hub) Join(key string, adp IAdapter) error

+ func (hub *Hub) RemoveByKey(key string)

+ func (hub *Hub) RemoveMulti(filter func(IAdapter) bool)

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

+ func (hub *Hub) RemoveOne(filter func(IAdapter) bool)

+ func (hub *Hub) SetConcurrencyQty(concurrencyQty int)

+ func (hub *Hub) Shutdown()

+ func (hub *Hub) Total() int

+ func (hub *Hub) UpdateByOldKey(oldKey string, update func(IAdapter) (freshKey string)) error

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

+ type IAdapter interface

+ Identifier func() string

+ IsStopped func() bool

+ Log func() Logger

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

+ RawInfra func() any

+ SetLog func(Logger)

+ Stop func() error

+ WaitStop func() chan struct{}

+ type Lifecycle struct

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

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

+ type LogLevel uint8

+ const LogLevelDebug

+ const LogLevelError

+ const LogLevelFatal

+ const LogLevelInfo

+ const LogLevelWarn

+ type Logger interface

+ Debug func(format string, a ...any)

+ Error func(format string, a ...any)

+ Fatal func(format string, a ...any)

+ Info func(format string, a ...any)

+ LogLevel func() LogLevel

+ SetLogLevel func(level LogLevel)

+ Warn func(format string, a ...any)

+ WithCallDepth func(externalDepth uint) Logger

+ WithKeyValue func(key string, v any) Logger

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

+ func DefaultLogger() Logger

+ func NewLogger(printPath bool, level LogLevel) Logger

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

+ func SilentLogger() Logger

+ type Message struct

+ Body any

+ Bytes []byte

+ Ctx context.Context

+ Metadata maputil.Data

+ Mutex sync.Mutex

+ RawInfra any

+ RouteParam maputil.Data

+ Subject string

+ func GetMessage() *Message

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

+ func (msg *Message) MsgId() string

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

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

+ type Middleware func(next HandleFunc) HandleFunc

+ func UseAsync() Middleware

+ func UseExclude(subjects []string) Middleware

+ func UseHowMuchTime() Middleware

+ func UseInclude(subjects []string) Middleware

+ func UseLogger(withMsgId bool, safeConcurrency SafeConcurrencyKind) Middleware

+ func UsePrintResult(isEgress bool, ignoreOkSubjects []string) Middleware

+ func UseRecover() Middleware

+ func UseRetry(retryMaxSecond int) Middleware

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

+ type Mux struct

+ func NewMux(routeDelimiter string) *Mux

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

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

+ func (mux *Mux) Endpoints(action func(subject, handler string))

+ func (mux *Mux) ErrorHandler(errHandlers ...Middleware) *Mux

+ func (mux *Mux) Group(groupName string) *Mux

+ func (mux *Mux) GroupByNumber(groupName int) *Mux

+ func (mux *Mux) HandleMessage(message *Message, dependency any) (err error)

+ func (mux *Mux) Handler(subject string, h HandleFunc, mw ...Middleware) *Mux

+ func (mux *Mux) HandlerByNumber(subject int, h HandleFunc, mw ...Middleware) *Mux

+ func (mux *Mux) Middleware(middlewares ...Middleware) *Mux

+ func (mux *Mux) NotFoundHandler(h HandleFunc) *Mux

+ func (mux *Mux) PostMiddleware(handleFuncs ...HandleFunc) *Mux

+ func (mux *Mux) PreMiddleware(handleFuncs ...HandleFunc) *Mux

+ func (mux *Mux) Transform(transform HandleFunc) *Mux

+ type Producer interface

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

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

+ type Prosumer interface

+ type SafeConcurrencyKind int

+ const SafeConcurrency_Copy

+ const SafeConcurrency_Mutex

+ const SafeConcurrency_Skip

+ type Shutdown struct

+ Logger Logger

+ func NewShutdown() *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{}

+ type WaitPingPong chan struct

+ func CtxGetPingPong(ctx context.Context) WaitPingPong

+ func NewWaitPingPong() WaitPingPong

+ func (wait WaitPingPong) Ack()

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