sqlv1

type Data struct {
	Columns []string `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
	Rows    []*Row   `protobuf:"bytes,2,rep,name=rows,proto3" json:"rows,omitempty"`
	// contains filtered or unexported fields
}

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

type DataSourceNamesResponse struct {
	Dsn []string `protobuf:"bytes,1,rep,name=dsn,proto3" json:"dsn,omitempty"`
	// contains filtered or unexported fields
}

type DatabaseServiceClient interface {
	Query(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[QueryRequest, QueryResponse], error)
	DataSourceNames(ctx context.Context, in *DataSourceNamesRequest, opts ...grpc.CallOption) (*DataSourceNamesResponse, error)
	Download(ctx context.Context, in *DownloadRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[DownloadResponse], error)
	LatestSnapshot(ctx context.Context, in *LatestSnapshotRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[LatestSnapshotResponse], error)
	ReplicationIDs(ctx context.Context, in *ReplicationIDsRequest, opts ...grpc.CallOption) (*ReplicationIDsResponse, error)
}

type DatabaseServiceServer interface {
	Query(grpc.BidiStreamingServer[QueryRequest, QueryResponse]) error
	DataSourceNames(context.Context, *DataSourceNamesRequest) (*DataSourceNamesResponse, error)
	Download(*DownloadRequest, grpc.ServerStreamingServer[DownloadResponse]) error
	LatestSnapshot(*LatestSnapshotRequest, grpc.ServerStreamingServer[LatestSnapshotResponse]) error
	ReplicationIDs(context.Context, *ReplicationIDsRequest) (*ReplicationIDsResponse, error)
	// contains filtered or unexported methods
}

type DatabaseService_DownloadClient = grpc.ServerStreamingClient[DownloadResponse]

type DatabaseService_DownloadServer = grpc.ServerStreamingServer[DownloadResponse]

type DatabaseService_LatestSnapshotClient = grpc.ServerStreamingClient[LatestSnapshotResponse]

type DatabaseService_LatestSnapshotServer = grpc.ServerStreamingServer[LatestSnapshotResponse]

type DatabaseService_QueryClient = grpc.BidiStreamingClient[QueryRequest, QueryResponse]

type DatabaseService_QueryServer = grpc.BidiStreamingServer[QueryRequest, QueryResponse]

type DownloadRequest struct {
	ReplicationId string `protobuf:"bytes,1,opt,name=replication_id,json=replicationId,proto3" json:"replication_id,omitempty"`
	// contains filtered or unexported fields
}

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

type LatestSnapshotRequest struct {
	ReplicationId string `protobuf:"bytes,1,opt,name=replication_id,json=replicationId,proto3" json:"replication_id,omitempty"`
	// contains filtered or unexported fields
}

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

type NamedValue struct {
	Name    string     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Ordinal int64      `protobuf:"varint,2,opt,name=ordinal,proto3" json:"ordinal,omitempty"`
	Value   *anypb.Any `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type QueryRequest struct {
	Type          QueryType     `protobuf:"varint,1,opt,name=type,proto3,enum=sql.v1.QueryType" json:"type,omitempty"`
	Sql           string        `protobuf:"bytes,2,opt,name=sql,proto3" json:"sql,omitempty"`
	Params        []*NamedValue `protobuf:"bytes,3,rep,name=params,proto3" json:"params,omitempty"`
	ReplicationId string        `protobuf:"bytes,4,opt,name=replication_id,json=replicationId,proto3" json:"replication_id,omitempty"`
	// contains filtered or unexported fields
}

type QueryResponse struct {
	ResultSet    *Data  `protobuf:"bytes,1,opt,name=result_set,json=resultSet,proto3" json:"result_set,omitempty"`
	RowsAffected int64  `protobuf:"varint,2,opt,name=rows_affected,json=rowsAffected,proto3" json:"rows_affected,omitempty"`
	LastInsertId int64  `protobuf:"varint,3,opt,name=last_insert_id,json=lastInsertId,proto3" json:"last_insert_id,omitempty"`
	Txseq        uint64 `protobuf:"varint,4,opt,name=txseq,proto3" json:"txseq,omitempty"`
	Error        string `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type QueryType int32

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

type ReplicationIDsResponse struct {
	ReplicationId []string `protobuf:"bytes,1,rep,name=replication_id,json=replicationId,proto3" json:"replication_id,omitempty"`
	// contains filtered or unexported fields
}

type Row struct {
	Values []*anypb.Any `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedDatabaseServiceServer struct{}

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