gocql

package module

Go to main page

Versions in this module

v1

v1.6.0

Aug 28, 2023

Changes in this version

type Batch

+ func (b *Batch) Table() string

type ExecutableQuery

+ Table func() string

type Query

+ func (q *Query) Table() string

v1.5.2

Jun 12, 2023

v1.5.1

Jun 12, 2023

v1.5.0

Jun 12, 2023

Changes in this version

type Query

+ func (q Query) Values() []interface{}

v1.4.0

Apr 26, 2023

Changes in this version

type HostInfo

+ func (h *HostInfo) ConnectAddressAndPort() string

v1.3.2

Mar 27, 2023

Changes in this version

+ var ErrCannotFindHost = errors.New("cannot find host")

+ var ErrHostAlreadyExists = errors.New("host already exists")

v1.3.1

Dec 13, 2022

v1.3.0

Nov 29, 2022

Changes in this version

type HostSelectionPolicy

+ func RackAwareRoundRobinPolicy(localDC string, localRack string) HostSelectionPolicy

+ type HostTierer interface

+ HostTier func(host *HostInfo) uint

+ MaxHostTier func() uint

v1.2.1

Sep 2, 2022

v1.2.0

Jul 7, 2022

Changes in this version

type ClusterConfig

+ HostDialer HostDialer

type ConnConfig

+ HostDialer HostDialer

+ type DialedHost struct

+ Conn net.Conn

+ DisableCoalesce bool

+ func WrapTLS(ctx context.Context, conn net.Conn, addr string, tlsConfig *tls.Config) (*DialedHost, error)

+ type HostDialer interface

+ DialHost func(ctx context.Context, host *HostInfo) (*DialedHost, error)

type HostInfo

+ func (h *HostInfo) SetHostID(hostID string)

type UUID

+ func MustRandomUUID() UUID

v1.1.0

Apr 29, 2022

Changes in this version

type ClusterConfig

+ StreamObserver StreamObserver

+ WriteTimeout time.Duration

type CollectionType

+ func (t CollectionType) NewWithError() (interface{}, error)

type ConnConfig

+ WriteTimeout time.Duration

type NativeType

+ func (t NativeType) NewWithError() (interface{}, error)

+ type ObservedStream struct

+ Host *HostInfo

+ type StreamObserver interface

+ StreamContext func(ctx context.Context) StreamObserverContext

+ type StreamObserverContext interface

+ StreamAbandoned func(observedStream ObservedStream)

+ StreamFinished func(observedStream ObservedStream)

+ StreamStarted func(observedStream ObservedStream)

type TupleTypeInfo

+ func (t TupleTypeInfo) NewWithError() (interface{}, error)

type TypeInfo

+ NewWithError func() (interface{}, error)

type UDTTypeInfo

+ func (u UDTTypeInfo) NewWithError() (interface{}, error)

v1.0.0

Feb 24, 2022

Changes in this version

+ const BatchSizeMaximum

+ const COLLECTION_TYPE

+ const COMPOSITE_TYPE

+ const DEFAULT_COLUMN_ALIAS

+ const DEFAULT_KEY_ALIAS

+ const DEFAULT_VALUE_ALIAS

+ const ErrCodeAlreadyExists

+ const ErrCodeBootstrapping

+ const ErrCodeCASWriteUnknown

+ const ErrCodeCDCWriteFailure

+ const ErrCodeConfig

+ const ErrCodeCredentials

+ const ErrCodeFunctionFailure

+ const ErrCodeInvalid

+ const ErrCodeOverloaded

+ const ErrCodeProtocol

+ const ErrCodeReadFailure

+ const ErrCodeReadTimeout

+ const ErrCodeServer

+ const ErrCodeSyntax

+ const ErrCodeTruncate

+ const ErrCodeUnauthorized

+ const ErrCodeUnavailable

+ const ErrCodeUnprepared

+ const ErrCodeWriteFailure

+ const ErrCodeWriteTimeout

+ const LIST_TYPE

+ const MAP_TYPE

+ const NodeDown

+ const NodeUp

+ const REVERSED_TYPE

+ const SET_TYPE

+ const VariantFuture

+ const VariantIETF

+ const VariantMicrosoft

+ const VariantNCSCompat

+ var ErrConnectionClosed = errors.New("gocql: connection closed waiting for response")

+ var ErrFrameTooBig = errors.New("frame length is bigger than the maximum allowed")

+ var ErrHostQueryFailed = errors.New("unable to populate Hosts")

