Versions in this module Expand all Collapse all v0 v0.0.1 May 14, 2021 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 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) 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 + 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 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 v0.0.0-0 May 14, 2021