irt

May 8, 2019

Changes in this version

+ const DefaultConnectionBuffer

+ const DefaultMaxPackageSize

+ const DefaultPingPeriod

+ const DefaultPongWaitTime

+ const DefaultProcessingThreads

+ const DefaultReadBufferSize

+ const DefaultRegistrationBuffer

+ const DefaultTimeout

+ const DefaultWriteBufferSize

+ const DefaultWriteWaitTime

+ const MessageKindBuzzerFailure

+ const MessageKindBuzzerRequest

+ const MessageKindBuzzerResponse

+ const MessageKindFailure

+ const MessageKindRPCFailure

+ const MessageKindRPCRequest

+ const MessageKindRPCResponse

+ const MessageKindStreamC2S

+ const MessageKindStreamS2C

+ const MessageRandomLength

+ const MessageRandomSymbols

+ var DATETIME_FORMATS = []string

+ func RandomMessageID(prefix string) string

+ func ReadDate(value string) (time.Time, error)

+ func ReadDateTime(value string, utc bool) (time.Time, error)

+ func ReadLocalDateTime(value string) (time.Time, error)

+ func ReadTime(value string) (time.Time, error)

+ func ReadUTCDateTime(value string) (time.Time, error)

+ func ReadZoneDateTime(value string) (time.Time, error)

+ func WriteDate(value time.Time) string

+ func WriteLocalDateTime(value time.Time) string

+ func WriteTime(value time.Time) string

+ func WriteUTCDateTime(value time.Time) string

+ func WriteZoneDateTime(value time.Time) string

+ type AuthApiKey struct

+ ApiKey string

+ func NewAuthApiKey(apiKey string) *AuthApiKey

+ type AuthBasic struct

+ Pass string

+ User string

+ func NewAuthBasic(user string, pass string) *AuthBasic

+ func (a *AuthBasic) GetPass() (string, error)

+ type AuthCustom struct

+ Value string

+ func NewAuthCustom(value string) *AuthCustom

+ type AuthToken struct

+ Token string

+ func NewAuthToken(token string) *AuthToken

+ type Authorization struct

+ ApiKey *AuthApiKey

+ Basic *AuthBasic

+ Custom *AuthCustom

+ Token *AuthToken

+ func (c *Authorization) Reset()

+ func (c *Authorization) ToValue() string

+ func (c *Authorization) UpdateFromHeaders(h http.Header) error

+ func (c *Authorization) UpdateFromRequest(r http.Request) error

+ func (c *Authorization) UpdateFromValue(auth string) error

+ type BinaryMarshaller struct

+ func NewBinaryMarshaller() *BinaryMarshaller

+ func (m *BinaryMarshaller) Marshal(data interface{}) ([]byte, error)

+ func (m *BinaryMarshaller) Unmarshal(data []byte, model interface{}) error

+ type ClientSocketTransport interface

+ type ClientTransport interface

+ GetAuthorization func() *Authorization

+ GetHeaders func() TransportHeaders

+ Send func(service string, method string, dataIn interface{}, dataOut interface{}) error

+ SetAuthorization func(auth *Authorization) error

+ SetHeaders func(headers TransportHeaders) error

+ func NewHTTPClientTransport(endpoint string, timeout time.Duration) ClientTransport

+ func NewHTTPClientTransportEx(endpoint string, timeout time.Duration, skipSSLVerify bool, ...) ClientTransport

+ func NewWebSocketClientTransport(endpoint string, subprotocols []string) (ClientTransport, error)

+ func NewWebSocketClientTransportEx(endpoint string, timeout time.Duration, skipSSLVerify bool, ...) (ClientTransport, error)

+ type ConnectionContext struct

+ System *SystemContext

+ User interface{}

+ type ConnectionHandlers struct

+ OnAuth OnAuth

+ OnConnect OnConnect

+ OnDisconnect OnDisconnect

+ type Dispatcher struct

+ func (d *Dispatcher) Dispatch(context interface{}, service string, method string, data []byte) (out []byte, derr error)

+ func (d *Dispatcher) Register(dispatcher ServiceDispatcher) error

+ func (d *Dispatcher) Unregister(serviceName string) bool

+ type JSONMarshaller struct

+ func NewJSONMarshaller(pretty bool) *JSONMarshaller

+ func (m *JSONMarshaller) Marshal(data interface{}) ([]byte, error)

+ func (m *JSONMarshaller) Unmarshal(data []byte, model interface{}) error

+ type LogLevel int

+ const LogDebug

+ const LogError

+ const LogInfo

+ const LogTrace

+ const LogWarning

+ type Logger interface

+ Logf func(level LogLevel, format string, params ...interface{})

+ func NewConsoleLogger(level LogLevel) Logger

+ func NewDummyLogger() Logger

+ type Marshaller interface

+ Marshal func(data interface{}) ([]byte, error)

+ Unmarshal func(data []byte, model interface{}) error

+ type OnAuth func(connection *ConnectionContext) error

+ type OnConnect func(connection *ConnectionContext, request *http.Request) error

+ type OnDisconnect func(connection *ConnectionContext)

+ type ServiceDispatcher interface

+ Dispatch func(context interface{}, method string, data []byte) ([]byte, error)

+ GetSupportedMethods func() []string

+ GetSupportedService func() string

+ type SystemContext struct

+ Auth *Authorization

+ RemoteAddr string

+ func (c *SystemContext) Update(r *http.Request) error

+ type TransportHeaders = map[string]string

+ type WebSocketFailureMessage struct

+ Cause string

+ Data string

+ Kind string

+ type WebSocketMessageBase struct

+ Kind string

+ type WebSocketRequestMessage struct

+ Data json.RawMessage

+ Headers map[string]string

+ ID string

+ Kind string

+ Method string

+ Service string

+ type WebSocketResponseMessage struct

+ Data json.RawMessage

+ Kind string

+ Ref string

+ type WebSocketServerTransport struct

+ func NewWebSocketServerTransport(dispatcher *Dispatcher, handlers *ConnectionHandlers) *WebSocketServerTransport

+ func NewWebSocketServerTransportEx(dispatcher *Dispatcher, marshaller Marshaller, logger Logger, ...) *WebSocketServerTransport

+ func (t *WebSocketServerTransport) ServeWS(w http.ResponseWriter, r *http.Request)

+ func (t *WebSocketServerTransport) Start()

+ func (t *WebSocketServerTransport) Stop()