realTimeRedisManager

Documentation

Index

• type Manager
  • func New(client redis.UniversalClient) (Manager, error)

Types

type Manager

type Manager interface {
	ConfirmUpdates(ctx context.Context, projectId sharedTypes.UUID, processed []sharedTypes.DocumentUpdate) error
	GetPendingUpdatesForDoc(ctx context.Context, docId sharedTypes.UUID) ([]sharedTypes.DocumentUpdate, error)
	GetUpdatesLength(ctx context.Context, docId sharedTypes.UUID) (int64, error)
	QueueUpdate(ctx context.Context, docId sharedTypes.UUID, update sharedTypes.DocumentUpdate) error
	ReportError(ctx context.Context, projectId, docId sharedTypes.UUID, err error) error
}

func New

func New(client redis.UniversalClient) (Manager, error)