proto

type AlreadyExists struct {
	Keyspace string `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Table    string `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	// contains filtered or unexported fields
}

type Batch struct {

	// The type of batch.
	Type Batch_Type `protobuf:"varint,1,opt,name=type,proto3,enum=stargate.Batch_Type" json:"type,omitempty"`
	// The CQL queries with their values.
	Queries []*BatchQuery `protobuf:"bytes,2,rep,name=queries,proto3" json:"queries,omitempty"`
	// The execution parameters for the batch.
	Parameters *BatchParameters `protobuf:"bytes,3,opt,name=parameters,proto3" json:"parameters,omitempty"`
	// contains filtered or unexported fields
}

type BatchParameters struct {

	// The keyspace to use when schema element names in the queries (tables, UDTs, functions) are not
	// fully qualified.
	Keyspace *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// The consistency level.
	// If unset, it defaults to LOCAL_QUORUM.
	Consistency *ConsistencyValue `protobuf:"bytes,2,opt,name=consistency,proto3" json:"consistency,omitempty"`
	// Whether the server should collect tracing information about the execution of the query.
	// If this is set, then a Traces message will be included in the Response message.
	Tracing bool `protobuf:"varint,3,opt,name=tracing,proto3" json:"tracing,omitempty"`
	// The query timestamp (in microseconds). This is used to order mutations on the server.
	// If unset, the server will assign one based on the time it received the batch.
	Timestamp *wrapperspb.Int64Value `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// The serial consistency level (if the batch contains lightweight transactions).
	// If unset, it defaults to SERIAL.
	SerialConsistency *ConsistencyValue `protobuf:"bytes,5,opt,name=serial_consistency,json=serialConsistency,proto3" json:"serial_consistency,omitempty"`
	// Forces the current time for the query (for testing purposes).
	// This affects TTL cell liveness in read queries and local deletion time for tombstones and TTL
	// cells in update requests.
	NowInSeconds *wrapperspb.Int32Value `protobuf:"bytes,6,opt,name=now_in_seconds,json=nowInSeconds,proto3" json:"now_in_seconds,omitempty"`
	// The consistency level to use to retrieve the query trace (if tracing is set).
	// If unset, it defaults to ONE.
	TracingConsistency *ConsistencyValue `protobuf:"bytes,7,opt,name=tracing_consistency,json=tracingConsistency,proto3" json:"tracing_consistency,omitempty"`
	// Whether to omit ResultSet.columns in the response.
	// This can be used to optimize response size when the client already knows that information.
	SkipMetadata bool `protobuf:"varint,8,opt,name=skip_metadata,json=skipMetadata,proto3" json:"skip_metadata,omitempty"`
	// contains filtered or unexported fields
}

type BatchQuery struct {

	// The query string. It can contain anonymous placeholders identified by a question mark (?), or
	// named placeholders prefixed by a column (:name).
	Cql string `protobuf:"bytes,1,opt,name=cql,proto3" json:"cql,omitempty"`
	// The values to fill the placeholders in the query string.
	Values *Values `protobuf:"bytes,2,opt,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

type Batch_Type int32

type CasWriteUnknown struct {

	// The consistency level of the operation that failed.
	Consistency Consistency `protobuf:"varint,1,opt,name=consistency,proto3,enum=stargate.Consistency" json:"consistency,omitempty"`
	// The number of replica that had acknowledged/responded to the operation before it failed.
	Received int32 `protobuf:"varint,2,opt,name=received,proto3" json:"received,omitempty"`
	// The minimum number of replica acknowledgements/responses that were required to fulfill the
	// operation.
	BlockFor int32 `protobuf:"varint,3,opt,name=block_for,json=blockFor,proto3" json:"block_for,omitempty"`
	// contains filtered or unexported fields
}

type Collection struct {
	Elements []*Value `protobuf:"bytes,1,rep,name=elements,proto3" json:"elements,omitempty"`
	// contains filtered or unexported fields
}

type ColumnSpec struct {

	// The CQL type.
	Type *TypeSpec `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// The name.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type Consistency int32

type ConsistencyValue struct {
	Value Consistency `protobuf:"varint,1,opt,name=value,proto3,enum=stargate.Consistency" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type Decimal struct {
	Scale uint32 `protobuf:"varint,1,opt,name=scale,proto3" json:"scale,omitempty"`
	Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type FunctionFailure struct {

	// The keyspace containing the function.
	Keyspace string `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// The name of the function.
	Function string `protobuf:"bytes,2,opt,name=function,proto3" json:"function,omitempty"`
	// The CQL types of the arguments of the function.
	ArgTypes []string `protobuf:"bytes,3,rep,name=arg_types,json=argTypes,proto3" json:"arg_types,omitempty"`
	// contains filtered or unexported fields
}

type Inet struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type Query struct {

	// The query string. It can contain anonymous placeholders identified by a question mark (?), or
	// named placeholders prefixed by a column (:name).
	Cql string `protobuf:"bytes,1,opt,name=cql,proto3" json:"cql,omitempty"`
	// The values to fill the placeholders in the query string.
	Values *Values `protobuf:"bytes,2,opt,name=values,proto3" json:"values,omitempty"`
	// The execution parameters for the query.
	Parameters *QueryParameters `protobuf:"bytes,3,opt,name=parameters,proto3" json:"parameters,omitempty"`
	// contains filtered or unexported fields
}

type QueryParameters struct {

	// The keyspace to use when schema element names in the query (tables, UDTs, functions) are not
	// fully qualified.
	Keyspace *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// The consistency level.
	// If unset, it defaults to LOCAL_QUORUM.
	Consistency *ConsistencyValue `protobuf:"bytes,2,opt,name=consistency,proto3" json:"consistency,omitempty"`
	// The maximum number of rows that will be returned in the response. If there are more results,
	// the response will contain a paging state, and additional queries will be needed to retrieve
	// subsequent pages.
	// Note that this is only a suggestion, the server reserves the right to return slightly smaller
	// or bigger pages.
	// If unset, it defaults to 100.
	PageSize *wrapperspb.Int32Value `protobuf:"bytes,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// A paging state that indicates where to resume iteration in the result set. This is used to
	// retrieve the next page of data when the number of results exceeds the page size.
	// This should be filled with the value returned by the previous response (see
	// ResultSet.paging_state). It is an opaque binary string that is only intended to be collected,
	// stored and reused; any attempt to modify its contents or reuse it with a different statement
	// will yield unpredictable results.
	PagingState *wrapperspb.BytesValue `protobuf:"bytes,4,opt,name=paging_state,json=pagingState,proto3" json:"paging_state,omitempty"`
	// Whether the server should collect tracing information about the execution of the query.
	// If this is set, then a Traces message will be included in the Response message.
	Tracing bool `protobuf:"varint,5,opt,name=tracing,proto3" json:"tracing,omitempty"`
	// Whether to omit ResultSet.columns in the response.
	// This can be used to optimize response size when the client already knows that information (for
	// example when fetching multiple pages for the same query).
	SkipMetadata bool `protobuf:"varint,6,opt,name=skip_metadata,json=skipMetadata,proto3" json:"skip_metadata,omitempty"`
	// The query timestamp (in microseconds). This is used to order mutations on the server.
	// If unset, the server will assign one based on the time it received the query.
	Timestamp *wrapperspb.Int64Value `protobuf:"bytes,7,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// The serial consistency level (if the query is a lightweight transaction).
	// If unset, it defaults to SERIAL.
	SerialConsistency *ConsistencyValue `protobuf:"bytes,8,opt,name=serial_consistency,json=serialConsistency,proto3" json:"serial_consistency,omitempty"`
	// Forces the current time for the query (for testing purposes).
	// This affects TTL cell liveness in read queries and local deletion time for tombstones and TTL
	// cells in update requests.
	NowInSeconds *wrapperspb.Int32Value `protobuf:"bytes,9,opt,name=now_in_seconds,json=nowInSeconds,proto3" json:"now_in_seconds,omitempty"`
	// The consistency level to use to retrieve the query trace (if tracing is set).
	// If unset, it defaults to ONE.
	TracingConsistency *ConsistencyValue `protobuf:"bytes,10,opt,name=tracing_consistency,json=tracingConsistency,proto3" json:"tracing_consistency,omitempty"`
	// contains filtered or unexported fields
}

type ReadFailure struct {

	// The consistency level of the operation that failed.
	Consistency Consistency `protobuf:"varint,1,opt,name=consistency,proto3,enum=stargate.Consistency" json:"consistency,omitempty"`
	// The number of replica that had acknowledged/responded to the operation before it failed.
	Received int32 `protobuf:"varint,2,opt,name=received,proto3" json:"received,omitempty"`
	// The minimum number of replica acknowledgements/responses that were required to fulfill the
	// operation.
	BlockFor int32 `protobuf:"varint,3,opt,name=block_for,json=blockFor,proto3" json:"block_for,omitempty"`
	// The number of replicas that experienced a failure while executing the request.
	NumFailures int32 `protobuf:"varint,4,opt,name=num_failures,json=numFailures,proto3" json:"num_failures,omitempty"`
	// Whether the actual data was amongst the received replica responses.
	// During reads, Cassandra doesn't request data from every replica to minimize internal network
	// traffic. Instead, some replicas are only asked for a checksum of the data. A read timeout may
	// occur even if enough replicas have responded to fulfill the consistency level, if only checksum
	// responses have been received. This field allows to detect that case.
	DataPresent bool `protobuf:"varint,5,opt,name=data_present,json=dataPresent,proto3" json:"data_present,omitempty"`
	// contains filtered or unexported fields
}

type ReadTimeout struct {

	// The consistency level of the operation that failed.
	Consistency Consistency `protobuf:"varint,1,opt,name=consistency,proto3,enum=stargate.Consistency" json:"consistency,omitempty"`
	// The number of replica that had acknowledged/responded to the operation before it failed.
	Received int32 `protobuf:"varint,2,opt,name=received,proto3" json:"received,omitempty"`
	// The minimum number of replica acknowledgements/responses that were required to fulfill the
	// operation.
	BlockFor int32 `protobuf:"varint,3,opt,name=block_for,json=blockFor,proto3" json:"block_for,omitempty"`
	// Whether the actual data was amongst the received replica responses.
	// During reads, Cassandra doesn't request data from every replica to minimize internal network
	// traffic. Instead, some replicas are only asked for a checksum of the data. A read timeout may
	// occur even if enough replicas have responded to fulfill the consistency level, if only checksum
	// responses have been received. This field allows to detect that case.
	DataPresent bool `protobuf:"varint,4,opt,name=data_present,json=dataPresent,proto3" json:"data_present,omitempty"`
	// contains filtered or unexported fields
}

type Response struct {

	// Types that are assignable to Result:
	//	*Response_ResultSet
	//	*Response_SchemaChange
	Result isResponse_Result `protobuf_oneof:"result"`
	// The server-side warnings for the query, if any.
	Warnings []string `protobuf:"bytes,2,rep,name=warnings,proto3" json:"warnings,omitempty"`
	// The tracing information, if it was requested for the query.
	Traces *Traces `protobuf:"bytes,3,opt,name=traces,proto3" json:"traces,omitempty"`
	// contains filtered or unexported fields
}

type Response_ResultSet struct {
	// The result data.
	ResultSet *ResultSet `protobuf:"bytes,1,opt,name=result_set,json=resultSet,proto3,oneof"`
}

type Response_SchemaChange struct {
	// How the query changed the CQL schema.
	SchemaChange *SchemaChange `protobuf:"bytes,4,opt,name=schema_change,json=schemaChange,proto3,oneof"`
}

type ResultSet struct {

	// Metadata about the columns that this result set contains.
	// This may be omitted if explicitly requested by the client (see QueryParameters.skip_metadata
	// and BatchParameters.skip_metadata).
	Columns []*ColumnSpec `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
	// The rows of CQL data.
	Rows []*Row `protobuf:"bytes,2,rep,name=rows,proto3" json:"rows,omitempty"`
	// If there are more pages, a paging state that will allow the client to build a new query for the
	// next page.
	PagingState *wrapperspb.BytesValue `protobuf:"bytes,3,opt,name=paging_state,json=pagingState,proto3" json:"paging_state,omitempty"`
	// contains filtered or unexported fields
}

type Row struct {

	// The values for the columns (in the same order as ResultSet.columns).
	Values []*Value `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

type SchemaChange struct {

	// The nature of the change (created, updated or dropped).
	ChangeType SchemaChange_Type `protobuf:"varint,1,opt,name=change_type,json=changeType,proto3,enum=stargate.SchemaChange_Type" json:"change_type,omitempty"`
	// The type of schema object that was affected.
	Target SchemaChange_Target `protobuf:"varint,2,opt,name=target,proto3,enum=stargate.SchemaChange_Target" json:"target,omitempty"`
	// The name of the keyspace.
	Keyspace string `protobuf:"bytes,3,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// If the target is a keyspace element (table, type, etc), its name.
	Name *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	// If the target is a function or aggregate, the CQL types of the arguments.
	ArgumentTypes []string `protobuf:"bytes,5,rep,name=argument_types,json=argumentTypes,proto3" json:"argument_types,omitempty"`
	// contains filtered or unexported fields
}

type SchemaChange_Target int32

type SchemaChange_Type int32

type StargateClient interface {
	// Executes a single CQL query.
	ExecuteQuery(ctx context.Context, in *Query, opts ...grpc.CallOption) (*Response, error)
	// Executes a batch of CQL queries.
	ExecuteBatch(ctx context.Context, in *Batch, opts ...grpc.CallOption) (*Response, error)
}

type StargateServer interface {
	// Executes a single CQL query.
	ExecuteQuery(context.Context, *Query) (*Response, error)
	// Executes a batch of CQL queries.
	ExecuteBatch(context.Context, *Batch) (*Response, error)
	// contains filtered or unexported methods
}

type Traces struct {

	// A technical identifier for this trace.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The server-side duration of the query (in microseconds).
	Duration int64 `protobuf:"varint,2,opt,name=duration,proto3" json:"duration,omitempty"`
	// The server-side timestamp of the start of the query.
	StartedAt int64           `protobuf:"varint,3,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	Events    []*Traces_Event `protobuf:"bytes,4,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

type Traces_Event struct {

	// Which activity the event corresponds to.
	Activity string `protobuf:"bytes,1,opt,name=activity,proto3" json:"activity,omitempty"`
	// Identifies the host having generated the event.
	Source string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	// The number of microseconds elapsed on the source when this event occurred since the moment
	// when the source started handling the query.
	SourceElapsed int64 `protobuf:"varint,3,opt,name=source_elapsed,json=sourceElapsed,proto3" json:"source_elapsed,omitempty"`
	// The name of the server thread on which this event occurred.
	Thread string `protobuf:"bytes,4,opt,name=thread,proto3" json:"thread,omitempty"`
	// A technical identifier for the event.
	EventId string `protobuf:"bytes,5,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	// contains filtered or unexported fields
}

type TypeSpec struct {

	// Types that are assignable to Spec:
	//	*TypeSpec_Basic_
	//	*TypeSpec_Map_
	//	*TypeSpec_List_
	//	*TypeSpec_Set_
	//	*TypeSpec_Udt_
	//	*TypeSpec_Tuple_
	Spec isTypeSpec_Spec `protobuf_oneof:"spec"`
	// contains filtered or unexported fields
}

type TypeSpec_Basic int32

type TypeSpec_Basic_ struct {
	Basic TypeSpec_Basic `protobuf:"varint,1,opt,name=basic,proto3,enum=stargate.TypeSpec_Basic,oneof"`
}

type TypeSpec_List struct {
	Element *TypeSpec `protobuf:"bytes,1,opt,name=element,proto3" json:"element,omitempty"`
	// contains filtered or unexported fields
}

type TypeSpec_List_ struct {
	List *TypeSpec_List `protobuf:"bytes,3,opt,name=list,proto3,oneof"`
}

type TypeSpec_Map struct {
	Key   *TypeSpec `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value *TypeSpec `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type TypeSpec_Map_ struct {
	Map *TypeSpec_Map `protobuf:"bytes,2,opt,name=map,proto3,oneof"`
}

type TypeSpec_Set struct {
	Element *TypeSpec `protobuf:"bytes,1,opt,name=element,proto3" json:"element,omitempty"`
	// contains filtered or unexported fields
}

type TypeSpec_Set_ struct {
	Set *TypeSpec_Set `protobuf:"bytes,4,opt,name=set,proto3,oneof"`
}

type TypeSpec_Tuple struct {
	Elements []*TypeSpec `protobuf:"bytes,1,rep,name=elements,proto3" json:"elements,omitempty"`
	// contains filtered or unexported fields
}

type TypeSpec_Tuple_ struct {
	Tuple *TypeSpec_Tuple `protobuf:"bytes,6,opt,name=tuple,proto3,oneof"`
}

type TypeSpec_Udt struct {
	Fields map[string]*TypeSpec `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

type TypeSpec_Udt_ struct {
	Udt *TypeSpec_Udt `protobuf:"bytes,5,opt,name=udt,proto3,oneof"`
}

type UdtValue struct {
	Fields map[string]*Value `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

type Unavailable struct {

	// The consistency level of the operation that failed.
	Consistency Consistency `protobuf:"varint,1,opt,name=consistency,proto3,enum=stargate.Consistency" json:"consistency,omitempty"`
	// The number of replica acknowledgements/responses required to perform the operation (with its
	// required consistency level).
	Required int32 `protobuf:"varint,2,opt,name=required,proto3" json:"required,omitempty"`
	// The number of replicas that were known to be alive by the coordinator node when it tried to
	// execute the operation.
	Alive int32 `protobuf:"varint,3,opt,name=alive,proto3" json:"alive,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedStargateServer struct {
}

type UnsafeStargateServer interface {
	// contains filtered or unexported methods
}

type Uuid struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type Value struct {

	// Types that are assignable to Inner:
	//	*Value_Null_
	//	*Value_Unset_
	//	*Value_Int
	//	*Value_Float
	//	*Value_Double
	//	*Value_Boolean
	//	*Value_String_
	//	*Value_Bytes
	//	*Value_Inet
	//	*Value_Uuid
	//	*Value_Date
	//	*Value_Time
	//	*Value_Collection
	//	*Value_Udt
	//	*Value_Varint
	//	*Value_Decimal
	Inner isValue_Inner `protobuf_oneof:"inner"`
	// contains filtered or unexported fields
}

type Value_Boolean struct {
	// CQL types: boolean
	Boolean bool `protobuf:"varint,6,opt,name=boolean,proto3,oneof"`
}

type Value_Bytes struct {
	// CQL types: blob, custom
	Bytes []byte `protobuf:"bytes,8,opt,name=bytes,proto3,oneof"`
}

type Value_Collection struct {
	// CQL types: list, set, map, tuple
	Collection *Collection `protobuf:"bytes,13,opt,name=collection,proto3,oneof"`
}

type Value_Date struct {
	// CQL types: date
	// An unsigned integer representing days with Unix epoch (January, 1 1970) at 2^31.
	// Examples:
	// 0:    -5877641-06-23
	// 2^31: 1970-1-1
	// 2^32: 5881580-07-11
	Date uint32 `protobuf:"varint,11,opt,name=date,proto3,oneof"`
}

type Value_Decimal struct {
	// CQL types: decimal
	Decimal *Decimal `protobuf:"bytes,16,opt,name=decimal,proto3,oneof"`
}

type Value_Double struct {
	// CQL types: double
	Double float64 `protobuf:"fixed64,5,opt,name=double,proto3,oneof"`
}

type Value_Float struct {
	// CQL types: float
	Float float32 `protobuf:"fixed32,4,opt,name=float,proto3,oneof"`
}

type Value_Inet struct {
	// CQL types: inet
	Inet *Inet `protobuf:"bytes,9,opt,name=inet,proto3,oneof"`
}

type Value_Int struct {
	// CQL types: tinyint, smallint, int, bigint, counter, timestamp
	Int int64 `protobuf:"zigzag64,3,opt,name=int,proto3,oneof"`
}

type Value_Null struct {
	// contains filtered or unexported fields
}

type Value_Null_ struct {
	// The CQL value NULL.
	Null *Value_Null `protobuf:"bytes,1,opt,name=null,proto3,oneof"`
}

type Value_String_ struct {
	// CQL types: ascii, varchar, text
	String_ string `protobuf:"bytes,7,opt,name=string,proto3,oneof"`
}

type Value_Time struct {
	// CQL types: time
	// An unsigned integer representing the number of nanoseconds since midnight. Valid values are
	// in the range 0 to 86399999999999 (inclusive).
	Time uint64 `protobuf:"varint,12,opt,name=time,proto3,oneof"`
}

type Value_Udt struct {
	// CQL types: user defined types
	Udt *UdtValue `protobuf:"bytes,14,opt,name=udt,proto3,oneof"`
}

type Value_Unset struct {
	// contains filtered or unexported fields
}

type Value_Unset_ struct {
	// An unset value.
	// This can only be used for bind values in requests.
	Unset *Value_Unset `protobuf:"bytes,2,opt,name=unset,proto3,oneof"`
}

type Value_Uuid struct {
	// CQL types: uuid, timeuuid
	Uuid *Uuid `protobuf:"bytes,10,opt,name=uuid,proto3,oneof"`
}

type Value_Varint struct {
	// CQL types: varint
	Varint *Varint `protobuf:"bytes,15,opt,name=varint,proto3,oneof"`
}

type Values struct {

	// The values.
	Values []*Value `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// The value names, if the query uses named placeholders.
	ValueNames []string `protobuf:"bytes,2,rep,name=value_names,json=valueNames,proto3" json:"value_names,omitempty"`
	// contains filtered or unexported fields
}

type Varint struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type WriteFailure struct {

	// The consistency level of the operation that failed.
	Consistency Consistency `protobuf:"varint,1,opt,name=consistency,proto3,enum=stargate.Consistency" json:"consistency,omitempty"`
	// The number of replica that had acknowledged/responded to the operation before it failed.
	Received int32 `protobuf:"varint,2,opt,name=received,proto3" json:"received,omitempty"`
	// The minimum number of replica acknowledgements/responses that were required to fulfill the
	// operation.
	BlockFor int32 `protobuf:"varint,3,opt,name=block_for,json=blockFor,proto3" json:"block_for,omitempty"`
	// The number of replicas that experienced a failure while executing the request.
	NumFailures int32 `protobuf:"varint,4,opt,name=num_failures,json=numFailures,proto3" json:"num_failures,omitempty"`
	// The type of the write for which an error was raised.
	WriteType string `protobuf:"bytes,5,opt,name=write_type,json=writeType,proto3" json:"write_type,omitempty"`
	// contains filtered or unexported fields
}

type WriteTimeout struct {

	// The consistency level of the operation that failed.
	Consistency Consistency `protobuf:"varint,1,opt,name=consistency,proto3,enum=stargate.Consistency" json:"consistency,omitempty"`
	// The number of replica that had acknowledged/responded to the operation before it failed.
	Received int32 `protobuf:"varint,2,opt,name=received,proto3" json:"received,omitempty"`
	// The minimum number of replica acknowledgements/responses that were required to fulfill the
	// operation.
	BlockFor int32 `protobuf:"varint,3,opt,name=block_for,json=blockFor,proto3" json:"block_for,omitempty"`
	// The type of the write for which a timeout was raised.
	WriteType string `protobuf:"bytes,4,opt,name=write_type,json=writeType,proto3" json:"write_type,omitempty"`
	// contains filtered or unexported fields
}