syncdeps

Aug 28, 2024

Changes in this version

+ const CName

+ const MsgTypeIncoming

+ const MsgTypeIncomingRequest

+ const MsgTypeOutgoing

+ const MsgTypeOutgoingRequest

+ const MsgTypeReceivedResponse

+ const MsgTypeSentResponse

+ type Message interface

+ MsgSize func() uint64

+ ObjectId func() string

+ type ObjectSyncHandler interface

+ HandleDeprecatedRequest func(ctx context.Context, req *spacesyncproto.ObjectSyncMessage) (resp *spacesyncproto.ObjectSyncMessage, err error)

+ HandleHeadUpdate func(ctx context.Context, statusUpdater syncstatus.StatusUpdater, ...) (Request, error)

+ HandleResponse func(ctx context.Context, peerId, objectId string, resp Response) error

+ HandleStreamRequest func(ctx context.Context, rq Request, updater QueueSizeUpdater, ...) (Request, error)

+ ResponseCollector func() ResponseCollector

+ type QueueSizeUpdater interface

+ UpdateQueueSize func(size uint64, msgType int, add bool)

+ type Request interface

+ MsgSize func() uint64

+ ObjectId func() string

+ PeerId func() string

+ Proto func() (proto.Message, error)

+ type RequestSender interface

+ SendRequest func(ctx context.Context, rq Request, collector ResponseCollector) error

+ type Response interface

+ type ResponseCollector interface

+ CollectResponse func(ctx context.Context, peerId, objectId string, resp Response) error

+ NewResponse func() Response

+ type SyncHandler interface

+ ApplyRequest func(ctx context.Context, rq Request, requestSender RequestSender) error

+ HandleDeprecatedObjectSync func(ctx context.Context, req *spacesyncproto.ObjectSyncMessage) (resp *spacesyncproto.ObjectSyncMessage, err error)

+ HandleHeadUpdate func(ctx context.Context, headUpdate drpc.Message) (Request, error)

+ HandleStreamRequest func(ctx context.Context, rq Request, updater QueueSizeUpdater, ...) (Request, error)

+ SendStreamRequest func(ctx context.Context, rq Request, receive func(stream drpc.Stream) error) (err error)