+ var ErrKeyspaceDoesNotExist = errors.New("keyspace does not exist")

+ var ErrNoConnections = errors.New("gocql: no hosts available in the pool")

+ var ErrNoConnectionsStarted = errors.New("no connections were made when creating the session")

+ var ErrNoHosts = errors.New("no hosts provided")

+ var ErrNoKeyspace = errors.New("no keyspace provided")

+ var ErrNoMetadata = errors.New("no metadata available")

+ var ErrNoStreams = errors.New("gocql: no streams available on connection")

+ var ErrNotFound = errors.New("not found")

+ var ErrQueryArgLength = errors.New("gocql: query argument length mismatch")

+ var ErrSessionClosed = errors.New("session has been closed")

+ var ErrTimeoutNoResponse = errors.New("gocql: no response received from cassandra within timeout period")

+ var ErrTooManyStmts = errors.New("too many statements")

+ var ErrTooManyTimeouts = errors.New("gocql: too many query timeouts on the connection")

+ var ErrUnavailable = errors.New("unavailable")

+ var ErrUnknownRetryType = errors.New("unknown retry type returned by retry policy")

+ var ErrUnsupported = errors.New("feature not supported")

+ var ErrUseStmt = errors.New(...)

+ var ErrorUDTUnavailable = errors.New("UDT are not available on protocols less than 3, please update config")

+ var TimeoutLimit int64 = 0

+ var UnsetValue = unsetColumn

+ func JoinHostPort(addr string, port int) string

+ func LookupIP(host string) ([]net.IP, error)

+ func Marshal(info TypeInfo, value interface{}) ([]byte, error)

+ func NamedValue(name string, value interface{}) interface

+ func NewErrProtocol(format string, args ...interface{}) error

+ func NonLocalReplicasFallback() func(policy *tokenAwareHostPolicy)

+ func ShuffleReplicas() func(*tokenAwareHostPolicy)

+ func SingleHostReadyPolicy(p HostSelectionPolicy) *singleHostReadyPolicy

+ func TupleColumnName(c string, n int) string

+ func Unmarshal(info TypeInfo, data []byte, value interface{}) error

+ type AddressTranslator interface

+ Translate func(addr net.IP, port int) (net.IP, int)

+ func IdentityTranslator() AddressTranslator

+ type AddressTranslatorFunc func(addr net.IP, port int) (net.IP, int)

+ func (fn AddressTranslatorFunc) Translate(addr net.IP, port int) (net.IP, int)

+ type AggregateMetadata struct

+ ArgumentTypes []TypeInfo

+ FinalFunc FunctionMetadata

+ InitCond string

+ Keyspace string

+ Name string

+ ReturnType TypeInfo

+ StateFunc FunctionMetadata

+ StateType TypeInfo

+ type Authenticator interface

+ Challenge func(req []byte) (resp []byte, auth Authenticator, err error)

+ Success func(data []byte) error

+ type Batch struct

+ Cons Consistency

+ CustomPayload map[string][]byte

+ Entries []BatchEntry

+ Type BatchType

+ func NewBatch(typ BatchType) *Batch

+ func (*Batch) Cancel()

+ func (b *Batch) AddAttempts(i int, host *HostInfo)

+ func (b *Batch) AddLatency(l int64, host *HostInfo)

+ func (b *Batch) Attempts() int

+ func (b *Batch) Bind(stmt string, bind func(q *QueryInfo) ([]interface{}, error))

+ func (b *Batch) Context() context.Context

+ func (b *Batch) DefaultTimestamp(enable bool) *Batch

+ func (b *Batch) GetConsistency() Consistency

+ func (b *Batch) GetRoutingKey() ([]byte, error)

+ func (b *Batch) IsIdempotent() bool

+ func (b *Batch) Keyspace() string

+ func (b *Batch) Latency() int64

+ func (b *Batch) Observer(observer BatchObserver) *Batch

+ func (b *Batch) Query(stmt string, args ...interface{})

+ func (b *Batch) RetryPolicy(r RetryPolicy) *Batch

+ func (b *Batch) SerialConsistency(cons SerialConsistency) *Batch

+ func (b *Batch) SetConsistency(c Consistency)

+ func (b *Batch) Size() int

+ func (b *Batch) SpeculativeExecutionPolicy(sp SpeculativeExecutionPolicy) *Batch

+ func (b *Batch) Trace(trace Tracer) *Batch

+ func (b *Batch) WithContext(ctx context.Context) *Batch

+ func (b *Batch) WithTimestamp(timestamp int64) *Batch

