ddp

package module

Go to main page

Versions in this module

v0

v0.0.6

Jul 13, 2023

Changes in this version

type Client

+ func NewClientWithLogger(url, origin string, logger *log.Entry) *Client

v0.0.5

Jan 13, 2023

Changes in this version

+ const DISCONNECTING

+ const RECONNECTING

v0.0.4

Oct 31, 2022

v0.0.3

Sep 6, 2021

Changes in this version

+ func IgnoreErr(err error, msg string)

+ type KeyManager struct

+ func NewKeyManager() *KeyManager

+ func (id *KeyManager) Next() string

+ type PingTracker struct

type ReaderStats

+ Reader io.Reader

+ type Time struct

+ func UnixMilli(i int64) Time

+ func (t *Time) UnmarshalJSON(b []byte) error

+ func (t Time) MarshalJSON() ([]byte, error)

type WriterStats

+ Writer io.Writer

v0.0.1

Sep 6, 2021

Changes in this version

+ const CONNECTED

+ const CONNECTING

+ const DIALING

+ const DISCONNECTED

+ const DataByte

+ const DataText

+ type Call struct

+ Args interface{}

+ Done chan *Call

+ Error error

+ ID string

+ Owner *Client

+ Reply interface{}

+ ServiceMethod string

+ type Client struct

+ HeartbeatInterval time.Duration

+ HeartbeatTimeout time.Duration

+ ReconnectInterval time.Duration

+ func NewClient(url, origin string) *Client

+ func (c *Client) AddConnectionListener(listener ConnectionListener)

+ func (c *Client) AddStatusListener(listener StatusListener)

+ func (c *Client) Call(serviceMethod string, args ...interface{}) (interface{}, error)

+ func (c *Client) Close()

+ func (c *Client) CollectionByName(name string) Collection

+ func (c *Client) CollectionStats() []CollectionStats

+ func (c *Client) Connect() error

+ func (c *Client) Go(serviceMethod string, done chan *Call, args ...interface{}) *Call

+ func (c *Client) Ping()

+ func (c *Client) PingPong(id string, timeout time.Duration, handler func(error))

+ func (c *Client) Reconnect()

+ func (c *Client) ResetStats()

+ func (c *Client) Send(msg interface{}) error

+ func (c *Client) Session() string

+ func (c *Client) SetSocketLogActive(active bool)

+ func (c *Client) SocketLogActive() bool

+ func (c *Client) Stats() *ClientStats

+ func (c *Client) Sub(subName string, args ...interface{}) error

+ func (c *Client) Subscribe(subName string, done chan *Call, args ...interface{}) *Call

+ func (c *Client) Version() string

+ type ClientStats struct

+ PingsRecv int64

+ PingsSent int64

+ Reads *Stats

+ Reconnects int64

+ TotalReads *Stats

+ TotalWrites *Stats

+ Writes *Stats

+ func (stats *ClientStats) String() string

+ type Collection interface

+ AddUpdateListener func(listener UpdateListener)

+ FindAll func() map[string]Update

+ FindOne func(id string) Update

+ func NewCollection(name string) Collection

+ func NewMockCollection() Collection

+ type CollectionStats struct

+ Count int

+ Name string

+ func (s *CollectionStats) String() string

+ type Connect struct

+ Session string

+ Support []string

+ Version string

+ func NewConnect() *Connect

+ func NewReconnect(session string) *Connect

+ type ConnectionListener interface

+ Connected func()

+ type ConnectionNotifier interface

+ AddConnectionListener func(listener ConnectionListener)

+ type Doc struct

+ func NewDoc(in interface{}) *Doc

+ func (d *Doc) Array(path string) []interface{}

+ func (d *Doc) Bool(path string) bool

+ func (d *Doc) Float(path string) float64

+ func (d *Doc) Item(path string) interface{}

+ func (d *Doc) Map(path string) map[string]interface{}

+ func (d *Doc) Set(path string, value interface{})

+ func (d *Doc) String(path string) string

