Documentation ¶
Index ¶
- func NewApiDistributionAccess(client distribution_client.DistributionServiceClient) distribution.DistributionAccess
- type QueryWatcher
- type QueryWatcherEvent
- type QueryWatcherParams
- type Watcher
- type WatcherConfig
- type WatcherEvent
- func (e *WatcherEvent) AppendChange(change *WatcherEventChange)
- func (e *WatcherEvent) AppendRawChange(change gotenaccess.WatcherEventChange)
- func (e *WatcherEvent) GetAt(index int) *WatcherEventChange
- func (e *WatcherEvent) GetRawAt(index int) gotenaccess.WatcherEventChange
- func (e *WatcherEvent) Length() int
- func (e *WatcherEvent) Merge(src *WatcherEvent)
- type WatcherEventChange
- func (c *WatcherEventChange) GetAdded() *distribution.Distribution
- func (c *WatcherEventChange) GetCurrent() *distribution.Distribution
- func (c *WatcherEventChange) GetDeleted() *distribution.Distribution
- func (c *WatcherEventChange) GetName() *distribution.Name
- func (c *WatcherEventChange) GetPrevious() *distribution.Distribution
- func (c *WatcherEventChange) GetRawAdded() gotenresource.Resource
- func (c *WatcherEventChange) GetRawCurrent() gotenresource.Resource
- func (c *WatcherEventChange) GetRawDeleted() gotenresource.Resource
- func (c *WatcherEventChange) GetRawName() gotenresource.Name
- func (c *WatcherEventChange) GetRawPrevious() gotenresource.Resource
- func (c *WatcherEventChange) IsAdd() bool
- func (c *WatcherEventChange) IsDelete() bool
- func (c *WatcherEventChange) IsModify() bool
- type WatcherFilterParams
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewApiDistributionAccess ¶
func NewApiDistributionAccess(client distribution_client.DistributionServiceClient) distribution.DistributionAccess
Types ¶
type QueryWatcher ¶
type QueryWatcher struct {
// contains filtered or unexported fields
}
QueryWatcher is a low-level, stateless watcher. Initial updates are sent in chunks. Once snapshot is complete, further changes are incremental - unless Reset flag is set, in which case another snapshot is received.
func NewQueryWatcher ¶
func NewQueryWatcher(id int, client distribution_client.DistributionServiceClient, params *QueryWatcherParams, evtsChan chan *QueryWatcherEvent) *QueryWatcher
type QueryWatcherEvent ¶
type QueryWatcherEvent struct { Identifier int Changes []*distribution.DistributionChange Reset bool LostSync bool InSync bool SnapshotSize int64 CheckSize bool }
type QueryWatcherParams ¶
type QueryWatcherParams struct { Parent *distribution.ParentReference Filter *distribution.Filter View view.View FieldMask *distribution.Distribution_FieldMask OrderBy *distribution.OrderBy Cursor *distribution.PagerCursor ChunkSize int PageSize int WatchType watch_type.WatchType RecoveryDeadline time.Duration RetryTimeout time.Duration }
type Watcher ¶
type Watcher struct {
// contains filtered or unexported fields
}
Watcher is higher level stateful watcher with dynamic + multi filter support.
func NewWatcher ¶
func NewWatcher(client distribution_client.DistributionServiceClient, config *WatcherConfig, filters ...*WatcherFilterParams) *Watcher
func (*Watcher) Events ¶
func (pw *Watcher) Events() <-chan WatcherEvent
func (*Watcher) GetFilters ¶
func (pw *Watcher) GetFilters() []*WatcherFilterParams
func (*Watcher) ResetFilters ¶
func (pw *Watcher) ResetFilters(ctx context.Context, filters ...*WatcherFilterParams) error
type WatcherConfig ¶
type WatcherConfig struct { *gotenaccess.WatcherConfig // common params that must be shared across queries WatchType watch_type.WatchType View view.View FieldMask *distribution.Distribution_FieldMask OrderBy *distribution.OrderBy ChunkSize int }
type WatcherEvent ¶
type WatcherEvent struct { gotenaccess.WatcherEventbase Changes []*WatcherEventChange }
func (*WatcherEvent) AppendChange ¶
func (e *WatcherEvent) AppendChange(change *WatcherEventChange)
func (*WatcherEvent) AppendRawChange ¶
func (e *WatcherEvent) AppendRawChange(change gotenaccess.WatcherEventChange)
func (*WatcherEvent) GetAt ¶
func (e *WatcherEvent) GetAt(index int) *WatcherEventChange
func (*WatcherEvent) GetRawAt ¶
func (e *WatcherEvent) GetRawAt(index int) gotenaccess.WatcherEventChange
func (*WatcherEvent) Length ¶
func (e *WatcherEvent) Length() int
func (*WatcherEvent) Merge ¶
func (e *WatcherEvent) Merge(src *WatcherEvent)
Merge makes a shallow merge of two events
type WatcherEventChange ¶
type WatcherEventChange struct {
// contains filtered or unexported fields
}
func NewAddWatcherEventChange ¶
func NewAddWatcherEventChange(resource *distribution.Distribution) *WatcherEventChange
func NewDeleteWatcherEventChange ¶
func NewDeleteWatcherEventChange(deleted *distribution.Distribution) *WatcherEventChange
func NewModifyWatcherEventChange ¶
func NewModifyWatcherEventChange(current, previous *distribution.Distribution) *WatcherEventChange
func (*WatcherEventChange) GetAdded ¶
func (c *WatcherEventChange) GetAdded() *distribution.Distribution
func (*WatcherEventChange) GetCurrent ¶
func (c *WatcherEventChange) GetCurrent() *distribution.Distribution
func (*WatcherEventChange) GetDeleted ¶
func (c *WatcherEventChange) GetDeleted() *distribution.Distribution
func (*WatcherEventChange) GetName ¶
func (c *WatcherEventChange) GetName() *distribution.Name
func (*WatcherEventChange) GetPrevious ¶
func (c *WatcherEventChange) GetPrevious() *distribution.Distribution
func (*WatcherEventChange) GetRawAdded ¶
func (c *WatcherEventChange) GetRawAdded() gotenresource.Resource
func (*WatcherEventChange) GetRawCurrent ¶
func (c *WatcherEventChange) GetRawCurrent() gotenresource.Resource
func (*WatcherEventChange) GetRawDeleted ¶
func (c *WatcherEventChange) GetRawDeleted() gotenresource.Resource
func (*WatcherEventChange) GetRawName ¶
func (c *WatcherEventChange) GetRawName() gotenresource.Name
func (*WatcherEventChange) GetRawPrevious ¶
func (c *WatcherEventChange) GetRawPrevious() gotenresource.Resource
func (*WatcherEventChange) IsAdd ¶
func (c *WatcherEventChange) IsAdd() bool
func (*WatcherEventChange) IsDelete ¶
func (c *WatcherEventChange) IsDelete() bool
func (*WatcherEventChange) IsModify ¶
func (c *WatcherEventChange) IsModify() bool
type WatcherFilterParams ¶
type WatcherFilterParams struct { Parent *distribution.ParentReference Filter *distribution.Filter }
func (*WatcherFilterParams) String ¶
func (p *WatcherFilterParams) String() string
Click to show internal directories.
Click to hide internal directories.