objectsync

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 9, 2023 License: MIT Imports: 20 Imported by: 0

Documentation

Index

Constants

View Source
const CName = "common.commonspace.objectsync"

Variables

This section is empty.

Functions

This section is empty.

Types

type HandleMessage added in v0.2.0

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 added in v0.2.0

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

type ObjectSync

type ObjectSync interface {
	LastUsage() time.Time
	HandleMessage(ctx context.Context, hm HandleMessage) (err error)
	HandleRequest(ctx context.Context, req *spacesyncproto.ObjectSyncMessage) (resp *spacesyncproto.ObjectSyncMessage, err error)
	CloseThread(id string) (err error)
	app.ComponentRunnable
}

func New added in v0.2.0

func New() ObjectSync

Directories

Path Synopsis
Package mock_objectsync is a generated GoMock package.
Package mock_objectsync is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL