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 *configv1alpha1.Config, ...) (*configv1alpha1.Config, error)
  • func (r *Context) GetAddress() string
  • func (r *Context) GetData(ctx context.Context, key storebackend.Key) (*configv1alpha1.RunningConfig, error)
  • func (r *Context) GetDataStore(ctx context.Context, in *sdcpb.GetDataStoreRequest, opts ...grpc.CallOption) (*sdcpb.GetDataStoreResponse, error)
  • func (r *Context) GetSchema() *configv1alpha1.ConfigStatusLastKnownGoodSchema
  • func (r *Context) IsReady() bool
  • func (r *Context) SetIntent(ctx context.Context, key storebackend.Key, config *configv1alpha1.Config, ...) (*configv1alpha1.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)

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 *configv1alpha1.Config, dryRun bool) (*configv1alpha1.Config, error)

func (*Context) GetAddress

func (r *Context) GetAddress() string

func (*Context) GetData

func (r *Context) GetData(ctx context.Context, key storebackend.Key) (*configv1alpha1.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() *configv1alpha1.ConfigStatusLastKnownGoodSchema

func (*Context) IsReady

func (r *Context) IsReady() bool

func (*Context) SetIntent

func (r *Context) SetIntent(ctx context.Context, key storebackend.Key, config *configv1alpha1.Config, useSpec, dryRun bool) (*configv1alpha1.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)