common

type APIError struct {
	// Code is a short description of the error in symbolic form
	Code string `json:"code"`
	// Error is one sentence describing the error
	Error string `json:"error"`
	// Description is longer, if you prefer that
	Description string `json:"description,omitempty"`
}

type Change struct {
	// Why the row was changed: insert, update, or delete
	Operation Operation `json:"operation"`
	// The name of the table that was updated
	Table string `json:"table"`
	// A value that indicates when the row is changed. It includes the
	// "commit LSN" and "CommitIndex" from below. This is the value that
	// clients should return to the API when looking for a list of changes.
	Sequence string `json:"sequence,omitempty"`
	// The LSN when the change was committed.
	CommitSequence uint64 `json:"commitSequence"`
	// The Postgres LSN when the row changed. This will be interleaved
	// in the change list because transactions commit at different times.
	ChangeSequence uint64 `json:"changeSequence"`
	// The order in which the change happened within the commit. For a transaction
	// affects multiple rows, changes will be listed in order, and this value
	// will begin at zero and be incremented by one.
	CommitIndex uint32 `json:"commitIndex"`
	// The Postgres Transaction ID when this change committed. This may be used
	// to find a CommitSequence from a particular snapshot. (TXIDs are 32
	// bits inside Postgres. We put the Postgres "epoch" in the high 32 bits
	// so that we deliver a 64-bit value that will not wrap around.)
	TransactionID uint64 `json:"txid"`
	// The time when the record was inserted to the database, in seconds since
	// the Unix epoch.
	Timestamp int64 `json:"timestamp,omitempty"`
	// For an insert operation, the columns that are being inserted. For an update,
	// the new value of the columns
	NewRow Row `json:"newRow,omitempty"`
	// For an update oepration, the old value of the columns. For a delete, the
	// value of the columns that are being deleted
	OldRow Row `json:"oldRow,omitempty"`
	// Sometimes we need to return an error instead of a change. If this is
	// not null, then it means a replication error occurred.
	Error error `json:"-"`
}

type ChangeList struct {
	// The highest value for "Sequence" in the whole database. The
	// client may use this to understand when they are at the end of the list
	// of changes.
	LastSequence string `json:"lastSequence"`
	// The lowest value for "Sequence" in the whole database. The client
	// may use this to determine if they are at the beginning of the whole
	// change list and must request a new snapshot to get consistent data.
	FirstSequence string `json:"firstSequence"`
	// All the changes, in order of "commit sequence" and "commit index"
	Changes []Change `json:"changes"`
}

