app

package

Go to main page

Versions in this module

v0

v0.2.6

Nov 16, 2023

Changes in this version

type Application

+ func (ap *Application) SessionState(id string) SessionState

v0.2.5

Nov 7, 2023

Changes in this version

+ const APP_BUILDING_OPT_DEFAULT_EVENT_HANDLER

+ const APP_BUILDING_OPT_DEFAULT_MESSAGE_HANDLER

+ const APP_BUILDING_OPT_ERROR_HANDLER

+ const APP_BUILDING_OPT_EVENT_CLIENT

+ const APP_BUILDING_OPT_EVENT_ROUTER

+ const APP_BUILDING_OPT_INVALID_EVENT_HANDLER

+ const APP_BUILDING_OPT_INVALID_MESSAGE_HANDLER

+ const APP_BUILDING_OPT_LOGGER_FLAGS

+ const APP_BUILDING_OPT_LOGGER_OUTPUT

+ const APP_BUILDING_OPT_MESSAGE_ROUTER

+ const APP_BUILDING_OPT_PROTOCOL_EMITTER

+ const APP_BUILDING_OPT_PROTOCOL_RESOLVER

+ const APP_BUILDING_OPT_SESSION_STATE_MANAGER

+ const APP_BUILDING_OPT_TEXT_MAP_PROPAGATOR

+ const APP_BUILDING_OPT_TRACER_PROVIDER

+ type AppBase struct

+ func (app *AppBase) EnableStackTrace(enabled bool)

+ func (app *AppBase) Logger() *log.Logger

+ func (app *AppBase) TextMapPropagator() propagation.TextMapPropagator

+ func (app *AppBase) TracerProvider() *trace.SeverityTracerProvider

+ type GenericApplicationBuildingOption struct

+ type LoggingWriter struct

+ EnableStackTrace bool

+ func NewLoggingWriter(writer io.Writer) *LoggingWriter

+ func (w *LoggingWriter) Write(p []byte) (n int, err error)

+ func (w *LoggingWriter) Writter() io.Writer

v0.2.5-alpha.20231107041337

Nov 7, 2023

v0.2.4

Nov 3, 2023

Changes in this version

+ const ErrJoinClosedMessageClientManager

+ const ErrSendMessageToClosedWriter

type Context

+ func (ctx *Context) CloseSend() error

+ func (ctx *Context) IsCloseSend() bool

v0.2.3

Oct 27, 2023

v0.2.2

Oct 25, 2023

Changes in this version

+ type MessageClientInfo struct

+ func NewMessageClientInfo() *MessageClientInfo

+ func (info *MessageClientInfo) ID() string

+ func (info *MessageClientInfo) Logger() *log.Logger

+ func (info *MessageClientInfo) StartAt() time.Time

+ type MessageClientInfoImpl interface

+ ID func() string

+ Logger func() *log.Logger

+ StartAt func() time.Time

+ type RestrictedMessageClient struct

+ func NewRestrictedMessageClient(client MessageClient) *RestrictedMessageClient

+ func (*RestrictedMessageClient) Close() error

+ func (*RestrictedMessageClient) RegisterCloseHandler(func(MessageClient))

+ func (*RestrictedMessageClient) Start(*MessagePipe)

+ func (*RestrictedMessageClient) Stop()

v0.2.1

Aug 21, 2023

Changes in this version

type ApplicationBuildingOption

+ func WithLoggerOutput(w io.Writer) ApplicationBuildingOption

v0.2.0

Aug 3, 2023

Changes in this version

+ const InvalidChannel

+ const JoinClosedMessageClientManagerErr

+ const Nop

+ const OPT_OFF

+ const OPT_ON

+ const TAG_CHANNEL

+ const TAG_OPT_EXPAND_ENV

+ const TAG_PROTOCOL

+ var AllMessageFormats = []MessageFormat

+ func StdProtocolEmitter(format MessageFormat, protocol string, payload []byte) []byte

+ type Application struct

+ Name string

+ func Build(appName string, opts ...ApplicationBuildingOption) (*Application, error)

