access

Feb 29, 2024

Changes in this version

type ApiAccessBuilder

+ func (re *ApiAccessBuilder) MakeQueryWatcherEvent(evtId int, changes resource.ResourceChangeList, ...) QueryWatcherEvent

+ type QueryWatcherEventConstructor func(evtId int, changes resource.ResourceChangeList, ...) QueryWatcherEvent

type Registry

+ func (r *Registry) RegisterQueryWatcherEventConstructor(descriptor resource.Descriptor, constructor QueryWatcherEventConstructor)

type WatcherFilterParams

+ GetIParentName func() resource.Name

Mar 6, 2023

Changes in this version

type WatcherEvent

+ FilterVersion func() int32

type WatcherEventBase

+ func (eb WatcherEventBase) FilterVersion() int32

Oct 29, 2022

Changes in this version

type ApiAccessBuilder

+ func (re *ApiAccessBuilder) MakeQueryWatcher(id int, grpcConn grpc.ClientConnInterface, params *QueryWatcherConfigParams, ...) QueryWatcher

+ type QueryWatcher interface

+ QueryWatcher func()

+ Run func(ctx context.Context) error

+ type QueryWatcherConfigParams struct

+ ChunkSize int

+ Cursor resource.Cursor

+ FieldMask object.FieldMask

+ Filter resource.Filter

+ OrderBy resource.OrderBy

+ PageSize int

+ Parent resource.Reference

+ RecoveryDeadline time.Duration

+ RetryTimeout time.Duration

+ StartingTime *timestamppb.Timestamp

+ View view.View

+ WatchType watch_type.WatchType

+ type QueryWatcherConstructor func(id int, grpcConn grpc.ClientConnInterface, params *QueryWatcherConfigParams, ...) QueryWatcher

+ type QueryWatcherEvent interface

+ GetChanges func() resource.ResourceChangeList

+ GetSnapshotSize func() int64

+ GetWatcherIdentifier func() int

+ HasSnapshotSize func() bool

+ IsLostSync func() bool

+ IsReset func() bool

+ IsSync func() bool

type Registry

+ func (r *Registry) RegisterQueryWatcherConstructor(descriptor resource.Descriptor, constructor QueryWatcherConstructor)

Feb 22, 2022

Changes in this version

+ type ApiAccessBuilder struct

+ func (re *ApiAccessBuilder) GetDescriptor() resource.Descriptor

+ func (re *ApiAccessBuilder) MakeApiAccess(grpcConn grpc.ClientConnInterface) resource.Access

+ func (re *ApiAccessBuilder) MakeWatcher(grpcConn grpc.ClientConnInterface, params *WatcherConfigParams, ...) Watcher

+ func (re *ApiAccessBuilder) MakeWatcherFilterParams(filter resource.Filter, parentRef resource.Reference) WatcherFilterParams

+ type ApiAccessConstructor func(grpcConn grpc.ClientConnInterface) resource.Access

+ type Registry struct

+ func GetRegistry() *Registry

+ func (r *Registry) FindApiAccessBuilder(descriptor resource.Descriptor) *ApiAccessBuilder

+ func (r *Registry) RegisterApiAccessConstructor(descriptor resource.Descriptor, constructor ApiAccessConstructor)

+ func (r *Registry) RegisterWatcherConstructor(descriptor resource.Descriptor, constructor WatcherConstructor)

+ func (r *Registry) RegisterWatcherFilterConstructor(descriptor resource.Descriptor, constructor WatcherFilterConstructor)

+ type Watcher interface

+ GetIFilters func() []WatcherFilterParams

+ IEvents func() <-chan WatcherEvent

+ InSync func() bool

+ ResetIFilters func(ctx context.Context, filters ...WatcherFilterParams) error

+ Run func(ctx context.Context) error

+ type WatcherConfigBase struct

+ RecoveryDeadline time.Duration

+ RetryTimeout time.Duration

+ WatcherEventBufferSize int

+ func NewWatcherConfigBase() *WatcherConfigBase

+ type WatcherConfigParams struct

+ CfgBase *WatcherConfigBase

+ ChunkSize int

+ FieldMask object.FieldMask

+ OrderBy resource.OrderBy

+ View view.View

+ WatchType watch_type.WatchType

+ type WatcherConstructor func(grpcConn grpc.ClientConnInterface, params *WatcherConfigParams, ...) Watcher

+ type WatcherEventBase struct

+ func NewWatcherEventBase(resync bool) WatcherEventBase

+ func NewWatcherEventBaseLostSync() WatcherEventBase

+ func (eb WatcherEventBase) LostSync() bool

+ func (eb WatcherEventBase) Resync() bool

+ type WatcherFilterConstructor func(filter resource.Filter, parentRef resource.Reference) WatcherFilterParams

+ type WatcherFilterParams interface

+ GetIFilter func() resource.Filter

+ GetIParentRef func() resource.Reference

Feb 1, 2022

Changes in this version

+ type WatcherConfig struct

+ RecoveryDeadline time.Duration

+ RetryTimeout time.Duration

+ WatcherEventBufferSize int

+ func NewWatcherConfig() *WatcherConfig

+ type WatcherEvent interface

+ AppendRawChange func(change WatcherEventChange)

+ GetRawAt func(index int) WatcherEventChange

+ Length func() int

+ LostSync func() bool

+ Resync func() bool

+ type WatcherEventChange interface

+ GetRawAdded func() resource.Resource

+ GetRawCurrent func() resource.Resource

+ GetRawDeleted func() resource.Resource

+ GetRawName func() resource.Name

+ GetRawPrevious func() resource.Resource

+ IsAdd func() bool

+ IsDelete func() bool

+ IsModify func() bool

+ type WatcherEventbase struct

+ func NewWatcherEvent(resync bool) WatcherEventbase

+ func NewWatcherEventLostSync() WatcherEventbase

+ func (eb WatcherEventbase) LostSync() bool

+ func (eb WatcherEventbase) Resync() bool