Documentation ¶
Index ¶
- type SegmentChangesCollection
- func (c *SegmentChangesCollection) Add(item *SegmentChangesItem) error
- func (c *SegmentChangesCollection) ChangeNumber(segment string) int64
- func (c *SegmentChangesCollection) Fetch(name string) (*SegmentChangesItem, error)
- func (c *SegmentChangesCollection) FetchAll() ([]SegmentChangesItem, error)
- func (c *SegmentChangesCollection) SetChangeNumber(segment string, since int64)
- type SegmentChangesItem
- type SegmentKey
- type SplitChangesCollection
- func (c *SplitChangesCollection) Add(item *SplitChangesItem) error
- func (c *SplitChangesCollection) ChangeNumber() int64
- func (c *SplitChangesCollection) Delete(item *SplitChangesItem) error
- func (c *SplitChangesCollection) FetchAll() (SplitsChangesItems, error)
- func (c *SplitChangesCollection) SegmentNames() *set.ThreadUnsafeSet
- func (c *SplitChangesCollection) SetChangeNumber(since int64)
- type SplitChangesItem
- type SplitsChangesItems
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SegmentChangesCollection ¶
type SegmentChangesCollection struct { boltdb.Collection // contains filtered or unexported fields }
SegmentChangesCollection represents a collection of SplitChangesItem
func NewSegmentChangesCollection ¶
func NewSegmentChangesCollection(dbb *bolt.DB) SegmentChangesCollection
NewSegmentChangesCollection returns an instance of SegmentChangesCollection
func (*SegmentChangesCollection) Add ¶
func (c *SegmentChangesCollection) Add(item *SegmentChangesItem) error
Add an item
func (*SegmentChangesCollection) ChangeNumber ¶
func (c *SegmentChangesCollection) ChangeNumber(segment string) int64
ChangeNumber returns changeNumber
func (*SegmentChangesCollection) Fetch ¶
func (c *SegmentChangesCollection) Fetch(name string) (*SegmentChangesItem, error)
Fetch return a SegmentChangesItem
func (*SegmentChangesCollection) FetchAll ¶
func (c *SegmentChangesCollection) FetchAll() ([]SegmentChangesItem, error)
FetchAll return a list of SegmentChangesItem
func (*SegmentChangesCollection) SetChangeNumber ¶
func (c *SegmentChangesCollection) SetChangeNumber(segment string, since int64)
SetChangeNumber sets changeNumber
type SegmentChangesItem ¶
type SegmentChangesItem struct { Name string Keys map[string]SegmentKey }
SegmentChangesItem represents an SplitChanges service response
type SegmentKey ¶
SegmentKey represents a segment key data
type SplitChangesCollection ¶
type SplitChangesCollection struct { boltdb.Collection // contains filtered or unexported fields }
SplitChangesCollection represents a collection of SplitChangesItem
func NewSplitChangesCollection ¶
func NewSplitChangesCollection(dbb *bolt.DB) SplitChangesCollection
NewSplitChangesCollection returns an instance of SplitChangesCollection
func (*SplitChangesCollection) Add ¶
func (c *SplitChangesCollection) Add(item *SplitChangesItem) error
Add an item
func (*SplitChangesCollection) ChangeNumber ¶
func (c *SplitChangesCollection) ChangeNumber() int64
ChangeNumber returns changeNumber
func (*SplitChangesCollection) Delete ¶
func (c *SplitChangesCollection) Delete(item *SplitChangesItem) error
Delete an item
func (*SplitChangesCollection) FetchAll ¶
func (c *SplitChangesCollection) FetchAll() (SplitsChangesItems, error)
FetchAll return a SplitChangesItem
func (*SplitChangesCollection) SegmentNames ¶
func (c *SplitChangesCollection) SegmentNames() *set.ThreadUnsafeSet
SegmentNames returns segments
func (*SplitChangesCollection) SetChangeNumber ¶
func (c *SplitChangesCollection) SetChangeNumber(since int64)
SetChangeNumber sets changeNumber
type SplitChangesItem ¶
type SplitChangesItem struct { ChangeNumber int64 `json:"changeNumber"` Name string `json:"name"` Status string `json:"status"` JSON string }
SplitChangesItem represents an SplitChanges service response
type SplitsChangesItems ¶
type SplitsChangesItems []SplitChangesItem
SplitsChangesItems Sortable list
func (SplitsChangesItems) Len ¶
func (slice SplitsChangesItems) Len() int
func (SplitsChangesItems) Less ¶
func (slice SplitsChangesItems) Less(i, j int) bool
func (SplitsChangesItems) Swap ¶
func (slice SplitsChangesItems) Swap(i, j int)