+ type BatchEntry struct

+ Args []interface{}

+ Idempotent bool

+ Stmt string

+ type BatchObserver interface

+ ObserveBatch func(context.Context, ObservedBatch)

+ type BatchType byte

+ const CounterBatch

+ const LoggedBatch

+ const UnloggedBatch

+ type ClusterConfig struct

+ AddressTranslator AddressTranslator

+ AuthProvider func(h *HostInfo) (Authenticator, error)

+ Authenticator Authenticator

+ BatchObserver BatchObserver

+ CQLVersion string

+ Compressor Compressor

+ ConnectObserver ConnectObserver

+ ConnectTimeout time.Duration

+ Consistency Consistency

+ ConvictionPolicy ConvictionPolicy

+ DefaultIdempotence bool

+ DefaultTimestamp bool

+ Dialer Dialer

+ DisableInitialHostLookup bool

+ DisableSkipMetadata bool

+ Events struct{ ... }

+ FrameHeaderObserver FrameHeaderObserver

+ HostFilter HostFilter

+ Hosts []string

+ IgnorePeerAddr bool

+ Keyspace string

+ Logger StdLogger

+ MaxPreparedStmts int

+ MaxRoutingKeyInfo int

+ MaxWaitSchemaAgreement time.Duration

+ NumConns int

+ PageSize int

+ PoolConfig PoolConfig

+ Port int

+ ProtoVersion int

+ QueryObserver QueryObserver

+ ReconnectInterval time.Duration

+ ReconnectionPolicy ReconnectionPolicy

+ RetryPolicy RetryPolicy

+ SerialConsistency SerialConsistency

+ SocketKeepalive time.Duration

+ SslOpts *SslOptions

+ Timeout time.Duration

+ WriteCoalesceWaitTime time.Duration

+ func NewCluster(hosts ...string) *ClusterConfig

+ func (cfg *ClusterConfig) CreateSession() (*Session, error)

+ type CollectionType struct

+ Elem TypeInfo

+ Key TypeInfo

+ func (c CollectionType) String() string

+ func (t CollectionType) New() interface{}

+ type ColumnIndexMetadata struct

+ Name string

+ Options map[string]interface{}

+ Type string

+ type ColumnInfo struct

+ Keyspace string

+ Name string

+ Table string

+ TypeInfo TypeInfo

+ func (c ColumnInfo) String() string

+ type ColumnKind int

+ const ColumnClusteringKey

+ const ColumnCompact

+ const ColumnPartitionKey

+ const ColumnRegular

+ const ColumnStatic

+ const ColumnUnkownKind

+ func (c *ColumnKind) UnmarshalCQL(typ TypeInfo, p []byte) error

+ func (c ColumnKind) String() string

+ type ColumnMetadata struct

+ ClusteringOrder string

+ ComponentIndex int

+ Index ColumnIndexMetadata

+ Keyspace string

+ Kind ColumnKind

+ Name string

+ Order ColumnOrder

+ Table string

+ Type TypeInfo

+ Validator string

+ type ColumnOrder bool

+ const ASC

+ const DESC

+ type Compressor interface

+ Decode func(data []byte) ([]byte, error)

+ Encode func(data []byte) ([]byte, error)

+ Name func() string

+ type Conn struct

+ func (c *Conn) Address() string

+ func (c *Conn) AvailableStreams() int

+ func (c *Conn) Close()

+ func (c *Conn) Closed() bool

+ func (c *Conn) Pick(qry *Query) *Conn

+ func (c *Conn) Read(p []byte) (n int, err error)

+ func (c *Conn) UseKeyspace(keyspace string) error

+ func (c *Conn) Write(p []byte) (n int, err error)

+ type ConnConfig struct

+ AuthProvider func(h *HostInfo) (Authenticator, error)

+ Authenticator Authenticator

+ CQLVersion string

+ Compressor Compressor

+ ConnectTimeout time.Duration

+ Dialer Dialer

+ Keepalive time.Duration

+ Logger StdLogger

+ ProtoVersion int

+ Timeout time.Duration

+ type ConnErrorHandler interface

+ HandleError func(conn *Conn, err error, closed bool)

+ type ConnectObserver interface

+ ObserveConnect func(ObservedConnect)

+ type Consistency uint16

+ const All

+ const Any

+ const EachQuorum

+ const LocalOne

+ const LocalQuorum

+ const One

+ const Quorum

+ const Three

+ const Two

+ func MustParseConsistency(s string) (Consistency, error)

