source

Documentation

Index

• type Handler
• type HandlerBuilder
• type Info
• type InfoFn
• type Manager
  • func NewManager() *Manager
  • func (m *Manager) AddDocumentDetails(d *watcherpb.DocumentDetails)
  • func (m *Manager) Collect(s *watcherpb.WatcherDetails) (*Manager, error)
  • func (m *Manager) Difference(current *watcherpb.Index) *Manager
  • func (m *Manager) GetIndex() *watcherpb.Index
  • func (m *Manager) MergeIndex(newIndex *Manager) error
  • func (m *Manager) SetCount(n int)
• type NewBuilderrFn

Types

type Handler

type Handler interface {
	Parse(context.Context, *v1.Source) (*Manager, error)
}

type HandlerBuilder

type HandlerBuilder interface {
	Validate() error
	Build() (Handler, error)
}

type Info

type Info struct {
	Name        string
	Impl        string
	Description string
	NewBuilder  NewBuilderrFn
}

type InfoFn

type InfoFn func() Info

type Manager

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

func NewManager

func NewManager() *Manager

func (*Manager) AddDocumentDetails

func (m *Manager) AddDocumentDetails(d *watcherpb.DocumentDetails)

func (*Manager) Collect

func (m *Manager) Collect(s *watcherpb.WatcherDetails) (*Manager, error)

Collect will fetch all documents found missing for the given syncronisation process

func (*Manager) Difference

func (m *Manager) Difference(current *watcherpb.Index) *Manager

func (*Manager) GetIndex

func (m *Manager) GetIndex() *watcherpb.Index

func (*Manager) MergeIndex

func (m *Manager) MergeIndex(newIndex *Manager) error

UpdateIndex reconcile and update two index with newly discovered contents

func (*Manager) SetCount

func (m *Manager) SetCount(n int)

type NewBuilderrFn

type NewBuilderrFn func() HandlerBuilder