apiproxy

Documentation

Index

• type APIProxy
  • func NewAPIProxy(object client.Object, client client.Client, recorder record.EventRecorder, ...) APIProxy
• type Chyt
  • func NewChyt(chyt *ytv1.Chyt, client client.Client, recorder record.EventRecorder, ...) *Chyt
  • func (c *Chyt) APIProxy() APIProxy
  • func (c *Chyt) GetResource() *ytv1.Chyt
  • func (c *Chyt) IsStatusConditionFalse(conditionType string) bool
  • func (c *Chyt) IsStatusConditionTrue(conditionType string) bool
  • func (c *Chyt) SaveReleaseStatus(ctx context.Context, releaseStatus ytv1.ChytReleaseStatus) error
  • func (c *Chyt) SetStatusCondition(condition metav1.Condition)
• type ConditionManager
• type Spyt
  • func NewSpyt(spyt *ytv1.Spyt, client client.Client, recorder record.EventRecorder, ...) *Spyt
  • func (c *Spyt) APIProxy() APIProxy
  • func (c *Spyt) GetResource() *ytv1.Spyt
  • func (c *Spyt) IsStatusConditionFalse(conditionType string) bool
  • func (c *Spyt) IsStatusConditionTrue(conditionType string) bool
  • func (c *Spyt) SaveReleaseStatus(ctx context.Context, releaseStatus ytv1.SpytReleaseStatus) error
  • func (c *Spyt) SetStatusCondition(condition metav1.Condition)
• type Ytsaurus
  • func NewYtsaurus(ytsaurus *ytv1.Ytsaurus, client client.Client, recorder record.EventRecorder, ...) *Ytsaurus
  • func (c *Ytsaurus) APIProxy() APIProxy
  • func (c *Ytsaurus) ClearUpdateStatus(ctx context.Context) error
  • func (c *Ytsaurus) GetClusterState() ytv1.ClusterState
  • func (c *Ytsaurus) GetCommonSpec() ytv1.CommonSpec
  • func (c *Ytsaurus) GetLocalUpdatingComponents() []string
  • func (c *Ytsaurus) GetResource() *ytv1.Ytsaurus
  • func (c *Ytsaurus) GetUpdateFlow() ytv1.UpdateFlow
  • func (c *Ytsaurus) GetUpdateState() ytv1.UpdateState
  • func (c *Ytsaurus) IsStatusConditionFalse(conditionType string) bool
  • func (c *Ytsaurus) IsStatusConditionTrue(conditionType string) bool
  • func (c *Ytsaurus) IsUpdateStatusConditionTrue(condition string) bool
  • func (c *Ytsaurus) IsUpdating() bool
  • func (c *Ytsaurus) LogUpdate(ctx context.Context, message string)
  • func (c *Ytsaurus) SaveClusterState(ctx context.Context, clusterState ytv1.ClusterState) error
  • func (c *Ytsaurus) SaveUpdateState(ctx context.Context, updateState ytv1.UpdateState) error
  • func (c *Ytsaurus) SaveUpdatingClusterState(ctx context.Context, flow ytv1.UpdateFlow, components []string) error
  • func (c *Ytsaurus) SetStatusCondition(condition metav1.Condition)
  • func (c *Ytsaurus) SetUpdateStatusCondition(ctx context.Context, condition metav1.Condition)
  • func (c *Ytsaurus) SyncObservedGeneration() bool

Types

type APIProxy

type APIProxy interface {
	Client() client.Client
	FetchObject(ctx context.Context, name string, obj client.Object) error
	ListObjects(ctx context.Context, objList client.ObjectList, opts ...client.ListOption) error
	RecordWarning(reason, message string)
	RecordNormal(reason, message string)
	SyncObject(ctx context.Context, oldObj, newObj client.Object) error
	DeleteObject(ctx context.Context, obj client.Object, opts ...client.DeleteOption) error

	UpdateStatus(ctx context.Context) error
}

func NewAPIProxy

func NewAPIProxy(
	object client.Object,
	client client.Client,
	recorder record.EventRecorder,
	scheme *runtime.Scheme) APIProxy

type Chyt

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

func NewChyt

func NewChyt(
	chyt *ytv1.Chyt,
	client client.Client,
	recorder record.EventRecorder,
	scheme *runtime.Scheme) *Chyt

func (*Chyt) APIProxy

func (c *Chyt) APIProxy() APIProxy

func (*Chyt) GetResource

func (c *Chyt) GetResource() *ytv1.Chyt

func (*Chyt) IsStatusConditionFalse

func (c *Chyt) IsStatusConditionFalse(conditionType string) bool

