pqs

type Event struct {
	Schema string    `protobuf:"bytes,1,opt,name=schema" json:"schema,omitempty"`
	Table  string    `protobuf:"bytes,2,opt,name=table" json:"table,omitempty"`
	Op     Operation `protobuf:"varint,3,opt,name=op,enum=pqs.Operation" json:"op,omitempty"`
	// if the id column exists, this will populate it
	Id string `protobuf:"bytes,4,opt,name=id" json:"id,omitempty"`
	// payload is a json encoded representation of the changed object.
	Payload *google_protobuf.Struct `protobuf:"bytes,5,opt,name=payload" json:"payload,omitempty"`
	// changes is, in the event of op==UPDATE an RFC7386 JSON merge patch.
	Changes *google_protobuf.Struct `protobuf:"bytes,6,opt,name=changes" json:"changes,omitempty"`
}

type ListenRequest struct {
	// if provided, this string will be used to match table names to track.
	TableRegexp string `protobuf:"bytes,1,opt,name=table_regexp,json=tableRegexp" json:"table_regexp,omitempty"`
}

type Operation int32

type PQStreamClient interface {
	// Listen responds with a stream of database operations.
	Listen(ctx context.Context, in *ListenRequest, opts ...grpc.CallOption) (PQStream_ListenClient, error)
}

type PQStreamServer interface {
	// Listen responds with a stream of database operations.
	Listen(*ListenRequest, PQStream_ListenServer) error
}

type PQStream_ListenClient interface {
	Recv() (*Event, error)
	grpc.ClientStream
}

type PQStream_ListenServer interface {
	Send(*Event) error
	grpc.ServerStream
}

type RawEvent struct {
	Schema   string                  `protobuf:"bytes,1,opt,name=schema" json:"schema,omitempty"`
	Table    string                  `protobuf:"bytes,2,opt,name=table" json:"table,omitempty"`
	Op       Operation               `protobuf:"varint,3,opt,name=op,enum=pqs.Operation" json:"op,omitempty"`
	Id       string                  `protobuf:"bytes,4,opt,name=id" json:"id,omitempty"`
	Payload  *google_protobuf.Struct `protobuf:"bytes,5,opt,name=payload" json:"payload,omitempty"`
	Previous *google_protobuf.Struct `protobuf:"bytes,6,opt,name=previous" json:"previous,omitempty"`
}