Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BroadcastOptions ¶
type BroadcastOptions struct {
EmptyPeers []string
}
type HeadUpdate ¶
type HeadUpdate struct {
Meta ObjectMeta
Bytes []byte
Update InnerHeadUpdate
}
func (*HeadUpdate) MsgSize ¶
func (h *HeadUpdate) MsgSize() uint64
func (*HeadUpdate) ObjectId ¶
func (h *HeadUpdate) ObjectId() string
func (*HeadUpdate) PeerId ¶
func (h *HeadUpdate) PeerId() string
func (*HeadUpdate) ProtoMessage ¶
func (h *HeadUpdate) ProtoMessage() (proto.Message, error)
func (*HeadUpdate) SetPeerId ¶
func (h *HeadUpdate) SetPeerId(peerId string)
func (*HeadUpdate) SetProtoMessage ¶
func (h *HeadUpdate) SetProtoMessage(message proto.Message) error
type InnerHeadUpdate ¶
type InnerHeadUpdate interface {
Marshall(data ObjectMeta) ([]byte, error)
Heads() []string
MsgSize() uint64
}
type InnerRequest ¶
type ObjectMeta ¶
type Request ¶
type Request struct {
Inner InnerRequest
Bytes []byte
// contains filtered or unexported fields
}
func NewByteRequest ¶
func NewRequest ¶
func NewRequest(peerId, spaceId, objectId string, inner InnerRequest) *Request
Click to show internal directories.
Click to hide internal directories.