notification_channel_access

Mar 29, 2024

Changes in this version

type WatcherFilterParams

+ func (p *WatcherFilterParams) GetIParentName() gotenresource.Name

Feb 22, 2023

Changes in this version

+ func NewApiNotificationChannelAccess(client notification_channel_client.NotificationChannelServiceClient) notification_channel.NotificationChannelAccess

+ type QueryWatcher struct

+ func NewQueryWatcher(id int, client notification_channel_client.NotificationChannelServiceClient, ...) *QueryWatcher

+ func NewQueryWatcherWithIChan(id int, client notification_channel_client.NotificationChannelServiceClient, ...) *QueryWatcher

+ func (qw *QueryWatcher) QueryWatcher()

+ func (qw *QueryWatcher) Run(ctx context.Context) error

+ type QueryWatcherEvent struct

+ Changes []*notification_channel.NotificationChannelChange

+ 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 *notification_channel.PagerCursor

+ FieldMask *notification_channel.NotificationChannel_FieldMask

+ Filter *notification_channel.Filter

+ OrderBy *notification_channel.OrderBy

+ PageSize int

+ Parent *notification_channel.ParentReference

+ RecoveryDeadline time.Duration

+ RetryTimeout time.Duration

+ StartingTime *timestamppb.Timestamp

+ View view.View

+ WatchType watch_type.WatchType

+ type Watcher struct

+ func NewWatcher(client notification_channel_client.NotificationChannelServiceClient, ...) *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) error

+ func (pw *Watcher) ResetIFilters(ctx context.Context, filters ...gotenaccess.WatcherFilterParams) error

+ func (pw *Watcher) Run(ctx context.Context) error

+ type WatcherConfig struct

+ ChunkSize int

+ FieldMask *notification_channel.NotificationChannel_FieldMask

+ OrderBy *notification_channel.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 *notification_channel.NotificationChannel) *WatcherEventChange

+ func NewDeleteWatcherEventChange(deleted *notification_channel.NotificationChannel) *WatcherEventChange

+ func NewModifyWatcherEventChange(current, previous *notification_channel.NotificationChannel) *WatcherEventChange

+ func (c *WatcherEventChange) GetAdded() *notification_channel.NotificationChannel

+ func (c *WatcherEventChange) GetCurrent() *notification_channel.NotificationChannel

+ func (c *WatcherEventChange) GetDeleted() *notification_channel.NotificationChannel

+ func (c *WatcherEventChange) GetName() *notification_channel.Name

+ func (c *WatcherEventChange) GetPrevious() *notification_channel.NotificationChannel

+ 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 *notification_channel.Filter

+ Parent *notification_channel.ParentReference

+ func (p *WatcherFilterParams) GetIFilter() gotenresource.Filter

+ func (p *WatcherFilterParams) GetIParentRef() gotenresource.Reference

+ func (p *WatcherFilterParams) String() string