response

package
v0.1.12 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 26, 2022 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ScyllaShard             = "SCYLLA_SHARD"
	ScyllaNrShards          = "SCYLLA_NR_SHARDS"
	ScyllaPartitioner       = "SCYLLA_PARTITIONER"
	ScyllaShardingAlgorithm = "SCYLLA_SHARDING_ALGORITHM"
	ScyllaShardingIgnoreMSB = "SCYLLA_SHARDING_IGNORE_MSB"
	ScyllaShardAwarePort    = "SCYLLA_SHARD_AWARE_PORT"
	ScyllaShardAwarePortSSL = "SCYLLA_SHARD_AWARE_PORT_SSL"
)

Variables

This section is empty.

Functions

func ParseEvent 

func ParseEvent(b *frame.Buffer) frame.Response

func ParseResult 

func ParseResult(b *frame.Buffer) frame.Response

Types

type AlreadyExistsError 

type AlreadyExistsError struct {
	ScyllaError
	Keyspace string
	Table    string
}

AlreadyExistsError spec: https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L1187

func ParseAlreadyExistsError 

func ParseAlreadyExistsError(b *frame.Buffer, err ScyllaError) AlreadyExistsError

type AuthChallenge 

type AuthChallenge struct {
	Token frame.Bytes
}

AuthChallenge spec: https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L802

func ParseAuthChallenge 

func ParseAuthChallenge(b *frame.Buffer) *AuthChallenge

type AuthSuccess 

type AuthSuccess struct {
	Token frame.Bytes
}

AuthSuccess spec: https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L814

func ParseAuthSuccess 

func ParseAuthSuccess(b *frame.Buffer) *AuthSuccess

type Authenticate 

type Authenticate struct {
	Name string
}

Authenticate spec: https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L517

func ParseAuthenticate 

func ParseAuthenticate(b *frame.Buffer) *Authenticate

type CodedError 

type CodedError interface {
	error
	ErrorCode() frame.ErrorCode
}

func ParseError 

func ParseError(b *frame.Buffer) CodedError

type FuncFailureError 

type FuncFailureError struct {
	ScyllaError
	Keyspace string
	Function string
	ArgTypes frame.StringList
}

FuncFailureError spec: https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L1140

func ParseFuncFailureError 

func ParseFuncFailureError(b *frame.Buffer, err ScyllaError) FuncFailureError

type PreparedResult 

type PreparedResult struct {
	ID             frame.ShortBytes
	Metadata       frame.PreparedMetadata
	ResultMetadata frame.ResultMetadata
}

PreparedResult spec: https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L675

func ParsePreparedResult 

func ParsePreparedResult(b *frame.Buffer) *PreparedResult

type ReadFailureError 

type ReadFailureError struct {
	ScyllaError
	Consistency frame.Consistency
	Received    frame.Int
	BlockFor    frame.Int
	NumFailures frame.Int
	DataPresent bool
}

ReadFailureError spec: https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L1125

func ParseReadFailureError 

func ParseReadFailureError(b *frame.Buffer, err ScyllaError) ReadFailureError

type ReadTimeoutError 

type ReadTimeoutError struct {
	ScyllaError
	Consistency frame.Consistency
	Received    frame.Int
	BlockFor    frame.Int
	DataPresent bool
}

ReadTimeoutError spec: https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L1108

func ParseReadTimeoutError 

func ParseReadTimeoutError(b *frame.Buffer, err ScyllaError) ReadTimeoutError

type Ready 

type Ready struct{}

Ready spec: https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L507

func ParseReady 

func ParseReady(_ *frame.Buffer) *Ready

type ResultKind 

type ResultKind = frame.Int
const (
	VoidKind         ResultKind = 1
	RowsKind         ResultKind = 2
	SetKeySpaceKind  ResultKind = 3
	PreparedKind     ResultKind = 4
	SchemaChangeKind ResultKind = 5
)

type RowsResult 

type RowsResult struct {
	Metadata    frame.ResultMetadata
	RowsCnt     frame.Int
	RowsContent []frame.Row
}

RowsResult spec: https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L568

func ParseRowsResult 

func ParseRowsResult(b *frame.Buffer) *RowsResult

type SchemaChange 

type SchemaChange struct {
	Change    frame.SchemaChangeType
	Target    frame.SchemaChangeTarget
	Keyspace  string
	Object    string
	Arguments frame.StringList
}

