target

Documentation

Index

• Variables
• type Collector
  • func NewCollector(targetKey storebackend.Key, subscriptions *Subscriptions) *Collector
  • func (r *Collector) GetUpdateChan() chan struct{}
  • func (r *Collector) IsRunning() bool
  • func (r *Collector) SetPort(port uint)
  • func (r *Collector) Start(ctx context.Context, req *sdcpb.CreateDataStoreRequest) error
  • func (r *Collector) StartSubscription(ctx context.Context)
  • func (r *Collector) Stop(ctx context.Context)
  • func (r *Collector) StopSubscription(ctx context.Context)
• type Context
  • func New(targetKey storebackend.Key, client client.Client, dsclient dsclient.Client) *Context
  • func (r *Context) CreateDS(ctx context.Context, datastoreReq *sdcpb.CreateDataStoreRequest) error
  • func (r *Context) DeleteDS(ctx context.Context) error
  • func (r *Context) DeleteIntent(ctx context.Context, key storebackend.Key, config *config.Config, dryRun bool) (*config.Config, error)
  • func (r *Context) DeleteSubscription(ctx context.Context, sub *invv1alpha1.Subscription) error
  • func (r *Context) GetAddress() string
  • func (r *Context) GetCache() cache.Cache
  • func (r *Context) GetData(ctx context.Context, key storebackend.Key) (*config.RunningConfig, error)
  • func (r *Context) GetDataStore(ctx context.Context, in *sdcpb.GetDataStoreRequest, opts ...grpc.CallOption) (*sdcpb.GetDataStoreResponse, error)
  • func (r *Context) GetPrombLabels() []prompb.Label
  • func (r *Context) GetSchema() *config.ConfigStatusLastKnownGoodSchema
  • func (r *Context) IsReady() bool
  • func (r *Context) SetIntent(ctx context.Context, key storebackend.Key, config *config.Config, ...) (*config.Config, error)
  • func (r *Context) SetNotReady(ctx context.Context)
  • func (r *Context) SetReady(ctx context.Context)
  • func (r *Context) UpsertSubscription(ctx context.Context, sub *invv1alpha1.Subscription) error
• type DeviationWatcher
  • func NewDeviationWatcher(targetKey storebackend.Key, client client.Client, dsclient dsclient.Client) *DeviationWatcher
  • func (r *DeviationWatcher) Start(ctx context.Context)
  • func (r *DeviationWatcher) Stop(ctx context.Context)
• type Path
• type PathSubscriptions
• type Subscription
• type Subscriptions
  • func NewSubscriptions() *Subscriptions
  • func (r *Subscriptions) AddSubscription(subscription *invv1alpha1.Subscription) error
  • func (r *Subscriptions) DelSubscription(subscription *invv1alpha1.Subscription) error
  • func (r *Subscriptions) GetPaths() map[invv1alpha1.Encoding][]Path
  • func (r *Subscriptions) HasSubscriptions() bool
• type TargetHandler
  • func NewTargetHandler(client client.Client, targetStore storebackend.Storer[*Context]) *TargetHandler
  • func (r *TargetHandler) DeleteIntent(ctx context.Context, targetKey types.NamespacedName, config *config.Config, ...) (*config.Config, error)
  • func (r *TargetHandler) GetData(ctx context.Context, targetKey types.NamespacedName) (*config.RunningConfig, error)
  • func (r *TargetHandler) GetTargetContext(ctx context.Context, targetKey types.NamespacedName) (*invv1alpha1.Target, *Context, error)
  • func (r *TargetHandler) SetIntent(ctx context.Context, targetKey types.NamespacedName, config *config.Config, ...) (*config.Config, *config.ConfigStatusLastKnownGoodSchema, error)

Variables

var LookupError = errors.New("target lookup error")

Types

type Collector

type Collector struct {
	// contains filtered or unexported fields
}

func NewCollector

func NewCollector(targetKey storebackend.Key, subscriptions *Subscriptions) *Collector

func (*Collector) GetUpdateChan

func (r *Collector) GetUpdateChan() chan struct{}

func (*Collector) IsRunning

func (r *Collector) IsRunning() bool

func (*Collector) SetPort

func (r *Collector) SetPort(port uint)

func (*Collector) Start

func (r *Collector) Start(ctx context.Context, req *sdcpb.CreateDataStoreRequest) error

func (*Collector) StartSubscription

func (r *Collector) StartSubscription(ctx context.Context)

func (*Collector) Stop

func (r *Collector) Stop(ctx context.Context)

func (*Collector) StopSubscription

func (r *Collector) StopSubscription(ctx context.Context)

type Context

type Context struct {
	// contains filtered or unexported fields
}

func New

func New(targetKey storebackend.Key, client client.Client, dsclient dsclient.Client) *Context