+ func ParseConsistency(s string) Consistency

+ func ParseConsistencyWrapper(s string) (consistency Consistency, err error)

+ func (c *Consistency) UnmarshalText(text []byte) error

+ func (c Consistency) MarshalText() (text []byte, err error)

+ func (c Consistency) String() string

+ type ConstantReconnectionPolicy struct

+ Interval time.Duration

+ MaxRetries int

+ func (c *ConstantReconnectionPolicy) GetInterval(currentRetry int) time.Duration

+ func (c *ConstantReconnectionPolicy) GetMaxRetries() int

+ type ConvictionPolicy interface

+ AddFailure func(error error, host *HostInfo) bool

+ Reset func(host *HostInfo)

+ type Dialer interface

+ DialContext func(ctx context.Context, network, addr string) (net.Conn, error)

+ type DowngradingConsistencyRetryPolicy struct

+ ConsistencyLevelsToTry []Consistency

+ func (d *DowngradingConsistencyRetryPolicy) Attempt(q RetryableQuery) bool

+ func (d *DowngradingConsistencyRetryPolicy) GetRetryType(err error) RetryType

+ type Duration struct

+ Days int32

+ Months int32

+ Nanoseconds int64

+ type ErrProtocol struct

+ type Error struct

+ Code int

+ Message string

+ func (e Error) Error() string

+ type ErrorMap map[string]uint16

+ type ExecutableQuery interface

+ GetRoutingKey func() ([]byte, error)

+ IsIdempotent func() bool

+ Keyspace func() string

+ type ExponentialBackoffRetryPolicy struct

+ Max time.Duration

+ Min time.Duration

+ NumRetries int

+ func (e *ExponentialBackoffRetryPolicy) Attempt(q RetryableQuery) bool

+ func (e *ExponentialBackoffRetryPolicy) GetRetryType(err error) RetryType

+ type ExponentialReconnectionPolicy struct

+ InitialInterval time.Duration

+ MaxInterval time.Duration

+ MaxRetries int

+ func (e *ExponentialReconnectionPolicy) GetInterval(currentRetry int) time.Duration

+ func (e *ExponentialReconnectionPolicy) GetMaxRetries() int

+ type FrameHeaderObserver interface

+ ObserveFrameHeader func(context.Context, ObservedFrameHeader)

+ type FunctionMetadata struct

+ ArgumentNames []string

+ ArgumentTypes []TypeInfo

+ Body string

+ CalledOnNullInput bool

+ Keyspace string

+ Language string

+ Name string

+ ReturnType TypeInfo

+ type HostFilter interface

+ Accept func(host *HostInfo) bool

+ func AcceptAllFilter() HostFilter

+ func DataCentreHostFilter(dataCentre string) HostFilter

+ func DenyAllFilter() HostFilter

+ func WhiteListHostFilter(hosts ...string) HostFilter

+ type HostFilterFunc func(host *HostInfo) bool

+ func (fn HostFilterFunc) Accept(host *HostInfo) bool

+ type HostInfo struct

+ func (h *HostInfo) BroadcastAddress() net.IP

+ func (h *HostInfo) ClusterName() string

+ func (h *HostInfo) ConnectAddress() net.IP

+ func (h *HostInfo) DSEVersion() string

+ func (h *HostInfo) DataCenter() string

+ func (h *HostInfo) Equal(host *HostInfo) bool

+ func (h *HostInfo) Graph() bool

+ func (h *HostInfo) HostID() string

+ func (h *HostInfo) HostnameAndPort() string

+ func (h *HostInfo) IsUp() bool

+ func (h *HostInfo) ListenAddress() net.IP

+ func (h *HostInfo) Partitioner() string

+ func (h *HostInfo) Peer() net.IP

+ func (h *HostInfo) Port() int

+ func (h *HostInfo) PreferredIP() net.IP

+ func (h *HostInfo) RPCAddress() net.IP

+ func (h *HostInfo) Rack() string

+ func (h *HostInfo) SetConnectAddress(address net.IP) *HostInfo

+ func (h *HostInfo) State() nodeState

+ func (h *HostInfo) String() string

+ func (h *HostInfo) Tokens() []string

+ func (h *HostInfo) Version() cassVersion

+ func (h *HostInfo) WorkLoad() string

+ type HostSelectionPolicy interface

+ Init func(*Session)

+ IsLocal func(host *HostInfo) bool

+ KeyspaceChanged func(KeyspaceUpdateEvent)

+ Pick func(ExecutableQuery) NextHost

