Documentation
¶
Index ¶
- func NewApiAttestationDomainAccess(client attestation_domain_client.AttestationDomainServiceClient) attestation_domain.AttestationDomainAccess
- type QueryWatcher
- type QueryWatcherEvent
- type QueryWatcherParams
- type 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
- 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 NewAddWatcherEventChange(resource *attestation_domain.AttestationDomain) *WatcherEventChange
- func NewDeleteWatcherEventChange(deleted *attestation_domain.AttestationDomain) *WatcherEventChange
- func NewModifyWatcherEventChange(current, previous *attestation_domain.AttestationDomain) *WatcherEventChange
- func (c *WatcherEventChange) GetAdded() *attestation_domain.AttestationDomain
- func (c *WatcherEventChange) GetCurrent() *attestation_domain.AttestationDomain
- func (c *WatcherEventChange) GetDeleted() *attestation_domain.AttestationDomain
- func (c *WatcherEventChange) GetName() *attestation_domain.Name
- func (c *WatcherEventChange) GetPrevious() *attestation_domain.AttestationDomain
- 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 NewApiAttestationDomainAccess ¶
func NewApiAttestationDomainAccess(client attestation_domain_client.AttestationDomainServiceClient) attestation_domain.AttestationDomainAccess
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 attestation_domain_client.AttestationDomainServiceClient, params *QueryWatcherParams, evtsChan chan *QueryWatcherEvent) *QueryWatcher
type QueryWatcherEvent ¶
type QueryWatcherEvent struct { Identifier int Changes []*attestation_domain.AttestationDomainChange Reset bool LostSync bool InSync bool SnapshotSize int64 CheckSize bool }
type QueryWatcherParams ¶
type QueryWatcherParams struct { Parent *attestation_domain.ParentReference Filter *attestation_domain.Filter View view.View FieldMask *attestation_domain.AttestationDomain_FieldMask OrderBy *attestation_domain.OrderBy Cursor *attestation_domain.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 attestation_domain_client.AttestationDomainServiceClient, config *WatcherConfig, filters ...*WatcherFilterParams) *Watcher
func (*Watcher) Events ¶
func (pw *Watcher) Events() <-chan WatcherEvent
func (*Watcher) GetFilters ¶
func (pw *Watcher) GetFilters() []*WatcherFilterParams
func (*Watcher) GetIFilters ¶ added in v0.4.16
func (pw *Watcher) GetIFilters() []gotenaccess.WatcherFilterParams
func (*Watcher) IEvents ¶ added in v0.4.16
func (pw *Watcher) IEvents() <-chan gotenaccess.WatcherEvent
func (*Watcher) ResetFilters ¶
func (pw *Watcher) ResetFilters(ctx context.Context, filters ...*WatcherFilterParams) error
func (*Watcher) ResetIFilters ¶ added in v0.4.16
func (pw *Watcher) ResetIFilters(ctx context.Context, filters ...gotenaccess.WatcherFilterParams) error
type WatcherConfig ¶
type WatcherConfig struct { *gotenaccess.WatcherConfigBase // common params that must be shared across queries WatchType watch_type.WatchType View view.View FieldMask *attestation_domain.AttestationDomain_FieldMask OrderBy *attestation_domain.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 *attestation_domain.AttestationDomain) *WatcherEventChange
func NewDeleteWatcherEventChange ¶
func NewDeleteWatcherEventChange(deleted *attestation_domain.AttestationDomain) *WatcherEventChange
func NewModifyWatcherEventChange ¶
func NewModifyWatcherEventChange(current, previous *attestation_domain.AttestationDomain) *WatcherEventChange
func (*WatcherEventChange) GetAdded ¶
func (c *WatcherEventChange) GetAdded() *attestation_domain.AttestationDomain
func (*WatcherEventChange) GetCurrent ¶
func (c *WatcherEventChange) GetCurrent() *attestation_domain.AttestationDomain
func (*WatcherEventChange) GetDeleted ¶
func (c *WatcherEventChange) GetDeleted() *attestation_domain.AttestationDomain
func (*WatcherEventChange) GetName ¶
func (c *WatcherEventChange) GetName() *attestation_domain.Name
func (*WatcherEventChange) GetPrevious ¶
func (c *WatcherEventChange) GetPrevious() *attestation_domain.AttestationDomain
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 *attestation_domain.ParentReference Filter *attestation_domain.Filter }
func (*WatcherFilterParams) GetIFilter ¶ added in v0.4.16
func (p *WatcherFilterParams) GetIFilter() gotenresource.Filter
func (*WatcherFilterParams) GetIParentRef ¶ added in v0.4.16
func (p *WatcherFilterParams) GetIParentRef() gotenresource.Reference
func (*WatcherFilterParams) String ¶
func (p *WatcherFilterParams) String() string
Click to show internal directories.
Click to hide internal directories.