transport

type Encoder interface {
	MarshalAuth(device, token string, offset int64) ([]byte, error)
	MarshalMessage(id, sender, recipient, mtype string, priority int, ciphertext []byte) ([]byte, error)
	UnmarshalHeader(data []byte) (Header, error)
	UnmarshalNotification(data []byte) (Notification, error)
	UnmarshalMessage(data []byte) (Message, int64, int64, error)
}

type Header interface {
	Id() []byte
	Msgtype() msgprotov2.MsgType
}

type Message interface {
	Id() []byte
	Sender() []byte
	Recipient() []byte
	CiphertextBytes() []byte
}

type Metadata interface {
	Offset() int64
	Timestamp() int64
}

type Notification interface {
	Id() []byte
	Msgtype() msgprotov2.MsgType
	Error() []byte
}

type Rest struct {
	// contains filtered or unexported fields
}

type RestConfig struct {
	SelfID     string
	KeyID      string
	PrivateKey ed25519.PrivateKey
	APIURL     string
	Client     *http.Client
}

type Websocket struct {
	// contains filtered or unexported fields
}

type WebsocketConfig struct {
	MessagingURL string
	SelfID       string
	DeviceID     string
	KeyID        string
	Offset       int64
	PrivateKey   ed25519.PrivateKey
	TCPDeadline  time.Duration
	InboxSize    int
	OnConnect    func()
	OnDisconnect func(err error)
	OnPing       func()
	// contains filtered or unexported fields
}