func (*Context) CreateDS

func (r *Context) CreateDS(ctx context.Context, datastoreReq *sdcpb.CreateDataStoreRequest) error

func (*Context) DeleteDS

func (r *Context) DeleteDS(ctx context.Context) error

func (*Context) DeleteIntent

func (r *Context) DeleteIntent(ctx context.Context, key storebackend.Key, config *config.Config, dryRun bool) (*config.Config, error)

func (*Context) DeleteSubscription

func (r *Context) DeleteSubscription(ctx context.Context, sub *invv1alpha1.Subscription) error

func (*Context) GetAddress

func (r *Context) GetAddress() string

func (*Context) GetCache

func (r *Context) GetCache() cache.Cache

func (*Context) GetData

func (r *Context) GetData(ctx context.Context, key storebackend.Key) (*config.RunningConfig, error)

func (*Context) GetDataStore

func (r *Context) GetDataStore(ctx context.Context, in *sdcpb.GetDataStoreRequest, opts ...grpc.CallOption) (*sdcpb.GetDataStoreResponse, error)

func (*Context) GetPrombLabels

func (r *Context) GetPrombLabels() []prompb.Label

func (*Context) GetSchema

func (r *Context) GetSchema() *config.ConfigStatusLastKnownGoodSchema

func (*Context) IsReady

func (r *Context) IsReady() bool

func (*Context) SetIntent

func (r *Context) SetIntent(ctx context.Context, key storebackend.Key, config *config.Config, useSpec, dryRun bool) (*config.Config, error)

func (*Context) SetNotReady

func (r *Context) SetNotReady(ctx context.Context)

func (*Context) SetReady

func (r *Context) SetReady(ctx context.Context)

func (*Context) UpsertSubscription

func (r *Context) UpsertSubscription(ctx context.Context, sub *invv1alpha1.Subscription) error

type DeviationWatcher

type DeviationWatcher struct {
	// contains filtered or unexported fields
}

func NewDeviationWatcher

func NewDeviationWatcher(targetKey storebackend.Key, client client.Client, dsclient dsclient.Client) *DeviationWatcher

func (*DeviationWatcher) Start

func (r *DeviationWatcher) Start(ctx context.Context)

func (*DeviationWatcher) Stop

func (r *DeviationWatcher) Stop(ctx context.Context)

type Path

type Path struct {
	Path     string
	Interval int
}

type PathSubscriptions

type PathSubscriptions struct {
	Current *Subscription
	// AllSubscriptions list all the subscriptions that are in the system, the key is name of the subscription CR
	AllSubscriptions map[string]*Subscription
}

type Subscription

type Subscription struct {
	NSN         string // namespacedname of the CR that originated this subscription
	Name        string // name of the subscription
	Description *string
	Labels      map[string]string
	Enabled     bool
	Interval    int // 0 = onChange
	Encoding    invv1alpha1.Encoding
}

type Subscriptions

type Subscriptions struct {
	Paths store.Storer[*PathSubscriptions]
}

func NewSubscriptions

func NewSubscriptions() *Subscriptions

func (*Subscriptions) AddSubscription

func (r *Subscriptions) AddSubscription(subscription *invv1alpha1.Subscription) error

Add or update a subscription

func (*Subscriptions) DelSubscription

func (r *Subscriptions) DelSubscription(subscription *invv1alpha1.Subscription) error

func (*Subscriptions) GetPaths

func (r *Subscriptions) GetPaths() map[invv1alpha1.Encoding][]Path

func (*Subscriptions) HasSubscriptions

func (r *Subscriptions) HasSubscriptions() bool

type TargetHandler

type TargetHandler struct {
	// contains filtered or unexported fields
}

func NewTargetHandler

func NewTargetHandler(client client.Client, targetStore storebackend.Storer[*Context]) *TargetHandler

func (*TargetHandler) DeleteIntent

func (r *TargetHandler) DeleteIntent(ctx context.Context, targetKey types.NamespacedName, config *config.Config, dryRun bool) (*config.Config, error)

func (*TargetHandler) GetData

func (r *TargetHandler) GetData(ctx context.Context, targetKey types.NamespacedName) (*config.RunningConfig, error)

func (*TargetHandler) GetTargetContext

func (r *TargetHandler) GetTargetContext(ctx context.Context, targetKey types.NamespacedName) (*invv1alpha1.Target, *Context, error)

GetTargetContext returns a invTarget and targetContext when the target is ready and the ctx is found

func (*TargetHandler) SetIntent

func (r *TargetHandler) SetIntent(ctx context.Context, targetKey types.NamespacedName, config *config.Config, useSpec, dryRun bool) (*config.Config, *config.ConfigStatusLastKnownGoodSchema, error)