target

Documentation

Index

• type Context
  • func New(targetKey storebackend.Key, client client.Client, dsclient dsclient.Client) *Context
  • func (r *Context) CreateDS(ctx context.Context, req *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) GetAddress() string
  • 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) 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) SetReady(ctx context.Context, ready bool)
• 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 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)

Types

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, req *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) GetAddress

func (r *Context) GetAddress() string

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) 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) SetReady

func (r *Context) SetReady(ctx context.Context, ready bool)

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 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)

GetTarget 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)