documentlog

package

Go to main page

Versions in this module

v0

v0.16.0

Jan 12, 2021

Changes in this version

type MockDocumentLog

+ func (m *MockDocumentLog) FindByContentsHash(hash model.Hash) ([]model.DocumentDescriptor, error)

type MockDocumentLogMockRecorder

+ func (mr *MockDocumentLogMockRecorder) FindByContentsHash(hash interface{}) *gomock.Call

+ type MockPublisher struct

+ func NewMockPublisher(ctrl *gomock.Controller) *MockPublisher

+ func (m *MockPublisher) EXPECT() *MockPublisherMockRecorder

+ func (m *MockPublisher) Subscribe(documentType string) DocumentQueue

+ type MockPublisherMockRecorder struct

+ func (mr *MockPublisherMockRecorder) Subscribe(documentType interface{}) *gomock.Call

v0.15.4

Nov 12, 2020

v0.15.3

Nov 12, 2020

v0.15.2

Nov 11, 2020

v0.15.1

Sep 30, 2020

v0.15.0

Sep 30, 2020

Changes in this version

+ var AdvertHashInterval = 2 * time.Second

+ var ErrMissingDocumentContents = errors.New("we don't have the contents for the document (yet)")

+ var ErrUnknownDocument = errors.New("unknown document")

+ type ConsistencyHashListStatistic struct

+ Hashes []string

+ func (d ConsistencyHashListStatistic) Name() string

+ func (d ConsistencyHashListStatistic) String() string

+ type DocumentLog interface

+ Configure func(store store.DocumentStore)

+ Start func()

+ Stop func()

+ func NewDocumentLog(protocol proto.Protocol) DocumentLog

+ type DocumentQueue interface

+ Get func() *model.Document

+ type LastConsistencyHashStatistic struct

+ Hash model.Hash

+ func (d LastConsistencyHashStatistic) Name() string

+ func (d LastConsistencyHashStatistic) String() string

+ type LogSizeStatistic struct

+ func (d LogSizeStatistic) Name() string

+ func (d LogSizeStatistic) String() string

+ type MockDocumentLog struct

+ func NewMockDocumentLog(ctrl *gomock.Controller) *MockDocumentLog

+ func (m *MockDocumentLog) AddDocument(arg0 model.Document) error

+ func (m *MockDocumentLog) AddDocumentContents(hash model.Hash, contents io.Reader) (*model.Document, error)

+ func (m *MockDocumentLog) AddDocumentWithContents(timestamp time.Time, documentType string, contents io.Reader) (*model.Document, error)

+ func (m *MockDocumentLog) Configure(store store.DocumentStore)

+ func (m *MockDocumentLog) Documents() ([]model.DocumentDescriptor, error)

+ func (m *MockDocumentLog) EXPECT() *MockDocumentLogMockRecorder

+ func (m *MockDocumentLog) GetDocument(hash model.Hash) (*model.DocumentDescriptor, error)

+ func (m *MockDocumentLog) GetDocumentContents(hash model.Hash) (io.ReadCloser, error)

+ func (m *MockDocumentLog) HasContentsForDocument(hash model.Hash) (bool, error)

+ func (m *MockDocumentLog) Start()

+ func (m *MockDocumentLog) Statistics() []stats.Statistic

+ func (m *MockDocumentLog) Stop()

+ func (m *MockDocumentLog) Subscribe(documentType string) DocumentQueue

+ type MockDocumentLogMockRecorder struct

+ func (mr *MockDocumentLogMockRecorder) AddDocument(arg0 interface{}) *gomock.Call

+ func (mr *MockDocumentLogMockRecorder) AddDocumentContents(hash, contents interface{}) *gomock.Call

+ func (mr *MockDocumentLogMockRecorder) AddDocumentWithContents(timestamp, documentType, contents interface{}) *gomock.Call

+ func (mr *MockDocumentLogMockRecorder) Configure(store interface{}) *gomock.Call

+ func (mr *MockDocumentLogMockRecorder) Documents() *gomock.Call

+ func (mr *MockDocumentLogMockRecorder) GetDocument(hash interface{}) *gomock.Call

+ func (mr *MockDocumentLogMockRecorder) GetDocumentContents(hash interface{}) *gomock.Call

+ func (mr *MockDocumentLogMockRecorder) HasContentsForDocument(hash interface{}) *gomock.Call

+ func (mr *MockDocumentLogMockRecorder) Start() *gomock.Call

+ func (mr *MockDocumentLogMockRecorder) Statistics() *gomock.Call

+ func (mr *MockDocumentLogMockRecorder) Stop() *gomock.Call

+ func (mr *MockDocumentLogMockRecorder) Subscribe(documentType interface{}) *gomock.Call

+ type MockDocumentQueue struct

+ func NewMockDocumentQueue(ctrl *gomock.Controller) *MockDocumentQueue

+ func (m *MockDocumentQueue) EXPECT() *MockDocumentQueueMockRecorder

+ func (m *MockDocumentQueue) Get() *model.Document

+ type MockDocumentQueueMockRecorder struct

+ func (mr *MockDocumentQueueMockRecorder) Get() *gomock.Call

+ type NumberOfDocumentsStatistic struct

+ NumberOfDocuments int

+ func (d NumberOfDocumentsStatistic) Name() string

+ func (d NumberOfDocumentsStatistic) String() string

+ type Publisher interface

+ Subscribe func(documentType string) DocumentQueue

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL