syncer

Documentation

Index

• Constants
• type Syncer
  • func New[T any, V comparable](insert func(ctx context.Context, value T) error, ...) *Syncer[T, V]
  • func (s *Syncer[T, V]) Sync(ctx context.Context, serverData []T, localData []T, ...) (err error)

Constants

const (
	Unchanged = 0
	Insert    = 1
	Update    = 2
	Delete    = 3
)

Types

type Syncer

type Syncer[T any, V comparable] struct {
	// contains filtered or unexported fields
}

func New

func New[T any, V comparable](
	insert func(ctx context.Context, value T) error,
	delete func(ctx context.Context, value T) error,
	update func(ctx context.Context, server T, local T) error,
	uuid func(value T) V,
	equal func(a T, b T) bool,
	notice func(ctx context.Context, state int, server, local T) error,
) *Syncer[T, V]

func (*Syncer[T, V]) Sync

func (s *Syncer[T, V]) Sync(ctx context.Context, serverData []T, localData []T, notice func(ctx context.Context, state int, server, local T) error, noDel ...bool) (err error)