waddell

type Client struct {
	*ClientConfig
	// contains filtered or unexported fields
}

type ClientConfig struct {
	// Dial is a function that dials the waddell server
	Dial DialFunc

	// ServerCert: PEM-encoded certificate by which to authenticate the waddell
	// server. If provided, connection to waddell is encrypted with TLS. If not,
	// connection will be made plain-text.
	ServerCert string

	// ReconnectAttempts specifies how many consecutive times to try
	// reconnecting in the event of a connection failure.
	//
	// Note - when auto reconnecting is enabled, the client will never resend
	// messages, it will simply reopen the connection.
	ReconnectAttempts int

	// OnId allows optionally registering a callback to be notified whenever a
	// PeerId is assigned to this client (i.e. on each successful connection to
	// the waddell server).
	OnId func(id PeerId)
}

type ClientMgr struct {
	// Dial is a function that dials the waddell server at the given addr.
	Dial func(addr string) (net.Conn, error)

	// ServerCert: PEM-encoded certificate by which to authenticate the waddell
	// server. If provided, connection to waddell is encrypted with TLS. If not,
	// connection will be made plain-text.
	ServerCert string

	// ReconnectAttempts specifies how many consecutive times to try
	// reconnecting in the event of a connection failure. See
	// Client.ReconnectAttempts for more information.
	ReconnectAttempts int

	// OnId allows optionally registering a callback to be notified whenever a
	// PeerId is assigned to the client connected to the indicated addr (i.e. on
	// each successful connection to the waddell server at addr).
	OnId func(addr string, id PeerId)
	// contains filtered or unexported fields
}

type DialFunc func() (net.Conn, error)

type MessageIn struct {
	From PeerId

	Body []byte
	// contains filtered or unexported fields
}

type MessageOut struct {
	To   PeerId
	Body [][]byte
}

type PeerId buuid.ID

type Server struct {
	// NumBuffers: number of buffers to cache for reading and writing (balances
	// overall memory consumption against CPU usage).  Defaults to 10,000.
	NumBuffers int

	// BufferBytes: size of each buffer (this places a cap on the maxmimum
	// message size that can be transmitted).  Defaults to 65,535.
	BufferBytes int
	// contains filtered or unexported fields
}

type TopicId uint16