+ func Init(v Module, opts ...ModuleBindingOption) *Application

+ func (ap *Application) MessageClientManager() *MessageClientManager

+ func (ap *Application) Start(ctx context.Context) error

+ func (ap *Application) Stop(ctx context.Context) error

+ func (ap *Application) TextMapPropagator() propagation.TextMapPropagator

+ func (ap *Application) TracerProvider() *trace.SeverityTracerProvider

+ type ApplicationBuildingOption interface

+ func WithDefaultEventHandler(handler EventHandler) ApplicationBuildingOption

+ func WithDefaultMessageHandler(handler MessageHandler) ApplicationBuildingOption

+ func WithErrorHandler(handler ErrorHandler) ApplicationBuildingOption

+ func WithEventClient(source EventClient) ApplicationBuildingOption

+ func WithEventRouter(router EventRouter) ApplicationBuildingOption

+ func WithInvalidEventHandler(handler EventHandler) ApplicationBuildingOption

+ func WithInvalidMessageHandler(handler MessageHandler) ApplicationBuildingOption

+ func WithLoggerFlags(flags int) ApplicationBuildingOption

+ func WithLoggerOuput(w io.Writer) ApplicationBuildingOption

+ func WithMessageRouter(router MessageRouter) ApplicationBuildingOption

+ func WithProtocolEmitter(emitter ProtocolEmitter) ApplicationBuildingOption

+ func WithProtocolResolver(resolver ProtocolResolver) ApplicationBuildingOption

+ func WithSessionStateManager(manager SessionStateManager) ApplicationBuildingOption

+ func WithTextMapPropagator(p propagation.TextMapPropagator) ApplicationBuildingOption

+ func WithTracerProvider(tp *trace.SeverityTracerProvider) ApplicationBuildingOption

+ type ApplicationBuildingOptionFunc func(*Application) error

+ type ApplicationWorker struct

+ type ClientIDValidator func(string) bool

+ type Context struct

+ GlobalState SessionState

+ SessionID string

+ SessionState SessionState

+ func (*Context) Deadline() (deadline time.Time, ok bool)

+ func (*Context) Done() <-chan struct{}

+ func (*Context) Err() error

+ func (ctx *Context) Forward(channel string, payload []byte)

+ func (ctx *Context) InvalidEvent(event *Event)

+ func (ctx *Context) InvalidMessage(message *Message)

+ func (ctx *Context) Logger() *log.Logger

+ func (ctx *Context) Send(format MessageFormat, protocol string, body []byte)

+ func (ctx *Context) SetValue(key interface{}, value interface{})

+ func (ctx *Context) Value(key any) any

+ type ErrorHandler func(err error)

+ type Event struct

+ Channel string

+ Delegate EventDelegate

+ Payload []byte

+ func (e *Event) Abort()

+ func (e *Event) Ack()

+ func (e *Event) Retry()

+ type EventClient interface

+ Close func() error

+ Start func(*EventPipe)

+ Stop func()

+ type EventDelegate interface

+ OnAbort func(event *Event)

+ OnAck func(event *Event)

+ OnRetry func(event *Event)

+ type EventForwarder interface

+ Forward func(channel string, payload []byte) error

+ type EventHandler func(ctx *Context, event *Event) error

+ type EventPipe struct

+ func (pipe *EventPipe) Error(err error)

+ func (pipe *EventPipe) Forward(event *Event)

+ type EventRouter map[string]EventHandler

+ func (r EventRouter) Add(channel string, handler EventHandler)

+ func (r EventRouter) Get(channel string) EventHandler

+ func (r EventRouter) Has(channel string) bool

+ func (r EventRouter) Remove(channel string)

+ type Message struct

+ Body []byte

+ Format MessageFormat

+ Protocol string

+ func (m *Message) DecodeContent(v MessageContent) error

+ func (m Message) Equals(other Message) bool

+ type MessageClient interface

+ Close func() error

+ RegisterCloseHandler func(func(MessageClient))

+ Start func(*MessagePipe)

+ Stop func()

+ type MessageClientManager struct

+ func (manager *MessageClientManager) Expel(client MessageClient) error

+ func (manager *MessageClientManager) Join(client MessageClient) error

+ type MessageContent interface

+ Decode func(format MessageFormat, body []byte) error

+ Encode func() (MessageFormat, []byte)

+ Validate func() error

+ type MessageError error

+ type MessageFormat uint

+ const BINARY_MESSAGE

+ const CLOSE_MESSAGE

+ const PING_MESSAGE

+ const PONG_MESSAGE

+ const TEXT_MESSAGE

+ const UNKNOWN_MESSAGE

+ func (format MessageFormat) IsControl() bool

+ func (format MessageFormat) IsData() bool

+ type MessageHandler func(ctx *Context, message *Message)

+ type MessagePipe struct

+ func (pipe *MessagePipe) Error(err error)

+ func (pipe *MessagePipe) Forward(client MessageClient, message *Message)

+ type MessageRouter map[string]MessageHandler

+ func (r MessageRouter) Add(code string, handler MessageHandler)

+ func (r MessageRouter) Get(code string) MessageHandler

+ func (r MessageRouter) Has(code string) bool

+ func (r MessageRouter) Remove(code string)

+ type MessageSender interface

+ Send func(format MessageFormat, payload []byte) error

+ type MessageSource struct

+ Client MessageClient

+ Message *Message

+ type MessageWorker struct

+ type Module interface

+ ModuleOptions func() []ApplicationBuildingOption

+ type ModuleBindingOption interface

+ func BindConfig(v interface{}) ModuleBindingOption

+ func BindEventClient(v interface{}) ModuleBindingOption

+ func BindServiceProvider(v interface{}) ModuleBindingOption

+ type ModuleBindingOptionFunc func(reflect.Value, TargetValueRole) error

+ type ModuleOptionCollection []ApplicationBuildingOption

+ func ModuleOptions(opts ...ApplicationBuildingOption) ModuleOptionCollection

+ func (c ModuleOptionCollection) ModuleOptions() []ApplicationBuildingOption

+ type MultiEventClient map[string]EventClient

+ func (hub MultiEventClient) Close() error

+ func (hub MultiEventClient) Forward(channel string, payload []byte) error

+ func (hub MultiEventClient) Start(pipe *EventPipe)

+ func (hub MultiEventClient) Stop()

+ type NoopEventClient struct

+ func (NoopEventClient) Close() error

+ func (NoopEventClient) Forward(channel string, payload []byte) error

+ func (NoopEventClient) Start(*EventPipe)

+ func (NoopEventClient) Stop()

+ type ProtocolEmitter func(format MessageFormat, protocol string, body []byte) []byte

+ type ProtocolResolver func(format MessageFormat, payload []byte) (string, []byte)

+ type SessionState interface

+ CanVisit func() bool

+ Lock func()

+ SetValue func(k, v interface{})

+ Unlock func()

+ Value func(k interface{}) interface{}

+ Visit func(func(k, v interface{}))

+ type SessionStateManager interface

+ Delete func(id string)

+ Load func(id string) SessionState

+ TryCreate func(id string) bool

+ Update func(id string, state SessionState)

+ type StdSessionState struct

+ func NewStdSessionState() *StdSessionState

+ func (state *StdSessionState) CanVisit() bool

+ func (state *StdSessionState) Lock()

+ func (state *StdSessionState) SetValue(k interface{}, v interface{})

+ func (state *StdSessionState) Unlock()

+ func (state *StdSessionState) Value(k interface{}) interface{}

+ func (state *StdSessionState) Visit(fn func(k interface{}, v interface{}))

+ type StdSessionStateManager struct

+ func NewStdSessionStateManager() *StdSessionStateManager

+ func (m *StdSessionStateManager) Delete(id string)

+ func (m *StdSessionStateManager) Load(id string) SessionState

+ func (m *StdSessionStateManager) TryCreate(id string) bool

+ func (m *StdSessionStateManager) Update(id string, state SessionState)

+ type TargetValueRole string

+ const APP

+ const MODULE_OPTIONS

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