probe_access

Documentation

Index

• func NewApiProbeAccess(client probe_client.ProbeServiceClient) probe.ProbeAccess
• type QueryWatcher
  • func NewQueryWatcher(id int, client probe_client.ProbeServiceClient, params *QueryWatcherParams, ...) *QueryWatcher
  • func (qw *QueryWatcher) Run(ctx context.Context) error
• type QueryWatcherEvent
• type QueryWatcherParams
• type Watcher
  • func NewWatcher(client probe_client.ProbeServiceClient, 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) 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 *probe.Probe) *WatcherEventChange
  • func NewDeleteWatcherEventChange(deleted *probe.Probe) *WatcherEventChange
  • func NewModifyWatcherEventChange(current, previous *probe.Probe) *WatcherEventChange
  • func (c *WatcherEventChange) GetAdded() *probe.Probe
  • func (c *WatcherEventChange) GetCurrent() *probe.Probe
  • func (c *WatcherEventChange) GetDeleted() *probe.Probe
  • func (c *WatcherEventChange) GetName() *probe.Name
  • func (c *WatcherEventChange) GetPrevious() *probe.Probe
  • 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
  • func (p *WatcherFilterParams) GetIFilter() gotenresource.Filter
  • func (p *WatcherFilterParams) GetIParentRef() gotenresource.Reference
  • func (p *WatcherFilterParams) String() string

Functions

func NewApiProbeAccess

func NewApiProbeAccess(client probe_client.ProbeServiceClient) probe.ProbeAccess

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 probe_client.ProbeServiceClient,
	params *QueryWatcherParams, evtsChan chan *QueryWatcherEvent) *QueryWatcher

func (*QueryWatcher) Run

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

type QueryWatcherEvent

type QueryWatcherEvent struct {
	Identifier   int
	Changes      []*probe.ProbeChange
	Reset        bool
	LostSync     bool
	InSync       bool
	SnapshotSize int64
	CheckSize    bool
}

type QueryWatcherParams

type QueryWatcherParams struct {
	Parent    *probe.ParentReference
	Filter    *probe.Filter
	View      view.View
	FieldMask *probe.Probe_FieldMask
	OrderBy   *probe.OrderBy
	Cursor    *probe.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 probe_client.ProbeServiceClient, 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

func (pw *Watcher) GetIFilters() []gotenaccess.WatcherFilterParams

func (*Watcher) IEvents

func (pw *Watcher) IEvents() <-chan gotenaccess.WatcherEvent

func (*Watcher) InSync

func (pw *Watcher) InSync() bool

func (*Watcher) ResetFilters

func (pw *Watcher) ResetFilters(ctx context.Context, filters ...*WatcherFilterParams) error

func (*Watcher) ResetIFilters

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

func (*Watcher) Run

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

type WatcherConfig

type WatcherConfig struct {
	*gotenaccess.WatcherConfigBase

	// common params that must be shared across queries
	WatchType watch_type.WatchType
	View      view.View
	FieldMask *probe.Probe_FieldMask
	OrderBy   *probe.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 *probe.Probe) *WatcherEventChange

func NewDeleteWatcherEventChange

func NewDeleteWatcherEventChange(deleted *probe.Probe) *WatcherEventChange

func NewModifyWatcherEventChange

func NewModifyWatcherEventChange(current, previous *probe.Probe) *WatcherEventChange

func (*WatcherEventChange) GetAdded

func (c *WatcherEventChange) GetAdded() *probe.Probe

func (*WatcherEventChange) GetCurrent

func (c *WatcherEventChange) GetCurrent() *probe.Probe

func (*WatcherEventChange) GetDeleted

func (c *WatcherEventChange) GetDeleted() *probe.Probe

func (*WatcherEventChange) GetName

func (c *WatcherEventChange) GetName() *probe.Name

func (*WatcherEventChange) GetPrevious

func (c *WatcherEventChange) GetPrevious() *probe.Probe

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 *probe.ParentReference
	Filter *probe.Filter
}

func (*WatcherFilterParams) GetIFilter

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

func (*WatcherFilterParams) GetIParentRef

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

func (*WatcherFilterParams) String

func (p *WatcherFilterParams) String() string