+ func (d *Doc) StringArray(path string) []string

+ func (d *Doc) Time(path string) time.Time

+ type KeyCache struct

+ Name string

+ func (c *KeyCache) AddUpdateListener(listener UpdateListener)

+ func (c *KeyCache) FindAll() map[string]Update

+ func (c *KeyCache) FindOne(id string) Update

+ type Logger struct

+ Active bool

+ Truncate int

+ func NewLogger(logger *log.Logger, active bool, dataType int, truncate int) Logger

+ func (l *Logger) Log(p []byte, n int, err error) (int, error)

+ type Login struct

+ Password *Password

+ User *User

+ func NewEmailLogin(email, pass string) *Login

+ func NewUsernameLogin(user, pass string) *Login

+ type LoginResume struct

+ Token string

+ func NewLoginResume(token string) *LoginResume

+ type Message struct

+ ID string

+ Type string

+ type Method struct

+ Args []interface{}

+ ServiceMethod string

+ func NewMethod(id, serviceMethod string, args []interface{}) *Method

+ type MockCache struct

+ func (c *MockCache) AddUpdateListener(ch UpdateListener)

+ func (c *MockCache) FindAll() map[string]Update

+ func (c *MockCache) FindOne(id string) Update

+ type OrderedCache struct

+ func (c *OrderedCache) AddUpdateListener(ch UpdateListener)

+ func (c *OrderedCache) FindAll() map[string]Update

+ func (c *OrderedCache) FindOne(id string) Update

+ type Password struct

+ Algorithm string

+ Digest string

+ func NewPassword(pass string) *Password

+ type Ping Message

+ func NewPing(id string) *Ping

+ type Pong Message

+ func NewPong(id string) *Pong

+ type ReaderLogger struct

+ func NewReaderDataLogger(reader io.Reader) *ReaderLogger

+ func NewReaderLogger(reader io.Reader, logger *log.Logger, active bool, dataType int, truncate int) *ReaderLogger

+ func NewReaderTextLogger(reader io.Reader) *ReaderLogger

+ func (r *ReaderLogger) Read(p []byte) (int, error)

+ type ReaderProxy struct

+ func NewReaderProxy(reader io.Reader) *ReaderProxy

+ func (r *ReaderProxy) SetReader(reader io.Reader)

+ type ReaderStats struct

+ func NewReaderStats(reader io.Reader) *ReaderStats

+ func (r *ReaderStats) Read(p []byte) (int, error)

+ type Stats struct

+ Bytes int64

+ Errors int64

+ Ops int64

+ Runtime time.Duration

+ type StatsTracker struct

+ func NewStatsTracker() *StatsTracker

+ func (t *StatsTracker) Op(n int, err error) (int, error)

+ func (t *StatsTracker) Reset() *Stats

+ func (t *StatsTracker) Snapshot() *Stats

+ type StatusListener interface

+ Status func(status int)

+ type StatusNotifier interface

+ AddStatusListener func(listener StatusListener)

+ type Sub struct

+ Args []interface{}

+ SubName string

+ func NewSub(id, subName string, args []interface{}) *Sub

+ type Update map[string]interface

+ type UpdateListener interface

+ CollectionUpdate func(collection, operation, id string, doc Update)

+ type User struct

+ Email string

+ Username string

+ type WriterLogger struct

+ func NewWriterDataLogger(writer io.Writer) *WriterLogger

+ func NewWriterLogger(writer io.Writer, logger *log.Logger, active bool, dataType int, truncate int) *WriterLogger

+ func NewWriterTextLogger(writer io.Writer) *WriterLogger

+ func (w *WriterLogger) Write(p []byte) (int, error)

+ type WriterProxy struct

+ func NewWriterProxy(writer io.Writer) *WriterProxy

+ func (w *WriterProxy) SetWriter(writer io.Writer)

+ type WriterStats struct

+ func NewWriterStats(writer io.Writer) *WriterStats

+ func (w *WriterStats) Write(p []byte) (int, error)

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