scyllacluster

Documentation

Index

• type DataInserter
  • func NewDataInserter(ctx context.Context, client corev1client.CoreV1Interface, ...) (*DataInserter, error)
  • func (di *DataInserter) Close()
  • func (di *DataInserter) GetExpected() []*TestData
  • func (di *DataInserter) Insert() error
  • func (di *DataInserter) Read() ([]*TestData, error)
  • func (di *DataInserter) UpdateClientEndpoints(ctx context.Context, sc *scyllav1.ScyllaCluster) error
• type TestData

Types

type DataInserter

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

func NewDataInserter

func NewDataInserter(ctx context.Context, client corev1client.CoreV1Interface, sc *scyllav1.ScyllaCluster, replicationFactor int32) (*DataInserter, error)

func (*DataInserter) Close

func (di *DataInserter) Close()

func (*DataInserter) GetExpected

func (di *DataInserter) GetExpected() []*TestData

func (*DataInserter) Insert

func (di *DataInserter) Insert() error

func (*DataInserter) Read

func (di *DataInserter) Read() ([]*TestData, error)

func (*DataInserter) UpdateClientEndpoints

func (di *DataInserter) UpdateClientEndpoints(ctx context.Context, sc *scyllav1.ScyllaCluster) error

UpdateClientEndpoints closes an existing session and opens a new one. In case an error was returned, DataInserter can no Longer be used.

type TestData

type TestData struct {
	Id   int    `db:"id"`
	Data string `db:"data"`
}