func (*Chyt) IsStatusConditionTrue

func (c *Chyt) IsStatusConditionTrue(conditionType string) bool

func (*Chyt) SaveReleaseStatus

func (c *Chyt) SaveReleaseStatus(ctx context.Context, releaseStatus ytv1.ChytReleaseStatus) error

func (*Chyt) SetStatusCondition

func (c *Chyt) SetStatusCondition(condition metav1.Condition)

type ConditionManager

type ConditionManager interface {
	SetStatusCondition(condition metav1.Condition)
	IsStatusConditionTrue(conditionType string) bool
	IsStatusConditionFalse(conditionType string) bool
}

type Spyt

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

func NewSpyt

func NewSpyt(
	spyt *ytv1.Spyt,
	client client.Client,
	recorder record.EventRecorder,
	scheme *runtime.Scheme) *Spyt

func (*Spyt) APIProxy

func (c *Spyt) APIProxy() APIProxy

func (*Spyt) GetResource

func (c *Spyt) GetResource() *ytv1.Spyt

func (*Spyt) IsStatusConditionFalse

func (c *Spyt) IsStatusConditionFalse(conditionType string) bool

func (*Spyt) IsStatusConditionTrue

func (c *Spyt) IsStatusConditionTrue(conditionType string) bool

func (*Spyt) SaveReleaseStatus

func (c *Spyt) SaveReleaseStatus(ctx context.Context, releaseStatus ytv1.SpytReleaseStatus) error

func (*Spyt) SetStatusCondition

func (c *Spyt) SetStatusCondition(condition metav1.Condition)

type Ytsaurus

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

func NewYtsaurus

func NewYtsaurus(
	ytsaurus *ytv1.Ytsaurus,
	client client.Client,
	recorder record.EventRecorder,
	scheme *runtime.Scheme) *Ytsaurus

func (*Ytsaurus) APIProxy

func (c *Ytsaurus) APIProxy() APIProxy

func (*Ytsaurus) ClearUpdateStatus

func (c *Ytsaurus) ClearUpdateStatus(ctx context.Context) error

func (*Ytsaurus) GetClusterState

func (c *Ytsaurus) GetClusterState() ytv1.ClusterState

func (*Ytsaurus) GetCommonSpec

func (c *Ytsaurus) GetCommonSpec() ytv1.CommonSpec

func (*Ytsaurus) GetLocalUpdatingComponents

func (c *Ytsaurus) GetLocalUpdatingComponents() []string

func (*Ytsaurus) GetResource

func (c *Ytsaurus) GetResource() *ytv1.Ytsaurus

func (*Ytsaurus) GetUpdateFlow

func (c *Ytsaurus) GetUpdateFlow() ytv1.UpdateFlow

func (*Ytsaurus) GetUpdateState

func (c *Ytsaurus) GetUpdateState() ytv1.UpdateState

func (*Ytsaurus) IsStatusConditionFalse

func (c *Ytsaurus) IsStatusConditionFalse(conditionType string) bool

func (*Ytsaurus) IsStatusConditionTrue

func (c *Ytsaurus) IsStatusConditionTrue(conditionType string) bool

func (*Ytsaurus) IsUpdateStatusConditionTrue

func (c *Ytsaurus) IsUpdateStatusConditionTrue(condition string) bool

func (*Ytsaurus) IsUpdating

func (c *Ytsaurus) IsUpdating() bool

func (*Ytsaurus) LogUpdate

func (c *Ytsaurus) LogUpdate(ctx context.Context, message string)

func (*Ytsaurus) SaveClusterState

func (c *Ytsaurus) SaveClusterState(ctx context.Context, clusterState ytv1.ClusterState) error

func (*Ytsaurus) SaveUpdateState

func (c *Ytsaurus) SaveUpdateState(ctx context.Context, updateState ytv1.UpdateState) error

func (*Ytsaurus) SaveUpdatingClusterState

func (c *Ytsaurus) SaveUpdatingClusterState(ctx context.Context, flow ytv1.UpdateFlow, components []string) error

func (*Ytsaurus) SetStatusCondition

func (c *Ytsaurus) SetStatusCondition(condition metav1.Condition)

func (*Ytsaurus) SetUpdateStatusCondition

func (c *Ytsaurus) SetUpdateStatusCondition(ctx context.Context, condition metav1.Condition)

func (*Ytsaurus) SyncObservedGeneration

func (c *Ytsaurus) SyncObservedGeneration() bool

SyncObservedGeneration confirms that current generation was observed. Returns true if generation actually has been changed and status must be saved.