Documentation ¶
Index ¶
- type CassandraClient
- func (cassandraClient *CassandraClient) CloseSession()
- func (cassandraClient *CassandraClient) CreateTableIfNotExist(tableSchema string, retryAmount int, retryInterval time.Duration) (returnedError error)
- func (cassandraClient *CassandraClient) GetSession() (returnedSession *gocql.Session, returnedError error)
- func (cassandraClient *CassandraClient) ResetSession()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CassandraClient ¶
type CassandraClient struct {
// contains filtered or unexported fields
}
func CreateCassandraClient ¶
func (*CassandraClient) CloseSession ¶
func (cassandraClient *CassandraClient) CloseSession()
func (*CassandraClient) CreateTableIfNotExist ¶
func (*CassandraClient) GetSession ¶
func (cassandraClient *CassandraClient) GetSession() (returnedSession *gocql.Session, returnedError error)
func (*CassandraClient) ResetSession ¶
func (cassandraClient *CassandraClient) ResetSession()
Click to show internal directories.
Click to hide internal directories.