project_access

Mar 29, 2024

Changes in this version

+ func NewApiProjectAccess(client project_client.ProjectServiceClient) project.ProjectAccess

+ type QueryWatcher struct

+ func NewQueryWatcher(id int, client project_client.ProjectServiceClient, params *QueryWatcherParams, ...) *QueryWatcher

+ func NewQueryWatcherWithIChan(id int, client project_client.ProjectServiceClient, params *QueryWatcherParams, ...) *QueryWatcher

+ func (qw *QueryWatcher) QueryWatcher()

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

+ type QueryWatcherEvent struct

+ Changes []*project.ProjectChange

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

+ FieldMask *project.Project_FieldMask

+ Filter *project.Filter

+ OrderBy *project.OrderBy

+ PageSize int

+ RecoveryDeadline time.Duration

+ RetryTimeout time.Duration

+ StartingTime *timestamppb.Timestamp

+ View view.View

+ WatchType watch_type.WatchType

+ type Watcher struct

+ func NewWatcher(client project_client.ProjectServiceClient, config *WatcherConfig, ...) *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 *project.Project_FieldMask

+ OrderBy *project.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 *project.Project) *WatcherEventChange

+ func NewDeleteWatcherEventChange(deleted *project.Project) *WatcherEventChange

+ func NewModifyWatcherEventChange(current, previous *project.Project) *WatcherEventChange

+ func (c *WatcherEventChange) GetAdded() *project.Project

+ func (c *WatcherEventChange) GetCurrent() *project.Project

+ func (c *WatcherEventChange) GetDeleted() *project.Project

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

+ func (c *WatcherEventChange) GetPrevious() *project.Project

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

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

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

+ func (p *WatcherFilterParams) String() string