+ func DCAwareRoundRobinPolicy(localDC string) HostSelectionPolicy

+ func HostPoolHostPolicy(hp hostpool.HostPool) HostSelectionPolicy

+ func RoundRobinHostPolicy() HostSelectionPolicy

+ func TokenAwareHostPolicy(fallback HostSelectionPolicy, opts ...func(*tokenAwareHostPolicy)) HostSelectionPolicy

+ type HostStateNotifier interface

+ AddHost func(host *HostInfo)

+ HostDown func(host *HostInfo)

+ HostUp func(host *HostInfo)

+ RemoveHost func(host *HostInfo)

+ type Iter struct

+ func (iter *Iter) Close() error

+ func (iter *Iter) Columns() []ColumnInfo

+ func (iter *Iter) GetCustomPayload() map[string][]byte

+ func (iter *Iter) Host() *HostInfo

+ func (iter *Iter) MapScan(m map[string]interface{}) bool

+ func (iter *Iter) NumRows() int

+ func (iter *Iter) PageState() []byte

+ func (iter *Iter) RowData() (RowData, error)

+ func (iter *Iter) Scan(dest ...interface{}) bool

+ func (iter *Iter) Scanner() Scanner

+ func (iter *Iter) SliceMap() ([]map[string]interface{}, error)

+ func (iter *Iter) Warnings() []string

+ func (iter *Iter) WillSwitchPage() bool

+ type KeyspaceMetadata struct

+ Aggregates map[string]*AggregateMetadata

+ DurableWrites bool

+ Functions map[string]*FunctionMetadata

+ MaterializedViews map[string]*MaterializedViewMetadata

+ Name string

+ StrategyClass string

+ StrategyOptions map[string]interface{}

+ Tables map[string]*TableMetadata

+ UserTypes map[string]*UserTypeMetadata

+ Views map[string]*ViewMetadata

+ type KeyspaceUpdateEvent struct

+ Change string

+ Keyspace string

+ type MarshalError string

+ func (m MarshalError) Error() string

+ type Marshaler interface

+ MarshalCQL func(info TypeInfo) ([]byte, error)

+ type MaterializedViewMetadata struct

+ BaseTable *TableMetadata

+ BaseTableId UUID

+ BloomFilterFpChance float64

+ Caching map[string]string

+ Comment string

+ Compaction map[string]string

+ Compression map[string]string

+ CrcCheckChance float64

+ DcLocalReadRepairChance float64

+ DefaultTimeToLive int

+ Extensions map[string]string

+ GcGraceSeconds int

+ Id UUID

+ IncludeAllColumns bool

+ Keyspace string

+ MaxIndexInterval int

+ MemtableFlushPeriodInMs int

+ MinIndexInterval int

+ Name string

+ ReadRepairChance float64

+ SpeculativeRetry string

+ type NativeType struct

+ func NewNativeType(proto byte, typ Type, custom string) NativeType

+ func (s NativeType) Custom() string

+ func (s NativeType) String() string

+ func (s NativeType) Type() Type

+ func (s NativeType) Version() byte

+ func (t NativeType) New() interface{}

+ type NextHost func() SelectedHost

+ type NonSpeculativeExecution struct

+ func (sp NonSpeculativeExecution) Attempts() int

+ func (sp NonSpeculativeExecution) Delay() time.Duration

+ type ObservedBatch struct

+ Attempt int

+ End time.Time

+ Err error

+ Host *HostInfo

+ Keyspace string

+ Metrics *hostMetrics

+ Start time.Time

+ Statements []string

+ Values [][]interface{}

+ type ObservedConnect struct

+ End time.Time

+ Err error

+ Host *HostInfo

+ Start time.Time

+ type ObservedFrameHeader struct

+ End time.Time

+ Flags byte

+ Host *HostInfo

+ Length int32

+ Opcode frameOp

+ Start time.Time

+ Stream int16

+ Version protoVersion

+ func (f ObservedFrameHeader) String() string

+ type ObservedQuery struct

+ Attempt int

+ End time.Time

+ Err error

+ Host *HostInfo

+ Keyspace string

+ Metrics *hostMetrics

+ Rows int

+ Start time.Time

+ Statement string

+ Values []interface{}

+ type PasswordAuthenticator struct

+ AllowedAuthenticators []string

+ Password string

+ Username string

+ func (p PasswordAuthenticator) Challenge(req []byte) ([]byte, Authenticator, error)

+ func (p PasswordAuthenticator) Success(data []byte) error

+ type PoolConfig struct

