Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Payload ¶
type Payload interface {
// Metadata returns raw metadata bytes.
// The ok result indicates whether metadata exists.
Metadata() (metadata []byte, ok bool)
// MetadataUTF8 returns metadata as UTF8 string.
// The ok result indicates whether metadata exists.
MetadataUTF8() (metadata string, ok bool)
// Data returns raw data bytes.
Data() []byte
// DataUTF8 returns data as UTF8 string.
DataUTF8() string
// Release release all resources of payload.
// Some payload implements is pooled, so you must release resoures after using it.
Release()
}
Payload is a stream message (upstream or downstream). It contains data associated with a stream created by a previous request. In Reactive Streams and Rx this is the 'onNext' event.
func MustNewFile ¶
MustNewFile create a new payload from file.
type SetupPayload ¶
type SetupPayload interface {
Payload
// DataMimeType returns MIME type of data.
DataMimeType() string
// MetadataMimeType returns MIME type of metadata.
MetadataMimeType() string
// TimeBetweenKeepalive returns interval duration of keepalive.
TimeBetweenKeepalive() time.Duration
// MaxLifetime returns max lifetime of RSocket connection.
MaxLifetime() time.Duration
// Version return RSocket protocol version.
Version() common.Version
}
SetupPayload is particular payload for RSocket Setup.
Click to show internal directories.
Click to hide internal directories.