Versions in this module Expand all Collapse all v1 v1.9.1 Dec 19, 2024 v1.9.0 Dec 16, 2024 Changes in this version + func NewApiTimeSeriesForwarderSinkAccess(client time_series_forwarder_sink_client.TimeSeriesForwarderSinkServiceClient) time_series_forwarder_sink.TimeSeriesForwarderSinkAccess + type QueryWatcher struct + func NewQueryWatcher(id int, ...) *QueryWatcher + func NewQueryWatcherWithIChan(id int, ...) *QueryWatcher + func (qw *QueryWatcher) QueryWatcher() + func (qw *QueryWatcher) Run(ctx context.Context) error + type QueryWatcherEvent struct + Changes []*time_series_forwarder_sink.TimeSeriesForwarderSinkChange + CheckSize bool + Identifier int + InSync bool + LostSync bool + Reset bool + SnapshotSize int64 + func (e *QueryWatcherEvent) GetChanges() gotenresource.ResourceChangeList + func (e *QueryWatcherEvent) GetSnapshotSize() int64 + func (e *QueryWatcherEvent) GetWatcherIdentifier() int + func (e *QueryWatcherEvent) HasSnapshotSize() bool + func (e *QueryWatcherEvent) IsLostSync() bool + func (e *QueryWatcherEvent) IsReset() bool + func (e *QueryWatcherEvent) IsSync() bool + type QueryWatcherParams struct + ChunkSize int + Cursor *time_series_forwarder_sink.PagerCursor + FieldMask *time_series_forwarder_sink.TimeSeriesForwarderSink_FieldMask + Filter *time_series_forwarder_sink.Filter + OrderBy *time_series_forwarder_sink.OrderBy + PageSize int + Parent *time_series_forwarder_sink.ParentName + RecoveryDeadline time.Duration + RetryTimeout time.Duration + StartingTime *timestamppb.Timestamp + View view.View + WatchType watch_type.WatchType + type Watcher struct + func NewWatcher(client time_series_forwarder_sink_client.TimeSeriesForwarderSinkServiceClient, ...) *Watcher + func (pw *Watcher) Events() <-chan WatcherEvent + func (pw *Watcher) GetFilters() []*WatcherFilterParams + func (pw *Watcher) GetIFilters() []gotenaccess.WatcherFilterParams + func (pw *Watcher) IEvents() <-chan gotenaccess.WatcherEvent + func (pw *Watcher) InSync() bool + func (pw *Watcher) ResetFilters(ctx context.Context, filters ...*WatcherFilterParams) (int32, error) + func (pw *Watcher) ResetIFilters(ctx context.Context, filters ...gotenaccess.WatcherFilterParams) (int32, error) + func (pw *Watcher) Run(ctx context.Context) error + type WatcherConfig struct + ChunkSize int + FieldMask *time_series_forwarder_sink.TimeSeriesForwarderSink_FieldMask + OrderBy *time_series_forwarder_sink.OrderBy + View view.View + WatchType watch_type.WatchType + type WatcherEvent struct + Changes []*WatcherEventChange + 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 struct + func NewAddWatcherEventChange(resource *time_series_forwarder_sink.TimeSeriesForwarderSink) *WatcherEventChange + func NewDeleteWatcherEventChange(deleted *time_series_forwarder_sink.TimeSeriesForwarderSink) *WatcherEventChange + func NewModifyWatcherEventChange(current, previous *time_series_forwarder_sink.TimeSeriesForwarderSink) *WatcherEventChange + func (c *WatcherEventChange) GetAdded() *time_series_forwarder_sink.TimeSeriesForwarderSink + func (c *WatcherEventChange) GetCurrent() *time_series_forwarder_sink.TimeSeriesForwarderSink + func (c *WatcherEventChange) GetDeleted() *time_series_forwarder_sink.TimeSeriesForwarderSink + func (c *WatcherEventChange) GetName() *time_series_forwarder_sink.Name + func (c *WatcherEventChange) GetPrevious() *time_series_forwarder_sink.TimeSeriesForwarderSink + 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 struct + Filter *time_series_forwarder_sink.Filter + Parent *time_series_forwarder_sink.ParentName + func (p *WatcherFilterParams) GetIFilter() gotenresource.Filter + func (p *WatcherFilterParams) GetIParentName() gotenresource.Name + func (p *WatcherFilterParams) String() string
Go to main page