type ChangeListPb struct {
	LastSequence     *string     `protobuf:"bytes,1,opt,name=lastSequence" json:"lastSequence,omitempty"`
	FirstSequence    *string     `protobuf:"bytes,2,opt,name=firstSequence" json:"firstSequence,omitempty"`
	Changes          []*ChangePb `protobuf:"bytes,3,rep,name=changes" json:"changes,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

type ChangePb struct {
	// operation -- May be 1, 2, 3 for insert, update, or delete
	Operation *int32 `protobuf:"varint,1,req,name=operation" json:"operation,omitempty"`
	// Table name, in "schema.table" format
	Table *string `protobuf:"bytes,2,req,name=table" json:"table,omitempty"`
	// Sequence number is generated by the change server by combining
	// the commitSequence and commitIndex
	Sequence *string `protobuf:"bytes,3,opt,name=sequence" json:"sequence,omitempty"`
	// LSN when the transaction was committed. Primary sort order.
	CommitSequence *uint64 `protobuf:"varint,4,opt,name=commitSequence" json:"commitSequence,omitempty"`
	// LSN when the change was made. Mostly of academic interest.
	ChangeSequence *uint64 `protobuf:"varint,5,opt,name=changeSequence" json:"changeSequence,omitempty"`
	// Order in which the change was made inside the transaction.
	// Secondary sort order.
	CommitIndex *uint32 `protobuf:"varint,6,opt,name=commitIndex" json:"commitIndex,omitempty"`
	// 32-bit Postgres transaction ID. Not used by newer code.
	// Rolls over.
	TransactionID *uint32 `protobuf:"varint,7,opt,name=transactionID" json:"transactionID,omitempty"`
	// Row added to an insert, or new row for an update.
	NewColumns []*ColumnPb `protobuf:"bytes,8,rep,name=newColumns" json:"newColumns,omitempty"`
	// Row removed on a delete, or old row for an update.
	OldColumns []*ColumnPb `protobuf:"bytes,9,rep,name=oldColumns" json:"oldColumns,omitempty"`
	// Time when the record was inserted, in seconds since the
	// Unix epoch.
	Timestamp *int64 `protobuf:"varint,10,opt,name=timestamp" json:"timestamp,omitempty"`
	// 64-bit Postgres transaction id, including the epoch. Will not
	// roll over.
	TransactionIDEpoch *uint64 `protobuf:"varint,11,opt,name=transactionIDEpoch" json:"transactionIDEpoch,omitempty"`
	XXX_unrecognized   []byte  `json:"-"`
}

type ColumnInfo struct {
	Name string
	Type int32
}

type ColumnPb struct {
	Name             *string  `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	Value            *ValuePb `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
	Type             *int32   `protobuf:"varint,3,opt,name=type" json:"type,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

type ColumnVal struct {
	// Column value, in the string format that comes straight from Postgres
	Value interface{} `json:"value"`
	// The Postgres type of the column, as defined in the Postgres source
	Type int32 `json:"type"`
}

type Operation int

type Row map[string]*ColumnVal

type RowPb struct {
	Values           []*ValuePb `protobuf:"bytes,1,rep,name=values" json:"values,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

type Sequence struct {
	LSN   uint64
	Index uint32
}

type Snapshot struct {
	// SnapshotInfo represents a Postgres transaction snapshot, in the format
	// "xmin:xmax:xip1,xip2,xip3..."
	SnapshotInfo string `json:"snapshotInfo"`
	// Timestamp is a Postgres timestamp that describes when the snapshot was created
	Timestamp string `json:"timestamp"`
	// The tables in the snapshot
	Tables []Table `json:"tables"`
}

type SnapshotHeaderPb struct {
	Timestamp        *string `protobuf:"bytes,1,req,name=timestamp" json:"timestamp,omitempty"`
	Snapshot         *string `protobuf:"bytes,2,req,name=snapshot" json:"snapshot,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

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

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

type StreamMessagePb struct {
	// Types that are valid to be assigned to Message:
	//	*StreamMessagePb_Table
	//	*StreamMessagePb_Row
	Message          isStreamMessagePb_Message `protobuf_oneof:"message"`
	XXX_unrecognized []byte                    `json:"-"`
}

type StreamMessagePb_Row struct {
	Row *RowPb `protobuf:"bytes,2,opt,name=row,oneof"`
}

type StreamMessagePb_Table struct {
	Table *TableHeaderPb `protobuf:"bytes,1,opt,name=table,oneof"`
}

type Table struct {
	Name string `json:"name"`
	Rows []Row  `json:"rows"`
}

type TableHeaderPb struct {
	Name             *string     `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	Columns          []*ColumnPb `protobuf:"bytes,2,rep,name=columns" json:"columns,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

type TableInfo struct {
	Name    string
	Columns []ColumnInfo
}

type ValuePb struct {
	// Types that are valid to be assigned to Value:
	//	*ValuePb_String_
	//	*ValuePb_Int
	//	*ValuePb_Uint
	//	*ValuePb_Double
	//	*ValuePb_Bytes
	//	*ValuePb_Bool
	//	*ValuePb_Timestamp
	Value            isValuePb_Value `protobuf_oneof:"value"`
	XXX_unrecognized []byte          `json:"-"`
}

type ValuePb_Bool struct {
	Bool bool `protobuf:"varint,6,opt,name=bool,oneof"`
}

type ValuePb_Bytes struct {
	Bytes []byte `protobuf:"bytes,5,opt,name=bytes,oneof"`
}

type ValuePb_Double struct {
	Double float64 `protobuf:"fixed64,4,opt,name=double,oneof"`
}

type ValuePb_Int struct {
	Int int64 `protobuf:"varint,2,opt,name=int,oneof"`
}

type ValuePb_String_ struct {
	String_ string `protobuf:"bytes,1,opt,name=string,oneof"`
}

type ValuePb_Timestamp struct {
	Timestamp int64 `protobuf:"varint,7,opt,name=timestamp,oneof"`
}

type ValuePb_Uint struct {
	Uint uint64 `protobuf:"varint,3,opt,name=uint,oneof"`
}