packs

Documentation

Index

• Variables
• func NewPushPullKey(documentKey *key.Key) sync.Key
• func NewSnapshotKey(documentKey *key.Key) sync.Key
• type ServerPack
  • func NewServerPack(key *key.Key, cp *checkpoint.Checkpoint, changeInfos []*db.ChangeInfo, ...) *ServerPack
  • func PushPull(ctx context.Context, be *backend.Backend, clientInfo *db.ClientInfo, ...) (*ServerPack, error)
  • func (p *ServerPack) ChangesLen() int
  • func (p *ServerPack) OperationsLen() int
  • func (p *ServerPack) SnapshotLen() int
  • func (p *ServerPack) ToPBChangePack() (*api.ChangePack, error)

Variables

var (
	// ErrInvalidServerSeq is returned when the given server seq greater than
	// the initial server seq.
	ErrInvalidServerSeq = errors.New("invalid server seq")
)

Functions

func NewPushPullKey

func NewPushPullKey(documentKey *key.Key) sync.Key

NewPushPullKey creates a new sync.Key of PushPull for the given document.

func NewSnapshotKey

func NewSnapshotKey(documentKey *key.Key) sync.Key

NewSnapshotKey creates a new sync.Key of Snapshot for the given document.

Types

type ServerPack

type ServerPack struct {
	// DocumentKey is key of the document.
	DocumentKey *key.Key

	// Checkpoint is used to determine the client received changes.
	Checkpoint *checkpoint.Checkpoint

	// ChangeInfos represents a unit of modification in the document.
	ChangeInfos []*db.ChangeInfo

	// Snapshot is a byte array that encode the document.
	Snapshot []byte

	// MinSyncedTicket is the minimum logical time taken by clients who attach the document.
	// It used to collect garbage on the replica on the client.
	MinSyncedTicket *time.Ticket
}

ServerPack is similar to change.Pack, but has ChangeInfos instead of Changes to reduce type conversion in Agent.

func NewServerPack

func NewServerPack(
	key *key.Key,
	cp *checkpoint.Checkpoint,
	changeInfos []*db.ChangeInfo,
	snapshot []byte,
) *ServerPack

NewServerPack creates a new instance of ServerPack.

func PushPull

func PushPull(
	ctx context.Context,
	be *backend.Backend,
	clientInfo *db.ClientInfo,
	docInfo *db.DocInfo,
	reqPack *change.Pack,
) (*ServerPack, error)

PushPull stores the given changes and returns accumulated changes of the given document.

func (*ServerPack) ChangesLen

func (p *ServerPack) ChangesLen() int

ChangesLen returns the size of the changes.

func (*ServerPack) OperationsLen

func (p *ServerPack) OperationsLen() int

OperationsLen returns the size of the operations.

func (*ServerPack) SnapshotLen

func (p *ServerPack) SnapshotLen() int

SnapshotLen returns the size of the snapshot.

func (*ServerPack) ToPBChangePack

func (p *ServerPack) ToPBChangePack() (*api.ChangePack, error)

ToPBChangePack converts the given model format to Protobuf format.