Back to godoc.org

Package sessions

v1.6.1
Latest Go to latest

The highest tagged major version is .

Published: Jul 9, 2019 | License: AGPL-3.0 | Module: github.com/EngineerIG/cells

Overview

Package sessions is used during indexation to start/stop a session an speed-up the process

Index

type BenchBatcher

type BenchBatcher struct {
	// contains filtered or unexported fields
}

func (*BenchBatcher) Flush

func (bb *BenchBatcher) Flush(ctx context.Context, dao index.DAO)

func (*BenchBatcher) Notify

func (bb *BenchBatcher) Notify(topic string, msg interface{})

func (*BenchBatcher) UpdateMPath

func (bb *BenchBatcher) UpdateMPath(path mtree.MPath, deltaSize int64)

type DAO

type DAO interface {
	PutSession(session *tree.IndexationSession) error
	ReadSession(sessionUuid string) (*tree.IndexationSession, SessionBatcher, error)
	DeleteSession(session *tree.IndexationSession) error
	CleanSessions() error
}

type MemoryBatcher

type MemoryBatcher struct {
	// contains filtered or unexported fields
}

func (*MemoryBatcher) Flush

func (b *MemoryBatcher) Flush(ctx context.Context, dao index.DAO)

func (*MemoryBatcher) Notify

func (b *MemoryBatcher) Notify(topic string, msg interface{})

func (*MemoryBatcher) UpdateMPath

func (b *MemoryBatcher) UpdateMPath(path mtree.MPath, deltaSize int64)

type SessionBatcher

type SessionBatcher interface {
	Notify(topic string, msg interface{})
	UpdateMPath(path mtree.MPath, deltaSize int64)
	Flush(ctx context.Context, dao index.DAO)
}

func GetBenchSessionBatcher

func GetBenchSessionBatcher(b SessionBatcher) SessionBatcher

type SessionMemoryStore

type SessionMemoryStore struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewSessionMemoryStore

func NewSessionMemoryStore() *SessionMemoryStore

func (*SessionMemoryStore) CleanSessions

func (s *SessionMemoryStore) CleanSessions() error

func (*SessionMemoryStore) DeleteSession

func (s *SessionMemoryStore) DeleteSession(session *tree.IndexationSession) error

func (*SessionMemoryStore) PutSession

func (s *SessionMemoryStore) PutSession(session *tree.IndexationSession) error

func (*SessionMemoryStore) ReadSession

func (s *SessionMemoryStore) ReadSession(sessionUuid string) (*tree.IndexationSession, SessionBatcher, error)

type StoredEvent

type StoredEvent struct {
	Topic     string
	Msg       interface{}
	EventTime time.Time
}

Package Files

Documentation was rendered with GOOS=linux and GOARCH=amd64.

Jump to identifier

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to identifier