Versions in this module Expand all Collapse all v1 v1.3.0 May 24, 2018 v1.2.0 Mar 22, 2018 v1.1.0 Feb 7, 2018 v1.0.8 Jan 22, 2018 v1.0.7 Nov 21, 2017 Changes in this version type Config + TLS TLS + type TLS struct + CAfile string + Certfile string + EnableHostVerification bool + Enabled bool + Keyfile string v1.0.6 Oct 30, 2017 v1.0.5 Oct 17, 2017 v1.0.4 Sep 26, 2017 Changes in this version + var ErrInvalidEndpointConfig = errors.New("cassandra: invalid configuration, endpoint and port not in valid format") + var ErrMissingEntityField = errors.New("cassandra: visitor entity is missing field") + var ErrMissingVisitorEntity = errors.New("cassandra: visitor is missing entity") + var ErrUnexportedEntityField = errors.New("cassandra: visitor entity with unexported field") v1.0.3 Sep 8, 2017 v1.0.2 Aug 28, 2017 Changes in this version + func CreateSessionFromConfig(config *ClientConfig) (*gocql.Session, error) + func ExpToString(exp sql.Expression) (sql string, bindings []interface{}, err error) + func HostsAsString(hostArr []string) string + func PutExpToString(whereCondition sql.Expression, entity interface{}) (sqlStr string, bindings []interface{}, err error) + func SelectExpToString(fromWhere sql.Expression) (sqlStr string, bindings []interface{}, err error) + func SliceOfFieldsWithValPtrs(val interface{}) (fieldNames []string, vals []interface{}) + type BrokerCassa struct + func NewBrokerUsingSession(gocqlSession gockle.Session) *BrokerCassa + func (pdb *BrokerCassa) Delete(fromWhere sql.Expression) error + func (pdb *BrokerCassa) Exec(statement string, binding ...interface{}) error + func (pdb *BrokerCassa) GetValue(query sql.Expression, reqObj interface{}) (found bool, err error) + func (pdb *BrokerCassa) ListValues(query sql.Expression) sql.ValIterator + func (pdb *BrokerCassa) NewTxn() sql.Txn + func (pdb *BrokerCassa) Put(where sql.Expression, pointerToAStruct interface{}) error + type ClientConfig struct + func ConfigToClientConfig(ymlConfig *Config) (*ClientConfig, error) + type Config struct + DialTimeout time.Duration + Endpoints []string + OpTimeout time.Duration + Port int + ProtocolVersion int + RedialInterval time.Duration + type Deps struct + type ErrIterator struct + LastError error + func (it *ErrIterator) Close() error + func (it *ErrIterator) GetNext(outVal interface{}) (stop bool) + type Plugin struct + func FromExistingSession(session gockle.Session) *Plugin + func (p *Plugin) AfterInit() error + func (p *Plugin) Close() error + func (p *Plugin) Init() (err error) + func (p *Plugin) NewBroker() sql.Broker + func (p *Plugin) String() string + type ValIterator struct + Delegate gockle.Iterator + func (it *ValIterator) Close() error + func (it *ValIterator) GetNext(outVal interface{}) (stop bool)
Go to main page