cassandra

Documentation

Index

• type Client
  • func (c *Client) CheckDbReadWrite() error
  • func (c *Client) CloseCassandraClient()
  • func (c *Client) CreateKeyspace() error
  • func (c *Client) CreateTable() error
  • func (c *Client) PingCassandra() error
  • func (c *Client) QueryData(name string) error
  • func (c *Client) UpdateData(name string, product string) error
• type KubeDBClientBuilder
  • func NewKubeDBClientBuilder(kc client.Client, db *api.Cassandra) *KubeDBClientBuilder
  • func (o *KubeDBClientBuilder) GetCassandraClient() (*Client, error)
  • func (o *KubeDBClientBuilder) WithContext(ctx context.Context) *KubeDBClientBuilder
  • func (o *KubeDBClientBuilder) WithPort(port *int) *KubeDBClientBuilder
  • func (o *KubeDBClientBuilder) WithURL(url string) *KubeDBClientBuilder

Types

type Client

type Client struct {
	*gocql.Session
}

func (*Client) CheckDbReadWrite

func (c *Client) CheckDbReadWrite() error

func (*Client) CloseCassandraClient

func (c *Client) CloseCassandraClient()

func (*Client) CreateKeyspace

func (c *Client) CreateKeyspace() error

CreateKeyspace creates a keyspace

func (*Client) CreateTable

func (c *Client) CreateTable() error

CreateTable creates a table

func (*Client) PingCassandra

func (c *Client) PingCassandra() error

func (*Client) QueryData

func (c *Client) QueryData(name string) error

queries a Data by ID

func (*Client) UpdateData

func (c *Client) UpdateData(name string, product string) error

UpdateData updates a record in the table

type KubeDBClientBuilder

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

func NewKubeDBClientBuilder

func NewKubeDBClientBuilder(kc client.Client, db *api.Cassandra) *KubeDBClientBuilder

func (*KubeDBClientBuilder) GetCassandraClient

func (o *KubeDBClientBuilder) GetCassandraClient() (*Client, error)

func (*KubeDBClientBuilder) WithContext

func (o *KubeDBClientBuilder) WithContext(ctx context.Context) *KubeDBClientBuilder

func (*KubeDBClientBuilder) WithPort

func (o *KubeDBClientBuilder) WithPort(port *int) *KubeDBClientBuilder

func (*KubeDBClientBuilder) WithURL

func (o *KubeDBClientBuilder) WithURL(url string) *KubeDBClientBuilder