Documentation ¶
Index ¶
- Variables
- func CompareBuckets(origin Bucket, destination Bucket) ([]Task, []Task, []Task, []error)
- func FetchAndSave(ctx context.Context, wg *sync.WaitGroup, workerId int, ...)
- func GenerateInsight(ctx context.Context, wg *sync.WaitGroup, workerId int, v *vault.Client, ...)
- func InfoFromConsul(c *consul.Client, i *Info, syncPath string) (err error)
- func InfoToConsul(c *consul.Client, i *Info, syncPath string) error
- type Bucket
- type Info
- func (origin *Info) Compare(destination *Info) ([]Task, []Task, []Task, []error)
- func (i *Info) Delete(path string) (int, error)
- func (i *Info) GetBucket(id int) (Bucket, error)
- func (i *Info) GetIndex() ([]string, error)
- func (i *Info) Put(path string, insight Insight) (int, error)
- func (i *Info) Reindex() error
- type Insight
- type KVV2Meta
- type Task
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidPath = fmt.Errorf("invalid vault kv path") ErrTransform = fmt.Errorf("transform error") ErrInvalidMeta = fmt.Errorf("invalid vault meta") ErrInvalidInfo = fmt.Errorf("invalid sync info") ErrInvalidBucket = fmt.Errorf("invalid sync info bucket") ErrInvalidIndex = fmt.Errorf("invalid sync info index") ErrInvalidInsight = fmt.Errorf("invalid insight") ErrUnknownOp = fmt.Errorf("unknown operation") ErrCorrupted = fmt.Errorf("I got ¡™£¢∞NeuRALyzED§¶•ªº! Sync info in corrupted state") ErrInitialize = fmt.Errorf("Nope, not gonna work! Sync info not initialized") )
View Source
var IgnoreDeletes = false
Functions ¶
func CompareBuckets ¶
func FetchAndSave ¶
func GenerateInsight ¶
Types ¶
Click to show internal directories.
Click to hide internal directories.