sessions

Documentation

Overview

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

Index

• type BenchBatcher
  • func (bb *BenchBatcher) Flush(ctx context.Context, dao index.DAO)
  • func (bb *BenchBatcher) Notify(topic string, msg interface{})
  • func (bb *BenchBatcher) UpdateMPath(path mtree.MPath, deltaSize int64)
• type DAO
• type MemoryBatcher
  • func (b *MemoryBatcher) Flush(ctx context.Context, dao index.DAO)
  • func (b *MemoryBatcher) Notify(topic string, msg interface{})
  • func (b *MemoryBatcher) UpdateMPath(path mtree.MPath, deltaSize int64)
• type SessionBatcher
  • func GetBenchSessionBatcher(b SessionBatcher) SessionBatcher
• type SessionMemoryStore
  • func NewSessionMemoryStore() *SessionMemoryStore
  • func (s *SessionMemoryStore) CleanSessions() error
  • func (s *SessionMemoryStore) DeleteSession(session *tree.IndexationSession) error
  • func (s *SessionMemoryStore) PutSession(session *tree.IndexationSession) error
  • func (s *SessionMemoryStore) ReadSession(sessionUuid string) (*tree.IndexationSession, SessionBatcher, error)
• type StoredEvent

Types

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
}