+ HostSelectionPolicy HostSelectionPolicy

+ type Query struct

+ func (q *Query) AddAttempts(i int, host *HostInfo)

+ func (q *Query) AddLatency(l int64, host *HostInfo)

+ func (q *Query) Attempts() int

+ func (q *Query) Bind(v ...interface{}) *Query

+ func (q *Query) Cancel()

+ func (q *Query) Consistency(c Consistency) *Query

+ func (q *Query) Context() context.Context

+ func (q *Query) CustomPayload(customPayload map[string][]byte) *Query

+ func (q *Query) DefaultTimestamp(enable bool) *Query

+ func (q *Query) Exec() error

+ func (q *Query) GetConsistency() Consistency

+ func (q *Query) GetRoutingKey() ([]byte, error)

+ func (q *Query) Idempotent(value bool) *Query

+ func (q *Query) IsIdempotent() bool

+ func (q *Query) Iter() *Iter

+ func (q *Query) Keyspace() string

+ func (q *Query) Latency() int64

+ func (q *Query) MapScan(m map[string]interface{}) error

+ func (q *Query) MapScanCAS(dest map[string]interface{}) (applied bool, err error)

+ func (q *Query) NoSkipMetadata() *Query

+ func (q *Query) Observer(observer QueryObserver) *Query

+ func (q *Query) PageSize(n int) *Query

+ func (q *Query) PageState(state []byte) *Query

+ func (q *Query) Prefetch(p float64) *Query

+ func (q *Query) Release()

+ func (q *Query) RetryPolicy(r RetryPolicy) *Query

+ func (q *Query) RoutingKey(routingKey []byte) *Query

+ func (q *Query) Scan(dest ...interface{}) error

+ func (q *Query) ScanCAS(dest ...interface{}) (applied bool, err error)

+ func (q *Query) SerialConsistency(cons SerialConsistency) *Query

+ func (q *Query) SetConsistency(c Consistency)

+ func (q *Query) SetSpeculativeExecutionPolicy(sp SpeculativeExecutionPolicy) *Query

+ func (q *Query) Trace(trace Tracer) *Query

+ func (q *Query) WithContext(ctx context.Context) *Query

+ func (q *Query) WithTimestamp(timestamp int64) *Query

+ func (q Query) Statement() string

+ func (q Query) String() string

+ type QueryInfo struct

+ Args []ColumnInfo

+ Id []byte

+ PKeyColumns []int

+ Rval []ColumnInfo

+ type QueryObserver interface

+ ObserveQuery func(context.Context, ObservedQuery)

+ type ReadyPolicy interface

+ Ready func() bool

+ type ReconnectionPolicy interface

+ GetInterval func(currentRetry int) time.Duration

+ GetMaxRetries func() int

+ type RequestErrAlreadyExists struct

+ Keyspace string

+ Table string

+ func (e RequestErrAlreadyExists) Code() int

+ func (e RequestErrAlreadyExists) Error() string

+ func (e RequestErrAlreadyExists) Message() string

+ func (e RequestErrAlreadyExists) String() string

+ type RequestErrCASWriteUnknown struct

+ BlockFor int

+ Consistency Consistency

+ Received int

+ func (e RequestErrCASWriteUnknown) Code() int

+ func (e RequestErrCASWriteUnknown) Error() string

+ func (e RequestErrCASWriteUnknown) Message() string

+ func (e RequestErrCASWriteUnknown) String() string

+ type RequestErrCDCWriteFailure struct

+ func (e RequestErrCDCWriteFailure) Code() int

+ func (e RequestErrCDCWriteFailure) Error() string

+ func (e RequestErrCDCWriteFailure) Message() string

+ func (e RequestErrCDCWriteFailure) String() string

+ type RequestErrFunctionFailure struct

+ ArgTypes []string

+ Function string

+ Keyspace string

+ func (e RequestErrFunctionFailure) Code() int

+ func (e RequestErrFunctionFailure) Error() string

+ func (e RequestErrFunctionFailure) Message() string

+ func (e RequestErrFunctionFailure) String() string

+ type RequestErrReadFailure struct

+ BlockFor int

+ Consistency Consistency

+ DataPresent bool

+ ErrorMap ErrorMap

+ NumFailures int

+ Received int

+ func (e RequestErrReadFailure) Code() int

+ func (e RequestErrReadFailure) Error() string

+ func (e RequestErrReadFailure) Message() string

+ func (e RequestErrReadFailure) String() string

+ type RequestErrReadTimeout struct

