services

Documentation

Index

• Constants
• type Resource
  • func NewResource(client client.Client) *Resource
  • func (r *Resource) IsNodeReady(ctx context.Context, nodeName types.NamespacedName) bool
  • func (r *Resource) IsPvCanUse(ctx context.Context, pvNameSpaceName *types.NamespacedName) (*string, bool)
  • func (r *Resource) SetPVCName(statefulPod *iapetosapiv1.StatefulPod, index int) string
  • func (r *Resource) SetServiceName(statefulPod *iapetosapiv1.StatefulPod) string
• type ServiceInf

Constants

const (
	ResourceVersionUnSame = "ResourceVersionUnSame"
	ParentNmae            = "parentName"
	StatefulPod           = "StatefulPod"
	Index                 = "index"
)

Types

type Resource

type Resource struct {
	client.Client
	Log logr.Logger
}

func NewResource

func NewResource(client client.Client) *Resource

func (*Resource) IsNodeReady

func (r *Resource) IsNodeReady(ctx context.Context, nodeName types.NamespacedName) bool

func (*Resource) IsPvCanUse

func (r *Resource) IsPvCanUse(ctx context.Context, pvNameSpaceName *types.NamespacedName) (*string, bool)

func (*Resource) SetPVCName

func (r *Resource) SetPVCName(statefulPod *iapetosapiv1.StatefulPod, index int) string

func (*Resource) SetServiceName

func (r *Resource) SetServiceName(statefulPod *iapetosapiv1.StatefulPod) string

type ServiceInf

type ServiceInf interface {
	Create(ctx context.Context, obj interface{}) (interface{}, error)
	Update(ctx context.Context, obj interface{}) (interface{}, error)
	Delete(ctx context.Context, obj interface{}) error
	IsExists(ctx context.Context, nameSpaceName types.NamespacedName) (interface{}, bool)
	CreateTemplate(ctx context.Context, statefulPod *iapetosapiv1.StatefulPod, name string, index int) interface{}
	GetName(statefulPod *iapetosapiv1.StatefulPod, index int) *string
	IsResourceVersionSame(ctx context.Context, obj interface{}) bool
	DeleteMandatory(ctx context.Context, obj interface{}, statefulPod *iapetosapiv1.StatefulPod) error
	Get(ctx context.Context, nameSpaceName types.NamespacedName) (interface{}, error)
}