Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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.
Source Files ¶
Click to show internal directories.
Click to hide internal directories.