+ BlockFor int

+ Consistency Consistency

+ DataPresent byte

+ Received int

+ func (e RequestErrReadTimeout) Code() int

+ func (e RequestErrReadTimeout) Error() string

+ func (e RequestErrReadTimeout) Message() string

+ func (e RequestErrReadTimeout) String() string

+ type RequestErrUnavailable struct

+ Alive int

+ Consistency Consistency

+ Required int

+ func (e *RequestErrUnavailable) String() string

+ func (e RequestErrUnavailable) Code() int

+ func (e RequestErrUnavailable) Error() string

+ func (e RequestErrUnavailable) Message() string

+ type RequestErrUnprepared struct

+ StatementId []byte

+ func (e RequestErrUnprepared) Code() int

+ func (e RequestErrUnprepared) Error() string

+ func (e RequestErrUnprepared) Message() string

+ func (e RequestErrUnprepared) String() string

+ type RequestErrWriteFailure struct

+ BlockFor int

+ Consistency Consistency

+ ErrorMap ErrorMap

+ NumFailures int

+ Received int

+ WriteType string

+ func (e RequestErrWriteFailure) Code() int

+ func (e RequestErrWriteFailure) Error() string

+ func (e RequestErrWriteFailure) Message() string

+ func (e RequestErrWriteFailure) String() string

+ type RequestErrWriteTimeout struct

+ BlockFor int

+ Consistency Consistency

+ Received int

+ WriteType string

+ func (e RequestErrWriteTimeout) Code() int

+ func (e RequestErrWriteTimeout) Error() string

+ func (e RequestErrWriteTimeout) Message() string

+ func (e RequestErrWriteTimeout) String() string

+ type RequestError interface

+ Code func() int

+ Error func() string

+ Message func() string

+ type RetryPolicy interface

+ Attempt func(RetryableQuery) bool

+ GetRetryType func(error) RetryType

+ type RetryType uint16

+ const Ignore

+ const Rethrow

+ const Retry

+ const RetryNextHost

+ type RetryableQuery interface

+ Attempts func() int

+ Context func() context.Context

+ GetConsistency func() Consistency

+ SetConsistency func(c Consistency)

+ type RowData struct

+ Columns []string

+ Values []interface{}

+ type Scanner interface

+ Err func() error

+ Next func() bool

+ Scan func(...interface{}) error

+ type SelectedHost interface

+ Info func() *HostInfo

+ Mark func(error)

+ type SerialConsistency uint16

+ const LocalSerial

+ const Serial

+ func (s *SerialConsistency) UnmarshalText(text []byte) error

+ func (s SerialConsistency) MarshalText() (text []byte, err error)

+ func (s SerialConsistency) String() string

+ type Session struct

+ func NewSession(cfg ClusterConfig) (*Session, error)

+ func (s *Session) AwaitSchemaAgreement(ctx context.Context) error

+ func (s *Session) Bind(stmt string, b func(q *QueryInfo) ([]interface{}, error)) *Query

+ func (s *Session) Close()

+ func (s *Session) Closed() bool

+ func (s *Session) ExecuteBatch(batch *Batch) error

+ func (s *Session) ExecuteBatchCAS(batch *Batch, dest ...interface{}) (applied bool, iter *Iter, err error)

+ func (s *Session) KeyspaceMetadata(keyspace string) (*KeyspaceMetadata, error)

+ func (s *Session) MapExecuteBatchCAS(batch *Batch, dest map[string]interface{}) (applied bool, iter *Iter, err error)

+ func (s *Session) NewBatch(typ BatchType) *Batch

+ func (s *Session) Query(stmt string, values ...interface{}) *Query

+ func (s *Session) SetConsistency(cons Consistency)

+ func (s *Session) SetPageSize(n int)

+ func (s *Session) SetPrefetch(p float64)

+ func (s *Session) SetTrace(trace Tracer)

+ type SetHosts interface

+ SetHosts func(hosts []*HostInfo)

+ type SetPartitioner interface

+ SetPartitioner func(partitioner string)

+ type SimpleConvictionPolicy struct

+ func (e *SimpleConvictionPolicy) AddFailure(error error, host *HostInfo) bool

+ func (e *SimpleConvictionPolicy) Reset(host *HostInfo)

+ type SimpleRetryPolicy struct

+ NumRetries int

+ func (s *SimpleRetryPolicy) Attempt(q RetryableQuery) bool

+ func (s *SimpleRetryPolicy) GetRetryType(err error) RetryType

+ type SimpleSpeculativeExecution struct

