cassdcutil

Documentation

Index

• type CassManager
  • func NewManager(client client.Client) *CassManager
  • func (c *CassManager) CassandraDatacenter(ctx context.Context, name, namespace string) (*cassdcapi.CassandraDatacenter, error)
  • func (c *CassManager) CassandraDatacenterPods(ctx context.Context, cassdc *cassdcapi.CassandraDatacenter) (*corev1.PodList, error)
  • func (c *CassManager) ModifyStoppedState(ctx context.Context, name, namespace string, stop, wait bool) error
  • func (c *CassManager) RefreshStatus(ctx context.Context, cassdc *cassdcapi.CassandraDatacenter, ...) (bool, error)
  • func (c *CassManager) RestartDc(ctx context.Context, name, namespace, rack string, wait bool) error

Types

type CassManager

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

func NewManager

func NewManager(client client.Client) *CassManager

func (*CassManager) CassandraDatacenter

func (c *CassManager) CassandraDatacenter(ctx context.Context, name, namespace string) (*cassdcapi.CassandraDatacenter, error)

CassandraDatacenter fetches the CassandraDatacenter by its name and namespace

func (*CassManager) CassandraDatacenterPods

func (c *CassManager) CassandraDatacenterPods(ctx context.Context, cassdc *cassdcapi.CassandraDatacenter) (*corev1.PodList, error)

CassandraDatacenterPods returns the pods of the CassandraDatacenter

func (*CassManager) ModifyStoppedState

func (c *CassManager) ModifyStoppedState(ctx context.Context, name, namespace string, stop, wait bool) error

ModifyStoppedState either stops or starts the cluster and does nothing if the state is already as requested

func (*CassManager) RefreshStatus

func (c *CassManager) RefreshStatus(ctx context.Context, cassdc *cassdcapi.CassandraDatacenter, status cassdcapi.DatacenterConditionType, wanted corev1.ConditionStatus) (bool, error)

func (*CassManager) RestartDc

func (c *CassManager) RestartDc(ctx context.Context, name, namespace, rack string, wait bool) error