Documentation
¶
Index ¶
- func NewApiServiceAccess(client service_client.ServiceServiceClient) service.ServiceAccess
- 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() *service.Service
- func (c *WatcherEventChange) GetCurrent() *service.Service
- func (c *WatcherEventChange) GetDeleted() *service.Service
- func (c *WatcherEventChange) GetName() *service.Name
- func (c *WatcherEventChange) GetPrevious() *service.Service
- 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 NewApiServiceAccess ¶
func NewApiServiceAccess(client service_client.ServiceServiceClient) service.ServiceAccess
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 service_client.ServiceServiceClient, params *QueryWatcherParams, evtsChan chan *QueryWatcherEvent) *QueryWatcher
type QueryWatcherEvent ¶
type QueryWatcherParams ¶
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 service_client.ServiceServiceClient, 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 *service.Service_FieldMask OrderBy *service.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 *service.Service) *WatcherEventChange
func NewDeleteWatcherEventChange ¶
func NewDeleteWatcherEventChange(deleted *service.Service) *WatcherEventChange
func NewModifyWatcherEventChange ¶
func NewModifyWatcherEventChange(current, previous *service.Service) *WatcherEventChange
func (*WatcherEventChange) GetAdded ¶
func (c *WatcherEventChange) GetAdded() *service.Service
func (*WatcherEventChange) GetCurrent ¶
func (c *WatcherEventChange) GetCurrent() *service.Service
func (*WatcherEventChange) GetDeleted ¶
func (c *WatcherEventChange) GetDeleted() *service.Service
func (*WatcherEventChange) GetName ¶
func (c *WatcherEventChange) GetName() *service.Name
func (*WatcherEventChange) GetPrevious ¶
func (c *WatcherEventChange) GetPrevious() *service.Service
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 ¶
func (*WatcherFilterParams) String ¶
func (p *WatcherFilterParams) String() string
Click to show internal directories.
Click to hide internal directories.