+ NumAttempts int

+ TimeoutDelay time.Duration

+ func (sp *SimpleSpeculativeExecution) Attempts() int

+ func (sp *SimpleSpeculativeExecution) Delay() time.Duration

+ type SnappyCompressor struct

+ func (s SnappyCompressor) Decode(data []byte) ([]byte, error)

+ func (s SnappyCompressor) Encode(data []byte) ([]byte, error)

+ func (s SnappyCompressor) Name() string

+ type SpeculativeExecutionPolicy interface

+ Attempts func() int

+ Delay func() time.Duration

+ type SslOptions struct

+ CaPath string

+ CertPath string

+ EnableHostVerification bool

+ KeyPath string

+ type StdLogger interface

+ Print func(v ...interface{})

+ Printf func(format string, v ...interface{})

+ Println func(v ...interface{})

+ var Logger StdLogger = &defaultLogger{}

+ type TableMetadata struct

+ ClusteringColumns []*ColumnMetadata

+ ColumnAliases []string

+ Columns map[string]*ColumnMetadata

+ Comparator string

+ DefaultValidator string

+ KeyAliases []string

+ KeyValidator string

+ Keyspace string

+ Name string

+ OrderedColumns []string

+ PartitionKey []*ColumnMetadata

+ ValueAlias string

+ type Tracer interface

+ Trace func(traceId []byte)

+ func NewTraceWriter(session *Session, w io.Writer) Tracer

+ type TupleTypeInfo struct

+ Elems []TypeInfo

+ func (t TupleTypeInfo) New() interface{}

+ func (t TupleTypeInfo) String() string

+ type Type int

+ const TypeAscii

+ const TypeBigInt

+ const TypeBlob

+ const TypeBoolean

+ const TypeCounter

+ const TypeCustom

+ const TypeDate

+ const TypeDecimal

+ const TypeDouble

+ const TypeDuration

+ const TypeFloat

+ const TypeInet

+ const TypeInt

+ const TypeList

+ const TypeMap

+ const TypeSet

+ const TypeSmallInt

+ const TypeText

+ const TypeTime

+ const TypeTimeUUID

+ const TypeTimestamp

+ const TypeTinyInt

+ const TypeTuple

+ const TypeUDT

+ const TypeUUID

+ const TypeVarchar

+ const TypeVarint

+ func (t Type) String() string

+ type TypeInfo interface

+ Custom func() string

+ New func() interface{}

+ Type func() Type

+ Version func() byte

+ type UDTField struct

+ Name string

+ Type TypeInfo

+ type UDTMarshaler interface

+ MarshalUDT func(name string, info TypeInfo) ([]byte, error)

+ type UDTTypeInfo struct

+ Elements []UDTField

+ KeySpace string

+ Name string

+ func (u UDTTypeInfo) New() interface{}

+ func (u UDTTypeInfo) String() string

+ type UDTUnmarshaler interface

+ UnmarshalUDT func(name string, info TypeInfo, data []byte) error

+ type UUID [16]byte

+ func MaxTimeUUID(t time.Time) UUID

+ func MinTimeUUID(t time.Time) UUID

+ func ParseUUID(input string) (UUID, error)

+ func RandomUUID() (UUID, error)

+ func TimeUUID() UUID

+ func TimeUUIDWith(t int64, clock uint32, node []byte) UUID

+ func UUIDFromBytes(input []byte) (UUID, error)

+ func UUIDFromTime(t time.Time) UUID

+ func (u *UUID) UnmarshalJSON(data []byte) error

+ func (u *UUID) UnmarshalText(text []byte) (err error)

+ func (u UUID) Bytes() []byte

+ func (u UUID) Clock() uint32

+ func (u UUID) MarshalJSON() ([]byte, error)

+ func (u UUID) MarshalText() ([]byte, error)

+ func (u UUID) Node() []byte

+ func (u UUID) String() string

+ func (u UUID) Time() time.Time

+ func (u UUID) Timestamp() int64

+ func (u UUID) Variant() int

+ func (u UUID) Version() int

+ type UnmarshalError string

+ func (m UnmarshalError) Error() string

+ type Unmarshaler interface

+ UnmarshalCQL func(info TypeInfo, data []byte) error

+ type UserTypeMetadata struct

+ FieldNames []string

+ FieldTypes []TypeInfo

+ Keyspace string

+ Name string

+ type ViewMetadata struct

+ FieldNames []string

+ FieldTypes []TypeInfo

+ Keyspace string

+ Name string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL