application

Sep 17, 2024

Changes in this version

+ type Sockets struct

+ func NewSockets() *Sockets

+ func (s *Sockets) ClientAuth(id any, stream rest.IStream)

+ func (s *Sockets) ClientExists(id any) bool

+ func (s *Sockets) Connect() chan<- rest.IStream

+ func (s *Sockets) OnlineCount() int64

+ func (s *Sockets) SendMessage(id any, message rest.IRequestOut)

+ type StreamStore struct

+ func NewStreamStore(stream rest.IStream) *StreamStore

+ func (s *StreamStore) SendMessage(message rest.IRequestOut)

+ func (s *StreamStore) Size() int

Jul 21, 2024

Changes in this version

type AppConfig

+ func (s *AppConfig) GetCommandsMethod() func(string) (rest.IExecuter, bool)

Jan 14, 2024

Changes in this version

+ func HTTPHeadersCrossOrigin() func() map[string]string

+ func New(appConf *AppConfig, swaggerConf *SwaggerConf, ctx context.Context) rest.IApplication

+ type AppConfig struct

+ Addr string

+ Commands func(string) (rest.IExecuter, bool)

+ Core any

+ HTTPHeaders func() map[string]string

+ Http bool

+ HttpPrefix string

+ OnSocketConnect func(rest.IStream)

+ OnSocketDisconnect func(rest.IStream)

+ SSL bool

+ Secret []byte

+ TLSCertPath string

+ TLSKeyPath string

+ Websocket bool

+ WebsocketPrefix string

+ func (s *AppConfig) GetHTTPHeaders() func() map[string]string

+ func (s *AppConfig) GetHttpPrefix() string

+ func (s *AppConfig) GetWebsocketPrefix() string

+ type Application struct

+ func (s *Application) Connect() chan<- rest.IStream

+ func (s *Application) Executer(r rest.IRequestIn) (rest.IExecuter, bool)

+ func (s *Application) Stop()

+ type Swagger struct

+ func NewSwagger(conf *SwaggerConf) *Swagger

+ func (s *Swagger) Start(ctx context.Context)

+ func (s *Swagger) Stop()

+ type SwaggerConf struct

+ Addr string

+ Enabled bool

+ Prefix string

+ SSL bool

+ TLSCertPath string

+ TLSKeyPath string

+ URI string