sync

Documentation

Index

• Constants
• Variables
• type HandleMessage
  • func (m HandleMessage) LogFields(fields ...zap.Field) []zap.Field
• type RequestManager
  • func NewRequestManager(handler syncdeps.SyncHandler, metric syncdeps.QueueSizeUpdater, ...) RequestManager
• type StreamResponse
• type SyncService
  • func NewSyncService() SyncService

Constants

const CName = "common.commonspace.sync"

Variables

var ErrUnexpectedMessage = errors.New("unexpected message")

Types

type HandleMessage

type HandleMessage struct {
	Id                uint64
	ReceiveTime       time.Time
	StartHandlingTime time.Time
	Deadline          time.Time
	SenderId          string
	Message           *spacesyncproto.ObjectSyncMessage
	PeerCtx           context.Context
}

func (HandleMessage) LogFields

func (m HandleMessage) LogFields(fields ...zap.Field) []zap.Field

type RequestManager

type RequestManager interface {
	QueueRequest(rq syncdeps.Request) error
	SendRequest(ctx context.Context, rq syncdeps.Request, collector syncdeps.ResponseCollector) error
	HandleStreamRequest(ctx context.Context, rq syncdeps.Request, stream drpc.Stream) error
	Close()
}

func NewRequestManager

func NewRequestManager(handler syncdeps.SyncHandler, metric syncdeps.QueueSizeUpdater, requestPool syncqueues.ActionPool, limit *syncqueues.Limit) RequestManager

type StreamResponse

type StreamResponse struct {
	Stream     drpc.Stream
	Connection drpc.Conn
}

type SyncService

type SyncService interface {
	app.Component
	BroadcastMessage(ctx context.Context, msg drpc.Message) error
	HandleStreamRequest(ctx context.Context, req syncdeps.Request, stream drpc.Stream) error
	HandleMessage(ctx context.Context, msg drpc.Message) error
	SendRequest(ctx context.Context, rq syncdeps.Request, collector syncdeps.ResponseCollector) error
	QueueRequest(ctx context.Context, rq syncdeps.Request) error
	CloseReceiveQueue(id string) error
}

func NewSyncService

func NewSyncService() SyncService