SchemaChange spec: https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L771

func ParseSchemaChange 

func ParseSchemaChange(b *frame.Buffer) *SchemaChange

type SchemaChangeResult 

type SchemaChangeResult struct {
	SchemaChange SchemaChange
}

SchemaChangeResult spec: https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L742

func ParseSchemaChangeResult 

func ParseSchemaChangeResult(b *frame.Buffer) *SchemaChangeResult

type ScyllaError 

type ScyllaError struct {
	Code    frame.ErrorCode
	Message string
}

ScyllaError is embedded in all error frames. ScyllaError spec: https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L1046

func ParseScyllaError 

func ParseScyllaError(b *frame.Buffer) ScyllaError

func (ScyllaError) Error 

func (e ScyllaError) Error() string

func (ScyllaError) ErrorCode 

func (e ScyllaError) ErrorCode() frame.ErrorCode

func (ScyllaError) String 

func (e ScyllaError) String() string

type ScyllaSupported 

type ScyllaSupported struct {
	Shard             uint16
	NrShards          uint16
	MsbIgnore         uint8
	Partitioner       string
	ShardingAlgorithm string
	ShardAwarePort    uint16
	ShardAwarePortSSL uint16
	LwtFlagMask       int
}

ScyllaSupported represents Scylla connection options as sent in SUPPORTED https://github.com/kulezi/scylla/blob/4bfcead2ba60072c720241cce6f42f620930c380/docs/dev/protocol-extensions.md#intranode-sharding

type SetKeyspaceResult 

type SetKeyspaceResult struct {
	Name string
}

SetKeyspaceResult spec: https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L669

func ParseSetKeyspaceResult 

func ParseSetKeyspaceResult(b *frame.Buffer) *SetKeyspaceResult

type StatusChange 

type StatusChange struct {
	Status  frame.StatusChangeType
	Address frame.Inet
}

StatusChange spec: https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L766

func ParseStatusChange 

func ParseStatusChange(b *frame.Buffer) *StatusChange

type Supported 

type Supported struct {
	Options frame.StringMultiMap
}

Supported spec: https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L537

func ParseSupported 

func ParseSupported(b *frame.Buffer) *Supported

func (*Supported) ScyllaSupported 

func (s *Supported) ScyllaSupported() *ScyllaSupported

type TopologyChange 

type TopologyChange struct {
	Change  frame.TopologyChangeType
	Address frame.Inet
}

TopologyChange spec: https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L760

func ParseTopologyChange 

func ParseTopologyChange(b *frame.Buffer) *TopologyChange

type UnavailableError 

type UnavailableError struct {
	ScyllaError
	Consistency frame.Consistency
	Required    frame.Int
	Alive       frame.Int
}

UnavailableError spec: https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L1060

func ParseUnavailableError 

func ParseUnavailableError(b *frame.Buffer, err ScyllaError) UnavailableError

type UnpreparedError 

type UnpreparedError struct {
	ScyllaError
	UnknownID frame.ShortBytes
}

UnpreparedError spec: https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L1197

func ParseUnpreparedError 

func ParseUnpreparedError(b *frame.Buffer, err ScyllaError) UnpreparedError

type VoidResult 

type VoidResult struct{}

VoidResult spec: https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L562

func ParseVoidResult 

func ParseVoidResult(_ *frame.Buffer) *VoidResult

type WriteFailureError 

type WriteFailureError struct {
	ScyllaError
	Consistency frame.Consistency
	Received    frame.Int
	BlockFor    frame.Int
	NumFailures frame.Int
	WriteType   frame.WriteType
}

WriteFailureError spec: https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L1147

func ParseWriteFailureError 

func ParseWriteFailureError(b *frame.Buffer, err ScyllaError) WriteFailureError

type WriteTimeoutError 

type WriteTimeoutError struct {
	ScyllaError
	Consistency frame.Consistency
	Received    frame.Int
	BlockFor    frame.Int
	WriteType   frame.WriteType
}

WriteTimeoutError spec: https://github.com/apache/cassandra/blob/adcff3f630c0d07d1ba33bf23fcb11a6db1b9af1/doc/native_protocol_v4.spec#L1076

func ParseWriteTimeoutError 

func ParseWriteTimeoutError(b *frame.Buffer, err ScyllaError) WriteTimeoutError

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.