proto

type BackupRequest struct {
	Format   BackupRequest_Format `protobuf:"varint,1,opt,name=format,proto3,enum=command.BackupRequest_Format" json:"format,omitempty"`
	Leader   bool                 `protobuf:"varint,2,opt,name=Leader,proto3" json:"Leader,omitempty"`
	Vacuum   bool                 `protobuf:"varint,3,opt,name=Vacuum,proto3" json:"Vacuum,omitempty"`
	Compress bool                 `protobuf:"varint,4,opt,name=Compress,proto3" json:"Compress,omitempty"`
	// contains filtered or unexported fields
}

type BackupRequest_Format int32

type Command struct {
	Type       Command_Type `protobuf:"varint,1,opt,name=type,proto3,enum=command.Command_Type" json:"type,omitempty"`
	SubCommand []byte       `protobuf:"bytes,2,opt,name=sub_command,json=subCommand,proto3" json:"sub_command,omitempty"`
	Compressed bool         `protobuf:"varint,3,opt,name=compressed,proto3" json:"compressed,omitempty"`
	// contains filtered or unexported fields
}

type Command_Type int32

type ExecuteQueryRequest struct {
	Request         *Request           `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	Timings         bool               `protobuf:"varint,2,opt,name=timings,proto3" json:"timings,omitempty"`
	Level           QueryRequest_Level `protobuf:"varint,3,opt,name=level,proto3,enum=command.QueryRequest_Level" json:"level,omitempty"`
	Freshness       int64              `protobuf:"varint,4,opt,name=freshness,proto3" json:"freshness,omitempty"`
	FreshnessStrict bool               `protobuf:"varint,5,opt,name=freshness_strict,json=freshnessStrict,proto3" json:"freshness_strict,omitempty"`
	// contains filtered or unexported fields
}

type ExecuteQueryResponse struct {

	// Types that are assignable to Result:
	//
	//	*ExecuteQueryResponse_Q
	//	*ExecuteQueryResponse_E
	//	*ExecuteQueryResponse_Error
	Result isExecuteQueryResponse_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

type ExecuteQueryResponse_E struct {
	E *ExecuteResult `protobuf:"bytes,2,opt,name=e,proto3,oneof"`
}

type ExecuteQueryResponse_Error struct {
	Error string `protobuf:"bytes,3,opt,name=error,proto3,oneof"`
}

type ExecuteQueryResponse_Q struct {
	Q *QueryRows `protobuf:"bytes,1,opt,name=q,proto3,oneof"`
}

type ExecuteRequest struct {
	Request *Request `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	Timings bool     `protobuf:"varint,2,opt,name=timings,proto3" json:"timings,omitempty"`
	// contains filtered or unexported fields
}

type ExecuteResult struct {
	LastInsertId int64   `protobuf:"varint,1,opt,name=last_insert_id,json=lastInsertId,proto3" json:"last_insert_id,omitempty"`
	RowsAffected int64   `protobuf:"varint,2,opt,name=rows_affected,json=rowsAffected,proto3" json:"rows_affected,omitempty"`
	Error        string  `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	Time         float64 `protobuf:"fixed64,4,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

type JoinRequest struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	Voter   bool   `protobuf:"varint,3,opt,name=voter,proto3" json:"voter,omitempty"`
	// contains filtered or unexported fields
}

type LoadChunkRequest struct {
	StreamId    string `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	SequenceNum int64  `protobuf:"varint,2,opt,name=sequence_num,json=sequenceNum,proto3" json:"sequence_num,omitempty"`
	IsLast      bool   `protobuf:"varint,3,opt,name=is_last,json=isLast,proto3" json:"is_last,omitempty"`
	Data        []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	Abort       bool   `protobuf:"varint,5,opt,name=abort,proto3" json:"abort,omitempty"`
	// contains filtered or unexported fields
}

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

type Noop struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type NotifyRequest struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

type Parameter struct {

	// Types that are assignable to Value:
	//
	//	*Parameter_I
	//	*Parameter_D
	//	*Parameter_B
	//	*Parameter_Y
	//	*Parameter_S
	Value isParameter_Value `protobuf_oneof:"value"`
	Name  string            `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type Parameter_B struct {
	B bool `protobuf:"varint,3,opt,name=b,proto3,oneof"`
}

type Parameter_D struct {
	D float64 `protobuf:"fixed64,2,opt,name=d,proto3,oneof"`
}

type Parameter_I struct {
	I int64 `protobuf:"zigzag64,1,opt,name=i,proto3,oneof"`
}

type Parameter_S struct {
	S string `protobuf:"bytes,5,opt,name=s,proto3,oneof"`
}

type Parameter_Y struct {
	Y []byte `protobuf:"bytes,4,opt,name=y,proto3,oneof"`
}

type QueryRequest struct {
	Request         *Request           `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	Timings         bool               `protobuf:"varint,2,opt,name=timings,proto3" json:"timings,omitempty"`
	Level           QueryRequest_Level `protobuf:"varint,3,opt,name=level,proto3,enum=command.QueryRequest_Level" json:"level,omitempty"`
	Freshness       int64              `protobuf:"varint,4,opt,name=freshness,proto3" json:"freshness,omitempty"`
	FreshnessStrict bool               `protobuf:"varint,5,opt,name=freshness_strict,json=freshnessStrict,proto3" json:"freshness_strict,omitempty"`
	// contains filtered or unexported fields
}

type QueryRequest_Level int32

type QueryRows struct {
	Columns []string  `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
	Types   []string  `protobuf:"bytes,2,rep,name=types,proto3" json:"types,omitempty"`
	Values  []*Values `protobuf:"bytes,3,rep,name=values,proto3" json:"values,omitempty"`
	Error   string    `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	Time    float64   `protobuf:"fixed64,5,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

type RemoveNodeRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type Request struct {
	Transaction bool         `protobuf:"varint,1,opt,name=transaction,proto3" json:"transaction,omitempty"` // if a transaction
	Statements  []*Statement `protobuf:"bytes,2,rep,name=statements,proto3" json:"statements,omitempty"`    // the statement/command
	DbTimeout   int64        `protobuf:"varint,3,opt,name=dbTimeout,proto3" json:"dbTimeout,omitempty"`     // timeout
	// contains filtered or unexported fields
}

type Statement struct {
	Sql        string       `protobuf:"bytes,1,opt,name=sql,proto3" json:"sql,omitempty"`
	Parameters []*Parameter `protobuf:"bytes,2,rep,name=parameters,proto3" json:"parameters,omitempty"`
	ForceQuery bool         `protobuf:"varint,3,opt,name=forceQuery,proto3" json:"forceQuery,omitempty"` // not really used as of now
	// contains filtered or unexported fields
}

type Values struct {
	Parameters []*Parameter `protobuf:"bytes,1,rep,name=parameters,proto3" json:"parameters,omitempty"`
	// contains filtered or unexported fields
}