redisManager

Documentation

Index

• Constants
• Variables
• type Manager
  • func New(rClient redis.UniversalClient) Manager

Constants

const (
	DocOpsTTL       = 60 * time.Minute
	DocOpsMaxLength = 100
)

const SmoothingOffset = int64(time.Second)

Variables

var ErrUpdateRangeNotAvailable = &errors.UpdateRangeNotAvailableError{}

Types

type Manager

type Manager interface {
	PutDocInMemory(ctx context.Context, projectId sharedTypes.UUID, docId sharedTypes.UUID, doc *types.Doc) error
	RemoveDocFromMemory(ctx context.Context, projectId sharedTypes.UUID, docId sharedTypes.UUID) error
	RemoveDocFromProject(ctx context.Context, projectId, docId sharedTypes.UUID) error
	GetDoc(ctx context.Context, projectId sharedTypes.UUID, docId sharedTypes.UUID) (*types.Doc, error)
	GetDocVersion(ctx context.Context, docId sharedTypes.UUID) (sharedTypes.Version, error)
	GetPreviousDocUpdates(ctx context.Context, docId sharedTypes.UUID, start sharedTypes.Version, end sharedTypes.Version) ([]sharedTypes.DocumentUpdate, error)
	GetPreviousDocUpdatesUnderLock(ctx context.Context, docId sharedTypes.UUID, begin sharedTypes.Version, end sharedTypes.Version, docVersion sharedTypes.Version) ([]sharedTypes.DocumentUpdate, error)
	UpdateDocument(ctx context.Context, docId sharedTypes.UUID, doc *types.Doc, appliedUpdates []sharedTypes.DocumentUpdate) (int64, error)
	RenameDoc(ctx context.Context, projectId sharedTypes.UUID, docId sharedTypes.UUID, doc *types.Doc, newPath sharedTypes.PathName) error
	ClearUnFlushedTime(ctx context.Context, docId sharedTypes.UUID) error
	GetDocIdsInProject(ctx context.Context, projectId sharedTypes.UUID) ([]sharedTypes.UUID, error)
	QueueFlushAndDeleteProject(ctx context.Context, projectId sharedTypes.UUID) error
	GetNextProjectToFlushAndDelete(ctx context.Context, cutoffTime time.Time) (sharedTypes.UUID, int64, int64, error)
}

func New

func New(rClient redis.UniversalClient) Manager